MqContextC - create and manage a slave context … More...

Collaboration diagram for MqContextC_SlaveApi_JV_API:

Functions
native MqContextC	jvmqmsgque.MqContextC.SlaveGetMaster ()
	`Java: MqContextC ctx.SlaveGetMaster()` → C-API opposite function of MqSlaveGetFilter

native MqContextC	jvmqmsgque.MqContextC.SlaveGet (int id)
	`Java: MqContextC ctx.SlaveGet(int id)` → C-API get the slave-context from a master-context …

native MqContextC	jvmqmsgque.MqContextC.SlaveGetFilter ()
	`Java: MqContextC ctx.SlaveGetFilter()` → C-API get the filter-ctx or the master-ctx …

native MqContextC	jvmqmsgque.MqContextC.SlaveGetProxy (int id)
	`Java: MqContextC ctx.SlaveGetProxy(int id)` → C-API on slave return the master and on master return the slave identified by id.

native boolean	jvmqmsgque.MqContextC.SlaveCheck (int id)
	`Java: boolean ctx.SlaveCheck(int id)` → C-API check if slave-id is valid

native void	jvmqmsgque.MqContextC.SlaveCreate (int id, MqContextC slave)
	`Java: ctx.SlaveCreate(int id, MqContextC slave)` → C-API create a master/slave link between the master-parent-context and the slave-parent-context …

native void	jvmqmsgque.MqContextC.SlaveDelete (int id)
	`Java: ctx.SlaveDelete(int id)` → C-API Delete a slave object from a master/slave link identified by id. …

native boolean	jvmqmsgque.MqContextC.SlaveIs ()
	`Java: boolean ctx.SlaveIs()` → C-API is the context a slave-context ? …

native void	jvmqmsgque.MqContextC.SlaveWorker (int id, String fct, MkBufferListC args)
	`Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?)` → C-API create a master/slave link using the image of the ctx object self. …

void	jvmqmsgque.MqContextC.SlaveWorker (int id, String fct, String... args)
	`Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?)` → C-API create a master/slave link using the image of the ctx object self. …

void	jvmqmsgque.MqContextC.SlaveWorker (int id)
	`Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?)` → C-API create a master/slave link using the image of the ctx object self. …

void	jvmqmsgque.MqContextC.SlaveWorker (int id, String fct)
	`Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?)` → C-API create a master/slave link using the image of the ctx object self. …

JNIEXPORT jobject JNICALL	Java_jvmqmsgque_MqContextC_SlaveGetMaster (JNIEnv *env, jobject self)
	`Java: MqContextC ctx.SlaveGetMaster()` → C-API opposite function of MqSlaveGetFilter

JNIEXPORT jobject JNICALL	Java_jvmqmsgque_MqContextC_SlaveGet (JNIEnv *env, jobject self, jint id)
	`Java: MqContextC ctx.SlaveGet(int id)` → C-API get the slave-context from a master-context …

JNIEXPORT jobject JNICALL	Java_jvmqmsgque_MqContextC_SlaveGetFilter (JNIEnv *env, jobject self)
	`Java: MqContextC ctx.SlaveGetFilter()` → C-API get the filter-ctx or the master-ctx …

JNIEXPORT jobject JNICALL	Java_jvmqmsgque_MqContextC_SlaveGetProxy (JNIEnv *env, jobject self, jint id)
	`Java: MqContextC ctx.SlaveGetProxy(int id)` → C-API on slave return the master and on master return the slave identified by id.

JNIEXPORT jboolean JNICALL	Java_jvmqmsgque_MqContextC_SlaveCheck (JNIEnv *env, jobject self, jint id)
	`Java: boolean ctx.SlaveCheck(int id)` → C-API check if slave-id is valid

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_SlaveCreate (JNIEnv *env, jobject self, jint id, jobject slave)
	`Java: ctx.SlaveCreate(int id, MqContextC slave)` → C-API create a master/slave link between the master-parent-context and the slave-parent-context …

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_SlaveDelete (JNIEnv *env, jobject self, jint id)
	`Java: ctx.SlaveDelete(int id)` → C-API Delete a slave object from a master/slave link identified by id. …

