#include <XrdClZipArchive.hh>

Collaboration diagram for XrdCl::ZipArchive:

Classes
struct	NewFile
	LFH of a newly appended file (in case it needs to be overwritten) More...

Public Member Functions
	ZipArchive (bool enablePlugIns=true)
	Constructor. More...

virtual	~ZipArchive ()
	Destructor. More...

XRootDStatus	OpenArchive (const std::string &url, OpenFlags::Flags flags, ResponseHandler *handler, uint16_t timeout=0)

XRootDStatus	OpenFile (const std::string &fn, OpenFlags::Flags flags=OpenFlags::None, uint64_t size=0, uint32_t crc32=0)

XRootDStatus	Read (uint64_t offset, uint32_t size, void buffer, ResponseHandler handler, uint16_t timeout=0)

XRootDStatus	ReadFrom (const std::string &fn, uint64_t offset, uint32_t size, void buffer, ResponseHandler handler, uint16_t timeout=0)

XRootDStatus	Write (uint32_t size, const void buffer, ResponseHandler handler, uint16_t timeout=0)

XRootDStatus	UpdateMetadata (uint32_t crc32)

XRootDStatus	AppendFile (const std::string &fn, uint32_t crc32, uint32_t size, const void buffer, ResponseHandler handler, uint16_t timeout=0)

XRootDStatus	Stat (const std::string &fn, StatInfo *&info)

XRootDStatus	Stat (StatInfo *&info)

XRootDStatus	GetCRC32 (const std::string &fn, uint32_t &cksum)

XRootDStatus	CloseArchive (ResponseHandler *handler, uint16_t timeout=0)
	Create the central directory at the end of ZIP archive and close it. More...

XRootDStatus	CloseFile ()

XRootDStatus	List (DirectoryList *&list)

bool	IsOpen ()

bool	SetProperty (const std::string &name, const std::string &value)
	Set property on the underlying File object. More...

bool	GetProperty (const std::string &name, std::string &value)
	Get property on the underlying File object. More...

Private Types
enum	OpenStages { None = 0, HaveEocdBlk, HaveZip64EocdlBlk, HaveZip64EocdBlk, HaveCdRecords, Done, Error, NotParsed }
	Stages of opening and parsing a ZIP archive. More...

typedef std::unordered_map < std::string, ZipCache >	zipcache_t
	Type that maps file name to its cache. More...

typedef std::unordered_map < std::string, NewFile >	new_files_t

Private Member Functions
XRootDStatus	WriteImpl (uint32_t size, const void buffer, ResponseHandler handler, uint16_t timeout)

XRootDStatus	OpenOnly (const std::string &url, bool update, ResponseHandler *handler, uint16_t timeout=0)

buffer_t	GetCD ()

void	SetCD (const buffer_t &buffer)

StatInfo *	make_stat (const std::string &fn)

void	Clear ()
	Clear internal ZipArchive objects. More...

Static Private Member Functions
template<typename Response >
static AnyObject *	PkgRsp (Response *rsp)

template<typename Response >
static void	Free (XRootDStatus st, Response rsp)
	Free status and response. More...

template<typename Response >
static void	Schedule (ResponseHandler handler, XRootDStatus st, Response *rsp=nullptr)

static StatInfo *	make_stat (const StatInfo &starch, uint64_t size)

static XRootDStatus *	make_status (const XRootDStatus &status=XRootDStatus())
	Allocate new XRootDStatus object. More...

Private Attributes
File	archive

uint64_t	archsize

bool	cdexists

bool	updated

std::unique_ptr< char[]>	buffer

std::unique_ptr< EOCD >	eocd

cdvec_t	cdvec

cdmap_t	cdmap

uint64_t	cdoff

uint32_t	orgcdsz

uint32_t	orgcdcnt

buffer_t	orgcdbuf

std::unique_ptr< ZIP64_EOCD >	zip64eocd

OpenStages	openstage

std::string	openfn

zipcache_t	zipcache

std::unique_ptr< LFH >	lfh

bool	ckpinit

new_files_t	newfiles

Friends
class	XrdEc::StrmWriter

class	XrdEc::Reader

template<bool >
class	XrdEc::OpenOnlyImpl

class	::MicroTest

Member Typedef Documentation

typedef std::unordered_map<std::string, NewFile> XrdCl::ZipArchive::new_files_t

private

typedef std::unordered_map<std::string, ZipCache> XrdCl::ZipArchive::zipcache_t

private

Type that maps file name to its cache.

Member Enumeration Documentation

enum XrdCl::ZipArchive::OpenStages

private

Stages of opening and parsing a ZIP archive.

Enumerator
None
HaveEocdBlk
HaveZip64EocdlBlk
HaveZip64EocdBlk
HaveCdRecords
Done
Error
NotParsed

