batchsend.C File Reference

#include <hobbes/hobbes.H>
#include <hobbes/storage.H>
#include <hobbes/ipc/net.H>
#include <hobbes/util/str.H>
#include <hobbes/util/codec.H>
#include <hobbes/util/os.H>
#include <hobbes/util/perf.H>
#include <iostream>
#include <map>
#include <thread>
#include <mutex>
#include <glob.h>
#include <zlib.h>
#include "netio.H"

Include dependency graph for batchsend.C:

Classes
struct	hog::BatchSendSession

Namespaces
	hog

Functions
ssize_t	sendfile (int toFD, int fromFD, off_t *o, size_t sz)
void	hog::sendFileContents (int connection, int sfd)
void	hog::sendSegmentFiles (int connection, const std::string &localdir)
void	hog::sendInitMessage (int connection, const std::string &groupName, const std::string &localdir)
void	hog::runConnectedSegmentSendingProcess (int connection, const std::string &groupName, const std::string &localdir)
void	hog::runSegmentSendingProcess (std::string groupName, std::string hostport, std::string localdir)
std::string	hog::segmentFileName (uint32_t seg)
void	hog::write (BatchSendSession *s, const uint8_t *d, size_t sz)
void	hog::write (BatchSendSession *s, const std::string &x)
void	hog::write (BatchSendSession *s, const std::vector< uint8_t > &x)
template<typename T >
void	hog::write (BatchSendSession *s, T x)
static void	hog::initNetSession (BatchSendSession *s, const std::string &groupName, const std::string &dir, storage::PipeQOS qos, storage::CommitMethod cm, const storage::statements &stmts)
void	hog::pushLocalData (const storage::QueueConnection &qc, const std::string &groupName, const std::string &dir, size_t clevel, size_t batchsendsize, long batchsendtime, const std::string &sendto)

Function Documentation

sendfile()

ssize_t sendfile	(	int	toFD,
		int	fromFD,
		off_t *	o,
		size_t	sz
	)