7zFile.cc File Reference

#include "7zFile.h"
#include <cerrno>

Go to the source code of this file.

Functions
WRes	File_Close (CSzFile *p)
void	File_Construct (CSzFile *p)
WRes	File_GetLength (CSzFile *p, UInt64 *length)
static WRes	File_Open (CSzFile *p, const char *name, int writeMode)
WRes	File_Read (CSzFile *p, void *data, size_t *size)
WRes	File_Seek (CSzFile *p, Int64 *pos, ESzSeek origin)
WRes	File_Write (CSzFile *p, const void *data, size_t *size)
void	FileInStream_CreateVTable (CFileInStream *p)
static SRes	FileInStream_Read (void *pp, void *buf, size_t *size)
static SRes	FileInStream_Seek (void *pp, Int64 *pos, ESzSeek origin)
void	FileOutStream_CreateVTable (CFileOutStream *p)
static size_t	FileOutStream_Write (void *pp, const void *data, size_t size)
void	FileSeqInStream_CreateVTable (CFileSeqInStream *p)
static SRes	FileSeqInStream_Read (void *pp, void *buf, size_t *size)
WRes	InFile_Open (CSzFile *p, const char *name)
WRes	OutFile_Open (CSzFile *p, const char *name)

Function Documentation

File_Close()

WRes File_Close

(

CSzFile *

p

)

Definition at line 77 of file 7zFile.cc.

References AlCaHLTBitMon_ParallelJobs::p.

Referenced by LzmaFile::Close().

                            {
#ifdef USE_WINDOWS_FILE
  if (p->handle != INVALID_HANDLE_VALUE) {
    if (!CloseHandle(p->handle))
      return GetLastError();
    p->handle = INVALID_HANDLE_VALUE;
  }
#else
  if (p->file != nullptr) {
    int res = fclose(p->file);
    if (res != 0)
      return res;
    p->file = nullptr;
  }
#endif
  return 0;
}

File_Construct()

void File_Construct

(

CSzFile *

p

)

Definition at line 28 of file 7zFile.cc.

References AlCaHLTBitMon_ParallelJobs::p.

Referenced by LzmaFile::Open().

                                {
#ifdef USE_WINDOWS_FILE
  p->handle = INVALID_HANDLE_VALUE;
#else
  p->file = nullptr;
#endif
}

File_GetLength()

WRes File_GetLength	(	CSzFile *	p,
		UInt64 *	length
	)

Definition at line 212 of file 7zFile.cc.

References AlCaHLTBitMon_ParallelJobs::p.

                                                {
#ifdef USE_WINDOWS_FILE

  DWORD sizeHigh;
  DWORD sizeLow = GetFileSize(p->handle, &sizeHigh);
  if (sizeLow == 0xFFFFFFFF) {
    DWORD res = GetLastError();
    if (res != NO_ERROR)
      return res;
  }
  *length = (((UInt64)sizeHigh) << 32) + sizeLow;
  return 0;

#else

  long pos = ftell(p->file);
  int res = fseek(p->file, 0, SEEK_END);
  *length = ftell(p->file);
  fseek(p->file, pos, SEEK_SET);
  return res;

#endif
}

File_Open()

static WRes File_Open ( CSzFile *  p, const char *  name, int  writeMode  )

static

Definition at line 37 of file 7zFile.cc.

References mergeVDriftHistosByStation::name, definitions::NULL, AlCaHLTBitMon_ParallelJobs::p, and EcalSimRawData_cfi::writeMode.

Referenced by InFile_Open(), and OutFile_Open().

                                                                   {
#ifdef USE_WINDOWS_FILE
  p->handle = CreateFileA(name,
                          writeMode ? GENERIC_WRITE : GENERIC_READ,
                          FILE_SHARE_READ,
                          NULL,
                          writeMode ? CREATE_ALWAYS : OPEN_EXISTING,
                          FILE_ATTRIBUTE_NORMAL,
                          NULL);
  return (p->handle != INVALID_HANDLE_VALUE) ? 0 : GetLastError();
#else
  p->file = fopen(name, writeMode ? "wb+" : "rb");
  return (p->file != nullptr) ? 0 :
#ifdef UNDER_CE
                              2; /* ENOENT */
#else
                              errno;
#endif
#endif
}

