Project

General

Profile

dead-subscription-subscriber.log

Nitesh Mor, 10/15/2016 03:56 PM

Download (43.3 KB)

 
1
mor@io:~/works/gdp/gdp/apps$ ./gdp-reader -s -t -D *=50 log.00
2
_gdp_lib_init(NULL)
3
    @(#)libgdp 0.7.2 (2016-10-15 14:47) 81af2bc3ae6360700dfaba76f6683aa6f0ebfdde
4
My GDP routing name = hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
5
gdp_lib_init: OK
6
_gdp_chan_open(172.30.0.1:8007)
7
Trying 172.30.0.1:8007
8
_gdp_chan_open: trying host 172.30.0.1 port 8007
9
successful connect
10
_gdp_chan_open: talking to router at 172.30.0.1:8007
11
_gdp_advertise(1):
12
gdp_event_loop: starting up I/O base loop
13
Inserted events:
14
  0xe67930 [fd 6] Read Persist
15
  0xe67dd0 [fd 7] Read Persist
16
  0xe67e58 [fd 7] Write Persist
17
gdp_datum_new => 0xe68460
18
_gdp_pdu_new => 0xe683e0
19
_gdp_req_new(gcl=(nil), cmd=CMD_ADVERTISE) => 0xe682e0 (rid=0)
20
_gdp_req_send: req@0xe682e0:
21
    nextrec=0, numrecs=0, chan=0xe67d20
22
    postproc=(nil), sub_cb=(nil), udata=(nil)
23
    state=ACTIVE, stat=OK
24
    act_ts=1970-01-01T00:00:00.000000000Z
25
    flags=0x100<ON_CHAN_LIST>
26
    GCL@(nil): NULL
27
    PDU@0xe683e0: 
28
    v=3, ttl=15, rsvd1=0, cmd=1=CMD_ADVERTISE
29
    dst=_wD_AP8A_wD_AP8A_wD_AP8A_wD_AP8A_wD_AP8A_wA
30
    src=(none)
31
    rid=0, olen=0, chan=(nil), seqno=0
32
    flags=0
33
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
34
        ts=(none)
35
    sigmdalg=0x0, siglen=0, sig=(nil)
36
    total header=80
37
_gdp_pdu_out, fd = 7, basemd = (nil):
38
    PDU@0xe683e0: 
39
    v=3, ttl=15, rsvd1=0, cmd=1=CMD_ADVERTISE
40
    dst=_wD_AP8A_wD_AP8A_wD_AP8A_wD_AP8A_wD_AP8A_wA
41
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
42
    rid=0, olen=0, chan=(nil), seqno=0
43
    flags=0
44
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
45
        ts=(none)
46
    sigmdalg=0x0, siglen=0, sig=(nil)
47
    total header=80
48
_gdp_pdu_out: sending PDU:
49
00000000 03 0f 00 01 ff 00 ff 00 ff 00 ff 00 ff 00 ff 00
50
00000010 ff 00 ff 00 ff 00 ff 00 ff 00 ff 00 ff 00 ff 00
51
00000020 ff 00 ff 00 87 23 a8 99 b3 81 78 7c 56 0a 92 03
52
00000030 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
53
00000040 a2 4f dc 02 00 00 00 00 00 00 00 00 00 00 00 00
54
_gdp_req_free(0xe682e0)  state=1, gcl=(nil)
55
_gdp_pdu_free(0xe683e0)
56
gdp_datum_free(0xe68460)
57
  ... draining 0 bytes
58
_gdp_advertise => OK
59
gdp_init: OK
60
Reading GCL jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
61

    
62
>>> gdp_gcl_open(jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8)
63
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 => NULL
64
_gdp_gcl_newhandle => 0xe685f0 (jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8)
65
gdp_datum_new => 0xe68460
66
_gdp_pdu_new => 0xe683e0
67
_gdp_req_new(gcl=0xe685f0, cmd=CMD_OPEN_RO) => 0xe682e0 (rid=1)
68

    
69
>>> _gdp_invoke(req=0xe682e0 rid=1): CMD_OPEN_RO (68), gcl@0xe685f0
70
    datum @ 0xe68460: recno -1, len 0, no timestamp
71
_gdp_invoke: sending 68, retries=2
72
_gdp_req_send: req@0xe682e0:
73
    nextrec=0, numrecs=0, chan=0xe67d20
74
    postproc=(nil), sub_cb=(nil), udata=(nil)
75
    state=ACTIVE, stat=OK
76
    act_ts=1970-01-01T00:00:00.000000000Z
77
    flags=0x540<ALLOC_RID,ON_CHAN_LIST,ROUTEFAIL>
78
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
79
    iomode = 1, refcnt = 1, reqs = (nil), nrecs = 0
80
    flags = 0x8<INUSE>
81
    PDU@0xe683e0: 
82
    v=3, ttl=15, rsvd1=0, cmd=68=CMD_OPEN_RO
83
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
84
    src=(none)
85
    rid=1, olen=0, chan=(nil), seqno=0
86
    flags=0
87
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
88
        ts=(none)
89
    sigmdalg=0x0, siglen=0, sig=(nil)
90
    total header=80
91
_gdp_gcl_cache_add: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 => 0xe685f0
92
_gdp_pdu_out, fd = 7, basemd = (nil):
93
    PDU@0xe683e0: 
94
    v=3, ttl=15, rsvd1=0, cmd=68=CMD_OPEN_RO
95
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
96
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
97
    rid=1, olen=0, chan=(nil), seqno=0
98
    flags=0
99
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
100
        ts=(none)
101
    sigmdalg=0x0, siglen=0, sig=(nil)
102
    total header=80
103
_gdp_pdu_out: sending PDU:
104
00000000 03 0f 00 44 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
105
00000010 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
106
00000020 50 d1 25 8f 87 23 a8 99 b3 81 78 7c 56 0a 92 03
107
00000030 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
108
00000040 a2 4f dc 02 00 00 00 01 00 00 00 00 00 00 00 00
109
_gdp_invoke: waiting on 0xe682e0
110
gdp_read_cb: fd 7, 156 bytes
111
gdp_datum_new => 0x7f0c08000e30
112
_gdp_pdu_new => 0x7f0c08000db0
113

    
114
    >>>>>  _gdp_pdu_in  >>>>>
115
_gdp_pdu_in: read PDU header:
116
00000000 03 0f 00 80 87 23 a8 99 b3 81 78 7c 56 0a 92 03
117
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
118
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
119
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
120
00000040 50 d1 25 8f 00 00 00 01 00 00 02 02 00 00 00 44
121
00000050 00 00 00 00 00 00 00 00
122
_gdp_pdu_in: reading 68 data bytes (68 available)
123
00000058                         00 03 00 43 54 4d 00 00
124
                                 ⌧  ⌧  ⌧  C  T  M  ⌧  ⌧ 
125
00000060 00 1e 00 43 49 44 00 00 00 06 00 58 49 44 00 00
126
         ⌧  ⌧  ⌧  C  I  D  ⌧  ⌧  ⌧  ⌧  ⌧  X  I  D  ⌧  ⌧ 
127
00000070 00 06 32 30 31 36 2d 31 30 2d 31 35 54 32 32 3a
128
         ⌧  ⌧  2  0  1  6  -  1  0  -  1  5  T  2  2  : 
129
00000080 34 30 3a 34 34 2e 38 37 33 34 31 33 30 30 30 5a
130
         4  0  :  4  4  .  8  7  3  4  1  3  0  0  0  Z 
131
00000090 6d 6f 72 40 69 6f 6c 6f 67 2e 30 30
132
         m  o  r  @  i  o  l  o  g  .  0  0 
133
_gdp_pdu_in(ACK_SUCCESS) => OK
134
PDU@0x7f0c08000db0: 
135
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
136
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
137
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
138
    rid=1, olen=8, chan=0xe67d20, seqno=0
139
    flags=0x2<HAS_RECNO>
140
    datum=0x7f0c08000e30, recno=0, dbuf=0x7f0c08000ea0, dlen=68
141
        ts=(none)
142
    sigmdalg=0x0, siglen=0, sig=(nil)
143
    total header=96
144

    
145
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
146
_gdp_gcl_touch(0xe685f0)
147
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
148
    0xe685f0 refcnt 2
149
gdp_pdu_proc_resp(0x7f0c08000db0 ACK_SUCCESS) gcl 0xe685f0
150
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 1
151
_gdp_req_find(gcl=0xe685f0, rid=1)
152
_gdp_req_find(gcl=0xe685f0, rid=1) => 0xe682e0, state WAITING
153
gdp_pdu_proc_resp: req@0xe682e0:
154
    nextrec=0, numrecs=0, chan=0xe67d20
155
    postproc=(nil), sub_cb=(nil), udata=(nil)
156
    state=WAITING, stat=OK
157
    act_ts=1970-01-01T00:00:00.000000000Z
158
    flags=0x540<ALLOC_RID,ON_CHAN_LIST,ROUTEFAIL>
159
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
160
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
161
    flags = 0xa<INCACHE,INUSE>
162
    PDU@0xe683e0: 
163
    v=3, ttl=15, rsvd1=0, cmd=68=CMD_OPEN_RO
164
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
165
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
166
    rid=1, olen=0, chan=(nil), seqno=0
167
    flags=0
168
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
169
        ts=(none)
170
    sigmdalg=0x0, siglen=0, sig=(nil)
171
    total header=80
172
    rPDU@0x7f0c08000db0: 
173
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
174
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
175
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
176
    rid=1, olen=8, chan=0xe67d20, seqno=0
177
    flags=0x2<HAS_RECNO>
178
    datum=0x7f0c08000e30, recno=0, dbuf=0x7f0c08000ea0, dlen=68
179
        ts=(none)
180
    sigmdalg=0x0, siglen=0, sig=(nil)
181
    total header=96
182
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 2], req@0xe682e0:
183
    nextrec=0, numrecs=0, chan=0xe67d20