JNIEXPORT jboolean JNICALL	Java_jvmqmsgque_MqContextC_SlaveIs (JNIEnv *env, jobject self)
	`Java: boolean ctx.SlaveIs()` → C-API is the context a slave-context ? …

JNIEXPORT void JNICALL	Java_jvmqmsgque_MqContextC_SlaveWorker (JNIEnv *env, jobject self, jint id, jstring fct, jobject args)
	`Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?)` → C-API create a master/slave link using the image of the ctx object self. …

Detailed Description

MqContextC - create and manage a slave context …

The master-slave-link is used to create a mesh of nodes defined by different parent-context. The master control the slave.

The master-slave-link is used to perform the following tasks:

report error messages from the slave-context to the master-context
to create a slave-child-context if a master-child-context is created
to delete a slave-context if a master-context is deleted

In difference to the client-server-link the master-slave-link connect two independent parent-context in the same process or thread (e.g. node). This leads to the restriction that only the master-context can be a server-context because only one server-context per node is possible.

   node-0   |           node-1/2        |   node-3/4/5
===================================================================

| <- client/server link -> | <- client/server link -> |

             | <-- master/slave link --> |

                           |- client1-0 -|- server3 ...
             |-  server1  -|
             |             |- client1-1 -|- server4 ...
  client0-0 -|
             |-  server2  -|- client1-2 -|- server5 ...

Definition of the "master-context"

the master-context is a parent-context without a child-context available.
the master-context is a client-context or a server-context.
the link between the master-context and the slave-context is done using MqSlaveWorker or MqSlaveCreate

Definition of the "slave-context"

the slave-context is a parent-context without a child-context available.
the slave-context is a client-context.
the slave-context lifetime is controlled by the master-context.
the slave-context report all error-messages to the master-context.
the slave-context is identified by a unique-slave-id starting with 0.
a special form of a slave-context is a worker-context

Definition of the "worker-context"

the worker-context is a slave-context using the image of the master-context self.
the master-context can be a server-context or a client-context.
the worker-context is created using MqSlaveWorker
the worker-context is identified by a unique-slave-id starting with 0.

Definition of the "slave-id"

the slave-id is defined at enum MqSlaveE
a slave is identified in his master-context by a slave-id
the slave-id work like a defined well-known-port-number in /etc/services
the slave-id is an integer value with valid values > 0
it is a good practice to plan the usage of your slave-id(s)

slave

slave-id	value	definition
MQ_SLAVE_MAX	1024	internal: the maximum slave-id … .
MQ_SLAVE_USER	10	internal: start of user-defined-slave-id .
MQ_SLAVE_LOOPBACK	0	internal: the loopback-slave-id, (call my own services) .
MQ_SLAVE_FILTER	1	internal: the filter-slave-id, (on a master get the filter-slave) .
MQ_SLAVE_MASTER	1	internal: the master-slave-id, (on a slave get the master) .
MQ_SLAVE_OTHER	1	internal: on the master-ctx get the slave-ctx and on the slave-ctx get the master-ctx .

range

range	definition
0 <= slave-id < MQ_SLAVE_MAX	range of valid slave-id's
0 <= slave-id < MQ_SLAVE_USER	internale usage
MQ_SLAVE_USER <= slave-id < MQ_SLAVE_MAX	external usage

Definition of the "LOOPBACK" (0) slave

   client   |           server            |
===========================================

| <--- client/server --->  | <-- loop --> |

            | <------ master/slave -----> |

  client -- | -- server -- | -- client -- #
                   ==             ==      #
                 server -- | -- client -- #

the loopback has always the slave-id = 0 .
the loopback has the same class as the parent, if reflection is not available the MqFactoryInitial is used.
the loopback is used to call a service on the same process or thread.
the loopback is a special filter without an additional process or thread to be started.
the loopback is only internal accessible
the service called by the loopback need the same attention as the service called by the filter, the context of the service is the loopback-context.
the loopback can call MqServiceCreate to create a new link between a service-token and a service-method, by default all services from the master-context (the owner of the loopback) are also accessible by the loopback.
in the service use MqSlaveGetMaster to get the master-context from the loopback-context.

