MqContextC - setup and manage a storage used to persist data-packages … More...

Collaboration diagram for MqContextC_StorageApi_JV_API:

Functions
native int	jvmqmsgque.MqContextC.StorageDelete (int transLIdP_inout)
	`Java: int ctx.StorageDelete(?int transLIdP_inout = 0?)` → C-API delete the storage-row identified by the *transLIdP_inout* …

int	jvmqmsgque.MqContextC.StorageDelete ()
	`Java: int ctx.StorageDelete(?int transLIdP_inout = 0?)` → C-API delete the storage-row identified by the *transLIdP_inout* …

native int	jvmqmsgque.MqContextC.StorageImport (int transLIdP_inout)
	`Java: int ctx.StorageImport(?int transLIdP_inout = 0?)` → C-API import the storage-package into the read-data-package …

int	jvmqmsgque.MqContextC.StorageImport ()
	`Java: int ctx.StorageImport(?int transLIdP_inout = 0?)` → C-API import the storage-package into the read-data-package …

native void	jvmqmsgque.MqContextC.StorageClose ()
	`Java: ctx.StorageClose()` → C-API close the storage. …

native void	jvmqmsgque.MqContextC.StorageDecrRef (int transLId)
	`Java: ctx.StorageDecrRef(int transLId)` → C-API decrease the internal refCount lock of the database-entry

native void	jvmqmsgque.MqContextC.StorageIncrRef (int transLId)
	`Java: ctx.StorageIncrRef(int transLId)` → C-API increase the internal refCount lock of the database-entry

native void	jvmqmsgque.MqContextC.StorageLog (String callfunc)
	`Java: ctx.StorageLog(?String callfunc = null?)` → C-API log the storage the status of the open transactions

void	jvmqmsgque.MqContextC.StorageLog ()
	`Java: ctx.StorageLog(?String callfunc = null?)` → C-API log the storage the status of the open transactions

native void	jvmqmsgque.MqContextC.StorageOpen (String storageFile)
	`Java: ctx.StorageOpen(String storageFile)` → C-API switch to a file-based-transaction-database …

native int	jvmqmsgque.MqContextC.StorageCount ()
	`Java: int ctx.StorageCount()` → C-API count the number of storage-rows …

native int	jvmqmsgque.MqContextC.StorageErrCnt (int transLId)
	`Java: int ctx.StorageErrCnt(int transLId)` → C-API increment and return the database row-error-count for the row defined with transLId

native int	jvmqmsgque.MqContextC.StorageExport ()
	`Java: int ctx.StorageExport()` → C-API export the read-data-package into the STORAGE …

native String[]	jvmqmsgque.MqContextC.StorageResolve ()
	`Java: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve()` → C-API extract the `context->link.protect.rmtTransLId` entry from the database

JNIEXPORT jint JNICALL	Java_jvmqmsgque_MqContextC_StorageDelete (JNIEnv *env, jobject self, jint transLIdP_inout)
	`Java: int ctx.StorageDelete(?int transLIdP_inout = 0?)` → C-API delete the storage-row identified by the *transLIdP_inout* …

JNIEXPORT jint JNICALL	Java_jvmqmsgque_MqContextC_StorageImport (JNIEnv *env, jobject self, jint transLIdP_inout)
	`Java: int ctx.StorageImport(?int transLIdP_inout = 0?)` → C-API import the storage-package into the read-data-package …

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_StorageClose (JNIEnv *env, jobject self)
	`Java: ctx.StorageClose()` → C-API close the storage. …

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_StorageDecrRef (JNIEnv *env, jobject self, jint transLId)
	`Java: ctx.StorageDecrRef(int transLId)` → C-API decrease the internal refCount lock of the database-entry

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_StorageIncrRef (JNIEnv *env, jobject self, jint transLId)
	`Java: ctx.StorageIncrRef(int transLId)` → C-API increase the internal refCount lock of the database-entry

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_StorageLog (JNIEnv *env, jobject self, jstring callfunc)
	`Java: ctx.StorageLog(?String callfunc = null?)` → C-API log the storage the status of the open transactions

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_StorageOpen (JNIEnv *env, jobject self, jstring storageFile)
	`Java: ctx.StorageOpen(String storageFile)` → C-API switch to a file-based-transaction-database …