184
    postproc=(nil), sub_cb=(nil), udata=(nil)
185
    state=WAITING, stat=OK
186
    act_ts=2016-10-15T22:41:13.359625000Z
187
    flags=0x540<ALLOC_RID,ON_CHAN_LIST,ROUTEFAIL>
188
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
189
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
190
    flags = 0xa<INCACHE,INUSE>
191
    PDU@0xe683e0: 
192
    v=3, ttl=15, rsvd1=0, cmd=68=CMD_OPEN_RO
193
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
194
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
195
    rid=1, olen=0, chan=(nil), seqno=0
196
    flags=0
197
    datum=0xe68460, recno=(none), dbuf=0xe684d0, dlen=0
198
        ts=(none)
199
    sigmdalg=0x0, siglen=0, sig=(nil)
200
    total header=80
201
    rPDU@0x7f0c08000db0: 
202
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
203
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
204
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
205
    rid=1, olen=8, chan=0xe67d20, seqno=0
206
    flags=0x2<HAS_RECNO>
207
    datum=0x7f0c08000e30, recno=0, dbuf=0x7f0c08000ea0, dlen=68
208
        ts=(none)
209
    sigmdalg=0x0, siglen=0, sig=(nil)
210
    total header=96
211
ack_success: received ACK_SUCCESS for CMD_OPEN_RO
212
ack_success: reusing old datum for req 0xe682e0
213
   datum @ 0xe68460: recno -1, len 0, no timestamp
214
gdp_datum_free(0x7f0c08000e30)
215
_gdp_pdu_free(0xe683e0)
216
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 2]
217
    OK [67896520 = 0x40c04c8]
218
acknak_from_estat: OK [67896520 = 0x40c04c8] ->
219
    ACK_SUCCESS
220
gdp_pdu_proc_resp(ACK_SUCCESS for CMD_OPEN_RO): OK [67896520 = 0x40c04c8]
221
gdp_pdu_proc_resp: signaling req@0xe682e0:
222
    nextrec=0, numrecs=0, chan=0xe67d20
223
    postproc=(nil), sub_cb=(nil), udata=(nil)
224
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
225
    act_ts=2016-10-15T22:41:13.360053000Z
226
    flags=0x542<DONE,ALLOC_RID,ON_CHAN_LIST,ROUTEFAIL>
227
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
228
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
229
    flags = 0xa<INCACHE,INUSE>
230
    PDU@0x7f0c08000db0: 
231
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
232
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
233
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
234
    rid=1, olen=8, chan=0xe67d20, seqno=0
235
    flags=0x2<HAS_RECNO>
236
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=68
237
        ts=(none)
238
    sigmdalg=0x0, siglen=0, sig=(nil)
239
    total header=96
240
gdp_pdu_proc_resp <<< done
241
_gdp_event_trigger_pending(0xe683c8): empty
242
<<< _gdp_invoke(0xe682e0 rid=1) CMD_OPEN_RO: OK [67896520 = 0x40c04c8]
243
  req@0xe682e0:
244
    nextrec=0, numrecs=0, chan=0xe67d20
245
    postproc=(nil), sub_cb=(nil), udata=(nil)
246
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
247
    act_ts=2016-10-15T22:41:13.360053000Z
248
    flags=0x543<ASYNCIO,DONE,ALLOC_RID,ON_CHAN_LIST,ROUTEFAIL>
249
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
250
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
251
    flags = 0xa<INCACHE,INUSE>
252
    PDU@0x7f0c08000db0: 
253
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
254
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
255
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
256
    rid=1, olen=8, chan=0xe67d20, seqno=0
257
    flags=0x2<HAS_RECNO>
258
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=68
259
        ts=(none)
260
    sigmdalg=0x0, siglen=0, sig=(nil)
261
    total header=96
262

    
263
_gdp_gclmd_deserialize:
264
  GCLMD@0xe686e0: nalloc = 3, nused = 3, databuf = 0xe68760
265
    flags = 0x1<READONLY>
266
    mds = 0xe68710
267
    id = 0043544d, len = 30, flags = 0
268
00000000 32 30 31 36 2d 31 30 2d 31 35 54 32 32 3a 34 30
269
         2  0  1  6  -  1  0  -  1  5  T  2  2  :  4  0 
270
00000010 3a 34 34 2e 38 37 33 34 31 33 30 30 30 5a
271
         :  4  4  .  8  7  3  4  1  3  0  0  0  Z 
272
    id = 00434944, len = 6, flags = 0
273
00000000 6d 6f 72 40 69 6f
274
         m  o  r  @  i  o 
275
    id = 00584944, len = 6, flags = 0
276
00000000 6c 6f 67 2e 30 30
277
         l  o  g  .  0  0 
278
_gdp_req_free(0xe682e0)  state=1, gcl=(nil)
279
_gdp_pdu_free(0x7f0c08000db0)
280
gdp_datum_free(0xe68460)
281
  ... draining 0 bytes
282
Opened GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
283
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
284
    flags = 0xa<INCACHE,INUSE>
285
    freefunc = (nil), gclmd = 0xe686e0, digest = (nil)
286
    utime = 2016-10-15 22:41:13, x = (nil)
287
<<< gdp_gcl_open(jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8): OK
288

    
289
>>> gdp_gcl_subscribe
290
gdp_datum_new => 0xe68460
291
_gdp_pdu_new => 0x7f0c08000db0
292
_gdp_req_new(gcl=0xe685f0, cmd=CMD_SUBSCRIBE) => 0xe682e0 (rid=2)
293

    
294
>>> _gdp_invoke(req=0xe682e0 rid=2): CMD_SUBSCRIBE (72), gcl@0xe685f0
295
    datum @ 0xe68460: recno 0, len 4, no timestamp
296
00000000 00 00 00 00
297
         ⌧  ⌧  ⌧  ⌧ 
298
_gdp_invoke: sending 72, retries=2
299
_gdp_req_send: req@0xe682e0:
300
    nextrec=0, numrecs=0, chan=0xe67d20
301
    postproc=(nil), sub_cb=(nil), udata=(nil)
302
    state=ACTIVE, stat=OK
303
    act_ts=2016-10-15T22:41:13.360053000Z
304
    flags=0x154<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_CHAN_LIST>
305
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
306
    iomode = 1, refcnt = 2, reqs = (nil), nrecs = 0
307
    flags = 0xa<INCACHE,INUSE>
308
    PDU@0x7f0c08000db0: 
309
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
310
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
311
    src=(none)
312
    rid=2, olen=0, chan=(nil), seqno=0
313
    flags=0
314
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=4
315
        ts=(none)
316
    sigmdalg=0x0, siglen=0, sig=(nil)
317
    total header=88
318
_gdp_gcl_cache_add(0xe685f0): already cached
319
_gdp_pdu_out, fd = 7, basemd = (nil):
320
    PDU@0x7f0c08000db0: 
321
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
322
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
323
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
324
    rid=2, olen=0, chan=(nil), seqno=0
325
    flags=0
326
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=4
327
        ts=(none)
328
    sigmdalg=0x0, siglen=0, sig=(nil)
329
    total header=88
330
_gdp_pdu_out: sending PDU:
331
00000000 03 0f 00 48 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
332
00000010 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
333
00000020 50 d1 25 8f 87 23 a8 99 b3 81 78 7c 56 0a 92 03
334
00000030 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
335
00000040 a2 4f dc 02 00 00 00 02 00 00 02 02 00 00 00 04
336
00000050 00 00 00 00 00 00 00 00
337
00000058                         00 00 00 00
338
                                 ⌧  ⌧  ⌧  ⌧ 
339
_gdp_invoke: waiting on 0xe682e0
340
gdp_read_cb: fd 7, 88 bytes
341
gdp_datum_new => 0x7f0c08000e30
342
_gdp_pdu_new => 0xe683e0
343

    
344
    >>>>>  _gdp_pdu_in  >>>>>
345
_gdp_pdu_in: read PDU header:
346
00000000 03 0f 00 80 87 23 a8 99 b3 81 78 7c 56 0a 92 03
347
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
348
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
349
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
350
00000040 50 d1 25 8f 00 00 00 02 00 00 02 02 00 00 00 00
351
00000050 00 00 00 00 00 00 00 01
352
_gdp_pdu_in: reading 0 data bytes (0 available)
353
_gdp_pdu_in(ACK_SUCCESS) => OK
354
PDU@0xe683e0: 
355
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
356
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
357
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
358
    rid=2, olen=8, chan=0xe67d20, seqno=0
359
    flags=0x2<HAS_RECNO>
360
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ea0, dlen=0
361
        ts=(none)
362
    sigmdalg=0x0, siglen=0, sig=(nil)
363
    total header=96
364

    
365
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
366
_gdp_gcl_touch(0xe685f0)
367
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
368
    0xe685f0 refcnt 3
369
gdp_pdu_proc_resp(0xe683e0 ACK_SUCCESS) gcl 0xe685f0
370
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 2
371
_gdp_req_find(gcl=0xe685f0, rid=2)
372
_gdp_req_find(gcl=0xe685f0, rid=2) => 0xe682e0, state WAITING
373
gdp_pdu_proc_resp: req@0xe682e0:
374
    nextrec=0, numrecs=0, chan=0xe67d20
375
    postproc=(nil), sub_cb=(nil), udata=(nil)
376
    state=WAITING, stat=OK
377
    act_ts=2016-10-15T22:41:13.360053000Z
378
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
379
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
380
    iomode = 1, refcnt = 3, reqs = 0xe682e0, nrecs = 0
381
    flags = 0xa<INCACHE,INUSE>
382
    PDU@0x7f0c08000db0: 
383
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
384
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
385
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
386
    rid=2, olen=0, chan=(nil), seqno=0
387
    flags=0
388
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=4
389
        ts=(none)
390
    sigmdalg=0x0, siglen=0, sig=(nil)
391
    total header=88
392
    rPDU@0xe683e0: 
393
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
394
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
395
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
396
    rid=2, olen=8, chan=0xe67d20, seqno=0
397
    flags=0x2<HAS_RECNO>
398
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ea0, dlen=0
399
        ts=(none)
400
    sigmdalg=0x0, siglen=0, sig=(nil)
401
    total header=96
402
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 3], req@0xe682e0:
403
    nextrec=0, numrecs=0, chan=0xe67d20
404
    postproc=(nil), sub_cb=(nil), udata=(nil)
405
    state=WAITING, stat=OK
406
    act_ts=2016-10-15T22:41:13.363788000Z
407
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
408
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
409
    iomode = 1, refcnt = 3, reqs = 0xe682e0, nrecs = 0
410
    flags = 0xa<INCACHE,INUSE>
411
    PDU@0x7f0c08000db0: 
412
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
413
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
414
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
415
    rid=2, olen=0, chan=(nil), seqno=0
416
    flags=0
417
    datum=0xe68460, recno=0, dbuf=0xe684d0, dlen=4
418
        ts=(none)
419
    sigmdalg=0x0, siglen=0, sig=(nil)
420
    total header=88
421
    rPDU@0xe683e0: 
422
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
423
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
424
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
425
    rid=2, olen=8, chan=0xe67d20, seqno=0
426
    flags=0x2<HAS_RECNO>
427
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ea0, dlen=0
428
        ts=(none)
429
    sigmdalg=0x0, siglen=0, sig=(nil)
430
    total header=96
431
ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE
432
ack_success: reusing old datum for req 0xe682e0
433
   datum @ 0xe68460: recno 0, len 4, no timestamp
434
00000000 00 00 00 00
435
         ⌧  ⌧  ⌧  ⌧ 
436
gdp_datum_free(0x7f0c08000e30)
437
_gdp_pdu_free(0x7f0c08000db0)
438
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 3]
439
    OK [67896520 = 0x40c04c8]
440
acknak_from_estat: OK [67896520 = 0x40c04c8] ->
441
    ACK_SUCCESS
442
gdp_pdu_proc_resp(ACK_SUCCESS for CMD_SUBSCRIBE): OK [67896520 = 0x40c04c8]
443
gdp_pdu_proc_resp: signaling req@0xe682e0:
444
    nextrec=0, numrecs=0, chan=0xe67d20
445
    postproc=(nil), sub_cb=(nil), udata=(nil)
446
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
447
    act_ts=2016-10-15T22:41:13.364212000Z
448
    flags=0x1d6<DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
449
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
450
    iomode = 1, refcnt = 3, reqs = 0xe682e0, nrecs = 0
451
    flags = 0xa<INCACHE,INUSE>
452
    PDU@0xe683e0: 
453
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
454
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
455
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
456
    rid=2, olen=8, chan=0xe67d20, seqno=0
457
    flags=0x2<HAS_RECNO>
458
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
459
        ts=(none)
460
    sigmdalg=0x0, siglen=0, sig=(nil)
461
    total header=96
462
gdp_pdu_proc_resp <<< done
463
_gdp_event_trigger_pending(0xe683c8): empty
464
<<< _gdp_invoke(0xe682e0 rid=2) CMD_SUBSCRIBE: OK [67896520 = 0x40c04c8]
465
  req@0xe682e0:
466
    nextrec=0, numrecs=0, chan=0xe67d20
467
    postproc=(nil), sub_cb=(nil), udata=(nil)
468
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
469
    act_ts=2016-10-15T22:41:13.364212000Z
470
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
471
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
472
    iomode = 1, refcnt = 3, reqs = 0xe682e0, nrecs = 0
473
    flags = 0xa<INCACHE,INUSE>
474
    PDU@0xe683e0: 
475
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
476
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
477
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
478
    rid=2, olen=8, chan=0xe67d20, seqno=0
479
    flags=0x2<HAS_RECNO>
480
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
481
        ts=(none)
482
    sigmdalg=0x0, siglen=0, sig=(nil)
483
    total header=96
484

    
485
gdp_datum_free(0xe68460)
486
  ... draining 0 bytes
487
Starting subscription poker thread
488
gdp_read_cb: fd 7, 109 bytes
489
gdp_datum_new => 0xe68460
490
_gdp_pdu_new => 0x7f0c08000db0
491

    
492
    >>>>>  _gdp_pdu_in  >>>>>
493
_gdp_pdu_in: read PDU header:
494
00000000 03 0f 00 85 87 23 a8 99 b3 81 78 7c 56 0a 92 03
495
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
496
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
497
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
498
00000040 50 d1 25 8f 00 00 00 02 00 00 06 0a 00 00 00 05
499
00000050 00 00 00 00 00 00 00 01 00 00 00 00 58 02 b0 8c
500
00000060 05 ef 80 30 00 00 00 00
501
_gdp_pdu_in: reading 5 data bytes (5 available)
502
00000068                         68 65 6c 6c 6f
503
                                 h  e  l  l  o 
504
_gdp_pdu_in(ACK_DATA_CONTENT) => OK
505
PDU@0x7f0c08000db0: 
506
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
507
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
508
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
509
    rid=2, olen=24, chan=0xe67d20, seqno=0
510
    flags=0xa<HAS_RECNO,HAS_TS>
511
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=5
512
        ts=2016-10-15T22:41:16.099582000Z
513
    sigmdalg=0x0, siglen=0, sig=(nil)
514
    total header=128
515

    
516
*** Processing ack/nak 133=ACK_DATA_CONTENT from socket 7
517
_gdp_gcl_touch(0xe685f0)
518
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
519
    0xe685f0 refcnt 4
520
gdp_pdu_proc_resp(0x7f0c08000db0 ACK_DATA_CONTENT) gcl 0xe685f0
521
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 2
522
_gdp_req_find(gcl=0xe685f0, rid=2)
523
_gdp_req_find(gcl=0xe685f0, rid=2) => 0xe682e0, state IDLE
524
gdp_pdu_proc_resp: req@0xe682e0:
525
    nextrec=0, numrecs=0, chan=0xe67d20
526
    postproc=(nil), sub_cb=(nil), udata=(nil)
527
    state=IDLE, stat=OK [67896520 = 0x40c04c8]
528
    act_ts=2016-10-15T22:41:13.364212000Z
529
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
530
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
531
    iomode = 1, refcnt = 4, reqs = 0xe682e0, nrecs = 0
532
    flags = 0xa<INCACHE,INUSE>
533
    PDU@0xe683e0: 
534
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
535
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
536
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
537
    rid=2, olen=8, chan=0xe67d20, seqno=0
538
    flags=0x2<HAS_RECNO>
539
    datum=(nil)
540
    total header=88
541
    rPDU@0x7f0c08000db0: 
