1 #ifndef RNPCLIENTCOMM_HH
2 #define RNPCLIENTCOMM_HH
55 bool effectivTypeIsRNP()
throw();
62 int openDB(
const char* database );
66 int createDB(
const char* name )
throw(
r_Error);
68 int destroyDB(
const char* name )
throw(
r_Error);
78 int openTA(
unsigned short readOnly = 0 )
throw(
r_Error);
104 void insertColl(
const char* collName,
const char* typeName,
const r_OId& oid )
throw(
r_Error );
106 void deleteCollByName(
const char* collName )
throw(
r_Error );
108 void deleteObjByOId(
const r_OId& oid )
throw(
r_Error );
110 void removeObjFromColl(
const char* name,
const r_OId& oid )
throw (
r_Error );
150 r_OId getNewOId(
unsigned short objType )
throw(
r_Error);
153 unsigned short getObjectType(
const r_OId& oid )
throw(
r_Error);
163 unsigned long getClientID()
const;
166 int setTransferFormat(
r_Data_Format format,
const char* formatParams=NULL );
169 int setStorageFormat(
r_Data_Format format,
const char *formatParams=NULL );
173 const char* getServerName();
176 void setUserIdentification(
const char *userName,
const char *plainTextPassword);
179 void setMaxRetry(
unsigned int newMaxRetry);
182 unsigned int getMaxRetry();
184 void setTurbo(
bool turbo);
190 void triggerAliveSignal();
191 void sendAliveSignal();
192 const char *getExtendedErrorInfo()
throw(
r_Error);
194 void setTimeoutInterval(
int seconds);
195 int getTimeoutInterval();
199 r_OId createCollection(
const char *collName,
const char *collTypeName)
throw(
r_Error);
201 r_OId createMDD(
const char* collName,
const char* mddTypeName,
const char* definitionDomain,
const char *tileDomain,
bool rcindex =
false)
throw(
r_Error);
203 void extendMDD(
r_OId mddOId,
const char *stripeDomain,
const char* tileDomain)
throw(
r_Error);
205 vector<r_OId> getOIdsFromCollection(
const char* name )
throw(
r_Error );
207 vector<r_OId> getOIdsFromCollection(
const r_OId& oid )
throw(
r_Error );
209 vector<r_Minterval> getTileDomains(
r_OId mddOId,
const char *stripeDomain)
throw(
r_Error );
212 void preloadTiles(
r_OId mddOId,
const char *tileDomain)
throw(
r_Error);
214 int getTileData(
r_OId mddOId,
const char *tileDomain,
char *&data,
bool preallocated =
false)
throw(
r_Error);
216 void replaceTileData(
r_OId mddOId,
const char *tileDomain,
const char *newData,
int dataLength,
const char *alfaData,
int alfaLength)
throw(
r_Error);
230 char serverHost[100];
235 char databaseName[100];
238 char capability[100];
241 char identificationString[100];
244 int getFreeServer(
bool readwrite,
bool openDB);
247 int executeGetFreeServer(
bool readwrite,
bool openDB);
254 int messageDigest(
const char *input,
char *output,
const char *mdName);
266 int concatArrayData(
const char *source,
unsigned long srcSize,
char *&dest,
267 unsigned long &destSize,
unsigned long &destLevel );
286 char* transferFormatParams;
288 char *storageFormatParams;
293 int serverCompresses;
298 void executeConnect();
299 void executeDisconnect();
300 void executeOpenDB(
const char*);
301 void executeCloseDB();
302 void executeBeginTA(
bool rw);
303 void executeCommitTA();
304 void executeAbortTA();
307 int executeEndTransfer();
310 void executeExecuteUpdateQuery(
const char *query)
throw(
r_Error);
311 int executeStartInsertTransMDD(
r_GMarray* mdd);
312 int executeInsertTile(
bool persistent,
RPCMarray* tile);
313 void executeEndInsertMDD(
bool persistent);
314 int executeInitUpdate();
315 int executeStartInsertPersMDD(
const char* collName,
r_GMarray* mar );
317 int executeInsertCollection(
const char* collName,
const char* typeName,
const r_OId& oid );
320 int executeSetFormat(
bool transferFormat,
r_Data_Format format,
const char* formatParams);
321 r_OId executeGetNewOId(
unsigned short objType )
throw(
r_Error);
322 unsigned short executeGetObjectType(
const r_OId& oid )
throw(
r_Error);
323 char* executeGetTypeStructure(
const char* typeName,
r_Type_Type typeType )
throw(
r_Error);
325 vector<r_OId> executeGetOIdsFromCollection (
const char* collName,
const r_OId& oid )
throw(
r_Error );
327 void turboOpenDB(
const char*);
328 void turboBeginTA(
bool rw);
329 void turboCommitTA();
335 void checkForRwTransaction()
throw (
r_Error);
338 void sendRequestGetAnswer()
throw (
r_Error);
340 int sendAndReturnStatus()
throw (
r_Error);
344 void reassemble_r_Error()
throw (
r_Error);
347 void helper012d(
const char* caller)
throw (
r_Error);
r_Type_Type
Definition: clientcomm.hh:196
Definition: raslib/basetype.hh:47
Definition: clientcomm.hh:46
Definition: rnpcommunication.hh:44
Definition: clientcomm.hh:67
r_Data_Format
Definition: mddtypes.hh:133
Definition: gmarray.hh:66
Definition: mddtypes.hh:135
Definition: parseparams.hh:44
Definition: oqlquery.hh:81
Definition: rnpclientcomm.hh:47
int writeWholeMessage(int socket, char *destBuffer, int buffSize)
int messageDigest(const char *input, char *output, const char *mdName)
const int RASMGRPORT
Definition: rminit.hh:59
Definition: rnpcommunication.hh:117
int readWholeMessage(int socket, char *destBuffer, int buffSize)