File_Read()

WRes File_Read	(	CSzFile *	p,
		void *	data,
		size_t *	size
	)

Definition at line 95 of file 7zFile.cc.

References data, definitions::NULL, AlCaHLTBitMon_ParallelJobs::p, and findQualityFiles::size.

Referenced by FileInStream_Read(), and FileSeqInStream_Read().

                                                     {
  size_t originalSize = *size;
  if (originalSize == 0)
    return 0;

#ifdef USE_WINDOWS_FILE

  *size = 0;
  do {
    DWORD curSize = (originalSize > kChunkSizeMax) ? kChunkSizeMax : (DWORD)originalSize;
    DWORD processed = 0;
    BOOL res = ReadFile(p->handle, data, curSize, &processed, NULL);
    data = (void *)((Byte *)data + processed);
    originalSize -= processed;
    *size += processed;
    if (!res)
      return GetLastError();
    if (processed == 0)
      break;
  } while (originalSize > 0);
  return 0;

#else

  *size = fread(data, 1, originalSize, p->file);
  if (*size == originalSize)
    return 0;
  return ferror(p->file);

#endif
}

File_Seek()

WRes File_Seek	(	CSzFile *	p,
		Int64 *	pos,
		ESzSeek	origin
	)

Definition at line 159 of file 7zFile.cc.

References AlCaHLTBitMon_ParallelJobs::p, SZ_SEEK_CUR, SZ_SEEK_END, SZ_SEEK_SET, and relativeConstraints::value.

Referenced by FileInStream_Seek().

                                                       {
#ifdef USE_WINDOWS_FILE

  LARGE_INTEGER value;
  DWORD moveMethod;
  value.LowPart = (DWORD)*pos;
  value.HighPart = (LONG)((UInt64)*pos >> 16 >> 16); /* for case when UInt64 is 32-bit only */
  switch (origin) {
    case SZ_SEEK_SET:
      moveMethod = FILE_BEGIN;
      break;
    case SZ_SEEK_CUR:
      moveMethod = FILE_CURRENT;
      break;
    case SZ_SEEK_END:
      moveMethod = FILE_END;
      break;
    default:
      return ERROR_INVALID_PARAMETER;
  }
  value.LowPart = SetFilePointer(p->handle, value.LowPart, &value.HighPart, moveMethod);
  if (value.LowPart == 0xFFFFFFFF) {
    WRes res = GetLastError();
    if (res != NO_ERROR)
      return res;
  }
  *pos = ((Int64)value.HighPart << 32) | value.LowPart;
  return 0;

#else

  int moveMethod;
  int res;
  switch (origin) {
    case SZ_SEEK_SET:
      moveMethod = SEEK_SET;
      break;
    case SZ_SEEK_CUR:
      moveMethod = SEEK_CUR;
      break;
    case SZ_SEEK_END:
      moveMethod = SEEK_END;
      break;
    default:
      return 1;
  }
  res = fseek(p->file, (long)*pos, moveMethod);
  *pos = ftell(p->file);
  return res;

#endif
}

File_Write()

WRes File_Write	(	CSzFile *	p,
		const void *	data,
		size_t *	size
	)

Definition at line 127 of file 7zFile.cc.

References data, definitions::NULL, AlCaHLTBitMon_ParallelJobs::p, and findQualityFiles::size.

Referenced by FileOutStream_Write().

                                                            {
  size_t originalSize = *size;
  if (originalSize == 0)
    return 0;

#ifdef USE_WINDOWS_FILE

  *size = 0;
  do {
    DWORD curSize = (originalSize > kChunkSizeMax) ? kChunkSizeMax : (DWORD)originalSize;
    DWORD processed = 0;
    BOOL res = WriteFile(p->handle, data, curSize, &processed, NULL);
    data = (void *)((Byte *)data + processed);
    originalSize -= processed;
    *size += processed;
    if (!res)
      return GetLastError();
    if (processed == 0)
      break;
  } while (originalSize > 0);
  return 0;

#else

  *size = fwrite(data, 1, originalSize, p->file);
  if (*size == originalSize)
    return 0;
  return ferror(p->file);

#endif
}

