![]() |
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>
Inheritance diagram for PDBScanWork:
Collaboration diagram for PDBScanWork: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.
Here is the call graph for this function:| 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.