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.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
PDBScanWork Class Reference

#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::PangeaStorageServerstorage
 
int & counter
 
pthread_mutex_t connection_mutex
 

Detailed Description

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.

Constructor & Destructor Documentation

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.

Member Function Documentation

bool PDBScanWork::acceptPagePinnedAck ( pdb::PDBCommunicatorPtr  myCommunicator,
bool &  wasError,
string &  info,
string &  errMsg 
)

Definition at line 82 of file PDBScanWork.cc.

+ Here is the caller graph for this function:

void PDBScanWork::execute ( PDBBuzzerPtr  callerBuzzer)
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 
)

Definition at line 53 of file PDBScanWork.cc.

+ Here is the caller graph for this function:

Member Data Documentation

pthread_mutex_t PDBScanWork::connection_mutex
private

Definition at line 62 of file PDBScanWork.h.

int& PDBScanWork::counter
private

Definition at line 61 of file PDBScanWork.h.

PageIteratorPtr PDBScanWork::iter
private

Definition at line 59 of file PDBScanWork.h.

pdb::PangeaStorageServer* PDBScanWork::storage
private

Definition at line 60 of file PDBScanWork.h.


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