542
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
543
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
544
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
545
    rid=2, olen=24, chan=0xe67d20, seqno=0
546
    flags=0xa<HAS_RECNO,HAS_TS>
547
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=5
548
        ts=2016-10-15T22:41:16.099582000Z
549
    sigmdalg=0x0, siglen=0, sig=(nil)
550
    total header=128
551
_gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 4], req@0xe682e0:
552
    nextrec=0, numrecs=0, chan=0xe67d20
553
    postproc=(nil), sub_cb=(nil), udata=(nil)
554
    state=IDLE, stat=OK [67896520 = 0x40c04c8]
555
    act_ts=2016-10-15T22:41:16.102527000Z
556
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
557
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
558
    iomode = 1, refcnt = 4, reqs = 0xe682e0, nrecs = 0
559
    flags = 0xa<INCACHE,INUSE>
560
    PDU@0xe683e0: 
561
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
562
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
563
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
564
    rid=2, olen=8, chan=0xe67d20, seqno=0
565
    flags=0x2<HAS_RECNO>
566
    datum=(nil)
567
    total header=88
568
    rPDU@0x7f0c08000db0: 
569
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
570
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
571
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
572
    rid=2, olen=24, chan=0xe67d20, seqno=0
573
    flags=0xa<HAS_RECNO,HAS_TS>
574
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=5
575
        ts=2016-10-15T22:41:16.099582000Z
576
    sigmdalg=0x0, siglen=0, sig=(nil)
577
    total header=128
578
ack_success: received ACK_DATA_CONTENT for ACK_SUCCESS
579
_gdp_pdu_free(0xe683e0)
580
_gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 4]
581
    OK [67896525 = 0x40c04cd]
582
acknak_from_estat: OK [67896525 = 0x40c04cd] ->
583
    ACK_DATA_CONTENT
584
gdp_pdu_proc_resp(ACK_DATA_CONTENT for ACK_SUCCESS): OK [67896525 = 0x40c04cd]
585
_gdp_event_new => 0x7f0c08000ea0
586
_gdp_event_trigger: adding event 0x7f0c08000ea0 (1) to active list
587
gdp_pdu_proc_resp <<< done
588
 >>> recno 1, len 5, ts 2016-10-15T22:41:16.099582000Z
589
hello
590
gdp_event_free(0x7f0c08000ea0)
591
gdp_datum_free(0xe68460)
592
  ... draining 5 bytes
593

    
594
subscr_poker_thread: poking
595

    
596
subscr_poker_thread: poking
597
gdp_read_cb: fd 7, 109 bytes
598
gdp_datum_new => 0xe68460
599
_gdp_pdu_new => 0xe683e0
600

    
601
    >>>>>  _gdp_pdu_in  >>>>>
602
_gdp_pdu_in: read PDU header:
603
00000000 03 0f 00 85 87 23 a8 99 b3 81 78 7c 56 0a 92 03
604
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
605
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
606
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
607
00000040 50 d1 25 8f 00 00 00 02 00 00 06 0a 00 00 00 05
608
00000050 00 00 00 00 00 00 00 02 00 00 00 00 58 02 b0 e1
609
00000060 2a 59 b0 a8 00 00 00 00
610
_gdp_pdu_in: reading 5 data bytes (5 available)
611
00000068                         77 6f 72 6c 64
612
                                 w  o  r  l  d 
613
_gdp_pdu_in(ACK_DATA_CONTENT) => OK
614
PDU@0xe683e0: 
615
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
616
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
617
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
618
    rid=2, olen=24, chan=0xe67d20, seqno=0
619
    flags=0xa<HAS_RECNO,HAS_TS>
620
    datum=0xe68460, recno=2, dbuf=0xe684d0, dlen=5
621
        ts=2016-10-15T22:42:41.710521000Z
622
    sigmdalg=0x0, siglen=0, sig=(nil)
623
    total header=128
624

    
625
*** Processing ack/nak 133=ACK_DATA_CONTENT from socket 7
626
_gdp_gcl_touch(0xe685f0)
627
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
628
    0xe685f0 refcnt 5
629
gdp_pdu_proc_resp(0xe683e0 ACK_DATA_CONTENT) gcl 0xe685f0
630
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 2
631
_gdp_req_find(gcl=0xe685f0, rid=2)
632
_gdp_req_find(gcl=0xe685f0, rid=2) => 0xe682e0, state IDLE
633
gdp_pdu_proc_resp: req@0xe682e0:
634
    nextrec=0, numrecs=0, chan=0xe67d20
635
    postproc=(nil), sub_cb=(nil), udata=(nil)
636
    state=IDLE, stat=OK [67896520 = 0x40c04c8]
637
    act_ts=2016-10-15T22:41:16.103243000Z
638
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
639
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
640
    iomode = 1, refcnt = 5, reqs = 0xe682e0, nrecs = 0
641
    flags = 0xa<INCACHE,INUSE>
642
    PDU@0x7f0c08000db0: 
643
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
644
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
645
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
646
    rid=2, olen=24, chan=0xe67d20, seqno=0
647
    flags=0xa<HAS_RECNO,HAS_TS>
648
    datum=(nil)
649
    total header=104
650
    rPDU@0xe683e0: 
651
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
652
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
653
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
654
    rid=2, olen=24, chan=0xe67d20, seqno=0
655
    flags=0xa<HAS_RECNO,HAS_TS>
656
    datum=0xe68460, recno=2, dbuf=0xe684d0, dlen=5
657
        ts=2016-10-15T22:42:41.710521000Z
658
    sigmdalg=0x0, siglen=0, sig=(nil)
659
    total header=128
660
_gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 5], req@0xe682e0:
661
    nextrec=0, numrecs=0, chan=0xe67d20
662
    postproc=(nil), sub_cb=(nil), udata=(nil)
663
    state=IDLE, stat=OK [67896520 = 0x40c04c8]
664
    act_ts=2016-10-15T22:42:41.714279000Z
665
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
666
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
667
    iomode = 1, refcnt = 5, reqs = 0xe682e0, nrecs = 0
668
    flags = 0xa<INCACHE,INUSE>
669
    PDU@0x7f0c08000db0: 
670
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
671
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
672
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
673
    rid=2, olen=24, chan=0xe67d20, seqno=0
674
    flags=0xa<HAS_RECNO,HAS_TS>
675
    datum=(nil)
676
    total header=104
677
    rPDU@0xe683e0: 
678
    v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT
679
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
680
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
681
    rid=2, olen=24, chan=0xe67d20, seqno=0
682
    flags=0xa<HAS_RECNO,HAS_TS>
683
    datum=0xe68460, recno=2, dbuf=0xe684d0, dlen=5
684
        ts=2016-10-15T22:42:41.710521000Z
685
    sigmdalg=0x0, siglen=0, sig=(nil)
686
    total header=128
687
ack_success: received ACK_DATA_CONTENT for ACK_DATA_CONTENT
688
_gdp_pdu_free(0x7f0c08000db0)
689
_gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 5]
690
    OK [67896525 = 0x40c04cd]
691
acknak_from_estat: OK [67896525 = 0x40c04cd] ->
692
    ACK_DATA_CONTENT
693
gdp_pdu_proc_resp(ACK_DATA_CONTENT for ACK_DATA_CONTENT): OK [67896525 = 0x40c04cd]
694
_gdp_event_new => 0x7f0c08000ea0
695
_gdp_event_trigger: adding event 0x7f0c08000ea0 (1) to active list
696
gdp_pdu_proc_resp <<< done
697
 >>> recno 2, len 5, ts 2016-10-15T22:42:41.710521000Z
698
world
699
gdp_event_free(0x7f0c08000ea0)
700
gdp_datum_free(0xe68460)
701
  ... draining 5 bytes
702

    
703
subscr_poker_thread: poking
704

    
705
subscr_poker_thread: poking
706

    
707
subscr_poker_thread: poking
708
subscr_resub: refreshing req@0xe682e0
709
gdp_datum_new => 0xe68460
710

    
711
>>> _gdp_invoke(req=0xe682e0 rid=2): CMD_SUBSCRIBE (72), gcl@0xe685f0
712
    datum @ 0xe68460: recno 1, len 4, no timestamp
713
00000000 00 00 00 00
714
         ⌧  ⌧  ⌧  ⌧ 
715
_gdp_invoke: sending 72, retries=2
716
_gdp_req_send: req@0xe682e0:
717
    nextrec=0, numrecs=0, chan=0xe67d20
718
    postproc=(nil), sub_cb=(nil), udata=(nil)
719
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
720
    act_ts=2016-10-15T22:42:41.715381000Z
721
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
722
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
723
    iomode = 1, refcnt = 5, reqs = 0xe682e0, nrecs = 0
724
    flags = 0xa<INCACHE,INUSE>
725
    PDU@0xe683e0: 
726
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
727
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
728
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
729
    rid=2, olen=24, chan=0xe67d20, seqno=0
730
    flags=0xa<HAS_RECNO,HAS_TS>
731
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
732
        ts=(none)
733
    sigmdalg=0x0, siglen=0, sig=(nil)
734
    total header=112
735
_gdp_pdu_out, fd = 7, basemd = (nil):
736
    PDU@0xe683e0: 
737
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
738
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
739
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
740
    rid=2, olen=24, chan=0xe67d20, seqno=0
741
    flags=0xa<HAS_RECNO,HAS_TS>
742
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
743
        ts=(none)
744
    sigmdalg=0x0, siglen=0, sig=(nil)
745
    total header=112
746
_gdp_pdu_out: sending PDU:
747
00000000 03 0f 00 48 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
748
00000010 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
749
00000020 50 d1 25 8f 87 23 a8 99 b3 81 78 7c 56 0a 92 03
750
00000030 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
751
00000040 a2 4f dc 02 00 00 00 02 00 00 02 02 00 00 00 04
752
00000050 00 00 00 00 00 00 00 01
753
00000058                         00 00 00 00
754
                                 ⌧  ⌧  ⌧  ⌧ 
755
_gdp_invoke: waiting on 0xe682e0
756
gdp_read_cb: fd 7, 88 bytes
757
gdp_datum_new => 0x7f0c08000e30
758
_gdp_pdu_new => 0x7f0c08000db0
759

    
760
    >>>>>  _gdp_pdu_in  >>>>>
761
_gdp_pdu_in: read PDU header:
762
00000000 03 0f 00 80 87 23 a8 99 b3 81 78 7c 56 0a 92 03
763
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
764
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
765
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
766
00000040 50 d1 25 8f 00 00 00 02 00 00 02 02 00 00 00 00
767
00000050 00 00 00 00 00 00 00 01
768
_gdp_pdu_in: reading 0 data bytes (0 available)
769
_gdp_pdu_in(ACK_SUCCESS) => OK
770
PDU@0x7f0c08000db0: 
771
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
772
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
773
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
774
    rid=2, olen=8, chan=0xe67d20, seqno=0
775
    flags=0x2<HAS_RECNO>
776
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
777
        ts=(none)
778
    sigmdalg=0x0, siglen=0, sig=(nil)
779
    total header=96
780

    
781
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
782
_gdp_gcl_touch(0xe685f0)
783
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
784
    0xe685f0 refcnt 6
785
gdp_pdu_proc_resp(0x7f0c08000db0 ACK_SUCCESS) gcl 0xe685f0
786
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 2
787
_gdp_req_find(gcl=0xe685f0, rid=2)
788
_gdp_req_find(gcl=0xe685f0, rid=2) => 0xe682e0, state WAITING
789
gdp_pdu_proc_resp: req@0xe682e0:
790
    nextrec=0, numrecs=0, chan=0xe67d20
791
    postproc=(nil), sub_cb=(nil), udata=(nil)
792
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
793
    act_ts=2016-10-15T22:42:41.715381000Z
794
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
795
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
796
    iomode = 1, refcnt = 6, reqs = 0xe682e0, nrecs = 0
797
    flags = 0xa<INCACHE,INUSE>
798
    PDU@0xe683e0: 
799
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
800
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
801
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
802
    rid=2, olen=24, chan=0xe67d20, seqno=0
803
    flags=0xa<HAS_RECNO,HAS_TS>
804
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
805
        ts=(none)
806
    sigmdalg=0x0, siglen=0, sig=(nil)
807
    total header=112
808
    rPDU@0x7f0c08000db0: 
809
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
810
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
811
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
812
    rid=2, olen=8, chan=0xe67d20, seqno=0
813
    flags=0x2<HAS_RECNO>
814
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
815
        ts=(none)
816
    sigmdalg=0x0, siglen=0, sig=(nil)
817
    total header=96
818
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 6], req@0xe682e0:
819
    nextrec=0, numrecs=0, chan=0xe67d20
820
    postproc=(nil), sub_cb=(nil), udata=(nil)
821
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
822
    act_ts=2016-10-15T22:43:43.369073000Z
823
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
824
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
825
    iomode = 1, refcnt = 6, reqs = 0xe682e0, nrecs = 0
826
    flags = 0xa<INCACHE,INUSE>
827
    PDU@0xe683e0: 
828
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
829
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
830
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
831
    rid=2, olen=24, chan=0xe67d20, seqno=0
832
    flags=0xa<HAS_RECNO,HAS_TS>
