hobbes
a language, embedded compiler, and runtime for efficient dynamic expression evaluation, data storage and analysis
Classes | Namespaces | Functions
batchrecv.C File Reference
#include <hobbes/hobbes.H>
#include <hobbes/storage.H>
#include <hobbes/ipc/net.H>
#include <hobbes/util/str.H>
#include <hobbes/util/os.H>
#include <iostream>
#include <map>
#include <thread>
#include <mutex>
#include <zlib.h>
#include "session.H"
#include "netio.H"
Include dependency graph for batchrecv.C:

Classes

struct  hog::gzbuffer
 

Namespaces

 hog
 

Functions

void hog::read (gzbuffer *in, uint8_t *b, size_t n)
 
void hog::read (gzbuffer *in, uint32_t *n)
 
void hog::read (gzbuffer *in, uint64_t *n)
 
void hog::read (gzbuffer *in, std::string *x)
 
void hog::read (gzbuffer *in, std::vector< uint8_t > *x)
 
void hog::read (gzbuffer *in, storage::statements *stmts)
 
void hog::runRecvConnection (int c, std::string dir)
 
void hog::runRecvServer (int socket, std::string dir)
 
std::thread hog::pullRemoteDataT (const std::string &dir, const std::string &listenport)
 
bool hog::pullRemoteData (const std::string &dir, const std::string &listenport)