class for checking if checksums match expectations Extends the copyRequest::base class with new printResults function that checks if sums match expected values and prints results in a way compatible with e.g. More...

Inheritance diagram for copyRequest::listingRequest:

[legend]

Collaboration diagram for copyRequest::listingRequest:

[legend]

Public Member Functions
	listingRequest (const std::string &aSource, std::unique_ptr< const genericStat > &aStat, inputHandler::base *aInputHandler)

void	process (perThreadData &) override

bool	compare (const base &rhs) const override

void	printResults (std::ostream &, std::ostream &logStream) override

Public Member Functions inherited from copyRequest::base
const genericStat &	getInitialStat () const

const std::string &	getSource () const

clock_type::duration	getAdvisedDelay () const
	returns the advised delay More...

void	registerIterator (decltype(filesInWorkIterator) iter)

decltype(filesInWorkIterator)	getFilesInWorkIteraror () const

fileInWork::slotTypes	getSlotType () const

void	changeRequestType (stateBitType newType)

	base (inputHandler::base *InputHandler, const std::string &aSource, const std::string &aDestination, std::unique_ptr< const genericStat > &aStat, const singleMap &aMapEntry, bool remove, clock_type::time_point timestamp)
	constructor for copy,link and remove requests. More...

	base (inputHandler::base *InputHandler, const std::string &aSource, const std::string &aDestination, const singleMap &aMapEntry, bool remove, clock_type::time_point timestamp)
	constructor for copy,link and remove requests. More...

	base (inputHandler::base *InputHandler, const std::string &aSource, const std::string &aDestination, const std::string &aMoveSource, const std::string &aOrigSource, const singleMap &aMapEntry, clock_type::time_point timestamp)
	constructor for rename requests only. More...

virtual	~base () noexcept(false)

const std::string &	getSuffix () const

void	addExpectedChecksumResult (const std::string &checkSumType, const std::string &expectedValue)

void	kw_size (std::string &value) const

void	kw_mtime (std::string &value) const

void	kw_inow (std::string &value) const

void	kw_now (std::string &value) const

void	kw_version (std::string &value) const

void	kw_commit (std::string &value) const

void	kw_prefix (std::string &value) const

void	kw_reason (std::string &value) const

void	kw_state (std::string &value) const

void	kw_finishtime (std::string &value) const

Static Public Member Functions
static void	printFinalLine (std::ostream &)

static void	prepareStatPrint ()
	setup statPrinter to print the final line for compatibiity mith eg. md5sum More...

Static Public Member Functions inherited from copyRequest::base
static std::map< std::string, void(base::*)(std::string &) const > &	keywordMap ()

static bool	adviseDelay (clock_type::duration dt, const std::string &suffix)
	update the advised delay in the map. More...

static void	printStats (std::ostream &stream)

static void	resetStats ()

static bool	retry (std::unique_ptr< base > &request, timedQueue &delayedRequests)

static void	waitForAllInstancesGone ()

static bool	checkForInstances ()

static std::function< void(std::ostream &)> &	getStatPrinter ()
	we can't have static functions virtual, so we explicitly use a function to give us the proper print function, which can be changed in derived classes. More...

static void	setStatPrinter (void(*f)(std::ostream &))

static void	processQueue (simpleQueue &queue, simpleQueue &resultQueue, timedQueue &delayedRequests)

static void	getSuffix (const std::string &path, std::string &suffix)

Protected Member Functions
void	printModeBits (std::ostream &stream, mode_t bits)

void	printMode (std::ostream &stream, mode_t bits)

Protected Member Functions inherited from copyRequest::base
void	adviseDelay (clock_type::duration dt=clock_type::duration::zero())

Static Protected Attributes
static options::single< bool >	reverse

static options::single< bool >	sortByTime

static options::single< bool >	sortBySize

static singleMap	dummyMapEntry

Static Protected Attributes inherited from copyRequest::base
static statCollector::typed< decltype(tWorkDone - tInotify) >	tTotalStat

