eyedb: serv_lib.h Source File

00001 /* 
00002    EyeDB Object Database Management System
00003    Copyright (C) 1994-2008 SYSRA
00004    
00005    EyeDB is free software; you can redistribute it and/or
00006    modify it under the terms of the GNU Lesser General Public
00007    License as published by the Free Software Foundation; either
00008    version 2.1 of the License, or (at your option) any later version.
00009    
00010    EyeDB is distributed in the hope that it will be useful,
00011    but WITHOUT ANY WARRANTY; without even the implied warranty of
00012    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
00013    Lesser General Public License for more details.
00014    
00015    You should have received a copy of the GNU Lesser General Public
00016    License along with this library; if not, write to the Free Software
00017    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA 
00018 */
00019 
00020 /*
00021    Author: Eric Viara <viara@sysra.com>
00022 */
00023 
00024 
00025 #ifndef _eyedb_idblib_be_
00026 #define _eyedb_idblib_be_
00027 
00028 #include <eyedblib/rpc_be.h>
00029 #include <eyedblib/rpc_fe.h>
00030 #include "rpc_lib.h"
00031 #include <eyedblib/rpcdb_be.h>
00032 
00033 namespace eyedb {
00034 
00035   typedef union {
00036     eyedblib::int32 a_int;
00037     eyedblib::int64 a_int64;
00038     char *a_string;
00039     rpc_ServerData a_data;
00040 
00041     /* specific idb */
00042     rpcDB_LocalDBContext a_ldbctx;
00043     eyedbsm::Oid a_oid;
00044     Bool a_bool;
00045     RPCStatusRec a_status;
00046   } ServerArg;
00047 
00048   extern rpc_ServerFunction
00049   *DBMCREATE_SERV_RPC,
00050     *DBMUPDATE_SERV_RPC,
00051 
00052     *DBCREATE_SERV_RPC,
00053     *DBDELETE_SERV_RPC,
00054 
00055     *DBINFO_SERV_RPC,
00056     *DBMOVE_SERV_RPC,
00057     *DBCOPY_SERV_RPC,
00058     *DBRENAME_SERV_RPC,
00059 
00060     *USER_ADD_SERV_RPC,
00061     *USER_DELETE_SERV_RPC,
00062     *USER_PASSWD_SET_SERV_RPC,
00063     *PASSWD_SET_SERV_RPC,
00064 
00065     *DEFAULT_DBACCESS_SET_SERV_RPC,
00066     *USER_DBACCESS_SET_SERV_RPC,
00067     *USER_SYSACCESS_SET_SERV_RPC,
00068 
00069     *BACKEND_INTERRUPT_SERV_RPC,
00070 
00071     *TRANSACTION_BEGIN_SERV_RPC,
00072     *TRANSACTION_ABORT_SERV_RPC,
00073     *TRANSACTION_COMMIT_SERV_RPC,
00074 
00075     *TRANSACTION_PARAMS_SET_SERV_RPC,
00076     *TRANSACTION_PARAMS_GET_SERV_RPC,
00077 
00078     *DBOPEN_SERV_RPC,
00079     *DBOPENLOCAL_SERV_RPC,
00080     *DBCLOSE_SERV_RPC,
00081 
00082     *OBJECT_CREATE_SERV_RPC,
00083     *OBJECT_READ_SERV_RPC,
00084     *OBJECT_WRITE_SERV_RPC,
00085     *OBJECT_DELETE_SERV_RPC,
00086     *OBJECT_HEADER_READ_SERV_RPC,
00087     *OBJECT_SIZE_MODIFY_SERV_RPC,
00088     *OBJECT_PROTECTION_SET_SERV_RPC,
00089     *OBJECT_PROTECTION_GET_SERV_RPC,
00090     *OBJECT_CHECK_SERV_RPC,
00091 
00092     *MAKE_OID_SERV_RPC,
00093 
00094     *DATA_CREATE_SERV_RPC,
00095     *DATA_READ_SERV_RPC,
00096     *DATA_WRITE_SERV_RPC,
00097     *DATA_DELETE_SERV_RPC,
00098     *DATA_SIZE_GET_SERV_RPC,
00099     *DATA_SIZE_MODIFY_SERV_RPC,
00100 
00101     *VDDATA_CREATE_SERV_RPC,
00102     *VDDATA_WRITE_SERV_RPC,
00103     *VDDATA_DELETE_SERV_RPC,
00104 
00105     *SCHEMA_COMPLETE_SERV_RPC,
00106 
00107     *ATTRIBUTE_INDEX_CREATE_SERV_RPC,
00108     *ATTRIBUTE_INDEX_REMOVE_SERV_RPC,
00109 
00110     *INDEX_CREATE_SERV_RPC,
00111     *INDEX_REMOVE_SERV_RPC,
00112 
00113     *CONSTRAINT_CREATE_SERV_RPC,
00114     *CONSTRAINT_DELETE_SERV_RPC,
00115 
00116     *COLLECTION_GET_BY_IND_SERV_RPC,
00117     *COLLECTION_GET_BY_VALUE_SERV_RPC,
00118 
00119     *SET_OBJECT_LOCK_SERV_RPC,
00120     *GET_OBJECT_LOCK_SERV_RPC,
00121 
00122     *QUERY_LANG_CREATE_SERV_RPC,
00123     *QUERY_DATABASE_CREATE_SERV_RPC,
00124     *QUERY_CLASS_CREATE_SERV_RPC,
00125     *QUERY_COLLECTION_CREATE_SERV_RPC,
00126     *QUERY_ATTRIBUTE_CREATE_SERV_RPC,
00127     *QUERY_DELETE_SERV_RPC,
00128     *QUERY_SCAN_NEXT_SERV_RPC,
00129 
00130     *EXECUTABLE_CHECK_SERV_RPC,
00131     *EXECUTABLE_EXECUTE_SERV_RPC,
00132     *EXECUTABLE_SET_EXTREF_PATH_SERV_RPC,
00133     *EXECUTABLE_GET_EXTREF_PATH_SERV_RPC,
00134 
00135     *OQL_CREATE_SERV_RPC,
00136     *OQL_DELETE_SERV_RPC,
00137     *OQL_GETRESULT_SERV_RPC,
00138 
00139     *SET_CONN_INFO_SERV_RPC,
00140     *CHECK_AUTH_SERV_RPC,
00141 
00142     *INDEX_GET_COUNT_SERV_RPC,
00143     *INDEX_GET_STATS_SERV_RPC,
00144     *INDEX_SIMUL_STATS_SERV_RPC,
00145     *COLLECTION_GET_IMPLSTATS_SERV_RPC,
00146     *COLLECTION_SIMUL_IMPLSTATS_SERV_RPC,
00147     *INDEX_GET_IMPL_SERV_RPC,
00148     *COLLECTION_GET_IMPL_SERV_RPC,
00149 
00150     *GET_DEFAULT_DATASPACE_SERV_RPC,
00151     *SET_DEFAULT_DATASPACE_SERV_RPC,
00152     *DATASPACE_SET_CURRENT_DATAFILE_SERV_RPC,
00153     *DATASPACE_GET_CURRENT_DATAFILE_SERV_RPC,
00154     *GET_DEFAULT_INDEX_DATASPACE_SERV_RPC,
00155     *SET_DEFAULT_INDEX_DATASPACE_SERV_RPC,
00156     *GET_INDEX_LOCATIONS_SERV_RPC,
00157     *MOVE_INDEX_SERV_RPC,
00158     *GET_INSTANCE_CLASS_LOCATIONS_SERV_RPC,
00159     *MOVE_INSTANCE_CLASS_SERV_RPC,
00160     *GET_OBJECTS_LOCATIONS_SERV_RPC,
00161     *MOVE_OBJECTS_SERV_RPC,
00162     *GET_ATTRIBUTE_LOCATIONS_SERV_RPC,
00163     *MOVE_ATTRIBUTE_SERV_RPC,
00164 
00165     *CREATE_DATAFILE_SERV_RPC,
00166     *DELETE_DATAFILE_SERV_RPC,
00167     *MOVE_DATAFILE_SERV_RPC,
00168     *DEFRAGMENT_DATAFILE_SERV_RPC,
00169     *RESIZE_DATAFILE_SERV_RPC,
00170     *GET_DATAFILEI_NFO_SERV_RPC,
00171     *RENAME_DATAFILE_SERV_RPC,
00172     *CREATE_DATASPACE_SERV_RPC,
00173     *UPDATE_DATASPACE_SERV_RPC,
00174     *DELETE_DATASPACE_SERV_RPC,
00175     *RENAME_DATASPACE_SERV_RPC,
00176     *GET_SERVER_OUTOFBAND_DATA_SERV_RPC,
00177 
00178     *SET_MAXOBJCOUNT_RPC,
00179     *GET_MAXOBJCOUNT_RPC,
00180     *SET_LOGSIZE_RPC,
00181     *GET_LOGSIZE_RPC;
00182 
00183   extern rpc_Server *
00184   rpcBeInit(void);
00185 
00186   extern rpc_Server *
00187   getRpcServer(void);
00188 
00189   extern void
00190   connection_handler(rpc_Server *, rpc_ClientId, rpc_Boolean);
00191 
00192   extern void
00193   DBCREATE_realize(rpc_ClientId, void *);
00194 
00195   extern void
00196   DBINFO_realize(rpc_ClientId, void *);
00197 
00198   extern void
00199   DBDELETE_realize(rpc_ClientId, void *);
00200 
00201   extern void
00202   DBMOVE_realize(rpc_ClientId, void *);
00203 
00204   extern void
00205   DBCOPY_realize(rpc_ClientId, void *);
00206 
00207   extern void
00208   DBRENAME_realize(rpc_ClientId, void *);
00209 
00210   extern void
00211   DBMCREATE_realize(rpc_ClientId, void *);
00212 
00213   extern void
00214   DBMUPDATE_realize(rpc_ClientId, void *);
00215 
00216   extern void
00217   USER_ADD_realize(rpc_ClientId, void *);
00218 
00219   extern void
00220   USER_DELETE_realize(rpc_ClientId, void *);
00221 
00222   extern void
00223   USER_PASSWD_SET_realize(rpc_ClientId, void *);
00224 
00225   extern void
00226   PASSWD_SET_realize(rpc_ClientId, void *);
00227 
00228   extern void
00229   DEFAULT_DBACCESS_SET_realize(rpc_ClientId, void *);
00230 
00231   extern void
00232   USER_DBACCESS_SET_realize(rpc_ClientId, void *);
00233 
00234   extern void
00235   USER_SYSACCESS_SET_realize(rpc_ClientId, void *);
00236 
00237   extern void
00238   BACKEND_INTERRUPT_realize(rpc_ClientId, void *);
00239 
00240   extern void
00241   TRANSACTION_BEGIN_realize(rpc_ClientId, void *);
00242 
00243   extern void
00244   TRANSACTION_COMMIT_realize(rpc_ClientId, void *);
00245 
00246   extern void
00247   TRANSACTION_ABORT_realize(rpc_ClientId, void *);
00248 
00249   extern void
00250   TRANSACTION_PARAMS_SET_realize(rpc_ClientId, void *);
00251 
00252   extern void
00253   TRANSACTION_PARAMS_GET_realize(rpc_ClientId, void *);
00254 
00255   extern void
00256   DBOPEN_realize(rpc_ClientId, void *);
00257 
00258   extern void
00259   DBOPENLOCAL_realize(rpc_ClientId, void *);
00260 
00261   extern void
00262   DBCLOSE_realize(rpc_ClientId, void *);
00263 
00264   /*
00265     extern void
00266     SCHEMA_CREATE_realize(rpc_ClientId, void *);
00267 
00268     extern void
00269     CLASS_CREATE_realize(rpc_ClientId, void *);
00270 
00271     extern void
00272     CLASS_UPDATE_realize(rpc_ClientId, void *);
00273 
00274     extern void
00275     CLASS_LOAD_realize(rpc_ClientId, void *);
00276 
00277     extern void
00278     CLASS_DELETE_realize(rpc_ClientId, void *);
00279   */
00280 
00281   extern void
00282   OBJECT_CREATE_realize(rpc_ClientId, void *);
00283 
00284   extern void
00285   OBJECT_READ_realize(rpc_ClientId, void *);
00286 
00287   extern void
00288   OBJECT_WRITE_realize(rpc_ClientId, void *);
00289 
00290   extern void
00291   OBJECT_DELETE_realize(rpc_ClientId, void *);
00292 
00293   extern void
00294   OBJECT_HEADER_READ_realize(rpc_ClientId, void *);
00295 
00296   extern void
00297   OBJECT_SIZE_MODIFY_realize(rpc_ClientId, void *);
00298 
00299   extern void
00300   OBJECT_CHECK_realize(rpc_ClientId, void *);
00301 
00302   extern void
00303   OBJECT_PROTECTION_SET_realize(rpc_ClientId, void *);
00304 
00305   extern void
00306   OBJECT_PROTECTION_GET_realize(rpc_ClientId, void *);
00307 
00308   extern void
00309   OID_MAKE_realize(rpc_ClientId, void *);
00310 
00311   extern void
00312   DATA_CREATE_realize(rpc_ClientId, void *);
00313 
00314   extern void
00315   DATA_READ_realize(rpc_ClientId, void *);
00316 
00317   extern void
00318   DATA_WRITE_realize(rpc_ClientId, void *);
00319 
00320   extern void
00321   DATA_DELETE_realize(rpc_ClientId, void *);
00322 
00323   extern void
00324   DATA_SIZE_GET_realize(rpc_ClientId, void *);
00325 
00326   extern void
00327   DATA_SIZE_MODIFY_realize(rpc_ClientId, void *);
00328 
00329   extern void
00330   VDDATA_CREATE_realize(rpc_ClientId, void *);
00331 
00332   extern void
00333   VDDATA_WRITE_realize(rpc_ClientId, void *);
00334 
00335   extern void
00336   VDDATA_DELETE_realize(rpc_ClientId, void *);
00337 
00338   extern void
00339   SCHEMA_COMPLETE_realize(rpc_ClientId, void *);
00340 
00341   extern void
00342   ATTRIBUTE_INDEX_CREATE_realize(rpc_ClientId, void *);
00343 
00344   extern void
00345   ATTRIBUTE_INDEX_REMOVE_realize(rpc_ClientId, void *);
00346 
00347   extern void
00348   INDEX_CREATE_realize(rpc_ClientId, void *);
00349 
00350   extern void
00351   INDEX_REMOVE_realize(rpc_ClientId, void *);
00352 
00353   extern void
00354   CONSTRAINT_CREATE_realize(rpc_ClientId, void *);
00355 
00356   extern void
00357   CONSTRAINT_DELETE_realize(rpc_ClientId, void *);
00358 
00359   extern void
00360   COLLECTION_GET_BY_IND_realize(rpc_ClientId, void *);
00361 
00362   extern void
00363   COLLECTION_GET_BY_VALUE_realize(rpc_ClientId, void *);
00364 
00365   extern void
00366   SET_OBJECT_LOCK_realize(rpc_ClientId, void *);
00367 
00368   extern void
00369   GET_OBJECT_LOCK_realize(rpc_ClientId, void *);
00370 
00371   extern void
00372   QUERY_LANG_CREATE_realize(rpc_ClientId, void *);
00373 
00374   extern void
00375   QUERY_DATABASE_CREATE_realize(rpc_ClientId, void *);
00376 
00377   extern void
00378   QUERY_CLASS_CREATE_realize(rpc_ClientId, void *);
00379 
00380   extern void
00381   QUERY_COLLECTION_CREATE_realize(rpc_ClientId, void *);
00382 
00383   extern void
00384   QUERY_ATTRIBUTE_CREATE_realize(rpc_ClientId, void *);
00385 
00386   extern void
00387   QUERY_DELETE_realize(rpc_ClientId, void *);
00388 
00389   extern void
00390   QUERY_SCAN_NEXT_realize(rpc_ClientId, void *);
00391 
00392   /* executables */
00393   extern void
00394   EXECUTABLE_CHECK_realize(rpc_ClientId, void *);
00395 
00396   extern void
00397   EXECUTABLE_EXECUTE_realize(rpc_ClientId, void *);
00398 
00399   extern void
00400   EXECUTABLE_SET_EXTREF_PATH_realize(rpc_ClientId, void *);
00401 
00402   extern void
00403   EXECUTABLE_GET_EXTREF_PATH_realize(rpc_ClientId, void *);
00404 
00405   extern void
00406   OQL_CREATE_realize(rpc_ClientId, void *);
00407 
00408   extern void
00409   OQL_DELETE_realize(rpc_ClientId, void *);
00410 
00411   extern void
00412   OQL_GETRESULT_realize(rpc_ClientId, void *);
00413 
00414   extern void
00415   SET_CONN_INFO_realize(rpc_ClientId, void *);
00416 
00417   extern void
00418   CHECK_AUTH_realize(rpc_ClientId, void *);
00419 
00420   extern void
00421   SET_LOG_MASK_realize(rpc_ClientId, void *);
00422 
00423   extern void
00424   INDEX_GET_COUNT_realize(rpc_ClientId, void *);
00425 
00426   extern void
00427   INDEX_GET_STATS_realize(rpc_ClientId, void *);
00428 
00429   extern void
00430   INDEX_SIMUL_STATS_realize(rpc_ClientId, void *);
00431 
00432   extern void
00433   COLLECTION_GET_IMPLSTATS_realize(rpc_ClientId, void *);
00434 
00435   extern void
00436   COLLECTION_SIMUL_IMPLSTATS_realize(rpc_ClientId, void *);
00437 
00438   extern void
00439   INDEX_GET_IMPL_realize(rpc_ClientId, void *);
00440 
00441   extern void
00442   COLLECTION_GET_IMPL_realize(rpc_ClientId, void *);
00443 
00444   extern void
00445   GET_DEFAULT_DATASPACE_realize(rpc_ClientId, void *);
00446 
00447   extern void
00448   SET_DEFAULT_DATASPACE_realize(rpc_ClientId, void *);
00449 
00450   extern void
00451   DATASPACE_SET_CURRENT_DATAFILE_realize(rpc_ClientId, void *);
00452 
00453   extern void
00454   DATASPACE_GET_CURRENT_DATAFILE_realize(rpc_ClientId, void *);
00455 
00456   extern void
00457   GET_DEFAULT_INDEX_DATASPACE_realize(rpc_ClientId, void *);
00458 
00459   extern void
00460   SET_DEFAULT_INDEX_DATASPACE_realize(rpc_ClientId, void *);
00461 
00462   extern void
00463   GET_INDEX_LOCATIONS_realize(rpc_ClientId, void *);
00464 
00465   extern void
00466   MOVE_INDEX_realize(rpc_ClientId, void *);
00467 
00468   extern void
00469   GET_INSTANCE_CLASS_LOCATIONS_realize(rpc_ClientId, void *);
00470 
00471   extern void
00472   MOVE_INSTANCE_CLASS_realize(rpc_ClientId, void *);
00473 
00474   extern void
00475   GET_OBJECTS_LOCATIONS_realize(rpc_ClientId, void *);
00476 
00477   extern void
00478   MOVE_OBJECTS_realize(rpc_ClientId, void *);
00479 
00480   extern void
00481   GET_ATTRIBUTE_LOCATIONS_realize(rpc_ClientId, void *);
00482 
00483   extern void
00484   MOVE_ATTRIBUTE_realize(rpc_ClientId, void *);
00485 
00486   extern void
00487   CREATE_DATAFILE_realize(rpc_ClientId, void *);
00488 
00489   extern void
00490   DELETE_DATAFILE_realize(rpc_ClientId, void *);
00491 
00492   extern void
00493   MOVE_DATAFILE_realize(rpc_ClientId, void *);
00494 
00495   extern void
00496   DEFRAGMENT_DATAFILE_realize(rpc_ClientId, void *);
00497 
00498   extern void
00499   RESIZE_DATAFILE_realize(rpc_ClientId, void *);
00500 
00501   extern void
00502   GET_DATAFILEI_NFO_realize(rpc_ClientId, void *);
00503 
00504   extern void
00505   RENAME_DATAFILE_realize(rpc_ClientId, void *);
00506 
00507   extern void
00508   CREATE_DATASPACE_realize(rpc_ClientId, void *);
00509 
00510   extern void
00511   UPDATE_DATASPACE_realize(rpc_ClientId, void *);
00512 
00513   extern void
00514   DELETE_DATASPACE_realize(rpc_ClientId, void *);
00515 
00516   extern void
00517   RENAME_DATASPACE_realize(rpc_ClientId, void *);
00518 
00519   extern void
00520   GET_SERVER_OUTOFBAND_DATA_realize(rpc_ClientId, void *);
00521 
00522   extern void
00523   SET_MAXOBJCOUNT_realize(rpc_ClientId, void *);
00524 
00525   extern void
00526   GET_MAXOBJCOUNT_realize(rpc_ClientId, void *);
00527 
00528   extern void
00529   SET_LOGSIZE_realize(rpc_ClientId, void *);
00530 
00531   extern void
00532   GET_LOGSIZE_realize(rpc_ClientId, void *);
00533 
00534   extern void
00535   setSePort(const char *);
00536 
00537   extern const char *
00538   getSePort(void);
00539 
00540   extern void *
00541   close_realize(rpcDB_DbHandleClientInfo *);
00542 
00543   extern void
00544   GARBAGE();
00545 
00546   extern void
00547   be_init();
00548 }
00549 
00550 #endif