JNIEXPORT jint JNICALL	Java_jvmqmsgque_MqContextC_StorageCount (JNIEnv *env, jobject self)
	`Java: int ctx.StorageCount()` → C-API count the number of storage-rows …

JNIEXPORT jint JNICALL	Java_jvmqmsgque_MqContextC_StorageErrCnt (JNIEnv *env, jobject self, jint transLId)
	`Java: int ctx.StorageErrCnt(int transLId)` → C-API increment and return the database row-error-count for the row defined with transLId

JNIEXPORT jint JNICALL	Java_jvmqmsgque_MqContextC_StorageExport (JNIEnv *env, jobject self)
	`Java: int ctx.StorageExport()` → C-API export the read-data-package into the STORAGE …

JNIEXPORT jobjectArray JNICALL	Java_jvmqmsgque_MqContextC_StorageResolve (JNIEnv *env, jobject self)
	`Java: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve()` → C-API extract the `context->link.protect.rmtTransLId` entry from the database

Detailed Description

MqContextC - setup and manage a storage used to persist data-packages …

The storage is divided into: INTERNAL and EXTERNAL storage. Only the read-data-package can be stored or dumped into the storage.

The read-data-package is saved into the storage using:

ServiceStorage	setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …
StorageExport	export the read-data-package into the STORAGE …

The read-data-package is restored from the storage using:

StorageImport	import the storage-package into the read-data-package …
ProxyForward	send the entire read-data-package-data to the link-target …
All this usually happen in an Event Handler

Some important facts of the storage-feature:

The internal-storage depends on SQLite.
The package-storage can be used to save all kind of package-data.
The longterm-transaction-package-data is allways saved into storage.
By default only an in-memory storage is in use, but this can be changed with MqStorageOpen or Storage
An entire service-call can be saved with MqServiceStorage

The following internal storages are supported:

default: The default-storage is set with the configuration parameter --storage fileName and defaults to "#memdb#". If a package have to be saved into the storage and the storage is not open the default-storage id used. The open will always be performed. If an explicit storage is required the default can be changed or a storage can explicit be opened with MqStorageOpen. Keep in mind that the default-storage is a per-context configuration but only one storage per process or thread is currently supported.

memdb: This is the default storage and can be set explicitly with MqStorageOpen using the "#memdb#" parameter.

tmpdb: This storage is like an in-memory-storage but export data to the TEMPORARY filesystem if the application run out of memory. This storage can explicit be set with MqStorageOpen with the parameter "#tmpdb#".

filedb: This storage always work on files. Only this storage is persistent and can explicit be set with MqStorageOpen with the storageFile parameter.

Performance analyse:

The performance is tested with: Nhi1Exec perfclient.c --all --storage VALUE @ perfserver.c.
The parameter VALUE is set to #memdb#, #tmpdb# or a filedb file.
If –storage is not set the filedb database is used together with an internal file-name.

database	performance	host crash	application crash	info
memdb	30.000	data lost	data lost	non persistent
tempdb	< 30.000	data lost	data lost	uses memory and/or temporary file
filedb (mem)	10.000	data lost	data safe	in memory filesystem
filedb (disc)	50	data safe	data safe	disc-speed is the key factor

The storage is divided into: INTERNAL and EXTERNAL storage. Only the read-data-package can be stored or dumped into the storage.

The read-data-package is saved into the storage using:

ServiceStorage	setup a service listen on a MqContextC_ServiceApi_Identifer and save all read-data-package into the STORAGE …
StorageExport	export the read-data-package into the STORAGE …

The read-data-package is restored from the storage using:

StorageImport	import the storage-package into the read-data-package …
ProxyForward	send the entire read-data-package-data to the link-target …
All this usually happen in an Event Handler

Some important facts of the storage-feature:

The internal-storage depends on SQLite.
The package-storage can be used to save all kind of package-data.
The longterm-transaction-package-data is allways saved into storage.
By default only an in-memory storage is in use, but this can be changed with MqStorageOpen or Storage
An entire service-call can be saved with MqServiceStorage

The following internal storages are supported:

default: The default-storage is set with the configuration parameter --storage fileName and defaults to "#memdb#". If a package have to be saved into the storage and the storage is not open the default-storage id used. The open will always be performed. If an explicit storage is required the default can be changed or a storage can explicit be opened with MqStorageOpen. Keep in mind that the default-storage is a per-context configuration but only one storage per process or thread is currently supported.