Constructor & Destructor Documentation

XrdCl::ZipArchive::ZipArchive ( bool enablePlugIns = true )

Constructor.

virtual XrdCl::ZipArchive::~ZipArchive ( )

virtual

Destructor.

Member Function Documentation

XRootDStatus XrdCl::ZipArchive::AppendFile	(	const std::string &	fn,
		uint32_t	crc32,
		uint32_t	size,
		const void *	buffer,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

Create a new file in the ZIP archive and append the data

Parameters

fn	: the name of the new file to be created
crc32	: the crc32 of the file
size	: the size of the file
buffer	: the buffer with the data
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

void XrdCl::ZipArchive::Clear ( )

inlineprivate

Clear internal ZipArchive objects.

XRootDStatus XrdCl::ZipArchive::CloseArchive	(	ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

Create the central directory at the end of ZIP archive and close it.

Parameters

handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

XRootDStatus XrdCl::ZipArchive::CloseFile ( )

inline

Close an open file within the ZIP archive

Returns: : the status of the operation

References XrdCl::errInvalidOp, and XrdCl::stError.

template<typename Response >

static void XrdCl::ZipArchive::Free	(	XRootDStatus *	st,
		Response *	rsp
	)

inlinestaticprivate

Free status and response.

buffer_t XrdCl::ZipArchive::GetCD ( )

private

Get a buffer with central directory of the ZIP archive

Returns: : buffer with central directory

XRootDStatus XrdCl::ZipArchive::GetCRC32	(	const std::string &	fn,
		uint32_t &	cksum
	)

inline

Get crc32 for a given file

Parameters

fn	: file name
cksum	: output parameter

Returns: : the status of the operation

References XrdCl::errInvalidOp, XrdCl::errNotFound, and XrdCl::stError.

bool XrdCl::ZipArchive::GetProperty	(	const std::string &	name,
		std::string &	value
	)

inline

Get property on the underlying File object.

bool XrdCl::ZipArchive::IsOpen ( )

inline

Returns: : true if ZIP archive has been successfully opened

XRootDStatus XrdCl::ZipArchive::List ( DirectoryList *& list )

List files in the ZIP archive

Returns: : the status of the operation

static StatInfo* XrdCl::ZipArchive::make_stat	(	const StatInfo &	starch,
		uint64_t	size
	)

inlinestaticprivate

Create a StatInfo object from ZIP archive stat info and the file size.

Parameters

starch	: ZIP archive stat info
size	: file size

Returns: : StatInfo object

References XrdCl::StatInfo::GetFlags(), XrdCl::StatInfo::IsWritable, XrdCl::StatInfo::SetFlags(), and XrdCl::StatInfo::SetSize().

StatInfo* XrdCl::ZipArchive::make_stat ( const std::string & fn )

inlineprivate

Create a StatInfo object for a given file within the ZIP archive.

Parameters

fn	: file name

Returns: : StatInfo object for the given file

static XRootDStatus* XrdCl::ZipArchive::make_status ( const XRootDStatus & status = XRootDStatus() )

inlinestaticprivate

Allocate new XRootDStatus object.

XRootDStatus XrdCl::ZipArchive::OpenArchive	(	const std::string &	url,
		OpenFlags::Flags	flags,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

Open ZIP Archive (and parse the Central Directory)

Parameters

url	: the URL of the ZIP archive
flags	: open flags to be used when openning the file
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

XRootDStatus XrdCl::ZipArchive::OpenFile	(	const std::string &	fn,
		OpenFlags::Flags	flags = `OpenFlags::None`,
		uint64_t	size = `0`,
		uint32_t	crc32 = `0`
	)

Open a file within the ZIP Archive

Parameters

fn	: file name to be opened
flags	: open flags (either 'Read' or 'New \| Write')
size	: file size (to be included in the LFH)
crc32	: file crc32 (to be included in the LFH)

Returns: : the status of the operation

XRootDStatus XrdCl::ZipArchive::OpenOnly	(	const std::string &	url,
		bool	update,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

private

Open the ZIP archive in read-only mode without parsing the central directory.

Parameters

url	: url of the ZIP archive
handler	: user callback
timeout	: operation timeout

Returns: : operation status

template<typename Response >

static AnyObject* XrdCl::ZipArchive::PkgRsp ( Response * rsp )

inlinestaticprivate

Package a response into AnyObject (erase the type)

Parameters

rsp	: the response to be packaged

Returns: : AnyObject with the response

References XrdCl::AnyObject::Set().

XRootDStatus XrdCl::ZipArchive::Read	(	uint64_t	offset,
		uint32_t	size,
		void *	buffer,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

inline

Read data from an open file

Parameters

offset	: offset within the file to read at
size	: number of bytes to be read
buffer	: the buffer for the data
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

References XrdCl::errInvalidOp, XrdCl::ReadFrom(), and XrdCl::stError.

XRootDStatus XrdCl::ZipArchive::ReadFrom	(	const std::string &	fn,
		uint64_t	offset,
		uint32_t	size,
		void *	buffer,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

Read data from a given file

Parameters

fn	: the name of the file from which we are going to read
offset	: offset within the file to read at
size	: number of bytes to be read
buffer	: the buffer for the data
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

template<typename Response >

static void XrdCl::ZipArchive::Schedule	(	ResponseHandler *	handler,
		XRootDStatus *	st,
		Response *	rsp = `nullptr`
	)

inlinestaticprivate

Schedule a user callback to be executed in the thread-pool with given status and response.

Parameters

handler	: user callback to be scheduled
st	: status to be passed to the callback
rsp	: response to be passed to the callback

References XrdCl::PostMaster::GetJobManager(), XrdCl::DefaultEnv::GetPostMaster(), XrdCl::ResponseHandler::HandleResponse(), XrdCl::JobManager::IsWorker(), and XrdCl::JobManager::QueueJob().

void XrdCl::ZipArchive::SetCD ( const buffer_t & buffer )

private

Set central directory for the ZIP archive

Parameters

buffer : a buffer with the central directory to be set

bool XrdCl::ZipArchive::SetProperty	(	const std::string &	name,
		const std::string &	value
	)

inline

Set property on the underlying File object.

XRootDStatus XrdCl::ZipArchive::Stat	(	const std::string &	fn,
		StatInfo *&	info
	)

inline

Get stat info for given file

Parameters

fn	: the name of the file
info	: output parameter

Returns: : the status of the operation

References XrdCl::errInvalidOp, XrdCl::errNotFound, and XrdCl::stError.

XRootDStatus XrdCl::ZipArchive::Stat ( StatInfo *& info )

inline

Get stat info for an open file

Parameters

info	: output parameter

Returns: : the status of the operation

References XrdCl::errInvalidOp, XrdCl::Stat(), and XrdCl::stError.

XRootDStatus XrdCl::ZipArchive::UpdateMetadata ( uint32_t crc32 )

Update the metadata of the currently open file

Parameters

crc32 : the crc32 checksum

Returns: : the status of the operation

XRootDStatus XrdCl::ZipArchive::Write	(	uint32_t	size,
		const void *	buffer,
		ResponseHandler *	handler,
		uint16_t	timeout = `0`
	)

inline

Append data to a new file

Parameters

size	: number of bytes to be appended
buffer	: the buffer with the data to be appended
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

References XrdCl::errInvalidOp, and XrdCl::stError.

XRootDStatus XrdCl::ZipArchive::WriteImpl	(	uint32_t	size,
		const void *	buffer,
		ResponseHandler *	handler,
		uint16_t	timeout
	)

private

Append data to a new file, implementation

Parameters

lfh	: the Local File Header record
size	: number of bytes to be appended
buffer	: the buffer with the data to be appended
handler	: user callback
timeout	: operation timeout

Returns: : the status of the operation

Friends And Related Function Documentation

friend class ::MicroTest

friend

template<bool >

friend class XrdEc::OpenOnlyImpl

friend

friend class XrdEc::Reader

friend

friend class XrdEc::StrmWriter

friend

Member Data Documentation

File XrdCl::ZipArchive::archive

private

uint64_t XrdCl::ZipArchive::archsize

private

std::unique_ptr<char[]> XrdCl::ZipArchive::buffer

private

bool XrdCl::ZipArchive::cdexists

private

cdmap_t XrdCl::ZipArchive::cdmap

private

uint64_t XrdCl::ZipArchive::cdoff

private

cdvec_t XrdCl::ZipArchive::cdvec

private

bool XrdCl::ZipArchive::ckpinit

private

std::unique_ptr<EOCD> XrdCl::ZipArchive::eocd

private

std::unique_ptr<LFH> XrdCl::ZipArchive::lfh

private

new_files_t XrdCl::ZipArchive::newfiles

private

std::string XrdCl::ZipArchive::openfn

private

OpenStages XrdCl::ZipArchive::openstage

private

buffer_t XrdCl::ZipArchive::orgcdbuf

private

uint32_t XrdCl::ZipArchive::orgcdcnt

private

uint32_t XrdCl::ZipArchive::orgcdsz

private

bool XrdCl::ZipArchive::updated

private

std::unique_ptr<ZIP64_EOCD> XrdCl::ZipArchive::zip64eocd

private

zipcache_t XrdCl::ZipArchive::zipcache

private

The documentation for this class was generated from the following file:

XrdClZipArchive.hh

Classes

Public Member Functions

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Friends

Member Typedef Documentation

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation