rasdaman complete source
Public Member Functions | List of all members
RnpClientComm Class Reference

#include <rnpclientcomm.hh>

Inheritance diagram for RnpClientComm:
rnp::RnpBaseClientComm

Public Member Functions

 RnpClientComm (const char *rasmgrHost, int rasmgrPort=RASMGRPORT) throw ( r_Error )
 constructor getting the host name of the rasmgr host and it's listening port (default 7001). More...
 
 ~RnpClientComm () throw ()
 
bool effectivTypeIsRNP () throw ()
 
unsigned long getClientID () const
 provides read access to my clientID More...
 
int setTransferFormat (r_Data_Format format, const char *formatParams=NULL)
 set the preferred transfer format More...
 
int setStorageFormat (r_Data_Format format, const char *formatParams=NULL)
 set the preferred storage format More...
 
const char * getServerName ()
 get real server name (the dinamic one, assigned by the RasMGR) More...
 
void setUserIdentification (const char *userName, const char *plainTextPassword)
 user identification for RasMGR More...
 
void setMaxRetry (unsigned int newMaxRetry)
 set maximum retry to get a server More...
 
unsigned int getMaxRetry ()
 get maximum retry to get a server More...
 
void setTurbo (bool turbo)
 
void triggerAliveSignal ()
 
void sendAliveSignal ()
 
const char * getExtendedErrorInfo () throw (r_Error)
 
void setTimeoutInterval (int seconds)
 
int getTimeoutInterval ()
 
r_OId createCollection (const char *collName, const char *collTypeName) throw (r_Error)
 
r_OId createMDD (const char *collName, const char *mddTypeName, const char *definitionDomain, const char *tileDomain, bool rcindex=false) throw (r_Error)
 
void extendMDD (r_OId mddOId, const char *stripeDomain, const char *tileDomain) throw (r_Error)
 
vector< r_OId > getOIdsFromCollection (const char *name) throw ( r_Error )
 
vector< r_OId > getOIdsFromCollection (const r_OId &oid) throw ( r_Error )
 
vector< r_Minterval > getTileDomains (r_OId mddOId, const char *stripeDomain) throw ( r_Error )
 
void preloadTiles (r_OId mddOId, const char *tileDomain) throw (r_Error)
 
int getTileData (r_OId mddOId, const char *tileDomain, char *&data, bool preallocated=false) throw (r_Error)
 
void replaceTileData (r_OId mddOId, const char *tileDomain, const char *newData, int dataLength, const char *alfaData, int alfaLength) throw (r_Error)
 
int openDB (const char *database)
 open database More...
 
int closeDB ()
 close current database More...
 
int createDB (const char *name) throw (r_Error)
 create a database More...
 
int destroyDB (const char *name) throw (r_Error)
 destroy a database More...
 
int openTA (unsigned short readOnly=0) throw (r_Error)
 begin transaction More...
 
int commitTA () throw (r_Error)
 commit current transaction More...
 
int abortTA ()
 abort current transaction More...
 
void insertMDD (const char *collName, r_GMarray *mar) throw ( r_Error )
 inserts a MDD object in an existing MDD collection on the server More...
 
r_Ref_Any getMDDByOId (const r_OId &oid) throw ( r_Error )
 gets MDD object by oid More...
 
void insertColl (const char *collName, const char *typeName, const r_OId &oid) throw ( r_Error )
 creates an empty MDD collection on the server More...
 
void deleteCollByName (const char *collName) throw ( r_Error )
 deletes an MDD collection by name More...
 
void deleteObjByOId (const r_OId &oid) throw ( r_Error )
 deletes an object by oid (right now, objects are collection only) More...
 
void removeObjFromColl (const char *name, const r_OId &oid) throw ( r_Error )
 removes an object from a collection More...
 
r_Ref_Any getCollByName (const char *name) throw ( r_Error )
 gets collection by name More...
 
r_Ref_Any getCollByOId (const r_OId &oid) throw ( r_Error )
 gets collection by oid More...
 
r_Ref_Any getCollOIdsByName (const char *name) throw ( r_Error )
 gets collection references by name More...
 
r_Ref_Any getCollOIdsByOId (const r_OId &oid) throw ( r_Error )
 gets collection references by oid More...
 
void executeQuery (const r_OQL_Query &query, r_Set< r_Ref_Any > &result) throw ( r_Error )
 query execution More...
 
void executeQuery (const r_OQL_Query &query) throw ( r_Error )
 update execution More...
 
r_OId getNewOId (unsigned short objType) throw (r_Error)
 get new oid More...
 
unsigned short getObjectType (const r_OId &oid) throw (r_Error)
 get oid type More...
 
char * getTypeStructure (const char *typeName, r_Type_Type typeType) throw (r_Error)
 

Constructor & Destructor Documentation

RnpClientComm::RnpClientComm ( const char *  rasmgrHost,
int  rasmgrPort = RASMGRPORT 
)
throw (r_Error
)

constructor getting the host name of the rasmgr host and it's listening port (default 7001).

RnpClientComm::~RnpClientComm ( )
throw (
)

Member Function Documentation

int RnpClientComm::abortTA ( )

abort current transaction

int RnpClientComm::closeDB ( )