memdb: This is the default storage and can be set explicitly with MqStorageOpen using the "#memdb#" parameter.

tmpdb: This storage is like an in-memory-storage but export data to the TEMPORARY filesystem if the application run out of memory. This storage can explicit be set with MqStorageOpen with the parameter "#tmpdb#".

filedb: This storage always work on files. Only this storage is persistent and can explicit be set with MqStorageOpen with the storageFile parameter.

Performance analyse:

The performance is tested with: Nhi1Exec perfclient.c --all --storage VALUE @ perfserver.c.
The parameter VALUE is set to #memdb#, #tmpdb# or a filedb file.
If –storage is not set the filedb database is used together with an internal file-name.

database	performance	host crash	application crash	info
memdb	30.000	data lost	data lost	non persistent
tempdb	< 30.000	data lost	data lost	uses memory and/or temporary file
filedb (mem)	10.000	data lost	data safe	in memory filesystem
filedb (disc)	50	data safe	data safe	disc-speed is the key factor

Function Documentation

◆ Java_jvmqmsgque_MqContextC_StorageClose()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageClose	(	JNIEnv *	env,
		jobject	self )

Java: ctx.StorageClose() → C-API
close the storage. …

Definition at line 2535 of file MqContextC_jv.c.

                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  enum MkErrorE errVal = MqStorageClose(hdl);
  MkErrorC_Check(hdl, errVal)
error:
  return;
}

◆ Java_jvmqmsgque_MqContextC_StorageCount()

JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageCount	(	JNIEnv *	env,
		jobject	self )

Java: int ctx.StorageCount() → C-API
count the number of storage-rows …

Definition at line 2602 of file MqContextC_jv.c.

                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_LTR cnt_out;
  enum MkErrorE errVal = MqStorageCount(hdl, &cnt_out);
  MkErrorC_Check(hdl, errVal)
  jint __retVal__S = cnt_out;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_StorageDecrRef()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageDecrRef	(	JNIEnv *	env,
		jobject	self,
		jint	transLId )

Java: ctx.StorageDecrRef(int transLId) → C-API
decrease the internal refCount lock of the database-entry

Definition at line 2546 of file MqContextC_jv.c.

                                                                                                             {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  enum MkErrorE errVal = MqStorageDecrRef(hdl, transLId);
  MkErrorC_Check(hdl, errVal)
error:
  return;
}

◆ Java_jvmqmsgque_MqContextC_StorageDelete()

JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageDelete	(	JNIEnv *	env,
		jobject	self,
		jint	transLIdP_inout )

Java: int ctx.StorageDelete(?int transLIdP_inout = 0?) → C-API
delete the storage-row identified by the transLIdP_inout …