static statCollector::typed< decltype(tWorkDone - tInotify) >	tTotal2Stat

static statCollector::typed< decltype(tWorkDone - tInotify) >	tInotifyStat

static statCollector::typed< decltype(tEnqueue - tInotify) >	tPipeStat

static statCollector::typed< decltype(tWorkStart - tEnqueue) >	tWaitStat

static statCollector::typed< decltype(tWorkDone - tWorkStart) >	tCopyStat

static statCollector::typed< decltype(readInitialStat->size) >	bytesStat

static statCollector::typed< double >	speedStat

static clock_type::time_point	tProgramStart

static std::atomic< unsigned int >	nConcurrentProcesses

static options::single< double >	maxDelayTime

static std::function< void(std::ostream &)>	statPrinter

Additional Inherited Members
Public Attributes inherited from copyRequest::base
decltype(fileInWork::filesInWork.begin())	filesInWorkIterator = fileInWork::filesInWork.end()

Static Public Attributes inherited from copyRequest::base
static options::single< bool >	setAttributesAfterClose

static options::single< bool >	perFileThreads

static options::single< size_t >	userWriteBlockSize

static options::single< size_t >	userReadBlockSize

static options::single< size_t >	maxMemoryBlockSize

static options::single< size_t >	minMemoryBlockSize

static statCollector::typed< copyRequest::clock_type::duration >	tEnqueueStat

static std::vector< std::atomic< unsigned int > > *	processMultiplicities

Protected Attributes inherited from copyRequest::base
std::unique_ptr< const genericStat >	readInitialStat

std::list< checksum::base * >	checkSums

perThreadData *	threadData

stateType	state

std::string	errorMessage

const std::string	source

const std::string	destination

const std::string	moveSource

const std::string	origSource

const singleMap &	mapEntry

std::string	suffix

std::string	prefix

size_t	memoryBlockSize

clock_type::time_point	tInotify

clock_type::time_point	tEnqueue

clock_type::time_point	tWorkStart

clock_type::time_point	tWorkDone

unsigned	retries

Detailed Description

class for checking if checksums match expectations Extends the copyRequest::base class with new printResults function that checks if sums match expected values and prints results in a way compatible with e.g.

md5sum command.

Definition at line 17 of file listingRequestProvider.cpp.

Constructor & Destructor Documentation

◆ listingRequest()

copyRequest::listingRequest::listingRequest	(	const std::string &	aSource,
		std::unique_ptr< const genericStat > &	aStat,
		inputHandler::base *	aInputHandler
	)

inline

Definition at line 57 of file listingRequestProvider.cpp.

59 :

60 base(aInputHandler, aSource, "", aStat, dummyMapEntry, false, copyRequest::clock_type::now()) {}

Member Function Documentation

◆ compare()

bool copyRequest::listingRequest::compare ( const base & rhs ) const

inlineoverridevirtual

Reimplemented from copyRequest::base.

Definition at line 63 of file listingRequestProvider.cpp.

                                                      {
             if (sortByTime) {
                 return (readInitialStat->mTime > rhs.getInitialStat().mTime) ^ reverse;
             } else if (sortBySize) {
                 return (readInitialStat->size > rhs.getInitialStat().size) ^ reverse;
             } else {
                 return (source < rhs.getSource()) ^ reverse;
             }
         }

References copyRequest::base::getInitialStat(), copyRequest::base::getSource(), genericStat::mTime, copyRequest::base::readInitialStat, reverse, genericStat::size, sortBySize, sortByTime, and copyRequest::base::source.

Here is the call graph for this function:

◆ prepareStatPrint()

static void copyRequest::listingRequest::prepareStatPrint ( )

inlinestatic

setup statPrinter to print the final line for compatibiity mith eg. md5sum

Definition at line 92 of file listingRequestProvider.cpp.

                                        {
             statPrinter = printFinalLine;
         }

References printFinalLine(), and copyRequest::base::statPrinter.

Here is the call graph for this function:

◆ printFinalLine()