Example from MyLoopServer.java → create a new loop-server

package example;

import jvmqmsgque.*;
import jvmkkernel.*;

// package-item
final class MyLoopServer extends MqContextC implements MqServerSetupIF {

  // set the "mydata" attribute to the master-context
  String mydata = "Hello World";

  // Factory Constructor
  public MyLoopServer(MqContextC tmpl) {
    super(tmpl);
  }

  // service to serve all EXTERNAL requests for token "HLWO"
  class HLWO_srv implements MqServiceIF {
    public void Callback(MqContextC ctx) {
      // get the "loopback" context
      MqContextC loop = SlaveGet(MqSlaveE.LOOPBACK.get());
      // call the LOOP service on the SAME server
      loop.Send("W","LOOP");
      // answer HLWO with string-return from LOOP
      Send("R", "C", loop.ReadSTR());
    }
  }

  // service to serve all INTERNAL requests for token "LOOP"
  class LOOP_srv implements MqServiceIF {
    public void Callback(MqContextC ctx) {
      // get the "master" context 
      MyLoopServer master = ((MyLoopServer)SlaveGetMaster());
      // answer LOOP with data from MASTER->mydata attribute
      Send("R", "C", master.mydata);
    }
  }

  // define a service as link between the token "HLWO" and the class "MyFirstService"
  public void ServerSetup() {
    // EXTERNAL: link the "HLWO" service with the "HLWO_srv"
    ServiceCreate("HLWO", new HLWO_srv());
    // INTERNAL: link the "LOOP" service with "LOOP_srv"
    SlaveGet(MqSlaveE.LOOPBACK.get()).ServiceCreate("LOOP", new LOOP_srv());
  }

  // -------------------------------------------------------------

  // package-main
  public static void main(String[] argv) {
  
    // create the "MyLoopServer" factory… and the instance
    MqContextC srv = MqFactoryC.Add(MyLoopServer.class).New();

    try {
      srv.LinkCreate(argv);
      srv.ProcessEvent(MqWaitOnEventE.FOREVER);
    } catch (Throwable e) {
      srv.ErrorCatch(e);
    }
    srv.Exit();
  }
}

Performance analyse

The performance-test is created with:

pipe
- Nhi1Exec perfclient.c --parent --wrk ? @ perfserver.c
spawn, fork, thread
- Nhi1Exec -r=uds perfserver.c --spawn|fork|thread
- Nhi1Exec -r=uds perfclient.c --parent --wrk ?
the number of workers are set with the –wrk option
the cpu is a xeon with 4/8
the performance is calculated as worker-context-created / time-in-sec with a ~2sec (default) measurement period.

performance-test code:

The test-setup is done as:

  perfclient                                worker                            perfserver
  ==========                                ======                            ==========
  |
  |- loop --wrk x
    |- MqSlaveWorker(...)               ->  worker[1] 
    |- MqSend(worker[1],"E","STR0..")   ->  PerfWorker_I160(...)
                                            |- loop endless
                                              |- MqContextCreate(...)
                                              |- MqLinkCreate(...)      <->   MqContextCreate(...)
                                              |- MqContextDelete(...)   <->   MqContextDelete(...)
  |- sleep x sec
  |- loop --wrk x
    |- MqSend(worker[1],"C"..,"END0")   ->  PerfWorker_END0(...)
    |                                       |- stop loop
    |- "callback" - add number to all   <-  |- return #context

Using the worker-code:
// asynchronous call