Definition at line 2507 of file MqContextC_jv.c.

                                                                                                                   {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  enum MkErrorE errVal = MqStorageDelete(hdl, &transLIdP_inout);
  MkErrorC_Check(hdl, errVal)
  jint __retVal__S = transLIdP_inout;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_StorageErrCnt()

JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageErrCnt	(	JNIEnv *	env,
		jobject	self,
		jint	transLId )

Java: int ctx.StorageErrCnt(int transLId) → C-API
increment and return the database row-error-count for the row defined with transLId

Definition at line 2616 of file MqContextC_jv.c.

                                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MK_I32 cnt_out;
  enum MkErrorE errVal = MqStorageErrCnt(hdl, transLId, &cnt_out);
  MkErrorC_Check(hdl, errVal)
  jint __retVal__S = cnt_out;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_StorageExport()

JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageExport	(	JNIEnv *	env,
		jobject	self )

Java: int ctx.StorageExport() → C-API
export the read-data-package into the STORAGE …

Definition at line 2630 of file MqContextC_jv.c.

                                                                                             {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_LTR ltid_out;
  enum MkErrorE errVal = MqStorageExport(hdl, &ltid_out);
  MkErrorC_Check(hdl, errVal)
  jint __retVal__S = ltid_out;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_StorageImport()

JNIEXPORT jint JNICALL Java_jvmqmsgque_MqContextC_StorageImport	(	JNIEnv *	env,
		jobject	self,
		jint	transLIdP_inout )

Java: int ctx.StorageImport(?int transLIdP_inout = 0?) → C-API
import the storage-package into the read-data-package …

Definition at line 2520 of file MqContextC_jv.c.

                                                                                                                   {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  enum MkErrorE errVal = MqStorageImport(hdl, &transLIdP_inout);
  MkErrorC_Check(hdl, errVal)
  jint __retVal__S = transLIdP_inout;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_StorageIncrRef()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageIncrRef	(	JNIEnv *	env,
		jobject	self,
		jint	transLId )

Java: ctx.StorageIncrRef(int transLId) → C-API
increase the internal refCount lock of the database-entry

Definition at line 2557 of file MqContextC_jv.c.

                                                                                                             {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  enum MkErrorE errVal = MqStorageIncrRef(hdl, transLId);
  MkErrorC_Check(hdl, errVal)
error:
  return;
}

◆ Java_jvmqmsgque_MqContextC_StorageLog()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageLog	(	JNIEnv *	env,
		jobject	self,
		jstring	callfunc )

Java: ctx.StorageLog(?String callfunc = null?) → C-API
log the storage the status of the open transactions

Definition at line 2568 of file MqContextC_jv.c.

                                                                                                            {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  if (callfunc == NULL) {
    (*env)->CallStaticVoidMethod(env,MK(Class_MkKernel),MK(MID_MkKernel_getCallerStack));
  }
  if (callfunc == NULL) {callfunc = MK(pGetCallerProc)(env);}
  MK_STRN callfunc_ptr = (callfunc?(*env)->GetStringUTFChars(env,callfunc,NULL):NULL);
  JavaErrorCheck;
  enum MkErrorE errVal = MqStorageLog(hdl, callfunc_ptr);
  MkErrorC_Check(hdl, errVal)
  if (callfunc_ptr) (*env)->ReleaseStringUTFChars(env,callfunc,callfunc_ptr);
error:
  return;
}

◆ Java_jvmqmsgque_MqContextC_StorageOpen()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_StorageOpen	(	JNIEnv *	env,
		jobject	self,
		jstring	storageFile )

Java: ctx.StorageOpen(String storageFile) → C-API
switch to a file-based-transaction-database …

Definition at line 2586 of file MqContextC_jv.c.

                                                                                                                {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MK_STRN storageFile_ptr = (storageFile?(*env)->GetStringUTFChars(env,storageFile,NULL):NULL);
  JavaErrorCheck;
  enum MkErrorE errVal = MqStorageOpen(hdl, storageFile_ptr);
  MkErrorC_Check(hdl, errVal)
  if (storageFile_ptr) (*env)->ReleaseStringUTFChars(env,storageFile,storageFile_ptr);
error:
  return;
}

◆ Java_jvmqmsgque_MqContextC_StorageResolve()

JNIEXPORT jobjectArray JNICALL Java_jvmqmsgque_MqContextC_StorageResolve	(	JNIEnv *	env,
		jobject	self )

Java: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve() → C-API
extract the context->link.protect.rmtTransLId entry from the database

Definition at line 2644 of file MqContextC_jv.c.

                                                                                                      {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX otherCtxP_out;
  MQ_LTR otherLIdP_out;
  enum MkErrorE errVal = MqStorageResolve(hdl, &otherCtxP_out, &otherLIdP_out);
  MkErrorC_Check(hdl, errVal)
  jobjectArray __retVal__L = (jobjectArray)(*env)->NewObjectArray(env,2,MK(Class_Object),NULL);
  (*env)->SetObjectArrayElement(env,__retVal__L,0,MQ(MqContextC_ObjNew)(MK_RT_CALL env,otherCtxP_out));
  (*env)->SetObjectArrayElement(env,__retVal__L,1,pNewIntObj(env,otherLIdP_out));
  jobjectArray __retVal__S = __retVal__L;
  return __retVal__S;
error:
  return 0;
}

◆ StorageClose()

native void jvmqmsgque.MqContextC.StorageClose ( )

Java: ctx.StorageClose() → C-API
close the storage. …

◆ StorageCount()

native int jvmqmsgque.MqContextC.StorageCount ( )

Java: int ctx.StorageCount() → C-API
count the number of storage-rows …

◆ StorageDecrRef()

native void jvmqmsgque.MqContextC.StorageDecrRef ( int transLId )

Java: ctx.StorageDecrRef(int transLId) → C-API
decrease the internal refCount lock of the database-entry

◆ StorageDelete() [1/2]

int jvmqmsgque.MqContextC.StorageDelete ( )

Java: int ctx.StorageDelete(?int transLIdP_inout = 0?) → C-API
delete the storage-row identified by the transLIdP_inout …

Definition at line 1088 of file MqContextC.java.

                              {
    return StorageDelete (0);
  }

Here is the caller graph for this function:

◆ StorageDelete() [2/2]

native int jvmqmsgque.MqContextC.StorageDelete ( int transLIdP_inout )

Java: int ctx.StorageDelete(?int transLIdP_inout = 0?) → C-API
delete the storage-row identified by the transLIdP_inout …

◆ StorageErrCnt()

native int jvmqmsgque.MqContextC.StorageErrCnt ( int transLId )

Java: int ctx.StorageErrCnt(int transLId) → C-API
increment and return the database row-error-count for the row defined with transLId

◆ StorageExport()

native int jvmqmsgque.MqContextC.StorageExport ( )

Java: int ctx.StorageExport() → C-API
export the read-data-package into the STORAGE …

◆ StorageImport() [1/2]

int jvmqmsgque.MqContextC.StorageImport ( )

Java: int ctx.StorageImport(?int transLIdP_inout = 0?) → C-API
import the storage-package into the read-data-package …

Definition at line 1096 of file MqContextC.java.

                              {
    return StorageImport (0);
  }

Here is the caller graph for this function:

◆ StorageImport() [2/2]

native int jvmqmsgque.MqContextC.StorageImport ( int transLIdP_inout )

Java: int ctx.StorageImport(?int transLIdP_inout = 0?) → C-API
import the storage-package into the read-data-package …

◆ StorageIncrRef()

native void jvmqmsgque.MqContextC.StorageIncrRef ( int transLId )

Java: ctx.StorageIncrRef(int transLId) → C-API
increase the internal refCount lock of the database-entry

◆ StorageLog() [1/2]

void jvmqmsgque.MqContextC.StorageLog ( )

Java: ctx.StorageLog(?String callfunc = null?) → C-API
log the storage the status of the open transactions

Definition at line 1115 of file MqContextC.java.

                            {
    StorageLog (null);
  }

Here is the caller graph for this function:

◆ StorageLog() [2/2]

native void jvmqmsgque.MqContextC.StorageLog ( String callfunc )

Java: ctx.StorageLog(?String callfunc = null?) → C-API
log the storage the status of the open transactions

◆ StorageOpen()

native void jvmqmsgque.MqContextC.StorageOpen ( String storageFile )

Java: ctx.StorageOpen(String storageFile) → C-API
switch to a file-based-transaction-database …

◆ StorageResolve()

native String[] jvmqmsgque.MqContextC.StorageResolve ( )

Java: {otherCtxP:MqContextC otherLIdP:int} ctx.StorageResolve() → C-API
extract the context->link.protect.rmtTransLId entry from the database

Functions

Detailed Description

Function Documentation

◆ Java_jvmqmsgque_MqContextC_StorageClose()

◆ Java_jvmqmsgque_MqContextC_StorageCount()

◆ Java_jvmqmsgque_MqContextC_StorageDecrRef()

◆ Java_jvmqmsgque_MqContextC_StorageDelete()

◆ Java_jvmqmsgque_MqContextC_StorageErrCnt()

◆ Java_jvmqmsgque_MqContextC_StorageExport()

◆ Java_jvmqmsgque_MqContextC_StorageImport()

◆ Java_jvmqmsgque_MqContextC_StorageIncrRef()

◆ Java_jvmqmsgque_MqContextC_StorageLog()

◆ Java_jvmqmsgque_MqContextC_StorageOpen()

◆ Java_jvmqmsgque_MqContextC_StorageResolve()

◆ StorageClose()

◆ StorageCount()

◆ StorageDecrRef()

◆ StorageDelete() [1/2]

◆ StorageDelete() [2/2]

◆ StorageErrCnt()

◆ StorageExport()

◆ StorageImport() [1/2]

◆ StorageImport() [2/2]

◆ StorageIncrRef()

◆ StorageLog() [1/2]

◆ StorageLog() [2/2]

◆ StorageOpen()

◆ StorageResolve()