A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
|
#include <PDBScanWork.h>
Public Member Functions | |
PDBScanWork (PageIteratorPtr iter, pdb::PangeaStorageServer *storage, int &counter) | |
~PDBScanWork () | |
bool | sendPagePinned (pdb::PDBCommunicatorPtr myCommunicator, bool morePagesToPin, NodeID nodeId, DatabaseID dbId, UserTypeID typeId, SetID setId, PageID pageId, size_t pageSize, size_t offset) |
bool | acceptPagePinnedAck (pdb::PDBCommunicatorPtr myCommunicator, bool &wasError, string &info, string &errMsg) |
void | execute (PDBBuzzerPtr callerBuzzer) override |
Public Member Functions inherited from pdb::PDBWork | |
virtual PDBBuzzerPtr | getLinkedBuzzer () |
void | execute (PDBWorkerQueue *parent, PDBBuzzerPtr callerBuzzer) |
PDBWorkerPtr | getWorker () |
PDBLoggerPtr | getLogger () |
Private Attributes | |
PageIteratorPtr | iter |
pdb::PangeaStorageServer * | storage |
int & | counter |
pthread_mutex_t | connection_mutex |
This class illustrates how a FrontEnd server scan set data and communicate with BackEnd server to notify loaded pages.
Definition at line 36 of file PDBScanWork.h.
PDBScanWork::PDBScanWork | ( | PageIteratorPtr | iter, |
pdb::PangeaStorageServer * | storage, | ||
int & | counter | ||
) |
Definition at line 42 of file PDBScanWork.cc.
PDBScanWork::~PDBScanWork | ( | ) |
Definition at line 49 of file PDBScanWork.cc.
bool PDBScanWork::acceptPagePinnedAck | ( | pdb::PDBCommunicatorPtr | myCommunicator, |
bool & | wasError, | ||
string & | info, | ||
string & | errMsg | ||
) |
|
overridevirtual |
Implements pdb::PDBWork.
Definition at line 110 of file PDBScanWork.cc.
bool PDBScanWork::sendPagePinned | ( | pdb::PDBCommunicatorPtr | myCommunicator, |
bool | morePagesToPin, | ||
NodeID | nodeId, | ||
DatabaseID | dbId, | ||
UserTypeID | typeId, | ||
SetID | setId, | ||
PageID | pageId, | ||
size_t | pageSize, | ||
size_t | offset | ||
) |
|
private |
Definition at line 62 of file PDBScanWork.h.
|
private |
Definition at line 61 of file PDBScanWork.h.
|
private |
Definition at line 59 of file PDBScanWork.h.
|
private |
Definition at line 60 of file PDBScanWork.h.