@@ -58,7 +58,12 @@ internal inline fun <R> withSortedHandleLocks(a: NativeHandle, b: NativeHandle,
5858}
5959
6060/* * Allocation-free three-handle lock: 3-compare sorting network, then nest. */
61- internal inline fun <R > withSortedHandleLocks (a : NativeHandle , b : NativeHandle , c : NativeHandle , body : () -> R ): R {
61+ internal inline fun <R > withSortedHandleLocks (
62+ a : NativeHandle ,
63+ b : NativeHandle ,
64+ c : NativeHandle ,
65+ body : () -> R ,
66+ ): R {
6267 var x = a
6368 var y = b
6469 var z = c
@@ -154,29 +159,125 @@ internal object JNINative {
154159 external fun zKeyexprAutocanonize (s : String , errorSink : Any ): Long
155160 external fun zKeyexprClone (ke : Long , errorSink : Any ): Long
156161 external fun zKeyexprConcat (aSel : Int , a0 : String? , a1 : Long , b : String , errorSink : Any ): Long
157- external fun zKeyexprIncludes (aSel : Int , a0 : String? , a1 : Long , bSel : Int , b0 : String? , b1 : Long , errorSink : Any ): Boolean
158- external fun zKeyexprIntersects (aSel : Int , a0 : String? , a1 : Long , bSel : Int , b0 : String? , b1 : Long , errorSink : Any ): Boolean
162+ external fun zKeyexprIncludes (
163+ aSel : Int ,
164+ a0 : String? ,
165+ a1 : Long ,
166+ bSel : Int ,
167+ b0 : String? ,
168+ b1 : Long ,
169+ errorSink : Any ,
170+ ): Boolean
171+ external fun zKeyexprIntersects (
172+ aSel : Int ,
173+ a0 : String? ,
174+ a1 : Long ,
175+ bSel : Int ,
176+ b0 : String? ,
177+ b1 : Long ,
178+ errorSink : Any ,
179+ ): Boolean
159180 external fun zKeyexprJoin (aSel : Int , a0 : String? , a1 : Long , b : String , errorSink : Any ): Long
160- external fun zKeyexprRelationTo (aSel : Int , a0 : String? , a1 : Long , bSel : Int , b0 : String? , b1 : Long , errorSink : Any ): Int
181+ external fun zKeyexprRelationTo (
182+ aSel : Int ,
183+ a0 : String? ,
184+ a1 : Long ,
185+ bSel : Int ,
186+ b0 : String? ,
187+ b1 : Long ,
188+ errorSink : Any ,
189+ ): Int
161190 external fun zKeyexprToString (ke : Long , errorSink : Any ): String
162191 external fun zKeyexprTryFrom (s : String , errorSink : Any ): Long
163- external fun zLivelinessDeclareSubscriber (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , history : Boolean , callback : Any , onClose : Any , errorSink : Any ): Long
164- external fun zLivelinessDeclareToken (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , errorSink : Any ): Long
165- external fun zLivelinessGet (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , timeoutMs : Long , callback : Any , onClose : Any , errorSink : Any )
192+ external fun zLivelinessDeclareSubscriber (
193+ session : Long ,
194+ keyExprSel : Int ,
195+ keyExpr0 : String? ,
196+ keyExpr1 : Long ,
197+ history : Boolean ,
198+ callback : Any ,
199+ onClose : Any ,
200+ errorSink : Any ,
201+ ): Long
202+ external fun zLivelinessDeclareToken (
203+ session : Long ,
204+ keyExprSel : Int ,
205+ keyExpr0 : String? ,
206+ keyExpr1 : Long ,
207+ errorSink : Any ,
208+ ): Long
209+ external fun zLivelinessGet (
210+ session : Long ,
211+ keyExprSel : Int ,
212+ keyExpr0 : String? ,
213+ keyExpr1 : Long ,
214+ timeoutMs : Long ,
215+ callback : Any ,
216+ onClose : Any ,
217+ errorSink : Any ,
218+ )
166219 external fun zOpen (config : Long , errorSink : Any ): Long
167220 external fun zPublisherDelete (publisher : Long , attachment : ByteArray? , errorSink : Any )
168- external fun zPublisherPut (publisher : Long , payload : ByteArray , encoding : String? , attachment : ByteArray? , errorSink : Any )
169- external fun zQuerierGet (querier : Long , parameters : String? , payload : ByteArray? , encoding : String? , attachment : ByteArray? , callback : Any , onClose : Any , errorSink : Any )
221+ external fun zPublisherPut (
222+ publisher : Long ,
223+ payload : ByteArray ,
224+ encoding : String? ,
225+ attachment : ByteArray? ,
226+ errorSink : Any ,
227+ )
228+ external fun zQuerierGet (
229+ querier : Long ,
230+ parameters : String? ,
231+ payload : ByteArray? ,
232+ encoding : String? ,
233+ attachment : ByteArray? ,
234+ callback : Any ,
235+ onClose : Any ,
236+ errorSink : Any ,
237+ )
170238 external fun zQueryAcceptsReplies (q : Long , errorSink : Any ): Int
171239 external fun zQueryAttachment (q : Long , errorSink : Any ): Long
172240 external fun zQueryEncoding (q : Long , errorSink : Any ): Long
173241 external fun zQueryKeyexpr (q : Long , errorSink : Any ): Long
174242 external fun zQueryParameters (q : Long , errorSink : Any ): String
175243 external fun zQueryPayload (q : Long , errorSink : Any ): Long
176- external fun zQueryReplyDelete (query : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , timestampNtp64 : Long? , attachment : ByteArray? , express : Boolean? , errorSink : Any )
177- external fun zQueryReplyError (query : Long , payload : ByteArray , encoding : String? , errorSink : Any )
178- external fun zQueryReplySample (query : Long , sampleKeyExprSel : Int , sampleKeyExpr0 : String? , sampleKeyExpr1 : Long , samplePayload : ByteArray , sampleEncoding : String , errorSink : Any )
179- external fun zQueryReplySuccess (query : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , payload : ByteArray , encoding : String? , timestampNtp64 : Long? , attachment : ByteArray? , express : Boolean? , errorSink : Any )
244+ external fun zQueryReplyDelete (
245+ query : Long ,
246+ keyExprSel : Int ,
247+ keyExpr0 : String? ,
248+ keyExpr1 : Long ,
249+ timestampNtp64 : Long? ,
250+ attachment : ByteArray? ,
251+ express : Boolean? ,
252+ errorSink : Any ,
253+ )
254+ external fun zQueryReplyError (
255+ query : Long ,
256+ payload : ByteArray ,
257+ encoding : String? ,
258+ errorSink : Any ,
259+ )
260+ external fun zQueryReplySample (
261+ query : Long ,
262+ sampleKeyExprSel : Int ,
263+ sampleKeyExpr0 : String? ,
264+ sampleKeyExpr1 : Long ,
265+ samplePayload : ByteArray ,
266+ sampleEncoding : String ,
267+ errorSink : Any ,
268+ )
269+ external fun zQueryReplySuccess (
270+ query : Long ,
271+ keyExprSel : Int ,
272+ keyExpr0 : String? ,
273+ keyExpr1 : Long ,
274+ payload : ByteArray ,
275+ encoding : String? ,
276+ timestampNtp64 : Long? ,
277+ attachment : ByteArray? ,
278+ express : Boolean? ,
279+ errorSink : Any ,
280+ )
180281 external fun zReplyErrorEncoding (r : Long , errorSink : Any ): Long
181282 external fun zReplyErrorPayload (r : Long , errorSink : Any ): Long
182283 external fun zReplyIsOk (r : Long , errorSink : Any ): Boolean
@@ -192,16 +293,105 @@ internal object JNINative {
192293 external fun zSamplePayload (s : Long , errorSink : Any ): Long
193294 external fun zSamplePriority (s : Long , errorSink : Any ): Int
194295 external fun zSampleTimestamp (s : Long , errorSink : Any ): Long
195- external fun zScout (whatami : Int , config : Long , callback : Any , onClose : Any , errorSink : Any ): Long
296+ external fun zScout (
297+ whatami : Int ,
298+ config : Long ,
299+ callback : Any ,
300+ onClose : Any ,
301+ errorSink : Any ,
302+ ): Long
196303 external fun zSessionDeclareKeyexpr (session : Long , keyExpr : String , errorSink : Any ): Long
197- external fun zSessionDeclarePublisher (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , congestionControl : Int? , priority : Int? , express : Boolean? , reliability : Int? , errorSink : Any ): Long
198- external fun zSessionDeclareQuerier (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , target : Int? , consolidation : Int? , congestionControl : Int? , priority : Int? , express : Boolean? , timeoutMs : Long? , acceptReplies : Int? , errorSink : Any ): Long
199- external fun zSessionDeclareQueryable (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , complete : Boolean? , callback : Any , onClose : Any , errorSink : Any ): Long
200- external fun zSessionDeclareSubscriber (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , callback : Any , onClose : Any , errorSink : Any ): Long
201- external fun zSessionDelete (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , congestionControl : Int? , priority : Int? , express : Boolean? , attachment : ByteArray? , reliability : Int? , errorSink : Any )
202- external fun zSessionGet (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , parameters : String? , timeoutMs : Long? , target : Int? , consolidation : Int? , acceptReplies : Int? , congestionControl : Int? , priority : Int? , express : Boolean? , payload : ByteArray? , encoding : String? , attachment : ByteArray? , callback : Any , onClose : Any , errorSink : Any )
304+ external fun zSessionDeclarePublisher (
305+ session : Long ,
306+ keyExprSel : Int ,
307+ keyExpr0 : String? ,
308+ keyExpr1 : Long ,
309+ congestionControl : Int? ,
310+ priority : Int? ,
311+ express : Boolean? ,
312+ reliability : Int? ,
313+ errorSink : Any ,
314+ ): Long
315+ external fun zSessionDeclareQuerier (
316+ session : Long ,
317+ keyExprSel : Int ,
318+ keyExpr0 : String? ,
319+ keyExpr1 : Long ,
320+ target : Int? ,
321+ consolidation : Int? ,
322+ congestionControl : Int? ,
323+ priority : Int? ,
324+ express : Boolean? ,
325+ timeoutMs : Long? ,
326+ acceptReplies : Int? ,
327+ errorSink : Any ,
328+ ): Long
329+ external fun zSessionDeclareQueryable (
330+ session : Long ,
331+ keyExprSel : Int ,
332+ keyExpr0 : String? ,
333+ keyExpr1 : Long ,
334+ complete : Boolean? ,
335+ callback : Any ,
336+ onClose : Any ,
337+ errorSink : Any ,
338+ ): Long
339+ external fun zSessionDeclareSubscriber (
340+ session : Long ,
341+ keyExprSel : Int ,
342+ keyExpr0 : String? ,
343+ keyExpr1 : Long ,
344+ callback : Any ,
345+ onClose : Any ,
346+ errorSink : Any ,
347+ ): Long
348+ external fun zSessionDelete (
349+ session : Long ,
350+ keyExprSel : Int ,
351+ keyExpr0 : String? ,
352+ keyExpr1 : Long ,
353+ congestionControl : Int? ,
354+ priority : Int? ,
355+ express : Boolean? ,
356+ attachment : ByteArray? ,
357+ reliability : Int? ,
358+ errorSink : Any ,
359+ )
360+ external fun zSessionGet (
361+ session : Long ,
362+ keyExprSel : Int ,
363+ keyExpr0 : String? ,
364+ keyExpr1 : Long ,
365+ parameters : String? ,
366+ timeoutMs : Long? ,
367+ target : Int? ,
368+ consolidation : Int? ,
369+ acceptReplies : Int? ,
370+ congestionControl : Int? ,
371+ priority : Int? ,
372+ express : Boolean? ,
373+ payload : ByteArray? ,
374+ encoding : String? ,
375+ attachment : ByteArray? ,
376+ callback : Any ,
377+ onClose : Any ,
378+ errorSink : Any ,
379+ )
203380 external fun zSessionPeersZid (session : Long , errorSink : Any ): List <ByteArray >
204- external fun zSessionPut (session : Long , keyExprSel : Int , keyExpr0 : String? , keyExpr1 : Long , payload : ByteArray , encoding : String? , congestionControl : Int? , priority : Int? , express : Boolean? , attachment : ByteArray? , reliability : Int? , errorSink : Any )
381+ external fun zSessionPut (
382+ session : Long ,
383+ keyExprSel : Int ,
384+ keyExpr0 : String? ,
385+ keyExpr1 : Long ,
386+ payload : ByteArray ,
387+ encoding : String? ,
388+ congestionControl : Int? ,
389+ priority : Int? ,
390+ express : Boolean? ,
391+ attachment : ByteArray? ,
392+ reliability : Int? ,
393+ errorSink : Any ,
394+ )
205395 external fun zSessionRoutersZid (session : Long , errorSink : Any ): List <ByteArray >
206396 external fun zSessionUndeclareKeyexpr (session : Long , keyExpr : Long , errorSink : Any )
207397 external fun zSessionZid (session : Long , errorSink : Any ): ByteArray
0 commit comments