static enum MkErrorE PerfWorker_STR0( MQ_SERVICE_CALL_ARGS ) {

MK_BFL largv = NULL;

MK_BFL pargv = NULL;

MK_I32 num = MqReadI32_e(mqctx);

pargv = MkBufferListDup(MqReadBFL_e(mqctx));

enum MkErrorE ret = MK_OK;

if (num == -1) num = 999999; // endless

// start test until "doNext" is "false" or "num" exceeds

for (int i=0; doNext && i<num; i++) {

// CREATE the context

MQ_CTX ctx = MqContextCreate(NULL, mqctx);

largv = MkBufferListDup(pargv);

MqLinkCreate_C (ctx, largv) {

MqContextErrorMove(mqctx,ctx);

MqContextDelete(ctx);

goto error;

}

//MqSend(ctx,"E","MARK:C","start");

MkBufferListDelete(largv);

// DELETE the context

MqContextDelete(ctx);

// count the loops

worker_count++;

// give PerfWorker_END0 time to update "doNext"

MqProcessEvent(mqctx, MQ_WAIT_NO, MK_TIMEOUT_DEFAULT);

}

end:

//printV("ret=%i, Delete=%p\n", ret, largv)

MkBufferListDelete(largv);

MkBufferListDelete(pargv);

if (doNext == true) {

// finish the test WITHOUT "END0" -> test on --num, answer required.

MqSend_E(mqctx, "R", "I", worker_count);

}

return ret;

error:

if (doNext == true) {

ret = MkErrorStack_1X(mqctx);

} else {

ret = MkErrorReset_1X(mqctx);

}

goto end;

}

performance-test results:

results generated using the debug environment

setup	–wrk	# worker-context	performance	info
pipe	1	2500	1000	the pipe start a new worker-context with spawn
spawn	1	2500	<1000	same as pipe but use network-protocoll
fork	1	3800	4000	the fork is faster than spawn
thread	1	16500	9000	the thread is faster than fork
pipe	4	8000	4500	the worker scale linear up to number of processors
spawn	4	7600	<4500	-
fork	4	23200	11500	-
thread	4	55500	27500	-
pipe	8	10000	5500	the additional scaling up to the max hyper-threading does not really help
spawn	8	9100	<5500	-
fork	8	23200	11500	-
thread	8	55500	27500	-

The master-slave-link is used to create a mesh of nodes defined by different parent-context. The master control the slave.

The master-slave-link is used to perform the following tasks:

report error messages from the slave-context to the master-context
to create a slave-child-context if a master-child-context is created
to delete a slave-context if a master-context is deleted

In difference to the client-server-link the master-slave-link connect two independent parent-context in the same process or thread (e.g. node). This leads to the restriction that only the master-context can be a server-context because only one server-context per node is possible.

   node-0   |           node-1/2        |   node-3/4/5
===================================================================

| <- client/server link -> | <- client/server link -> |

             | <-- master/slave link --> |

                           |- client1-0 -|- server3 ...
             |-  server1  -|
             |             |- client1-1 -|- server4 ...
  client0-0 -|
             |-  server2  -|- client1-2 -|- server5 ...

Definition of the "master-context"

the master-context is a parent-context without a child-context available.
the master-context is a client-context or a server-context.
the link between the master-context and the slave-context is done using MqSlaveWorker or MqSlaveCreate

Definition of the "slave-context"

the slave-context is a parent-context without a child-context available.
the slave-context is a client-context.
the slave-context lifetime is controlled by the master-context.
the slave-context report all error-messages to the master-context.
the slave-context is identified by a unique-slave-id starting with 0.
a special form of a slave-context is a worker-context

Definition of the "worker-context"

the worker-context is a slave-context using the image of the master-context self.
the master-context can be a server-context or a client-context.
the worker-context is created using MqSlaveWorker
the worker-context is identified by a unique-slave-id starting with 0.

Definition of the "slave-id"

the slave-id is defined at enum MqSlaveE
a slave is identified in his master-context by a slave-id
the slave-id work like a defined well-known-port-number in /etc/services
the slave-id is an integer value with valid values > 0
it is a good practice to plan the usage of your slave-id(s)

slave

slave-id	value	definition
MQ_SLAVE_MAX	1024	internal: the maximum slave-id … .
MQ_SLAVE_USER	10	internal: start of user-defined-slave-id .
MQ_SLAVE_LOOPBACK	0	internal: the loopback-slave-id, (call my own services) .
MQ_SLAVE_FILTER	1	internal: the filter-slave-id, (on a master get the filter-slave) .
MQ_SLAVE_MASTER	1	internal: the master-slave-id, (on a slave get the master) .
MQ_SLAVE_OTHER	1	internal: on the master-ctx get the slave-ctx and on the slave-ctx get the master-ctx .