static void copyRequest::listingRequest::printFinalLine ( std::ostream & )

inlinestatic

Definition at line 89 of file listingRequestProvider.cpp.

89 {

90 }

Referenced by prepareStatPrint().

Here is the caller graph for this function:

◆ printMode()

void copyRequest::listingRequest::printMode	(	std::ostream &	stream,
		mode_t	bits
	)

inlineprotected

Definition at line 26 of file listingRequestProvider.cpp.

                                                         {
             switch (bits & S_IFMT) {
                 case S_IFSOCK:
                     stream << "s";
                     break;
                 case S_IFLNK:
                     stream << "l";
                     break;
                 case S_IFREG:
                     stream << "-";
                     break;
                 case S_IFBLK:
                     stream << "b";
                     break;
                 case S_IFDIR:
                     stream << "d";
                     break;
                 case S_IFCHR:
                     stream << "c";
                     break;
                 case S_IFIFO:
                     stream << "f";
                     break;
             }
             printModeBits(stream, bits >> 6);
             printModeBits(stream, bits >> 3);
             printModeBits(stream, bits >> 0);
             stream << " ";
         }

References printModeBits().

Referenced by printResults().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ printModeBits()

void copyRequest::listingRequest::printModeBits	(	std::ostream &	stream,
		mode_t	bits
	)

inlineprotected

Definition at line 23 of file listingRequestProvider.cpp.

                                                             {
             stream << (bits & 4 ? "r" : "-") << (bits & 2 ? "w" : "-")  << (bits & 1 ? "x" : "-");
         }

Referenced by printMode().

Here is the caller graph for this function:

◆ printResults()

void copyRequest::listingRequest::printResults	(	std::ostream &	,
		std::ostream &	logStream
	)

inlineoverridevirtual

Reimplemented from copyRequest::base.

Definition at line 73 of file listingRequestProvider.cpp.

                                                           {
             static auto escaper = escapism::newEscaper("C");
             timerInst(print);
             std::string name;
             escaper->escape(source, name);
             printMode(logStream, readInitialStat->mode);
             logStream << std::setw(6)  << readInitialStat->ownerUid << " ";
             logStream << std::setw(10) << readInitialStat->ownerGid << " ";
             logStream << std::setw(13) << readInitialStat->size << " ";
             std::string time;
             readInitialStat->getMtime(time);
             logStream << time << " ";
             logStream << name << "\n";
             timerInst(nix);
         }

References escapism::newEscaper(), printMode(), copyRequest::base::readInitialStat, copyRequest::base::source, and timerInst.

Here is the call graph for this function:

◆ process()

void copyRequest::listingRequest::process ( perThreadData & )

inlineoverridevirtual

Reimplemented from copyRequest::base.

Definition at line 61 of file listingRequestProvider.cpp.

61 {

62 }

Member Data Documentation

◆ dummyMapEntry

singleMap copyRequest::listingRequest::dummyMapEntry

staticprotected

Definition at line 55 of file listingRequestProvider.cpp.

◆ reverse

options::single<bool> copyRequest::listingRequest::reverse

staticprotected

Definition at line 19 of file listingRequestProvider.cpp.

Referenced by compare().

◆ sortBySize

options::single<bool> copyRequest::listingRequest::sortBySize

staticprotected

Definition at line 21 of file listingRequestProvider.cpp.

Referenced by compare().

◆ sortByTime

options::single<bool> copyRequest::listingRequest::sortByTime

staticprotected

Definition at line 20 of file listingRequestProvider.cpp.

Referenced by compare().

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

src/listingRequestProvider.cpp (v0.19-24-g0617ca1 with changes)

Public Member Functions

Static Public Member Functions

Protected Member Functions

Static Protected Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ listingRequest()

Member Function Documentation

◆ compare()

◆ prepareStatPrint()

◆ printFinalLine()

◆ printMode()

◆ printModeBits()

◆ printResults()

◆ process()

Member Data Documentation

◆ dummyMapEntry

◆ reverse

◆ sortBySize

◆ sortByTime