833
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
834
        ts=(none)
835
    sigmdalg=0x0, siglen=0, sig=(nil)
836
    total header=112
837
    rPDU@0x7f0c08000db0: 
838
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
839
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
840
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
841
    rid=2, olen=8, chan=0xe67d20, seqno=0
842
    flags=0x2<HAS_RECNO>
843
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
844
        ts=(none)
845
    sigmdalg=0x0, siglen=0, sig=(nil)
846
    total header=96
847
ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE
848
ack_success: reusing old datum for req 0xe682e0
849
   datum @ 0xe68460: recno 1, len 4, no timestamp
850
00000000 00 00 00 00
851
         ⌧  ⌧  ⌧  ⌧ 
852
gdp_datum_free(0x7f0c08000e30)
853
_gdp_pdu_free(0xe683e0)
854
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 6]
855
    OK [67896520 = 0x40c04c8]
856
acknak_from_estat: OK [67896520 = 0x40c04c8] ->
857
    ACK_SUCCESS
858
gdp_pdu_proc_resp(ACK_SUCCESS for CMD_SUBSCRIBE): OK [67896520 = 0x40c04c8]
859
gdp_pdu_proc_resp: signaling req@0xe682e0:
860
    nextrec=0, numrecs=0, chan=0xe67d20
861
    postproc=(nil), sub_cb=(nil), udata=(nil)
862
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
863
    act_ts=2016-10-15T22:43:43.369503000Z
864
    flags=0x1d6<DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
865
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
866
    iomode = 1, refcnt = 6, reqs = 0xe682e0, nrecs = 0
867
    flags = 0xa<INCACHE,INUSE>
868
    PDU@0x7f0c08000db0: 
869
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
870
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
871
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
872
    rid=2, olen=8, chan=0xe67d20, seqno=0
873
    flags=0x2<HAS_RECNO>
874
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
875
        ts=(none)
876
    sigmdalg=0x0, siglen=0, sig=(nil)
877
    total header=96
878
gdp_pdu_proc_resp <<< done
879
_gdp_event_trigger_pending(0xe683c8): empty
880
<<< _gdp_invoke(0xe682e0 rid=2) CMD_SUBSCRIBE: OK [67896520 = 0x40c04c8]
881
  req@0xe682e0:
882
    nextrec=0, numrecs=0, chan=0xe67d20
883
    postproc=(nil), sub_cb=(nil), udata=(nil)
884
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
885
    act_ts=2016-10-15T22:43:43.369503000Z
886
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
887
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
888
    iomode = 1, refcnt = 6, reqs = 0xe682e0, nrecs = 0
889
    flags = 0xa<INCACHE,INUSE>
890
    PDU@0x7f0c08000db0: 
891
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
892
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
893
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
894
    rid=2, olen=8, chan=0xe67d20, seqno=0
895
    flags=0x2<HAS_RECNO>
896
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
897
        ts=(none)
898
    sigmdalg=0x0, siglen=0, sig=(nil)
899
    total header=96
900

    
901
subscr_resub(jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8) ->
902
    OK [67896520 = 0x40c04c8]
903
gdp_datum_free(0xe68460)
904
  ... draining 0 bytes
905

    
906
subscr_poker_thread: poking
907

    
908
subscr_poker_thread: poking
909
subscr_resub: refreshing req@0xe682e0
910
gdp_datum_new => 0xe68460
911

    
912
>>> _gdp_invoke(req=0xe682e0 rid=2): CMD_SUBSCRIBE (72), gcl@0xe685f0
913
    datum @ 0xe68460: recno 1, len 4, no timestamp
914
00000000 00 00 00 00
915
         ⌧  ⌧  ⌧  ⌧ 
916
_gdp_invoke: sending 72, retries=2
917
_gdp_req_send: req@0xe682e0:
918
    nextrec=0, numrecs=0, chan=0xe67d20
919
    postproc=(nil), sub_cb=(nil), udata=(nil)
920
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
921
    act_ts=2016-10-15T22:43:43.369503000Z
922
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
923
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
924
    iomode = 1, refcnt = 6, reqs = 0xe682e0, nrecs = 0
925
    flags = 0xa<INCACHE,INUSE>
926
    PDU@0x7f0c08000db0: 
927
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
928
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
929
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
930
    rid=2, olen=8, chan=0xe67d20, seqno=0
931
    flags=0x2<HAS_RECNO>
932
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
933
        ts=(none)
934
    sigmdalg=0x0, siglen=0, sig=(nil)
935
    total header=96
936
_gdp_pdu_out, fd = 7, basemd = (nil):
937
    PDU@0x7f0c08000db0: 
938
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
939
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
940
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
941
    rid=2, olen=8, chan=0xe67d20, seqno=0
942
    flags=0x2<HAS_RECNO>
943
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
944
        ts=(none)
945
    sigmdalg=0x0, siglen=0, sig=(nil)
946
    total header=96
947
_gdp_pdu_out: sending PDU:
948
00000000 03 0f 00 48 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
949
00000010 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
950
00000020 50 d1 25 8f 87 23 a8 99 b3 81 78 7c 56 0a 92 03
951
00000030 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
952
00000040 a2 4f dc 02 00 00 00 02 00 00 02 02 00 00 00 04
953
00000050 00 00 00 00 00 00 00 01
954
00000058                         00 00 00 00
955
                                 ⌧  ⌧  ⌧  ⌧ 
956
_gdp_invoke: waiting on 0xe682e0
957
gdp_read_cb: fd 7, 88 bytes
958
gdp_datum_new => 0x7f0c08000e30
959
_gdp_pdu_new => 0xe683e0
960

    
961
    >>>>>  _gdp_pdu_in  >>>>>
962
_gdp_pdu_in: read PDU header:
963
00000000 03 0f 00 80 87 23 a8 99 b3 81 78 7c 56 0a 92 03
964
00000010 ec d2 8d 07 23 30 74 46 13 c7 ea bc c2 3f a4 61
965
00000020 a2 4f dc 02 8c fc e8 a7 0f 33 87 85 fa 08 9f 62
966
00000030 c4 f5 2a e3 73 a1 95 49 5e 55 18 63 8c 34 9e 71
967
00000040 50 d1 25 8f 00 00 00 02 00 00 02 02 00 00 00 00
968
00000050 00 00 00 00 00 00 00 01
969
_gdp_pdu_in: reading 0 data bytes (0 available)
970
_gdp_pdu_in(ACK_SUCCESS) => OK
971
PDU@0xe683e0: 
972
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
973
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
974
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
975
    rid=2, olen=8, chan=0xe67d20, seqno=0
976
    flags=0x2<HAS_RECNO>
