Public Member Functions
bool	open (const std::string &fileName, bool raw, const char *mode)

int	put_wordbuf (int *data, int len)

int	put (char *data, int len)

int	get_wordbuf (int *data, int len)

int	get (char *data, int len)

Private Attributes
std::unique_ptr< SeqFile >	m_sfile

FILE *	m_rfile = nullptr

Detailed Description

Definition at line 18 of file HLTFile.h.

Constructor & Destructor Documentation

◆ ~HLTFile()

~HLTFile ( )

virtual

Definition at line 36 of file HLTFile.cc.

{
  if (m_rfile) {
    fclose(m_rfile);
  }
}

Member Function Documentation

◆ get()

int get	(	char *	data,
		int	len
	)

Definition at line 80 of file HLTFile.cc.

{
  const int bcount = m_sfile->read(data, len);
  if (bcount <= 0) {
    B2ERROR("Error in getting the data: " << strerror(errno));
    return bcount;
  }
  return bcount;
}

◆ get_wordbuf()

int get_wordbuf	(	int *	data,
		int	len
	)

Definition at line 90 of file HLTFile.cc.

{
  if (not m_rfile) {
    B2ERROR("Trying to read from a closed file!");
    return -1;
  }
  int br = std::fread(wrdbuf, sizeof(int), 1, m_rfile);
  if (br <= 0) {
    if (std::feof(m_rfile)) {
      return 0;
    }
    B2ERROR("Error in getting the size: " << strerror(errno));
    return br;
  }
 
  const int gcount = (wrdbuf[0] - 1);
  if (gcount > len) {
    B2ERROR("buffer too small! " << gcount << " < " << len);
    return -1;
  }
  // ATTENTION: the send size is size / 4
  const int bcount = std::fread(&wrdbuf[1], sizeof(int), gcount, m_rfile);
  if (bcount <= 0) {
    if (std::feof(m_rfile)) {
      return 0;
    }
    B2ERROR("Error in getting the data: " << strerror(errno));
    return bcount;
  }
 
  B2ASSERT("Read buffer size != buffer size in data: " << bcount << " != " << gcount, bcount == gcount);
  return (wrdbuf[0]);
}

◆ open()

bool open	(	const std::string &	fileName,
		bool	raw,
		const char *	mode
	)

Definition at line 13 of file HLTFile.cc.

{
  if (m_rfile) {
    fclose(m_rfile);
  }
 
  if (raw) {
    m_rfile = std::fopen(fileName.c_str(), mode);
    if (!m_rfile) {
      B2ERROR("File opening failed! " << strerror(errno));
      return false;
    }
  } else {
    m_sfile.reset(new SeqFile(fileName, mode));
    if (m_sfile->status() <= 0) {
      B2ERROR("File opening failed! " << strerror(errno));
      return false;
    }
  }
 
  return true;
}

◆ put()

int put	(	char *	data,
		int	len
	)

Definition at line 43 of file HLTFile.cc.

{
  if (not m_sfile) {
    B2ERROR("Trying to write to a closed file");
  }
  const int bcount = m_sfile->write(data);
  if (bcount <= 0) {
    B2ERROR("Error in sending the data: " << strerror(errno));
    return bcount;
  }
  B2ASSERT("Written buffer size != buffer size in data!", bcount == len);
  return bcount;
}

◆ put_wordbuf()

int put_wordbuf	(	int *	data,
		int	len
	)

Definition at line 57 of file HLTFile.cc.

{
  if (not m_rfile) {
    B2ERROR("Trying to write to a closed file!");
    return -1;
  }
 
  const int gcount = data[0];
  B2ASSERT("The first entry in the data must be the buffer size!", gcount == len);
 
  int bcount = std::fwrite(data, sizeof(char), len * sizeof(int), m_rfile);
  if (bcount <= 0) {
    B2ERROR("Error in writing the data: " << strerror(errno));
    return bcount;
  }
  bcount = ((bcount - 1) / sizeof(int) + 1);
 
  B2ASSERT("Written buffer size != buffer size in data!" << bcount << " " << len, bcount == len);
 
  // ATTENTION: the returned size is size / 4
  return bcount;
}

Member Data Documentation

◆ m_rfile

FILE* m_rfile = nullptr

private

Definition at line 30 of file HLTFile.h.

◆ m_sfile

std::unique_ptr<SeqFile> m_sfile