range

range	definition
0 <= slave-id < MQ_SLAVE_MAX	range of valid slave-id's
0 <= slave-id < MQ_SLAVE_USER	internale usage
MQ_SLAVE_USER <= slave-id < MQ_SLAVE_MAX	external usage

Definition of the "LOOPBACK" (0) slave

   client   |           server            |
===========================================

| <--- client/server --->  | <-- loop --> |

            | <------ master/slave -----> |

  client -- | -- server -- | -- client -- #
                   ==             ==      #
                 server -- | -- client -- #

the loopback has always the slave-id = 0 .
the loopback has the same class as the parent, if reflection is not available the MqFactoryInitial is used.
the loopback is used to call a service on the same process or thread.
the loopback is a special filter without an additional process or thread to be started.
the loopback is only internal accessible
the service called by the loopback need the same attention as the service called by the filter, the context of the service is the loopback-context.
the loopback can call MqServiceCreate to create a new link between a service-token and a service-method, by default all services from the master-context (the owner of the loopback) are also accessible by the loopback.
in the service use MqSlaveGetMaster to get the master-context from the loopback-context.

Example from MyLoopServer.java → create a new loop-server

package example;

import jvmqmsgque.*;
import jvmkkernel.*;

// package-item
final class MyLoopServer extends MqContextC implements MqServerSetupIF {

  // set the "mydata" attribute to the master-context
  String mydata = "Hello World";

  // Factory Constructor
  public MyLoopServer(MqContextC tmpl) {
    super(tmpl);
  }

  // service to serve all EXTERNAL requests for token "HLWO"
  class HLWO_srv implements MqServiceIF {
    public void Callback(MqContextC ctx) {
      // get the "loopback" context
      MqContextC loop = SlaveGet(MqSlaveE.LOOPBACK.get());
      // call the LOOP service on the SAME server
      loop.Send("W","LOOP");
      // answer HLWO with string-return from LOOP
      Send("R", "C", loop.ReadSTR());
    }
  }

  // service to serve all INTERNAL requests for token "LOOP"
  class LOOP_srv implements MqServiceIF {
    public void Callback(MqContextC ctx) {
      // get the "master" context 
      MyLoopServer master = ((MyLoopServer)SlaveGetMaster());
      // answer LOOP with data from MASTER->mydata attribute
      Send("R", "C", master.mydata);
    }
  }

  // define a service as link between the token "HLWO" and the class "MyFirstService"
  public void ServerSetup() {
    // EXTERNAL: link the "HLWO" service with the "HLWO_srv"
    ServiceCreate("HLWO", new HLWO_srv());
    // INTERNAL: link the "LOOP" service with "LOOP_srv"
    SlaveGet(MqSlaveE.LOOPBACK.get()).ServiceCreate("LOOP", new LOOP_srv());
  }

  // -------------------------------------------------------------

  // package-main
  public static void main(String[] argv) {
  
    // create the "MyLoopServer" factory… and the instance
    MqContextC srv = MqFactoryC.Add(MyLoopServer.class).New();

    try {
      srv.LinkCreate(argv);
      srv.ProcessEvent(MqWaitOnEventE.FOREVER);
    } catch (Throwable e) {
      srv.ErrorCatch(e);
    }
    srv.Exit();
  }
}

Performance analyse

The performance-test is created with:

pipe
- Nhi1Exec perfclient.c --parent --wrk ? @ perfserver.c
spawn, fork, thread
- Nhi1Exec -r=uds perfserver.c --spawn|fork|thread
- Nhi1Exec -r=uds perfclient.c --parent --wrk ?
the number of workers are set with the –wrk option
the cpu is a xeon with 4/8
the performance is calculated as worker-context-created / time-in-sec with a ~2sec (default) measurement period.

performance-test code:

The test-setup is done as:

  perfclient                                worker                            perfserver
  ==========                                ======                            ==========
  |
  |- loop --wrk x
    |- MqSlaveWorker(...)               ->  worker[1] 
    |- MqSend(worker[1],"E","STR0..")   ->  PerfWorker_I160(...)
                                            |- loop endless
                                              |- MqContextCreate(...)
                                              |- MqLinkCreate(...)      <->   MqContextCreate(...)
                                              |- MqContextDelete(...)   <->   MqContextDelete(...)
  |- sleep x sec
  |- loop --wrk x
    |- MqSend(worker[1],"C"..,"END0")   ->  PerfWorker_END0(...)
    |                                       |- stop loop
    |- "callback" - add number to all   <-  |- return #context

Using the worker-code:
// asynchronous call

static enum MkErrorE PerfWorker_STR0( MQ_SERVICE_CALL_ARGS ) {

MK_BFL largv = NULL;

MK_BFL pargv = NULL;

MK_I32 num = MqReadI32_e(mqctx);

pargv = MkBufferListDup(MqReadBFL_e(mqctx));

enum MkErrorE ret = MK_OK;

if (num == -1) num = 999999; // endless

// start test until "doNext" is "false" or "num" exceeds

for (int i=0; doNext && i<num; i++) {

// CREATE the context

MQ_CTX ctx = MqContextCreate(NULL, mqctx);

largv = MkBufferListDup(pargv);

MqLinkCreate_C (ctx, largv) {

MqContextErrorMove(mqctx,ctx);

MqContextDelete(ctx);

goto error;

}

//MqSend(ctx,"E","MARK:C","start");

MkBufferListDelete(largv);

// DELETE the context

MqContextDelete(ctx);

// count the loops

worker_count++;

// give PerfWorker_END0 time to update "doNext"

MqProcessEvent(mqctx, MQ_WAIT_NO, MK_TIMEOUT_DEFAULT);

}

end:

//printV("ret=%i, Delete=%p\n", ret, largv)

MkBufferListDelete(largv);

MkBufferListDelete(pargv);

if (doNext == true) {

// finish the test WITHOUT "END0" -> test on --num, answer required.

MqSend_E(mqctx, "R", "I", worker_count);

}

return ret;

error:

if (doNext == true) {

ret = MkErrorStack_1X(mqctx);

} else {

ret = MkErrorReset_1X(mqctx);

}

goto end;

}

performance-test results:

results generated using the debug environment

setup	–wrk	# worker-context	performance	info
pipe	1	2500	1000	the pipe start a new worker-context with spawn
spawn	1	2500	<1000	same as pipe but use network-protocoll
fork	1	3800	4000	the fork is faster than spawn
thread	1	16500	9000	the thread is faster than fork
pipe	4	8000	4500	the worker scale linear up to number of processors
spawn	4	7600	<4500	-
fork	4	23200	11500	-
thread	4	55500	27500	-
pipe	8	10000	5500	the additional scaling up to the max hyper-threading does not really help
spawn	8	9100	<5500	-
fork	8	23200	11500	-
thread	8	55500	27500	-

Function Documentation

◆ Java_jvmqmsgque_MqContextC_SlaveCheck()

JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveCheck	(	JNIEnv *	env,
		jobject	self,
		jint	id )

Java: boolean ctx.SlaveCheck(int id) → C-API
check if slave-id is valid