977
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
978
        ts=(none)
979
    sigmdalg=0x0, siglen=0, sig=(nil)
980
    total header=96
981

    
982
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
983
_gdp_gcl_touch(0xe685f0)
984
gdp_gcl_cache_get: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8 =>
985
    0xe685f0 refcnt 7
986
gdp_pdu_proc_resp(0xe683e0 ACK_SUCCESS) gcl 0xe685f0
987
gdp_pdu_proc_resp: searching gcl 0xe685f0 for rid 2
988
_gdp_req_find(gcl=0xe685f0, rid=2)
989
_gdp_req_find(gcl=0xe685f0, rid=2) => 0xe682e0, state WAITING
990
gdp_pdu_proc_resp: req@0xe682e0:
991
    nextrec=0, numrecs=0, chan=0xe67d20
992
    postproc=(nil), sub_cb=(nil), udata=(nil)
993
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
994
    act_ts=2016-10-15T22:43:43.369503000Z
995
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
996
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
997
    iomode = 1, refcnt = 7, reqs = 0xe682e0, nrecs = 0
998
    flags = 0xa<INCACHE,INUSE>
999
    PDU@0x7f0c08000db0: 
1000
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
1001
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1002
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1003
    rid=2, olen=8, chan=0xe67d20, seqno=0
1004
    flags=0x2<HAS_RECNO>
1005
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
1006
        ts=(none)
1007
    sigmdalg=0x0, siglen=0, sig=(nil)
1008
    total header=96
1009
    rPDU@0xe683e0: 
1010
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
1011
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1012
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1013
    rid=2, olen=8, chan=0xe67d20, seqno=0
1014
    flags=0x2<HAS_RECNO>
1015
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
1016
        ts=(none)
1017
    sigmdalg=0x0, siglen=0, sig=(nil)
1018
    total header=96
1019
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 7], req@0xe682e0:
1020
    nextrec=0, numrecs=0, chan=0xe67d20
1021
    postproc=(nil), sub_cb=(nil), udata=(nil)
1022
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
1023
    act_ts=2016-10-15T22:44:43.374098000Z
1024
    flags=0x1d4<CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
1025
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1026
    iomode = 1, refcnt = 7, reqs = 0xe682e0, nrecs = 0
1027
    flags = 0xa<INCACHE,INUSE>
1028
    PDU@0x7f0c08000db0: 
1029
    v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE
1030
    dst=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1031
    src=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1032
    rid=2, olen=8, chan=0xe67d20, seqno=0
1033
    flags=0x2<HAS_RECNO>
1034
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=4
1035
        ts=(none)
1036
    sigmdalg=0x0, siglen=0, sig=(nil)
1037
    total header=96
1038
    rPDU@0xe683e0: 
1039
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
1040
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1041
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1042
    rid=2, olen=8, chan=0xe67d20, seqno=0
1043
    flags=0x2<HAS_RECNO>
1044
    datum=0x7f0c08000e30, recno=1, dbuf=0x7f0c08000ee0, dlen=0
1045
        ts=(none)
1046
    sigmdalg=0x0, siglen=0, sig=(nil)
1047
    total header=96
1048
ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE
1049
ack_success: reusing old datum for req 0xe682e0
1050
   datum @ 0xe68460: recno 1, len 4, no timestamp
1051
00000000 00 00 00 00
1052
         ⌧  ⌧  ⌧  ⌧ 
1053
gdp_datum_free(0x7f0c08000e30)
1054
_gdp_pdu_free(0x7f0c08000db0)
1055
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 7]
1056
    OK [67896520 = 0x40c04c8]
1057
acknak_from_estat: OK [67896520 = 0x40c04c8] ->
1058
    ACK_SUCCESS
1059
gdp_pdu_proc_resp(ACK_SUCCESS for CMD_SUBSCRIBE): OK [67896520 = 0x40c04c8]
1060
gdp_pdu_proc_resp: signaling req@0xe682e0:
1061
    nextrec=0, numrecs=0, chan=0xe67d20
1062
    postproc=(nil), sub_cb=(nil), udata=(nil)
1063
    state=WAITING, stat=OK [67896520 = 0x40c04c8]
1064
    act_ts=2016-10-15T22:44:43.374532000Z
1065
    flags=0x1d6<DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
1066
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1067
    iomode = 1, refcnt = 7, reqs = 0xe682e0, nrecs = 0
1068
    flags = 0xa<INCACHE,INUSE>
1069
    PDU@0xe683e0: 
1070
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
1071
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1072
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1073
    rid=2, olen=8, chan=0xe67d20, seqno=0
1074
    flags=0x2<HAS_RECNO>
1075
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
1076
        ts=(none)
1077
    sigmdalg=0x0, siglen=0, sig=(nil)
1078
    total header=96
1079
gdp_pdu_proc_resp <<< done
1080
_gdp_event_trigger_pending(0xe683c8): empty
1081
<<< _gdp_invoke(0xe682e0 rid=2) CMD_SUBSCRIBE: OK [67896520 = 0x40c04c8]
1082
  req@0xe682e0:
1083
    nextrec=0, numrecs=0, chan=0xe67d20
1084
    postproc=(nil), sub_cb=(nil), udata=(nil)
1085
    state=ACTIVE, stat=OK [67896520 = 0x40c04c8]
1086
    act_ts=2016-10-15T22:44:43.374532000Z
1087
    flags=0x1d7<ASYNCIO,DONE,CLT_SUBSCR,PERSIST,ALLOC_RID,ON_GCL_LIST,ON_CHAN_LIST>
1088
    GCL@0xe685f0: jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1089
    iomode = 1, refcnt = 7, reqs = 0xe682e0, nrecs = 0
1090
    flags = 0xa<INCACHE,INUSE>
1091
    PDU@0xe683e0: 
1092
    v=3, ttl=15, rsvd1=0, cmd=128=ACK_SUCCESS
1093
    dst=hyOombOBeHxWCpID7NKNByMwdEYTx-q8wj-kYaJP3AI
1094
    src=jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8
1095
    rid=2, olen=8, chan=0xe67d20, seqno=0
1096
    flags=0x2<HAS_RECNO>
1097
    datum=0xe68460, recno=1, dbuf=0xe684d0, dlen=0
1098
        ts=(none)
1099
    sigmdalg=0x0, siglen=0, sig=(nil)
1100
    total header=96
1101

    
1102
subscr_resub(jPzopw8zh4X6CJ9ixPUq43OhlUleVRhjjDSecVDRJY8) ->
1103
    OK [67896520 = 0x40c04c8]
1104
gdp_datum_free(0xe68460)
1105
  ... draining 0 bytes
1106
^C
1107
Exiting on signal 2
1108