close current database

int RnpClientComm::commitTA ( )
throw (r_Error
)

commit current transaction

r_OId RnpClientComm::createCollection ( const char *  collName,
const char *  collTypeName 
)
throw (r_Error
)
int RnpClientComm::createDB ( const char *  name)
throw (r_Error
)

create a database

r_OId RnpClientComm::createMDD ( const char *  collName,
const char *  mddTypeName,
const char *  definitionDomain,
const char *  tileDomain,
bool  rcindex = false 
)
throw (r_Error
)
void RnpClientComm::deleteCollByName ( const char *  collName)
throw (r_Error
)

deletes an MDD collection by name

void RnpClientComm::deleteObjByOId ( const r_OId &  oid)
throw (r_Error
)

deletes an object by oid (right now, objects are collection only)

int RnpClientComm::destroyDB ( const char *  name)
throw (r_Error
)

destroy a database

bool RnpClientComm::effectivTypeIsRNP ( )
throw (
)
void RnpClientComm::executeQuery ( const r_OQL_Query &  query,
r_Set< r_Ref_Any > &  result 
)
throw (r_Error
)

query execution

void RnpClientComm::executeQuery ( const r_OQL_Query &  query)
throw (r_Error
)

update execution

void RnpClientComm::extendMDD ( r_OId  mddOId,
const char *  stripeDomain,
const char *  tileDomain 
)
throw (r_Error
)
unsigned long RnpClientComm::getClientID ( ) const

provides read access to my clientID

r_Ref_Any RnpClientComm::getCollByName ( const char *  name)
throw (r_Error
)

gets collection by name

r_Ref_Any RnpClientComm::getCollByOId ( const r_OId &  oid)
throw (r_Error
)

gets collection by oid

r_Ref_Any RnpClientComm::getCollOIdsByName ( const char *  name)
throw (r_Error
)

gets collection references by name

r_Ref_Any RnpClientComm::getCollOIdsByOId ( const r_OId &  oid)
throw (r_Error
)

gets collection references by oid

const char* RnpClientComm::getExtendedErrorInfo ( )
throw (r_Error
)
unsigned int RnpClientComm::getMaxRetry ( )

get maximum retry to get a server

r_Ref_Any RnpClientComm::getMDDByOId ( const r_OId &  oid)
throw (r_Error
)

gets MDD object by oid

r_OId RnpClientComm::getNewOId ( unsigned short  objType)
throw (r_Error
)

get new oid

unsigned short RnpClientComm::getObjectType ( const r_OId &  oid)
throw (r_Error
)

get oid type

vector<r_OId> RnpClientComm::getOIdsFromCollection ( const char *  name)
throw (r_Error
)
vector<r_OId> RnpClientComm::getOIdsFromCollection ( const r_OId &  oid)
throw (r_Error
)
const char* RnpClientComm::getServerName ( )

get real server name (the dinamic one, assigned by the RasMGR)

int RnpClientComm::getTileData ( r_OId  mddOId,
const char *  tileDomain,
char *&  data,
bool  preallocated = false 
)
throw (r_Error
)
vector<r_Minterval> RnpClientComm::getTileDomains ( r_OId  mddOId,
const char *  stripeDomain 
)
throw (r_Error
)
int RnpClientComm::getTimeoutInterval ( )
char* RnpClientComm::getTypeStructure ( const char *  typeName,
r_Type_Type  typeType 
)
throw (r_Error
)

get type structure dallocate using delete []

void RnpClientComm::insertColl ( const char *  collName,
const char *  typeName,
const r_OId &  oid 
)
throw (r_Error
)

creates an empty MDD collection on the server

void RnpClientComm::insertMDD ( const char *  collName,
r_GMarray *  mar 
)
throw (r_Error
)

inserts a MDD object in an existing MDD collection on the server

int RnpClientComm::openDB ( const char *  database)

open database

int RnpClientComm::openTA ( unsigned short  readOnly = 0)
throw (r_Error
)

begin transaction

void RnpClientComm::preloadTiles ( r_OId  mddOId,
const char *  tileDomain 
)
throw (r_Error
)
void RnpClientComm::removeObjFromColl ( const char *  name,
const r_OId &  oid 
)
throw (r_Error
)

removes an object from a collection

void RnpClientComm::replaceTileData ( r_OId  mddOId,
const char *  tileDomain,
const char *  newData,
int  dataLength,
const char *  alfaData,
int  alfaLength 
)
throw (r_Error
)
void RnpClientComm::sendAliveSignal ( )
void RnpClientComm::setMaxRetry ( unsigned int  newMaxRetry)

set maximum retry to get a server

int RnpClientComm::setStorageFormat ( r_Data_Format  format,
const char *  formatParams = NULL 
)

set the preferred storage format

void RnpClientComm::setTimeoutInterval ( int  seconds)
int RnpClientComm::setTransferFormat ( r_Data_Format  format,
const char *  formatParams = NULL 
)

set the preferred transfer format

void RnpClientComm::setTurbo ( bool  turbo)
void RnpClientComm::setUserIdentification ( const char *  userName,
const char *  plainTextPassword 
)

user identification for RasMGR

void RnpClientComm::triggerAliveSignal ( )

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