Definition at line 2434 of file MqContextC_jv.c.

                                                                                                       {
  MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MK_BOOL __retVal__L = MqSlaveCheck(hdl, id);
  jboolean __retVal__S = __retVal__L;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveCreate()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveCreate	(	JNIEnv *	env,
		jobject	self,
		jint	id,
		jobject	slave )

Java: ctx.SlaveCreate(int id, MqContextC slave) → C-API
create a master/slave link between the master-parent-context and the slave-parent-context …

Definition at line 2446 of file MqContextC_jv.c.

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

◆ Java_jvmqmsgque_MqContextC_SlaveDelete()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveDelete	(	JNIEnv *	env,
		jobject	self,
		jint	id )

Java: ctx.SlaveDelete(int id) → C-API
Delete a slave object from a master/slave link identified by id. …

Definition at line 2459 of file MqContextC_jv.c.

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

◆ Java_jvmqmsgque_MqContextC_SlaveGet()

JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGet	(	JNIEnv *	env,
		jobject	self,
		jint	id )

Java: MqContextC ctx.SlaveGet(int id) → C-API
get the slave-context from a master-context …

Definition at line 2390 of file MqContextC_jv.c.

                                                                                                    {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX ctx_out;
  enum MkErrorE errVal = MqSlaveGet(hdl, id, &ctx_out);
  MkErrorC_Check(hdl, errVal)
  jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveGetFilter()

JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetFilter	(	JNIEnv *	env,
		jobject	self )

Java: MqContextC ctx.SlaveGetFilter() → C-API
get the filter-ctx or the master-ctx …

Definition at line 2404 of file MqContextC_jv.c.

                                                                                                 {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX ctx_out;
  enum MkErrorE errVal = MqSlaveGetFilter(hdl, &ctx_out);
  MkErrorC_Check(hdl, errVal)
  jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveGetMaster()

JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetMaster	(	JNIEnv *	env,
		jobject	self )

Java: MqContextC ctx.SlaveGetMaster() → C-API
opposite function of MqSlaveGetFilter

Definition at line 2376 of file MqContextC_jv.c.

                                                                                                 {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX __retVal__L = MqSlaveGetMaster(hdl);
  jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,__retVal__L);
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveGetProxy()

JNIEXPORT jobject JNICALL Java_jvmqmsgque_MqContextC_SlaveGetProxy	(	JNIEnv *	env,
		jobject	self,
		jint	id )

Java: MqContextC ctx.SlaveGetProxy(int id) → C-API
on slave return the master and on master return the slave identified by id.

Definition at line 2418 of file MqContextC_jv.c.

                                                                                                         {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MQ_CTX ctx_out;
  enum MkErrorE errVal = MqSlaveGetProxy(hdl, id, &ctx_out);
  MkErrorC_Check(hdl, errVal)
  jobject __retVal__S = MQ(MqContextC_ObjNew)(MK_RT_CALL env,ctx_out);
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveIs()

JNIEXPORT jboolean JNICALL Java_jvmqmsgque_MqContextC_SlaveIs	(	JNIEnv *	env,
		jobject	self )

Java: boolean ctx.SlaveIs() → C-API
is the context a slave-context ? …

Definition at line 2470 of file MqContextC_jv.c.

                                                                                           {
  MQ_CTXN hdl = (MQ_CTXN)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MK_BOOL __retVal__L = MqSlaveIs(hdl);
  jboolean __retVal__S = __retVal__L;
  return __retVal__S;
error:
  return 0;
}

◆ Java_jvmqmsgque_MqContextC_SlaveWorker()

JNIEXPORT void JNICALL Java_jvmqmsgque_MqContextC_SlaveWorker	(	JNIEnv *	env,
		jobject	self,
		jint	id,
		jstring	fct,
		jobject	args )

Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?) → C-API
create a master/slave link using the image of the ctx object self. …

Definition at line 2482 of file MqContextC_jv.c.

                                                                                                                               {
  MQ_CTX hdl = (MQ_CTX)pObj2Hdl(env,"MqContextC",self);
  JavaErrorCheck;
  MkRtSetup_X(hdl);
  MK_BAC args_hdl = (MK_BAC)pObj2Hdl__null_allow(env,args);
  JavaErrorCheck;
  MK_STRN fct_ptr = (fct?(*env)->GetStringUTFChars(env,fct,NULL):NULL);
  JavaErrorCheck;
  enum MkErrorE errVal = MqSlaveWorker(hdl, id, fct_ptr, args_hdl);
  MkErrorC_Check(hdl, errVal)
  if (fct_ptr) (*env)->ReleaseStringUTFChars(env,fct,fct_ptr);
error:
  return;
}

◆ SlaveCheck()

native boolean jvmqmsgque.MqContextC.SlaveCheck ( int id )

Java: boolean ctx.SlaveCheck(int id) → C-API
check if slave-id is valid

◆ SlaveCreate()

native void jvmqmsgque.MqContextC.SlaveCreate	(	int	id,
		MqContextC	slave )

Java: ctx.SlaveCreate(int id, MqContextC slave) → C-API
create a master/slave link between the master-parent-context and the slave-parent-context …

◆ SlaveDelete()

native void jvmqmsgque.MqContextC.SlaveDelete ( int id )

Java: ctx.SlaveDelete(int id) → C-API
Delete a slave object from a master/slave link identified by id. …

◆ SlaveGet()

native MqContextC jvmqmsgque.MqContextC.SlaveGet ( int id )

Java: MqContextC ctx.SlaveGet(int id) → C-API
get the slave-context from a master-context …

◆ SlaveGetFilter()

native MqContextC jvmqmsgque.MqContextC.SlaveGetFilter ( )

Java: MqContextC ctx.SlaveGetFilter() → C-API
get the filter-ctx or the master-ctx …

◆ SlaveGetMaster()

native MqContextC jvmqmsgque.MqContextC.SlaveGetMaster ( )

Java: MqContextC ctx.SlaveGetMaster() → C-API
opposite function of MqSlaveGetFilter

◆ SlaveGetProxy()

native MqContextC jvmqmsgque.MqContextC.SlaveGetProxy ( int id )

Java: MqContextC ctx.SlaveGetProxy(int id) → C-API
on slave return the master and on master return the slave identified by id.

◆ SlaveIs()

native boolean jvmqmsgque.MqContextC.SlaveIs ( )

Java: boolean ctx.SlaveIs() → C-API
is the context a slave-context ? …

◆ SlaveWorker() [1/4]

void jvmqmsgque.MqContextC.SlaveWorker ( int id )

Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?) → C-API
create a master/slave link using the image of the ctx object self. …

Definition at line 1066 of file MqContextC.java.

                                   {
    SlaveWorker (id, "WORKER", (MkBufferListC) null);
  }

◆ SlaveWorker() [2/4]

void jvmqmsgque.MqContextC.SlaveWorker	(	int	id,
		String	fct )

Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?) → C-API
create a master/slave link using the image of the ctx object self. …

Definition at line 1071 of file MqContextC.java.

                                               {
    SlaveWorker (id, fct, (MkBufferListC) null);
  }

◆ SlaveWorker() [3/4]

native void jvmqmsgque.MqContextC.SlaveWorker	(	int	id,
		String	fct,
		MkBufferListC	args )

Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?) → C-API
create a master/slave link using the image of the ctx object self. …

