arzmq-sys 0.5.1

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

#include "normJni.h"
#include "normStreamJni.h"

JNIEXPORT void JNICALL PKGNAME(NormStream_close)
    (JNIEnv *env, jobject obj, jboolean graceful) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  NormStreamClose(objectHandle, graceful);
}

JNIEXPORT jint JNICALL PKGNAME(NormStream_write)
    (JNIEnv *env, jobject obj, jbyteArray buffer,
    jint offset, jint length) {
  NormObjectHandle objectHandle;
  jbyte *bytes;
  unsigned int n;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);
  bytes = env->GetByteArrayElements(buffer, 0);

  n = NormStreamWrite(objectHandle, (const char*)(bytes + offset), length);

  env->ReleaseByteArrayElements(buffer, bytes, JNI_ABORT);

  return (jint)n;
}

JNIEXPORT void JNICALL PKGNAME(NormStream_flush)
    (JNIEnv *env, jobject obj, jboolean eom, jobject flushMode) {
  NormObjectHandle objectHandle;
  NormFlushMode mode;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);
  mode = (NormFlushMode)env->CallIntMethod(flushMode,
    mid_NormFlushMode_ordinal);

  NormStreamFlush(objectHandle, eom, mode);
}

JNIEXPORT void JNICALL PKGNAME(NormStream_setAutoFlush)
    (JNIEnv *env, jobject obj, jobject flushMode) {
  NormObjectHandle objectHandle;
  NormFlushMode mode;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);
  mode = (NormFlushMode)env->CallIntMethod(flushMode,
    mid_NormFlushMode_ordinal);

  NormStreamSetAutoFlush(objectHandle, mode);
}

JNIEXPORT void JNICALL PKGNAME(NormStream_setPushEnable)
    (JNIEnv *env, jobject obj, jboolean pushEnable) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  NormStreamSetPushEnable(objectHandle, pushEnable);
}

JNIEXPORT jboolean JNICALL PKGNAME(NormStream_hasVacancy)
    (JNIEnv *env, jobject obj) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  return NormStreamHasVacancy(objectHandle);
}

JNIEXPORT void JNICALL PKGNAME(NormStream_markEom)
    (JNIEnv *env, jobject obj) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  NormStreamMarkEom(objectHandle);
}

JNIEXPORT jint JNICALL PKGNAME(NormStream_read)
    (JNIEnv *env, jobject obj, jbyteArray buffer, jint offset, jint length) {
  NormObjectHandle objectHandle;
  jbyte *bytes;
  unsigned int n = length;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);
  bytes = env->GetByteArrayElements(buffer, 0);

  if (!NormStreamRead(objectHandle, (char*)(bytes + offset), &n)) {
    return -1;
  }

  env->ReleaseByteArrayElements(buffer, bytes, 0);

  return (jint)n;
}

JNIEXPORT jboolean JNICALL PKGNAME(NormStream_seekMsgStart)
    (JNIEnv *env, jobject obj) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  return NormStreamSeekMsgStart(objectHandle);
}

JNIEXPORT jlong JNICALL PKGNAME(NormStream_getReadOffset)
    (JNIEnv *env, jobject obj) {
  NormObjectHandle objectHandle;

  objectHandle = (NormObjectHandle)env->GetLongField(obj,
    fid_NormObject_handle);

  return NormStreamGetReadOffset(objectHandle);
}