/* ---------------------------------------------------------------------------- | mg-dbx.node | | Author: Chris Munt cmunt@mgateway.com | | chris.e.munt@gmail.com | | Copyright (c) 2019-2026 MGateway Ltd | | Surrey UK. | | All rights reserved. | | | | http://www.mgateway.com | | | | Licensed under the Apache License, Version 2.0 (the "License"); you may | | not use this file except in compliance with the License. | | You may obtain a copy of the License at | | | | http:www.apache.org/licenses/LICENSE-2.0 | | | | Unless required by applicable law or agreed to in writing, software | | distributed under the License is distributed on an "AS IS" BASIS, | | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | | See the License for the specific language governing permissions and | | limitations under the License. | | | ---------------------------------------------------------------------------- */ #ifndef MG_DBX_H #define MG_DBX_H #include #define DBX_NODE_VERSION (NODE_MAJOR_VERSION * 10000) + (NODE_MINOR_VERSION * 100) + NODE_PATCH_VERSION #define DBX_VERSION_MAJOR "2" #define DBX_VERSION_MINOR "5" #define DBX_VERSION_BUILD "33" #define DBX_VERSION DBX_VERSION_MAJOR "." DBX_VERSION_MINOR "." DBX_VERSION_BUILD #define DBX_STR_HELPER(x) #x #define DBX_STR(x) DBX_STR_HELPER(x) /* #if defined(_WIN32) #define DBX_USE_SECURE_CRT 1 #endif */ /* #if !defined(SOLARIS) #define DBX_CHK_SECURE_CRT 1 #endif */ #define DBX_DBNAME dbx #define DBX_DBNAME_STR "dbx" #define DBX_MAGIC_NUMBER 120861 #define DBX_MAGIC_NUMBER_MGLOBAL 100863 #define DBX_MAGIC_NUMBER_MCLASS 50474 #define DBX_MAGIC_NUMBER_MCURSOR 200438 #define DBX_MAGIC_NUMBER_MNET 30232 #if defined(_WIN32) #define BUILDING_NODE_EXTENSION 1 #if defined(_MSC_VER) /* Check for MS compiler later than VC6 */ #if (_MSC_VER >= 1400) #if !defined(DBX_USE_SECURE_CRT) #define _CRT_SECURE_NO_DEPRECATE 1 #define _CRT_NONSTDC_NO_DEPRECATE 1 #endif #endif #endif #elif defined(__linux__) || defined(__linux) || defined(linux) #if !defined(LINUX) #define LINUX 1 #endif #elif defined(__APPLE__) #if !defined(MACOSX) #define MACOSX 1 #endif #endif #if defined(SOLARIS) #ifndef __GNUC__ # define __attribute__(x) #endif #endif #if defined(_WIN32) #include #include #if defined(DBX_WINSOCK2) #define INCL_WINSOCK_API_TYPEDEFS 1 #include #include #endif #endif #if !defined(_WIN32) #include #include #include #include #include #include #include #include #include #include #endif #if defined(__GNUC__) && __GNUC__ >= 8 #define DISABLE_WCAST_FUNCTION_TYPE _Pragma("GCC diagnostic push") _Pragma("GCC diagnostic ignored \"-Wcast-function-type\"") #define DISABLE_WCAST_FUNCTION_TYPE_END _Pragma("GCC diagnostic pop") #else #define DISABLE_WCAST_FUNCTION_TYPE #define DISABLE_WCAST_FUNCTION_TYPE_END #endif DISABLE_WCAST_FUNCTION_TYPE #include #include #include #include #include #if !defined(_WIN32) #include #include #endif #define DBX_MAXARGS 64 #define DBX_DEFAULT_TIMEOUT 30 #define DBX_THREADPOOL_MAX 8 #define DBX_ERROR_SIZE 512 #define DBX_THREAD_STACK_SIZE 0xf0000 #define DBX_TEXT_E_ASYNC "Unable to process task asynchronously" #define DBX_DSORT_INVALID 0 #define DBX_DSORT_DATA 1 #define DBX_DSORT_SUBSCRIPT 2 #define DBX_DSORT_GLOBAL 3 #define DBX_DSORT_EOD 9 #define DBX_DSORT_STATUS 10 #define DBX_DSORT_ERROR 11 #define DBX_DSORT_ISVALID(a) ((a == DBX_DSORT_GLOBAL) || (a == DBX_DSORT_SUBSCRIPT) || (a == DBX_DSORT_DATA) || (a == DBX_DSORT_EOD) || (a == DBX_DSORT_STATUS) || (a == DBX_DSORT_ERROR)) #define DBX_DTYPE_NONE 0 #define DBX_DTYPE_STR 1 #define DBX_DTYPE_STR8 2 #define DBX_DTYPE_STR16 3 #define DBX_DTYPE_INT 4 #define DBX_DTYPE_INT64 5 #define DBX_DTYPE_DOUBLE 6 #define DBX_DTYPE_OREF 7 #define DBX_DTYPE_NULL 10 #define DBX_DTYPE_STROBJ 11 #define DBX_CMND_OPEN 1 #define DBX_CMND_CLOSE 2 #define DBX_CMND_NSGET 3 #define DBX_CMND_NSSET 4 #define DBX_CMND_GSET 11 #define DBX_CMND_GGET 12 #define DBX_CMND_GNEXT 13 #define DBX_CMND_GNEXTDATA 131 #define DBX_CMND_GPREVIOUS 14 #define DBX_CMND_GPREVIOUSDATA 141 #define DBX_CMND_GDELETE 15 #define DBX_CMND_GDEFINED 16 #define DBX_CMND_GINCREMENT 17 #define DBX_CMND_GLOCK 18 #define DBX_CMND_GUNLOCK 19 #define DBX_CMND_GMERGE 20 #define DBX_CMND_GNNODE 21 #define DBX_CMND_GNNODEDATA 211 #define DBX_CMND_GPNODE 22 #define DBX_CMND_GPNODEDATA 221 #define DBX_CMND_FUNCTION 31 #define DBX_CMND_CCMETH 41 #define DBX_CMND_CGETP 42 #define DBX_CMND_CSETP 43 #define DBX_CMND_CMETH 44 /* v2.4.28 */ #define DBX_CMND_CCLOSE 45 #define DBX_CMND_GNAMENEXT 51 #define DBX_CMND_GNAMEPREVIOUS 52 /* v2.3.23 */ #define DBX_CMND_TSTART 61 #define DBX_CMND_TLEVEL 62 #define DBX_CMND_TCOMMIT 63 #define DBX_CMND_TROLLBACK 64 #define DBX_IBUFFER_OFFSET 15 #if defined(MAX_PATH) && (MAX_PATH>511) #define DBX_MAX_PATH MAX_PATH #else #define DBX_MAX_PATH 512 #endif #if defined(_WIN32) #define DBX_NULL_DEVICE "//./nul" #else #define DBX_NULL_DEVICE "/dev/null/" #endif #if defined(_WIN32) #define DBX_CACHE_DLL "cache.dll" #define DBX_IRIS_DLL "irisdb.dll" #define DBX_YDB_DLL "yottadb.dll" #else /* v2.1.19 */ #define DBX_CACHE_SO "libcache.so" #define DBX_CACHE_DYLIB "libcache.dylib" #define DBX_ISCCACHE_SO "libisccache.so" #define DBX_ISCCACHE_DYLIB "libisccache.dylib" #define DBX_IRIS_SO "libirisdb.so" #define DBX_IRIS_DYLIB "libirisdb.dylib" #define DBX_ISCIRIS_SO "libiscirisdb.so" #define DBX_ISCIRIS_DYLIB "libiscirisdb.dylib" #define DBX_YDB_SO "libyottadb.so" #define DBX_YDB_DYLIB "libyottadb.dylib" #endif #if defined(_WIN32) #define _dbxso(a) _countof(a) #else #define _dbxso(a) sizeof(a) #endif #if defined(DBX_USE_SECURE_CRT) /* #define T_STRCPY(a, b, c) _tcscpy_s(a, b, c) */ /* #define T_STRNCPY(a, b, c, d) _tcsncpy_s(a, b, c, d) */ #define T_STRCPY(a, b, c) strcpy_s(a, b, c) #define T_STRNCPY(a, b, c, d) memcpy_s(a, b, c, d) #define T_STRCAT(a, b, c) strcat_s(a, b, c) #define T_STRNCAT(a, b, c, d) strncat_s(a, b, c, d) #define T_SPRINTF(a, b, c, ...) sprintf_s(a, b, c, __VA_ARGS__) #if defined(LINUX) #define T_MEMCPY(a,b,c) memmove(a,b,c) #else #define T_MEMCPY(a,b,c) memcpy(a,b,c) #endif #elif defined(DBX_CHK_SECURE_CRT) #define T_STRCPY(a, b, c) dbx_strcpy_s(a, b, c, __FILE__, __FUNCTION__, __LINE__) #define T_STRNCPY(a, b, c, d) dbx_strncpy_s(a, b, c, d, __FILE__, __FUNCTION__, __LINE__) #define T_STRCAT(a, b, c) dbx_strcat_s(a, b, c, __FILE__, __FUNCTION__, __LINE__) #define T_STRNCAT(a, b, c, d) dbx_strncat_s(a, b, c, d, __FILE__, __FUNCTION__, __LINE__) #define T_SPRINTF(a, b, c, ...) dbx_sprintf_s(a, b, c, __FILE__, __FUNCTION__, __LINE__, __VA_ARGS__) #if defined(LINUX) #define T_MEMCPY(a,b,c) memmove(a,b,c) #else #define T_MEMCPY(a,b,c) memcpy(a,b,c) #endif #else #define T_STRCPY(a, b, c) strcpy(a, c) #define T_STRNCPY(a, b, c, d) strncpy(a, c, d) #define T_STRCAT(a, b, c) strcat(a, c) #define T_STRNCAT(a, b, c, d) strncat(a, c, d) #define T_SPRINTF(a, b, c, ...) sprintf(a, c, __VA_ARGS__) #if defined(LINUX) #define T_MEMCPY(a,b,c) memmove(a,b,c) #else #define T_MEMCPY(a,b,c) memcpy(a,b,c) #endif #endif #define DBX_INTEGER_NEW(a) Integer::New(isolate, a) #define DBX_INT32_NEW(a) Int32::New(isolate, a) #define DBX_UINT32_NEW(a) Uint32::New(isolate, a) #define DBX_NUMBER_NEW(a) Number::New(isolate, a) #define DBX_BOOLEAN_NEW(a) Boolean::New(isolate, a) #define DBX_NULL() Null(isolate) #define DBX_DATE(a) Date::New(isolate, a) #define DBX_OBJECT_NEW() Object::New(isolate) #define DBX_ARRAY_NEW(a) Array::New(isolate, a) #define DBX_NODE_SET_PROTOTYPE_METHOD(a, b, c) NODE_SET_PROTOTYPE_METHOD(a, b, c); /* #define DBX_NODE_SET_PROTOTYPE_METHOD(a, b, c) dbx_set_prototype_method(a, c, b, b); */ #if DBX_NODE_VERSION >= 100000 /* v2.0.15 */ #if 0 #define DBX_GET_ISOLATE \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ Isolate* isolate = c->isolate; \ #define DBX_GET_ICONTEXT \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ if (c->got_icontext == 0) { \ c->icontext = c->isolate->GetCurrentContext(); \ c->got_icontext = 1; \ } \ Isolate* isolate = c->isolate; \ Local icontext = c->icontext; \ #elif 1 #define DBX_GET_ISOLATE \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ Isolate* isolate = c->isolate; \ #define DBX_GET_ICONTEXT \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ Isolate* isolate = c->isolate; \ Local icontext = isolate->GetCurrentContext(); \ c->icontext = icontext;\ c->got_icontext = 1; \ #else #define DBX_GET_ISOLATE \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ Isolate* isolate = c->isolate; \ #define DBX_GET_ICONTEXT \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ c->icontext = c->isolate->GetCurrentContext(); \ Isolate* isolate = c->isolate; \ Local icontext = c->icontext; \ #endif #else #define DBX_GET_ISOLATE \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ Isolate* isolate = c->isolate; \ #define DBX_GET_ICONTEXT \ if (c->isolate == NULL) { \ c->isolate = args.GetIsolate(); \ HandleScope scope(c->isolate); \ } \ Isolate* isolate = c->isolate; \ #endif #if DBX_NODE_VERSION >= 120000 #define DBX_DBFUN_START(C, PCON, PMETH) \ if (!PCON) { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, (char *) "Database object not created", NewStringType::kNormal).ToLocalChecked())); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ else { \ if (!PCON->open) { \ if (PCON->error[0]) { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, PCON->error, NewStringType::kNormal).ToLocalChecked())); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ else { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, (char *) "Database not open", NewStringType::kNormal).ToLocalChecked())); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ } \ } \ #else #define DBX_DBFUN_START(C, PCON, PMETH) \ if (!PCON) { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, (char *) "Database object not created"))); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ else { \ if (!PCON->open) { \ if (PCON->error[0]) { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, PCON->error))); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ else { \ isolate->ThrowException(Exception::Error(String::NewFromUtf8(isolate, (char *) "Database not open"))); \ dbx_request_memory_free(PCON, PMETH, 0); \ return; \ } \ } \ } \ #endif /* v2.4.30 */ #if DBX_NODE_VERSION >= 240000 #define DBX_GET(a,b) a->Get(icontext,b).ToLocalChecked() #define DBX_SET(a,b,c) a->Set(icontext,b,c).FromJust() #define DBX_TO_OBJECT(a) a->ToObject(icontext).ToLocalChecked() #define DBX_TO_STRING(a) a->ToString(icontext).ToLocalChecked() #define DBX_TO_BOOLEAN(a) a->ToBoolean(isolate) #define DBX_NUMBER_VALUE(a) a->NumberValue(icontext).ToChecked() #define DBX_INT32_VALUE(a) a->Int32Value(icontext).FromJust() #define DBX_WRITE_UTF8(a,b,c) a->WriteUtf8V2(isolate, b, c, v8::String::WriteFlags::kNullTerminate) #define DBX_WRITE(a,b) a->WriteV2(isolate, 0, a->Length(), (uint16_t *) b, v8::String::WriteFlags::kNullTerminate) #define DBX_WRITE_ONE_BYTE(a,b) a->WriteOneByteV2(isolate, 0, a->Length(), b, v8::String::WriteFlags::kNullTerminate) #define DBX_UTF8_LENGTH(a) (int) a->Utf8LengthV2(isolate) #define DBX_LENGTH(a) a->Length() #elif DBX_NODE_VERSION >= 120000 #define DBX_GET(a,b) a->Get(icontext,b).ToLocalChecked() #define DBX_SET(a,b,c) a->Set(icontext,b,c).FromJust() #define DBX_TO_OBJECT(a) a->ToObject(icontext).ToLocalChecked() #define DBX_TO_STRING(a) a->ToString(icontext).ToLocalChecked() #define DBX_TO_BOOLEAN(a) a->ToBoolean(isolate) #define DBX_NUMBER_VALUE(a) a->NumberValue(icontext).ToChecked() #define DBX_INT32_VALUE(a) a->Int32Value(icontext).FromJust() #define DBX_WRITE_UTF8(a,b,c) a->WriteUtf8(isolate, b) #define DBX_WRITE(a,b) a->Write(isolate, (uint16_t *) b) #define DBX_WRITE_ONE_BYTE(a,b) a->WriteOneByte(isolate, b) #define DBX_UTF8_LENGTH(a) a->Utf8Length(isolate) #define DBX_LENGTH(a) a->Length() #elif DBX_NODE_VERSION >= 100000 #define DBX_GET(a,b) a->Get(icontext,b).ToLocalChecked() #define DBX_SET(a,b,c) a->Set(icontext,b,c).FromJust() #define DBX_TO_OBJECT(a) a->ToObject(icontext).ToLocalChecked() #define DBX_TO_STRING(a) a->ToString(icontext).ToLocalChecked() #define DBX_TO_BOOLEAN(a) a->ToBoolean(icontext).ToLocalChecked() #define DBX_NUMBER_VALUE(a) a->NumberValue(icontext).ToChecked() #define DBX_INT32_VALUE(a) a->Int32Value(icontext).FromJust() #define DBX_WRITE_UTF8(a,b,c) a->WriteUtf8(b) #define DBX_WRITE(a,b) a->Write((uint16_t *) b) #define DBX_WRITE_ONE_BYTE(a,b) a->WriteOneByte(b) #define DBX_UTF8_LENGTH(a) a->Utf8Length() #define DBX_LENGTH(a) a->Length() #else #define DBX_GET(a,b) a->Get(b) #define DBX_SET(a,b,c) a->Set(b,c) #define DBX_TO_OBJECT(a) a->ToObject() #define DBX_TO_STRING(a) a->ToString() #define DBX_TO_BOOLEAN(a) a->ToBoolean() #define DBX_NUMBER_VALUE(a) a->NumberValue() #define DBX_INT32_VALUE(a) a->Int32Value() #define DBX_WRITE_UTF8(a,b,c) a->WriteUtf8(b) #define DBX_WRITE(a,b) a->Write((uint16_t *) b) #define DBX_WRITE_ONE_BYTE(a,b) a->WriteOneByte(b) #define DBX_UTF8_LENGTH(a) a->Utf8Length() #define DBX_LENGTH(a) a->Length() #endif #define DBX_INTEGER_NEW(a) Integer::New(isolate, a) #define DBX_OBJECT_NEW() Object::New(isolate) #define DBX_ARRAY_NEW(a) Array::New(isolate, a) #define DBX_ARRAY_NEW(a) Array::New(isolate, a) #define DBX_NUMBER_NEW(a) Number::New(isolate, a) #define DBX_BOOLEAN_NEW(a) Boolean::New(isolate, a) #define DBX_NULL() Null(isolate) #define DBX_CALLBACK_FUN(JSNARG, ASYNC) \ JSNARG = args.Length(); \ if (JSNARG > 0 && args[JSNARG - 1]->IsFunction()) { \ ASYNC = 1; \ JSNARG --; \ } \ else { \ ASYNC = 0; \ } \ #define DBX_DBFUN_END(C) #define DBX_DB_LOCK(TIMEOUT) \ if (pcon->use_mutex) { \ dbx_mutex_lock(pcon->p_mutex, TIMEOUT); \ } \ #define DBX_DB_LOCK_EX(RC, TIMEOUT) \ if (pcon->use_mutex) { \ RC = dbx_mutex_lock(pcon->p_mutex, TIMEOUT); \ } \ #define DBX_DB_UNLOCK() \ if (pcon->use_mutex) { \ dbx_mutex_unlock(pcon->p_mutex); \ } \ #define DBX_DB_UNLOCK_EX(RC) \ if (pcon->use_mutex) { \ RC = dbx_mutex_unlock(pcon->p_mutex); \ } \ typedef void async_rtn; #if defined(_WIN32) typedef DWORD DBXTHID; typedef HINSTANCE DBXPLIB; typedef FARPROC DBXPROC; #else /* #if defined(_WIN32) */ typedef pthread_t DBXTHID; typedef void *DBXPLIB; typedef void *DBXPROC; #if !defined(NODE_ENGINE_CHAKRACORE) typedef unsigned long DWORD; #endif typedef unsigned long WORD; typedef int SOCKET; #endif /* #if defined(_WIN32) */ typedef struct tagDBXZV { unsigned char dbtype; double dbx_version; int majorversion; int minorversion; int dbx_build; unsigned long vnumber; /* yymbbbb */ char version[64]; /* v1.0.17 */ } DBXZV, *PDBXZV; typedef struct tagDBXMUTEX { unsigned char created; int stack; #if defined(_WIN32) HANDLE h_mutex; #else pthread_mutex_t h_mutex; #endif /* #if defined(_WIN32) */ DBXTHID thid; } DBXMUTEX, *PDBXMUTEX; typedef struct tagDBXTID { int thread_id; DBXMUTEX *p_mutex; DBXZV *p_zv; } DBXTID, *PDBXTID; /* Cache/IRIS */ #define CACHE_MAXSTRLEN 32767 #define CACHE_MAXLOSTSZ 3641144 typedef char Callin_char_t; #define CACHE_INT64 long long #define CACHESTR CACHE_ASTR typedef struct { unsigned short len; Callin_char_t str[CACHE_MAXSTRLEN]; } CACHE_ASTR, *CACHE_ASTRP; typedef struct { unsigned int len; union { Callin_char_t * ch; unsigned short *wch; unsigned short *lch; } str; } CACHE_EXSTR, *CACHE_EXSTRP; #define CACHE_TTALL 1 #define CACHE_TTNEVER 8 #define CACHE_PROGMODE 32 #define CACHE_INCREMENTAL_LOCK 1 #define CACHE_SHARED_LOCK 2 #define CACHE_IMMEDIATE_RELEASE 4 #define CACHE_INT 1 #define CACHE_DOUBLE 2 #define CACHE_ASTRING 3 #define CACHE_CHAR 4 #define CACHE_INT2 5 #define CACHE_INT4 6 #define CACHE_INT8 7 #define CACHE_UCHAR 8 #define CACHE_UINT2 9 #define CACHE_UINT4 10 #define CACHE_UINT8 11 #define CACHE_FLOAT 12 #define CACHE_HFLOAT 13 #define CACHE_UINT 14 #define CACHE_WSTRING 15 #define CACHE_OREF 16 #define CACHE_LASTRING 17 #define CACHE_LWSTRING 18 #define CACHE_IEEE_DBL 19 #define CACHE_HSTRING 20 #define CACHE_UNDEF 21 #define CACHE_CHANGEPASSWORD -16 #define CACHE_ACCESSDENIED -15 #define CACHE_EXSTR_INUSE -14 #define CACHE_NORES -13 #define CACHE_BADARG -12 #define CACHE_NOTINCACHE -11 #define CACHE_RETTRUNC -10 #define CACHE_ERUNKNOWN -9 #define CACHE_RETTOOSMALL -8 #define CACHE_NOCON -7 #define CACHE_INTERRUPT -6 #define CACHE_CONBROKEN -4 #define CACHE_STRTOOLONG -3 #define CACHE_ALREADYCON -2 #define CACHE_FAILURE -1 #define CACHE_SUCCESS 0 #define CACHE_ERMXSTR 5 #define CACHE_ERNOLINE 8 #define CACHE_ERUNDEF 9 #define CACHE_ERSYSTEM 10 #define CACHE_ERSUBSCR 16 #define CACHE_ERNOROUTINE 17 #define CACHE_ERSTRINGSTACK 20 #define CACHE_ERUNIMPLEMENTED 22 #define CACHE_ERARGSTACK 25 #define CACHE_ERPROTECT 27 #define CACHE_ERPARAMETER 40 #define CACHE_ERNAMSP 83 #define CACHE_ERWIDECHAR 89 #define CACHE_ERNOCLASS 122 #define CACHE_ERBADOREF 119 #define CACHE_ERNOMETHOD 120 #define CACHE_ERNOPROPERTY 121 #define CACHE_ETIMEOUT -100 #define CACHE_BAD_STRING -101 #define CACHE_BAD_NAMESPACE -102 #define CACHE_BAD_GLOBAL -103 #define CACHE_BAD_FUNCTION -104 /* End of Cache/IRIS */ /* YottaDB */ #define YDB_OK 0 #define YDB_DEL_TREE 1 #define YDB_INT_MAX ((int)0x7fffffff) #define YDB_TP_RESTART (YDB_INT_MAX - 1) #define YDB_TP_ROLLBACK (YDB_INT_MAX - 2) #define YDB_NODE_END (YDB_INT_MAX - 3) #define YDB_LOCK_TIMEOUT (YDB_INT_MAX - 4) #define YDB_NOTOK (YDB_INT_MAX - 5) #define YDB_MAX_TP 32 #define YDB_TPCTX_DB 1 #define YDB_TPCTX_TLEVEL 2 #define YDB_TPCTX_COMMIT 3 #define YDB_TPCTX_ROLLBACK 4 #define YDB_TPCTX_FUN 10 #define YDB_TPCTX_QUERY 11 #define YDB_TPCTX_ORDER 12 /* v2.5.32 */ #define DBX_DB_CHECK(RC) \ if (RC != CACHE_SUCCESS) { \ isolate->ThrowException(Exception::Error(dbx_new_string8(isolate, (char *) "Invalid global name", 1))); \ DBX_DBFUN_END(c); \ DBX_DB_UNLOCK(); \ dbx_request_memory_free(pcon, pmeth, 0); \ return; \ } \ typedef struct { unsigned int len_alloc; unsigned int len_used; char *buf_addr; } ydb_buffer_t; typedef struct { unsigned long length; char *address; } ydb_string_t; typedef struct { ydb_string_t rtn_name; void *handle; } ci_name_descriptor; typedef ydb_buffer_t DBXSTR; typedef char ydb_char_t; typedef long ydb_long_t; typedef int (*ydb_tpfnptr_t) (void *tpfnparm); /* End of YottaDB */ typedef struct tagDBXCVAL { void *pstr; CACHE_EXSTR zstr; unsigned int len_alloc; unsigned int len_used; unsigned short *buf16_addr; } DBXCVAL, *PDBXCVAL; typedef struct tagDBXVAL { int type; int sort; union { int int32; long long int64; double real; unsigned int oref; } num; unsigned long offs; unsigned int csize; ydb_buffer_t svalue; DBXCVAL cvalue; struct tagDBXVAL *pnext; } DBXVAL, *PDBXVAL; typedef struct tagDBXFUN { unsigned int rflag; int label_len; char * label; unsigned short *label16; int routine_len; char * routine; unsigned short *routine16; union { char str8[128]; unsigned short str16[128]; } buffer; int argc; /* v2.3.25 */ ydb_string_t in[DBX_MAXARGS]; ydb_string_t out; ydb_buffer_t * global; int in_nkeys; ydb_buffer_t * in_keys; int * out_nkeys; ydb_buffer_t * out_keys; int getdata; ydb_buffer_t * data; int dir; int rc; } DBXFUN, *PDBXFUN; typedef struct tagDBXGREF { char * global; int global_len; unsigned short *global16; int global16_len; DBXVAL * pkey; } DBXGREF, *PDBXGREF; typedef struct tagDBXFREF { char * function; unsigned short *function16; int function_len; } DBXFREF, *PDBXFREF; typedef struct tagDBXCREF { short optype; char * class_name; int class_name_len; unsigned short *class_name16; int class_name16_len; int oref; } DBXCREF, *PDBXCREF; #define DBX_SQL_MGSQL 1 #define DBX_SQL_ISCSQL 2 #define DBX_SQL_MAXCOL 128 typedef struct tagDBXSQLCOL { short type; ydb_buffer_t name; char * stype; } DBXSQLCOL, *PDBXSQLCOL; typedef struct tagDBXSQL { short sql_type; int sql_no; char * sql_script; int sql_script_len; int sqlcode; char sqlstate[8]; unsigned long row_no; int no_cols; DBXSQLCOL * cols[DBX_SQL_MAXCOL]; } DBXSQL, *PDBXSQL; #define DBX_DBTYPE_CACHE 1 #define DBX_DBTYPE_IRIS 2 #define DBX_DBTYPE_YOTTADB 5 typedef struct tagDBXISCSO { short loaded; short iris; short merge_enabled; short functions_enabled; short objects_enabled; short multithread_enabled; int no_connections; int multiple_connections; char funprfx[8]; char libdir[256]; char libnam[256]; char dbname[32]; DBXPLIB p_library; DBXZV zv; int (* p_CacheSetDir) (char * dir); int (* p_CacheSecureStartA) (CACHE_ASTRP username, CACHE_ASTRP password, CACHE_ASTRP exename, unsigned long flags, int tout, CACHE_ASTRP prinp, CACHE_ASTRP prout); int (* p_CacheEnd) (void); unsigned char * (* p_CacheExStrNew) (CACHE_EXSTRP zstr, int size); unsigned short * (* p_CacheExStrNewW) (CACHE_EXSTRP zstr, int size); wchar_t * (* p_CacheExStrNewH) (CACHE_EXSTRP zstr, int size); int (* p_CachePushExStr) (CACHE_EXSTRP sptr); int (* p_CachePushExStrW) (CACHE_EXSTRP sptr); int (* p_CachePushExStrH) (CACHE_EXSTRP sptr); int (* p_CachePopExStr) (CACHE_EXSTRP sstrp); int (* p_CachePopExStrW) (CACHE_EXSTRP sstrp); int (* p_CachePopExStrH) (CACHE_EXSTRP sstrp); int (* p_CacheExStrKill) (CACHE_EXSTRP obj); int (* p_CachePushStr) (int len, Callin_char_t * ptr); int (* p_CachePushStrW) (int len, unsigned short * ptr); int (* p_CachePushStrH) (int len, wchar_t * ptr); int (* p_CachePopStr) (int * lenp, Callin_char_t ** strp); int (* p_CachePopStrW) (int * lenp, unsigned short ** strp); int (* p_CachePopStrH) (int * lenp, wchar_t ** strp); int (* p_CachePushDbl) (double num); int (* p_CachePushIEEEDbl) (double num); int (* p_CachePopDbl) (double * nump); int (* p_CachePushInt) (int num); int (* p_CachePopInt) (int * nump); int (* p_CachePushInt64) (CACHE_INT64 num); int (* p_CachePopInt64) (CACHE_INT64 * nump); int (* p_CachePushGlobal) (int nlen, const Callin_char_t * nptr); int (* p_CachePushGlobalW) (int nlen, const unsigned short * nptr); int (* p_CachePushGlobalX) (int nlen, const Callin_char_t * nptr, int elen, const Callin_char_t * eptr); int (* p_CacheGlobalGet) (int narg, int flag); int (* p_CacheGlobalSet) (int narg); int (* p_CacheGlobalData) (int narg, int valueflag); int (* p_CacheGlobalKill) (int narg, int nodeonly); int (* p_CacheGlobalOrder) (int narg, int dir, int valueflag); int (* p_CacheGlobalQuery) (int narg, int dir, int valueflag); int (* p_CacheGlobalIncrement) (int narg); int (* p_CacheGlobalRelease) (void); int (* p_CacheAcquireLock) (int nsub, int flg, int tout, int * rval); int (* p_CacheReleaseAllLocks) (void); int (* p_CacheReleaseLock) (int nsub, int flg); int (* p_CachePushLock) (int nlen, const Callin_char_t * nptr); int (* p_CachePushLockW) (int nlen, const unsigned short * nptr); int (* p_CacheAddGlobal) (int num, const Callin_char_t * nptr); int (* p_CacheAddGlobalW) (int num, const unsigned short * nptr); int (* p_CacheAddGlobalDescriptor) (int num); int (* p_CacheAddSSVN) (int num, const Callin_char_t * nptr); int (* p_CacheAddSSVNDescriptor) (int num); int (* p_CacheMerge) (void); int (* p_CachePushFunc) (unsigned int * rflag, int tlen, const Callin_char_t * tptr, int nlen, const Callin_char_t * nptr); int (* p_CachePushFuncW) (unsigned int * rflag, int tlen, const unsigned short * tptr, int nlen, const unsigned short * nptr); int (* p_CacheExtFun) (unsigned int flags, int narg); int (* p_CachePushRtn) (unsigned int * rflag, int tlen, const Callin_char_t * tptr, int nlen, const Callin_char_t * nptr); int (* p_CacheDoFun) (unsigned int flags, int narg); int (* p_CacheDoRtn) (unsigned int flags, int narg); int (* p_CacheCloseOref) (unsigned int oref); int (* p_CacheIncrementCountOref) (unsigned int oref); int (* p_CachePopOref) (unsigned int * orefp); int (* p_CachePushOref) (unsigned int oref); int (* p_CacheInvokeMethod) (int narg); int (* p_CachePushMethod) (unsigned int oref, int mlen, const Callin_char_t * mptr, int flg); int (* p_CachePushMethodW) (unsigned int oref, int mlen, const unsigned short * mptr, int flg); int (* p_CacheInvokeClassMethod) (int narg); int (* p_CachePushClassMethod) (int clen, const Callin_char_t * cptr, int mlen, const Callin_char_t * mptr, int flg); int (* p_CachePushClassMethodW) (int clen, const unsigned short * cptr, int mlen, const unsigned short * mptr, int flg); int (* p_CacheGetProperty) (void); int (* p_CacheSetProperty) (void); int (* p_CachePushProperty) (unsigned int oref, int plen, const Callin_char_t * pptr); int (* p_CachePushPropertyW) (unsigned int oref, int plen, const unsigned short * pptr); int (* p_CacheType) (void); #if DBX_NODE_VERSION >= 240000 int (* p_CacheEvalA) (CACHE_ASTRP expr); int (* p_CacheExecuteA) (CACHE_ASTRP cmd); #else int (* p_CacheEvalA) (CACHE_ASTRP volatile expr); int (* p_CacheExecuteA) (CACHE_ASTRP volatile cmd); #endif int (* p_CacheConvert) (unsigned long type, void * rbuf); int (* p_CacheErrorA) (CACHE_ASTRP, CACHE_ASTRP, int *); int (* p_CacheErrxlateA) (int, CACHE_ASTRP); int (* p_CacheEnableMultiThread) (void); int (* p_CacheTStart) (void); int (* p_CacheTLevel) (void); int (* p_CacheTCommit) (void); int (* p_CacheTRollback) (int nlev); } DBXISCSO, *PDBXISCSO; typedef struct tagDBXYDBSO { short loaded; int no_connections; int multiple_connections; char libdir[256]; char libnam[256]; char funprfx[8]; char dbname[32]; DBXPLIB p_library; DBXZV zv; int (* p_ydb_init) (void); int (* p_ydb_exit) (void); int (* p_ydb_malloc) (size_t size); int (* p_ydb_free) (void *ptr); int (* p_ydb_data_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, unsigned int *ret_value); int (* p_ydb_delete_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, int deltype); int (* p_ydb_set_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, ydb_buffer_t *value); int (* p_ydb_get_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, ydb_buffer_t *ret_value); int (* p_ydb_subscript_next_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, ydb_buffer_t *ret_value); int (* p_ydb_subscript_previous_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, ydb_buffer_t *ret_value); int (* p_ydb_node_next_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, int *ret_subs_used, ydb_buffer_t *ret_subsarray); int (* p_ydb_node_previous_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, int *ret_subs_used, ydb_buffer_t *ret_subsarray); int (* p_ydb_incr_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray, ydb_buffer_t *increment, ydb_buffer_t *ret_value); int (* p_ydb_ci) (const char *c_rtn_name, ...); int (* p_ydb_cip) (ci_name_descriptor *ci_info, ...); int (* p_ydb_lock_incr_s) (unsigned long long timeout_nsec, ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray); int (* p_ydb_lock_decr_s) (ydb_buffer_t *varname, int subs_used, ydb_buffer_t *subsarray); void (* p_ydb_zstatus) (ydb_char_t* msg_buffer, ydb_long_t buf_len); int (* p_ydb_tp_s) (ydb_tpfnptr_t tpfn, void *tpfnparm, const char *transid, int namecount, ydb_buffer_t *varnames); } DBXYDBSO, *PDBXYDBSO; typedef struct tagDBXCON { short open; short dbtype; short utf8; short utf16; short use_mutex; short error_mode; /* v2.2.21 */ char type[64]; char path[256]; char username[64]; char password[64]; char nspace[64]; char input_device[64]; char output_device[64]; int error_code; char error[DBX_ERROR_SIZE]; DBXMUTEX *p_mutex; DBXZV *p_zv; DBXISCSO *p_isc_so; DBXYDBSO *p_ydb_so; short net_connection; int tcp_port; char net_host[128]; int timeout; int eof; SOCKET cli_socket; char info[256]; DBXZV zv; int (* p_dbxfun) (struct tagDBXMETH * pmeth); void *pmeth_base; /* v2.1.17 */ int log_errors; int log_functions; int log_transmissions; char log_file[256]; char log_filter[512]; int tlevel; void * pthrt[YDB_MAX_TP]; } DBXCON, *PDBXCON; /* v2.1.17 */ typedef struct tagDBXMETH { short done; short lock; short increment; int binary; int argc; int cargc; unsigned int ibuffer_size; unsigned int ibuffer_used; unsigned char *ibuffer; unsigned int ibuffer16_size; unsigned int ibuffer16_used; unsigned short *ibuffer16; DBXVAL args[DBX_MAXARGS]; ydb_buffer_t yargs[DBX_MAXARGS]; DBXVAL output_val; DBXSQL *psql; int (* p_dbxfun) (struct tagDBXMETH * pmeth); DBXCON *pcon; DBXFUN *pfun; } DBXMETH, *PDBXMETH; typedef struct tagDBXQR { ydb_buffer_t global_name; DBXVAL global_name16; unsigned int kbuffer_size; unsigned int kbuffer_used; unsigned char *kbuffer; unsigned int kbuffer16_size; unsigned int kbuffer16_used; unsigned short *kbuffer16; int keyn; ydb_buffer_t ykeys[DBX_MAXARGS]; DBXVAL keys[DBX_MAXARGS]; DBXVAL data; } DBXQR, *PDBXQR; struct dbx_pool_task { #if !defined(_WIN32) pthread_t parent_tid; #endif int task_id; DBXMETH *pmeth; struct dbx_pool_task *next; }; /* v2.3.25 */ typedef struct tagDBXTHRT { int context; int done; #if !defined(_WIN32) pthread_t parent_tid; pthread_t tp_tid; pthread_mutex_t req_cv_mutex; pthread_cond_t req_cv; pthread_mutex_t res_cv_mutex; pthread_cond_t res_cv; #endif int task_id; DBXMETH *pmeth; } DBXTHRT, *PDBXTHRT; class DBX_DBNAME : public node::ObjectWrap { public: int dbx_count; int counter; short use_mutex; short handle_sigint; short handle_sigterm; unsigned long pid; DBXMUTEX * p_mutex; DBXCON * pcon; DBXCON con; v8::Isolate *isolate; v8::Local icontext; short got_icontext; static v8::Persistent constructor; /* v2.1.17 */ struct dbx_baton_t { DBX_DBNAME * c; void * gx; void * cx; void * clx; v8::Local result_str; v8::Local result_obj; v8::Persistent cb; v8::Isolate * isolate; DBXCON * pcon; DBXMETH * pmeth; }; #if DBX_NODE_VERSION >= 100000 static void Init (v8::Local exports); #else static void Init (v8::Handle exports); #endif explicit DBX_DBNAME (int value = 0); ~DBX_DBNAME(); static void New (const v8::FunctionCallbackInfo& args); static dbx_baton_t * dbx_make_baton (DBX_DBNAME *c, DBXMETH *pmeth); static int dbx_destroy_baton (dbx_baton_t *baton, DBXMETH *pmeth); static int dbx_queue_task (void * work_cb, void * after_work_cb, dbx_baton_t *baton, short context); static async_rtn dbx_process_task (uv_work_t *req); static async_rtn dbx_uv_close_callback (uv_work_t *req); static async_rtn dbx_invoke_callback (uv_work_t *req); static async_rtn dbx_invoke_callback_sql_execute (uv_work_t *req); static void About (const v8::FunctionCallbackInfo& args); static void Version (const v8::FunctionCallbackInfo& args); static void SetLogLevel (const v8::FunctionCallbackInfo& args); static v8::Local StringifyJSON (DBX_DBNAME *c, v8::Local json); static void SetTimeout (const v8::FunctionCallbackInfo& args); static void GetErrorMessage (const v8::FunctionCallbackInfo& args); static void LogMessage (const v8::FunctionCallbackInfo& args); static void Charset (const v8::FunctionCallbackInfo& args); static void Open (const v8::FunctionCallbackInfo& args); static void Close (const v8::FunctionCallbackInfo& args); static void Namespace (const v8::FunctionCallbackInfo& args); static int LogFunction (DBX_DBNAME *c, const v8::FunctionCallbackInfo& args, void *pctx, char *name); static int GlobalReference (DBX_DBNAME *c, const v8::FunctionCallbackInfo& args, DBXMETH *pmeth, DBXGREF *pgref, short context); static void Get (const v8::FunctionCallbackInfo& args); static void Get_bx (const v8::FunctionCallbackInfo& args); static void GetEx (const v8::FunctionCallbackInfo& args, int binary); static void Set (const v8::FunctionCallbackInfo& args); static void Defined (const v8::FunctionCallbackInfo& args); static void Delete (const v8::FunctionCallbackInfo& args); static void Next (const v8::FunctionCallbackInfo& args); static void Previous (const v8::FunctionCallbackInfo& args); static void Increment (const v8::FunctionCallbackInfo& args); static void Lock (const v8::FunctionCallbackInfo& args); static void Unlock (const v8::FunctionCallbackInfo& args); static void Sleep (const v8::FunctionCallbackInfo& args); static void MGlobal (const v8::FunctionCallbackInfo& args); static void MGlobal_Close (const v8::FunctionCallbackInfo& args); static void MGlobalQuery (const v8::FunctionCallbackInfo& args); static void MGlobalQuery_Close (const v8::FunctionCallbackInfo& args); static int ExtFunctionReference (DBX_DBNAME *c, const v8::FunctionCallbackInfo& args, DBXMETH *pmeth, DBXFREF *pfref, DBXFUN *pfun, short context); static void ExtFunction (const v8::FunctionCallbackInfo& args); static void ExtFunction_bx (const v8::FunctionCallbackInfo& args); static void ExtFunctionEx (const v8::FunctionCallbackInfo& args, int binary); static int ClassReference (DBX_DBNAME *c, const v8::FunctionCallbackInfo& args, DBXMETH *pmeth, DBXCREF *pcref, int argc_offset, short context); static void ClassMethod (const v8::FunctionCallbackInfo& args); static void ClassMethod_bx (const v8::FunctionCallbackInfo& args); static void ClassMethodEx (const v8::FunctionCallbackInfo& args, int binary); static void ClassMethod_Close (const v8::FunctionCallbackInfo& args); static void SQL (const v8::FunctionCallbackInfo& args); static void SQL_Close (const v8::FunctionCallbackInfo& args); static void TStart (const v8::FunctionCallbackInfo& args); static void TLevel (const v8::FunctionCallbackInfo& args); static void TCommit (const v8::FunctionCallbackInfo& args); static void TRollback (const v8::FunctionCallbackInfo& args); static void Benchmark (const v8::FunctionCallbackInfo& args); private: unsigned char csize; }; DBXMETH * dbx_request_memory (DBXCON *pcon, short allow_char16, short context); DBXMETH * dbx_request_memory_alloc (DBXCON *pcon, short alloc_char16, short context); int dbx_request_memory_free (DBXCON *pcon, DBXMETH *pmeth, short context); #if DBX_NODE_VERSION >= 100000 void dbx_set_prototype_method (v8::Local t, v8::FunctionCallback callback, const char* name, const char* data); #else void dbx_set_prototype_method (v8::Handle t, v8::FunctionCallback callback, const char* name, const char* data); #endif v8::Local dbx_is_object (v8::Local value, int *otype); int dbx_string8_length (v8::Isolate * isolate, v8::Local str, int utf8); int dbx_string16_length (v8::Isolate * isolate, v8::Local str); v8::Local dbx_new_string8 (v8::Isolate * isolate, char * buffer, int utf8); v8::Local dbx_new_string16 (v8::Isolate * isolate, unsigned short * buffer); v8::Local dbx_new_string8n (v8::Isolate * isolate, char * buffer, unsigned long len, int utf8); v8::Local dbx_new_string16n (v8::Isolate * isolate, unsigned short * buffer, unsigned long len); int dbx_write_char8 (v8::Isolate * isolate, v8::Local str, char * buffer, int buffer_size, int utf8); int dbx_write_char16 (v8::Isolate * isolate, v8::Local str, unsigned short * buffer); int dbx_ibuffer_add (DBXMETH *pmeth, v8::Isolate * isolate, int argn, v8::Local str, void * pbuffer, int buffer_len, short char16, short context); int dbx_ibuffer16_add (DBXMETH *pmeth, v8::Isolate * isolate, int argn, v8::Local str, void * pbuffer, int buffer_len, short char16, short context); int dbx_cursor_init (void *pcx); int dbx_global_reset (const v8::FunctionCallbackInfo& args, v8::Isolate * isolate, DBXCON *pcon, DBXMETH *pmeth, void *pgx, int argc_offset, short context); int dbx_cursor_reset (const v8::FunctionCallbackInfo& args, v8::Isolate * isolate, DBXCON *pcon, DBXMETH *pmeth, void *pcx, int argc_offset, short context); int isc_load_library (DBXCON *pcon); int isc_authenticate (DBXCON *pcon); int isc_open (DBXMETH *pmeth); int isc_parse_zv (char *zv, DBXZV * p_sv); int isc_change_namespace (DBXCON *pcon, char *nspace); int isc_get_namespace (DBXCON *pcon, char *nspace, int nspace_len); int isc_cleanup (DBXMETH *pmeth); int isc_pop_value (DBXMETH *pmeth, DBXVAL *value, int required_type); char * isc_callin_message (DBXCON *pcon, int error_code); int isc_error_message (DBXCON *pcon, int error_code); int isc_error (DBXCON *pcon, int error_code); int ydb_load_library (DBXCON *pcon); int ydb_open (DBXMETH *pmeth); int ydb_parse_zv (char *zv, DBXZV * p_isc_sv); int ydb_change_namespace (DBXCON *pcon, char *nspace); int ydb_get_namespace (DBXCON *pcon, char *nspace, int nspace_len); int ydb_get_intsvar (DBXCON *pcon, char *svarname); int ydb_error_message (DBXCON *pcon, int error_code); int ydb_error (DBXCON *pcon, int error_code); int ydb_function (DBXMETH *pmeth, DBXFUN *pfun); int ydb_function_ex (DBXMETH *pmeth, DBXFUN *pfun); int ydb_transaction_cb (void *pargs); #if defined(_WIN32) LPTHREAD_START_ROUTINE ydb_transaction_thread (LPVOID pargs); #else void * ydb_transaction_thread (void *pargs); #endif int ydb_transaction (DBXMETH *pmeth); int ydb_transaction_task (DBXMETH *pmeth, int context); int dbx_version (DBXMETH *pmeth); int dbx_open (DBXMETH *pmeth); int dbx_do_nothing (DBXMETH *pmeth); int dbx_close (DBXMETH *pmeth); int dbx_namespace (DBXMETH *pmeth); int dbx_reference (DBXMETH *pmeth, int n); int dbx_global_reference (DBXMETH *pmeth); int dbx_get (DBXMETH *pmeth); int dbx_set (DBXMETH *pmeth); int dbx_defined (DBXMETH *pmeth); int dbx_delete (DBXMETH *pmeth); int dbx_next (DBXMETH *pmeth); int dbx_previous (DBXMETH *pmeth); int dbx_increment (DBXMETH *pmeth); int dbx_lock (DBXMETH *pmeth); int dbx_unlock (DBXMETH *pmeth); int dbx_merge (DBXMETH *pmeth); int dbx_tstart (DBXMETH *pmeth); int dbx_tlevel (DBXMETH *pmeth); int dbx_tcommit (DBXMETH *pmeth); int dbx_trollback (DBXMETH *pmeth); int dbx_function_reference (DBXMETH *pmeth, DBXFUN *pfun); int dbx_function (DBXMETH *pmeth); int dbx_class_reference (DBXMETH *pmeth, int optype); int dbx_classmethod (DBXMETH *pmeth); int dbx_method (DBXMETH *pmeth); int dbx_setproperty (DBXMETH *pmeth); int dbx_getproperty (DBXMETH *pmeth); int dbx_sql_execute (DBXMETH *pmeth); int dbx_sql_row (DBXMETH *pmeth, int rn, int dir); int dbx_sql_cleanup (DBXMETH *pmeth); int dbx_global_directory (DBXMETH *pmeth, DBXQR *pqr_prev, short dir, int *counter); int dbx_global_order (DBXMETH *pmeth, DBXQR *pqr_prev, short dir, short getdata); int dbx_global_query (DBXMETH *pmeth, DBXQR *pqr_next, DBXQR *pqr_prev, short dir, short getdata); int dbx_parse_global_reference (DBXMETH *pmeth, DBXQR *pqr, char *global_ref, int global_ref_len); int dbx_parse_global_reference16 (DBXMETH *pmeth, DBXQR *pqr, unsigned short *global_ref, int global_ref_len); int dbx_validate_name (DBXMETH *pmeth, void * pbuffer, int buffer_len, short char16, short context); int dbx_launch_thread (DBXMETH *pmeth); #if defined(_WIN32) LPTHREAD_START_ROUTINE dbx_thread_main (LPVOID pargs); #else void * dbx_thread_main (void *pargs); #endif struct dbx_pool_task * dbx_pool_add_task (DBXMETH *pmeth); struct dbx_pool_task * dbx_pool_get_task (void); void dbx_pool_execute_task (struct dbx_pool_task *task, int thread_id); void * dbx_pool_requests_loop (void *data); int dbx_pool_thread_init (DBXCON *pcon, int num_threads); int dbx_pool_submit_task (DBXMETH *pmeth); int dbx_add_block_size (unsigned char *block, unsigned long offset, unsigned long data_len, int dsort, int dtype); unsigned long dbx_get_block_size (unsigned char *block, unsigned long offset, int *dsort, int *dtype); int dbx_set_size (unsigned char *str, unsigned long data_len); unsigned long dbx_get_size (unsigned char *str); void * dbx_realloc (void *p, int curr_size, int new_size, short id); void * dbx_malloc (int size, short id); int dbx_free (void *p, short id); DBXQR * dbx_alloc_dbxqr (DBXQR *pqr, int dsize, short alloc_char16, short context); int dbx_free_dbxqr (DBXQR *pqr); int dbx_ucase (char *string); int dbx_lcase (char *string); int dbx_isalpha (int c); int dbx_create_string (DBXSTR *pstr, void *data, short type); int dbx_log_transmission (DBXCON *pcon, DBXMETH *pmeth, char *name); int dbx_log_response (DBXCON *pcon, char *ibuffer, int ibuffer_len, char *name); int dbx_log_event (DBXCON *pcon, char *message, char *title, int level); int dbx_log_buffer (DBXCON *pcon, char *buffer, int buffer_len, char *title, int level); int dbx_test_file_access (char *file, int mode); DBXPLIB dbx_dso_load (char * library); DBXPROC dbx_dso_sym (DBXPLIB p_library, char * symbol); int dbx_dso_unload (DBXPLIB p_library); DBXTHID dbx_current_thread_id (void); unsigned long dbx_current_process_id (void); int dbx_error_message (DBXMETH *pmeth, int error_code); int dbx_mutex_create (DBXMUTEX *p_mutex); int dbx_mutex_lock (DBXMUTEX *p_mutex, int timeout); int dbx_mutex_unlock (DBXMUTEX *p_mutex); int dbx_mutex_destroy (DBXMUTEX *p_mutex); int dbx_enter_critical_section (void *p_crit); int dbx_leave_critical_section (void *p_crit); int dbx_sleep (unsigned long msecs); int dbx_fopen (FILE **pfp, const char *file, const char *mode); int dbx_strcpy_s (char *to, size_t size, const char *from, const char *file, const char *fun, const unsigned int line); int dbx_strncpy_s (char *to, size_t size, const char *from, size_t count, const char *file, const char *fun, const unsigned int line); int dbx_strcat_s (char *to, size_t size, const char *from, const char *file, const char *fun, const unsigned int line); int dbx_strncat_s (char *to, size_t size, const char *from, size_t count, const char *file, const char *fun, const unsigned int line); int dbx_sprintf_ (char *to, size_t size, const char *format, const char *file, const char *fun, const unsigned int line, ...); #endif