Here is the caller graph for this function:

◆ SlaveWorker() [4/4]

void jvmqmsgque.MqContextC.SlaveWorker	(	int	id,
		String	fct,
		String...	args )

Java: ctx.SlaveWorker(int id, ?String fct = "WORKER"?, ?MkBufferListC args = null?) → C-API
create a master/slave link using the image of the ctx object self. …

Definition at line 1061 of file MqContextC.java.

                                                               {
    SlaveWorker (id, fct, new MkBufferListC(args));
  }

Functions

Detailed Description

Function Documentation

◆ Java_jvmqmsgque_MqContextC_SlaveCheck()

◆ Java_jvmqmsgque_MqContextC_SlaveCreate()

◆ Java_jvmqmsgque_MqContextC_SlaveDelete()

◆ Java_jvmqmsgque_MqContextC_SlaveGet()

◆ Java_jvmqmsgque_MqContextC_SlaveGetFilter()

◆ Java_jvmqmsgque_MqContextC_SlaveGetMaster()

◆ Java_jvmqmsgque_MqContextC_SlaveGetProxy()

◆ Java_jvmqmsgque_MqContextC_SlaveIs()

◆ Java_jvmqmsgque_MqContextC_SlaveWorker()

◆ SlaveCheck()

◆ SlaveCreate()

◆ SlaveDelete()

◆ SlaveGet()

◆ SlaveGetFilter()

◆ SlaveGetMaster()

◆ SlaveGetProxy()

◆ SlaveIs()

◆ SlaveWorker() [1/4]

◆ SlaveWorker() [2/4]

◆ SlaveWorker() [3/4]

◆ SlaveWorker() [4/4]