arzmq-sys 0.6.3

Low-level bindings to the zeromq library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128


#include "protoPipeJni.h"
#include "protoPipe.h"

#ifdef __cplusplus
extern "C" {
#endif
/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    createProtoPipe
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_createProtoPipe
  (JNIEnv* env, jobject obj)
{
    ProtoPipe* thePipe = new ProtoPipe(ProtoPipe::MESSAGE);
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    env->SetLongField(obj, fid, (jlong)thePipe);
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    listen
 * Signature: (Ljava/lang/String;)Ljava/lang/Boolean;
 */
JNIEXPORT jboolean JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_listen
  (JNIEnv* env, jobject obj, jstring pipeName)
{
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    const char* namePtr = env->GetStringUTFChars(pipeName, NULL);
    bool result = thePipe->Listen(namePtr);
    env->ReleaseStringUTFChars(pipeName, namePtr);
    return (jboolean)result;
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    read
 * Signature: ([BII)I
 */
JNIEXPORT jint JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_read
  (JNIEnv* env, jobject obj, jbyteArray buffer, jint offset, jint length)
{
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    unsigned int numBytes = (unsigned int) length;
    jbyte* ptr = env->GetByteArrayElements(buffer, NULL);
    if (thePipe->Recv((char*)ptr, numBytes))
    {
        // Release the jbyte* to copy them back to the jbyteArray
        env->ReleaseByteArrayElements(buffer, ptr, 0);
        return (jint)numBytes;
    }
    else
    {
        // Release the jbyte* to copy them back to the jbyteArray
        env->ReleaseByteArrayElements(buffer, ptr, 0);
        return (jint)-1;
    }
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    connect
 * Signature: (Ljava/lang/String;)Ljava/lang/Boolean;
 */
JNIEXPORT jboolean JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_connect
  (JNIEnv* env, jobject obj, jstring pipeName)
 {
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    const char* namePtr = env->GetStringUTFChars(pipeName, NULL);
    bool result = thePipe->Connect(namePtr);
    env->ReleaseStringUTFChars(pipeName, namePtr);
    return (jboolean)result;
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    write
 * Signature: ([BII)V
 */
JNIEXPORT void JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_write
  (JNIEnv* env, jobject obj, jbyteArray buffer, jint offset, jint length)
{
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    unsigned int numBytes = (unsigned int)length;
    jbyte* ptr = env->GetByteArrayElements(buffer, NULL);
    thePipe->Send((char*)ptr, numBytes);
    env->ReleaseByteArrayElements(buffer, ptr, 0);
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    close
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_close
  (JNIEnv* env, jobject obj)
{
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    thePipe->Close();
}

/*
 * Class:     mil_navy_nrl_protolib_ProtoPipe
 * Method:    doFinalize
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_mil_navy_nrl_protolib_ProtoPipe_doFinalize
  (JNIEnv* env, jobject obj)
{
    jfieldID fid = env->GetFieldID(env->GetObjectClass(obj), "handle", "J");
    ProtoPipe* thePipe = (ProtoPipe*)env->GetLongField(obj, fid);
    if (NULL != thePipe)
    {
        if (thePipe->IsOpen()) thePipe->Close();
        delete thePipe;
        env->SetLongField(obj, fid, (jlong)0);
    }
}

#ifdef __cplusplus
}
#endif