FileInStream_CreateVTable()

void FileInStream_CreateVTable

(

CFileInStream *

p

)

Definition at line 257 of file 7zFile.cc.

References FileInStream_Read(), FileInStream_Seek(), and AlCaHLTBitMon_ParallelJobs::p.

                                                 {
  p->s.Read = FileInStream_Read;
  p->s.Seek = FileInStream_Seek;
}

FileInStream_Read()

static SRes FileInStream_Read ( void *  pp, void *  buf, size_t *  size  )

static

Definition at line 247 of file 7zFile.cc.

References visDQMUpload::buf, File_Read(), AlCaHLTBitMon_ParallelJobs::p, createTree::pp, findQualityFiles::size, SZ_ERROR_READ, and SZ_OK.

Referenced by FileInStream_CreateVTable().

                                                                 {
  CFileInStream *p = (CFileInStream *)pp;
  return (File_Read(&p->file, buf, size) == 0) ? SZ_OK : SZ_ERROR_READ;
}

FileInStream_Seek()

static SRes FileInStream_Seek ( void *  pp, Int64 *  pos, ESzSeek  origin  )

static

Definition at line 252 of file 7zFile.cc.

References File_Seek(), AlCaHLTBitMon_ParallelJobs::p, and createTree::pp.

Referenced by FileInStream_CreateVTable().

                                                                    {
  CFileInStream *p = (CFileInStream *)pp;
  return File_Seek(&p->file, pos, origin);
}

FileOutStream_CreateVTable()

void FileOutStream_CreateVTable

(

CFileOutStream *

p

)

Definition at line 270 of file 7zFile.cc.

References FileOutStream_Write(), and AlCaHLTBitMon_ParallelJobs::p.

{ p->s.Write = FileOutStream_Write; }

FileOutStream_Write()

static size_t FileOutStream_Write ( void *  pp, const void *  data, size_t  size  )

static

Definition at line 264 of file 7zFile.cc.

References data, File_Write(), AlCaHLTBitMon_ParallelJobs::p, createTree::pp, and findQualityFiles::size.

Referenced by FileOutStream_CreateVTable().

                                                                           {
  CFileOutStream *p = (CFileOutStream *)pp;
  File_Write(&p->file, data, &size);
  return size;
}

FileSeqInStream_CreateVTable()

void FileSeqInStream_CreateVTable

(

CFileSeqInStream *

p

)

Definition at line 243 of file 7zFile.cc.

References FileSeqInStream_Read(), and AlCaHLTBitMon_ParallelJobs::p.

Referenced by LzmaFile::Open().

{ p->s.Read = FileSeqInStream_Read; }

FileSeqInStream_Read()

static SRes FileSeqInStream_Read ( void *  pp, void *  buf, size_t *  size  )

static

Definition at line 238 of file 7zFile.cc.

References visDQMUpload::buf, File_Read(), AlCaHLTBitMon_ParallelJobs::p, createTree::pp, findQualityFiles::size, SZ_ERROR_READ, and SZ_OK.

Referenced by FileSeqInStream_CreateVTable().

                                                                    {
  CFileSeqInStream *p = (CFileSeqInStream *)pp;
  return File_Read(&p->file, buf, size) == 0 ? SZ_OK : SZ_ERROR_READ;
}

InFile_Open()

WRes InFile_Open	(	CSzFile *	p,
		const char *	name
	)

Definition at line 58 of file 7zFile.cc.

References File_Open(), mergeVDriftHistosByStation::name, and AlCaHLTBitMon_ParallelJobs::p.

Referenced by LzmaFile::Open().

{ return File_Open(p, name, 0); }

OutFile_Open()

WRes OutFile_Open	(	CSzFile *	p,
		const char *	name
	)

Definition at line 59 of file 7zFile.cc.

References File_Open(), mergeVDriftHistosByStation::name, and AlCaHLTBitMon_ParallelJobs::p.

{ return File_Open(p, name, 1); }