Updating local copy of the accessors repository. In "/Users/cxh/ptII/org/terraswarm/accessor/accessors", about to execute: svn update --non-interactive --trust-server-cert --accept postpone Updating '.': At revision 1572. All Done Updated accessor repository. GDPLogCreate.js: initialize() GDPLogAppend.js: initialize() GDPLogCreate.js: create() Start. GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910, 3, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@12a5de5, 3, org.terraswarm.gdp.GDP_NAME@5b3243f7) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@12a5de5(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s), RA, org.terraswarm.gdp.GDP_NAME@5b3243f7(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s) _gdp_lib_init(NULL) @(#)libgdp 0.7.2 (2017-04-18 17:01) f759690d6c300b2ab034867e50baa3dfa9167014 My GDP routing name = 6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I gdp_lib_init: OK _gdp_chan_open(gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu) Trying gdp-03.eecs.berkeley.edu _gdp_chan_open: trying host gdp-03.eecs.berkeley.edu port 8007 _gdp_chan_open: talking to router at gdp-03.eecs.berkeley.edu:8007 gdp_event_loop: starting up I/O base loop Inserted events: 0x7fcddfee07e0 [fd 123] Write Persist 0x7fcddfee0760 [fd 123] Read Persist 0x7fcde2b77d20 [fd -1] Persist Timeout=1492560908.469310 Active events: _gdp_req_new: allocated new pdu @ 0x7fcddfee1850 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_ADVERTISE gdp_init: OK _gdp_req_new: allocated new pdu @ 0x7fcddfee1850 >>> _gdp_invoke(req=0x7fcddfee1930 rid=1): CMD_OPEN_RA (75), gcl@0x7fcddfee2000 datum @ 0x7fcddfee0da0: recno -1, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_OPEN_RA _gdp_pdu_in(NAK_R_NOROUTE) => OK *** Processing ack/nak 240=NAK_R_NOROUTE from socket 123 gdp_pdu_proc_resp(0x7fcde2b775d0 NAK_R_NOROUTE) gcl 0x7fcddfee2000 _gdp_req_dispatch >>> NAK_R_NOROUTE (240) [gcl->refcnt 2] nak_router: received NAK_R_NOROUTE for CMD_OPEN_RA _gdp_req_dispatch <<< NAK_R_NOROUTE [gcl->refcnt 2] ERROR: 600 no route available [Berkeley:Swarm-GDP:600] <<< _gdp_invoke(0x7fcddfee1930 rid=1) CMD_OPEN_RA: ERROR: 600 no route available [Berkeley:Swarm-GDP:600] Couldn't open GCL xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s: ERROR: 600 no route available [Berkeley:Swarm-GDP:600] <<< gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s): ERROR: 600 no route available [Berkeley:Swarm-GDP:600] GDP_GCL: gdp_gcl_open() failed, trying to create the log and call gdp_gcl_open() again. GDP_GCL.java: create(org.terraswarm.gdp.GDP_NAME@12a5de5, , org.terraswarm.gdp.GDP_NAME@5b3243f7, {}) >>> gdp_gcl_create _gdp_gcl_create: gcl=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s logd=m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U _gdp_req_new: allocated new pdu @ 0x7fcddfee1850 >>> _gdp_invoke(req=0x7fcddfee1930 rid=2): CMD_CREATE (66), gcl@0x7fcddfee2110 datum @ 0x7fcddfee0da0: recno -1, len 34, no timestamp 00000000 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 1d 52 7d d5 Æ d 7 Ü 9 j « ° ÷ ? C ÷ ? R } Õ 00000010 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 9b a5 33 db þ c ½ î U Þ ´ O - ? õ k ? ¥ 3 Û 00000020 00 00 ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_CREATE _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcde2b775d0 ACK_DATA_CREATED) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 2] ack_success: received ACK_DATA_CREATED for CMD_CREATE _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 2] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcddfee1930 rid=2) CMD_CREATE: OK [201 = 0xc9] <<< gdp_gcl_create: OK [201 = 0xc9] >>> gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcddfee2110 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK GDPLogCreate.js: create() Done! GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910, 1, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@603abf58, 1, org.terraswarm.gdp.GDP_NAME@313fa1ba) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@603abf58(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s), RO, org.terraswarm.gdp.GDP_NAME@313fa1ba(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcddfee2110 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK _gdp_req_new: allocated new pdu @ 0x7fcddfee1850 >>> _gdp_invoke(req=0x7fcddfee1930 rid=3): CMD_SUBSCRIBE (72), gcl@0x7fcddfee2110 datum @ 0x7fcddfee0da0: recno 0, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcde2b775d0 ACK_SUCCESS) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 5] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 5] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfee1930 rid=3) CMD_SUBSCRIBE: OK [200 = 0xc8] Starting subscription poker thread Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910 GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910, 2, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@4addea9e, 2, org.terraswarm.gdp.GDP_NAME@418be79f) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@4addea9e(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s), AO, org.terraswarm.gdp.GDP_NAME@418be79f(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcddfee2110 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK Append data: 1 GDPHelper.append(1) ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] gdp_datum_new => 0x7fcddfee0da0 >>> gdp_gcl_append ep_thr_mutex_lock gdp_api.c:465 0x7fcddfee2110 (gcl) [0x700010677000] ep_thr_mutex_lock gdp_req.c:139 0x158c83070 (&ReqFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_req.c:144 0x158c83070 (&ReqFreeListMutex) [0x700010677000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_init gdp_req.c:161 0x7fcddfbdc610 (&req->mutex) [0x700010677000] ep_thr_cond_init gdp_req.c:163 0x7fcddfbdc660 (&req->cond) [0x700010677000] _gdp_req_lock: req @ 0x7fcddfbdc610 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfbdc610 (&req->mutex) [0x700010677000] ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x700010677000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] gdp_datum_new => 0x7fcde2b77390 _gdp_pdu_new => 0x7fcde2b775d0 _gdp_req_new: allocated new pdu @ 0x7fcde2b775d0 ep_thr_mutex_lock gdp_req.c:195 0x7fcddfee0690 (&chan->mutex) [0x700010677000] ep_thr_mutex_unlock gdp_req.c:205 0x7fcddfee0690 (&chan->mutex) [0x700010677000] _gdp_req_new(gcl=0x7fcddfee2110, cmd=CMD_APPEND) => 0x7fcddfbdc610 (rid=0) >>> _gdp_invoke(req=0x7fcddfbdc610 rid=0): CMD_APPEND (71), gcl@0x7fcddfee2110 datum @ 0x7fcde2b77390: recno 1, len 1, no timestamp 00000000 31 1 ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x700010677000] _gdp_invoke: sending 71, retries=2 _gdp_req_send: req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=ACTIVE, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 6, reqs = 0x7fcddfee1930, nrecs = 0 flags = 0xe cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=(none) rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 _gdp_req_send(0x7fcddfbdc610) gcl=0x7fcddfee2110 _gdp_req_send(0x7fcddfee2110) adding to cache _gdp_gcl_cache_add(0x7fcddfee2110): adding _gdp_gcl_cache_add(0x7fcddfee2110): already cached _gdp_pdu_out, fd = 123, basemd = 0x0: PDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 _gdp_pdu_out: sending PDU: 00000000 03 0f 00 47 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 00000010 1d 52 7d d5 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 00000020 9b a5 33 db e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000030 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000040 41 73 6f 82 00 00 00 00 00 00 02 02 00 00 00 01 00000050 00 00 00 00 00 00 00 01 00000058 31 1 _gdp_invoke: waiting on 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_proto.c:143 0x7fcddfee2110 (req->gcl) [0x700010677000] ep_thr_cond_wait-cv gdp_proto.c:146 0x7fcddfbdc660 (&req->cond) [0x700010677000] ep_thr_cond-wait-mtx gdp_proto.c:146 0x7fcddfbdc610 (&req->cond) [0x700010677000] gdp_read_cb: fd 123, 105 bytes ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x70000e766000] ep_thr_mutex_init gdp_datum.c:75 0x7fcddbb221e0 (&datum->mutex) [0x70000e766000] gdp_datum_new => 0x7fcddbb221e0 _gdp_pdu_new => 0x7fcddbb20490 >>>>> _gdp_pdu_in >>>>> _gdp_pdu_in: fixed pdu header: 00000000 03 0f 00 85 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 00000030 1d 52 7d d5 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 00000040 9b a5 33 db 00 00 00 03 00 00 06 0a 00 00 00 01 _gdp_pdu_in: read PDU header: 00000000 03 0f 00 85 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 00000030 1d 52 7d d5 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 00000040 9b a5 33 db 00 00 00 03 00 00 06 0a 00 00 00 01 00000050 00 00 00 00 00 00 00 01 00 00 00 00 58 f6 ab ee 00000060 25 1d ff b8 00 00 00 00 _gdp_pdu_in: reading 1 data bytes (1 available) 00000068 31 1 _gdp_pdu_in(ACK_DATA_CONTENT) => OK PDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=3, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddbb221e0, recno=1, dbuf=0x7fcddbb22340, dlen=1 ts=2017-04-19 00:14:38.622723000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 ep_thr_mutex_lock ep_hash.c:169 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_gcl_cache.c:227 0x7fcddfee2110 (gcl) [0x70000e766000] _gdp_gcl_touch(0x7fcddfee2110) _gdp_gcl_incref(0x7fcddfee2110): 7 gdp_gcl_cache_get: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U => 0x7fcddfee2110 refcnt 7 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CONTENT) gcl 0x7fcddfee2110 gdp_pdu_proc_resp: searching gcl 0x7fcddfee2110 for rid 3 _gdp_req_find(gcl=0x7fcddfee2110, rid=3) _gdp_req_lock: req @ 0x7fcddfbdc610 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] _gdp_req_unlock: req @ 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] _gdp_req_lock: req @ 0x7fcddfee1930 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfee1930 (&req->mutex) [0x70000e766000] _gdp_req_find(gcl=0x7fcddfee2110, rid=3) => 0x7fcddfee1930, state IDLE ... found req@0x7fcddfee1930: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:14:38.606167000Z flags=0x1d7 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcddfbdc610, nrecs = 0 flags = 0xe cPDU@0x7fcddfee1850: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=3, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 ep_thr_mutex_unlock gdp_main.c:410 0x7fcddfee2110 (gcl) [0x70000e766000] gdp_pdu_proc_resp: req@0x7fcddfee1930: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:14:38.606167000Z flags=0x1d7 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcddfbdc610, nrecs = 0 flags = 0xa cPDU@0x7fcddfee1850: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=3, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=3, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddbb221e0, recno=1, dbuf=0x7fcddbb22340, dlen=1 ts=2017-04-19 00:14:38.622723000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 7], req@0x7fcddfee1930: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:14:38.639194000Z flags=0x1d7 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcddfbdc610, nrecs = 0 flags = 0xa cPDU@0x7fcddfee1850: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=3, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=3, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddbb221e0, recno=1, dbuf=0x7fcddbb22340, dlen=1 ts=2017-04-19 00:14:38.622723000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 7] OK [205 = 0xcd] req@0x7fcddfee1930: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:14:38.639255000Z flags=0x1d7 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddfee1850: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=3, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=3, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddbb221e0, recno=1, dbuf=0x7fcddbb22340, dlen=1 ts=2017-04-19 00:14:38.622723000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 acknak_from_estat: OK [205 = 0xcd] -> ACK_DATA_CONTENT gdp_pdu_proc_resp(ACK_DATA_CONTENT for CMD_SUBSCRIBE): OK [205 = 0xcd] req@0x7fcddfee1930: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:14:38.639255000Z flags=0x1d7 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddfee1850: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=3, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=3, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddbb221e0, recno=1, dbuf=0x7fcddbb22340, dlen=1 ts=2017-04-19 00:14:38.622723000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 ep_thr_mutex_lock gdp_event.c:72 0x158c81a20 (&FreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:75 0x158c81a20 (&FreeListMutex) [0x70000e766000] _gdp_event_new => 0x7fcddb905b00 ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x70000e766000] ep_thr_mutex_init gdp_datum.c:75 0x7fcddb924820 (&datum->mutex) [0x70000e766000] gdp_datum_new => 0x7fcddb924820 _gdp_event_trigger: adding event 0x7fcddb905b00 (1) to active list ep_thr_mutex_lock gdp_event.c:201 0x158c81a80 (&ActiveListMutex) [0x70000e766000] ep_thr_cond_broadcast gdp_event.c:203 0x158c81ae0 (&ActiveListSig) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:204 0x158c81a80 (&ActiveListMutex) [0x70000e766000] _gdp_pdu_free(0x7fcddbb20490) gdp_datum_free(0x7fcddbb221e0) ... draining 1 bytes gdp_event_next: ep_thr_cond_wait => 0 ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddbb221e0 (&datum->mutex) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:175 0x158c81a80 (&ActiveListMutex) [0x70001077a000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddbb221e0 (&datum->mutex) [0x70000e766000] gdp_event_next => 0x7fcddb905b00 ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] _gdp_req_unlock: req @ 0x7fcddfee1930 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfee1930 (&req->mutex) [0x70000e766000] gdp_pdu_proc_resp <<< done gdp_event_free(0x7fcddb905b00) gdp_datum_free(0x7fcddb924820) ... draining 1 bytes ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddb924820 (&datum->mutex) [0x70001077a000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddb924820 (&datum->mutex) [0x70001077a000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70001077a000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70001077a000] ep_thr_mutex_lock gdp_event.c:104 0x158c81a20 (&FreeListMutex) [0x70001077a000] ep_thr_mutex_unlock gdp_event.c:106 0x158c81a20 (&FreeListMutex) [0x70001077a000] gdp_event_next: gcl 0x7fcddfee2110 ep_thr_mutex_lock gdp_event.c:132 0x158c81a80 (&ActiveListMutex) [0x70001077a000] gdp_event_next: empty ActiveList; waiting ep_thr_cond_wait-cv gdp_event.c:141 0x158c81ae0 (&ActiveListSig) [0x70001077a000] ep_thr_cond-wait-mtx gdp_event.c:141 0x158c81a80 (&ActiveListSig) [0x70001077a000] gdp_read_cb: fd 123, 88 bytes ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] gdp_datum_new => 0x7fcddb924820 _gdp_pdu_new => 0x7fcddbb20490 >>>>> _gdp_pdu_in >>>>> _gdp_pdu_in: fixed pdu header: 00000000 03 0f 00 81 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 00000030 1d 52 7d d5 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 00000040 9b a5 33 db 00 00 00 00 00 00 02 02 00 00 00 00 _gdp_pdu_in: read PDU header: 00000000 03 0f 00 81 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 c6 64 37 dc 39 6a ab b0 f7 07 43 f7 00000030 1d 52 7d d5 fe 63 bd ee 55 de b4 4f 2d 84 f5 6b 00000040 9b a5 33 db 00 00 00 00 00 00 02 02 00 00 00 00 00000050 00 00 00 00 00 00 00 01 _gdp_pdu_in: reading 0 data bytes (0 available) _gdp_pdu_in(ACK_DATA_CREATED) => OK PDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcddb908350, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 ep_thr_mutex_lock ep_hash.c:169 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_gcl_cache.c:227 0x7fcddfee2110 (gcl) [0x70000e766000] _gdp_gcl_touch(0x7fcddfee2110) _gdp_gcl_incref(0x7fcddfee2110): 8 gdp_gcl_cache_get: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U => 0x7fcddfee2110 refcnt 8 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CREATED) gcl 0x7fcddfee2110 gdp_pdu_proc_resp: searching gcl 0x7fcddfee2110 for rid 0 _gdp_req_find(gcl=0x7fcddfee2110, rid=0) _gdp_req_lock: req @ 0x7fcddfbdc610 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] _gdp_req_find(gcl=0x7fcddfee2110, rid=0) => 0x7fcddfbdc610, state WAITING ... found req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xe cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 ep_thr_mutex_unlock gdp_main.c:410 0x7fcddfee2110 (gcl) [0x70000e766000] gdp_pdu_proc_resp: req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xa cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcddb908350, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 8], req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:14:38.678084000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xa cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcddb908350, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 ack_success: received ACK_DATA_CREATED for CMD_APPEND ack_success: reusing old datum for req 0x7fcddfbdc610 datum @ 0x7fcde2b77390: recno 1, len 1, no timestamp 00000000 31 1 gdp_datum_free(0x7fcddb924820) ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddb924820 (&datum->mutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddb924820 (&datum->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 8] OK [201 = 0xc9] req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:14:38.678176000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xa cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 acknak_from_estat: OK [201 = 0xc9] -> ACK_DATA_CREATED gdp_pdu_proc_resp(ACK_DATA_CREATED for CMD_APPEND): OK [201 = 0xc9] req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:14:38.678176000Z flags=0x100 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xa cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 gdp_pdu_proc_resp: signaling req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK [201 = 0xc9] act_ts=2017-04-19 00:14:38.678176000Z flags=0x103 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xa cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 ep_thr_cond_signal gdp_main.c:497 0x7fcddfbdc660 (&req->cond) [0x70000e766000] ep_thr_yield gdp_main.c:501 0x0 ((null)) [0x70000e766000] _gdp_req_unlock: req @ 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] gdp_pdu_proc_resp <<< done _gdp_req_unlock: req @ 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfbdc610 (&req->mutex) [0x700010677000] ep_thr_mutex_lock gdp_proto.c:153 0x7fcddfee2110 (req->gcl) [0x700010677000] _gdp_req_lock: req @ 0x7fcddfbdc610 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfbdc610 (&req->mutex) [0x700010677000] _gdp_invoke wait: got 0, done=1, state=2, stat=OK [201 = 0xc9] _gdp_event_trigger_pending(0x7fcddfbdc720): empty <<< _gdp_invoke(0x7fcddfbdc610 rid=0) CMD_APPEND: OK [201 = 0xc9] req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=ACTIVE, stat=OK [201 = 0xc9] act_ts=2017-04-19 00:14:38.678176000Z flags=0x103 GCL@0x7fcddfee2110: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfee1930, nrecs = 1 flags = 0xe cPDU@0x7fcde2b775d0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcddff31630, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 _gdp_req_free(0x7fcddfbdc610) state=1, gcl=0x7fcddfee2110 ep_thr_mutex_lock gdp_req.c:272 0x7fcddfee0690 (&req->chan->mutex) [0x700010677000] ep_thr_mutex_unlock gdp_req.c:275 0x7fcddfee0690 (&req->chan->mutex) [0x700010677000] _gdp_pdu_free(0x7fcddbb20490) gdp_datum_free(0x7fcde2b77390) ... draining 0 bytes ep_thr_mutex_trylock gdp_datum.c:117 0x7fcde2b77390 (&datum->mutex) [0x700010677000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcde2b77390 (&datum->mutex) [0x700010677000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x700010677000] ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x700010677000] _gdp_pdu_free(0x7fcde2b775d0) ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x700010677000] ep_thr_mutex_lock gdp_req.c:313 0x158c83070 (&ReqFreeListMutex) [0x700010677000] ep_thr_mutex_unlock gdp_req.c:316 0x158c83070 (&ReqFreeListMutex) [0x700010677000] _gdp_req_unlock: req @ 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfbdc610 (&req->mutex) [0x700010677000] ep_thr_mutex_unlock gdp_api.c:467 0x7fcddfee2110 (gcl) [0x700010677000] <<< gdp_gcl_append: OK [201 = 0xc9] GDPLogRead.read(0): start GDPLogRead.read(0): About to call new GDP.GDP() GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910, 1, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@43d5fa02, 1, org.terraswarm.gdp.GDP_NAME@50a5e12a) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@43d5fa02(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s), RO, org.terraswarm.gdp.GDP_NAME@50a5e12a(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(xmQ33Dlqq7D3B0P3HVJ91f5jve5V3rRPLYT1a5ulM9s) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcddfee2110 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK GDPLogRead.read(0): recno was 0, sending nil GDPHelper.subscribe(): about to call _notifyIncoming {recno=1, data=[B@3131f483, ts=EP_TIME_SPEC(auto-allocated@0x7fcddba04ab0 (16 bytes)) { long tv_sec@0=58f6abee int tv_nsec@8=251dffb8 float tv_accuracy@c=0.0 }} ****** received: 1 ****** sent data: 1 Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910 Append data: 2 GDPHelper.append(2) _gdp_req_new: allocated new pdu @ 0x7fcde2b775d0 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=0): CMD_APPEND (71), gcl@0x7fcddfee2110 datum @ 0x7fcddb924820: recno 2, len 1, no timestamp 00000000 32 2 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CONTENT) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 10] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 10] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CREATED) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 11] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 11] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcddfbdc610 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=2, data=[B@9768fa2, ts=EP_TIME_SPEC(auto-allocated@0x7fcddffaa8b0 (16 bytes)) { long tv_sec@0=58f6abef int tv_nsec@8=179b1740 float tv_accuracy@c=0.0 }} ****** received: 2 ****** sent data: 2 GDPLogRead.read(1): start _gdp_req_new: allocated new pdu @ 0x7fcde2b775d0 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=0): CMD_READ (70), gcl@0x7fcddfee2110 datum @ 0x7fcddffa9400: recno 1, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CONTENT) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 12] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 12] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcddfbdc610 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(1): sending 1 Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.8976365770414.1434499910 Append data: 3 GDPHelper.append(3) _gdp_req_new: allocated new pdu @ 0x7fcde2b775d0 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=0): CMD_APPEND (71), gcl@0x7fcddfee2110 datum @ 0x7fcddbb221e0: recno 2, len 1, no timestamp 00000000 33 3 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CONTENT) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 13] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 13] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CREATED) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 14] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 14] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcddfbdc610 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=2, data=[B@7649a451, ts=EP_TIME_SPEC(auto-allocated@0x7fcddffa7840 (16 bytes)) { long tv_sec@0=58f6abf0 int tv_nsec@8=1770d2f0 float tv_accuracy@c=0.0 }} ****** received: 3 ****** sent data: 3 GDPLogRead.read(2): start _gdp_req_new: allocated new pdu @ 0x7fcde2b775d0 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=0): CMD_READ (70), gcl@0x7fcddfee2110 datum @ 0x7fcddffaf6e0: recno 2, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddbb20490 ACK_DATA_CONTENT) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 15] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 15] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcddfbdc610 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(2): sending 3 >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK 4405 ms. Memory: 524800K Free: 405550K (77%) >>> _gdp_invoke(req=0x7fcddfee1930 rid=3): CMD_SUBSCRIBE (72), gcl@0x7fcddfee2110 datum @ 0x7fcddffaf6e0: recno 3, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcde2b775d0 ACK_SUCCESS) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 16] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 16] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfee1930 rid=3) CMD_SUBSCRIBE: OK [200 = 0xc8] subscr_resub(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) -> OK [200 = 0xc8] Warning: '.GDPLogSubscribe.Test' is in training mode, set the trainingMode parameter to false before checking in GDPLogCreate.js: initialize() Warning: '.GDPLogSubscribe.Test2' is in training mode, set the trainingMode parameter to false before checking in GDPLogAppend.js: initialize() GDPLogCreate.js: create() Start. GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023, 3, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@118f6781, 3, org.terraswarm.gdp.GDP_NAME@4aa0610) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@118f6781(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI), RA, org.terraswarm.gdp.GDP_NAME@4aa0610(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI) _gdp_req_new: allocated new pdu @ 0x7fcddbb20490 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=4): CMD_OPEN_RA (75), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddbb221e0: recno -1, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_OPEN_RA _gdp_pdu_in(NAK_R_NOROUTE) => OK *** Processing ack/nak 240=NAK_R_NOROUTE from socket 123 gdp_pdu_proc_resp(0x7fcddff47cc0 NAK_R_NOROUTE) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> NAK_R_NOROUTE (240) [gcl->refcnt 2] nak_router: received NAK_R_NOROUTE for CMD_OPEN_RA _gdp_req_dispatch <<< NAK_R_NOROUTE [gcl->refcnt 2] ERROR: 600 no route available [Berkeley:Swarm-GDP:600] <<< _gdp_invoke(0x7fcddfbdc610 rid=4) CMD_OPEN_RA: ERROR: 600 no route available [Berkeley:Swarm-GDP:600] Couldn't open GCL 9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI: ERROR: 600 no route available [Berkeley:Swarm-GDP:600] <<< gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI): ERROR: 600 no route available [Berkeley:Swarm-GDP:600] GDP_GCL: gdp_gcl_open() failed, trying to create the log and call gdp_gcl_open() again. GDP_GCL.java: create(org.terraswarm.gdp.GDP_NAME@118f6781, , org.terraswarm.gdp.GDP_NAME@4aa0610, {}) >>> gdp_gcl_create _gdp_gcl_create: gcl=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI logd=m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U _gdp_req_new: allocated new pdu @ 0x7fcddbb20490 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=5): CMD_CREATE (66), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddbb221e0: recno -1, len 34, no timestamp 00000000 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b e7 55 90 84 õ ? ¿ Ö _ Â F ¤ m Ó Ü [ ç U ? ? 00000010 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 68 82 24 42 r ? " ? ; ? / ? ? ´ Þ ? h ? $ B 00000020 00 00 ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_CREATE _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddff47cc0 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 2] ack_success: received ACK_DATA_CREATED for CMD_CREATE _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 2] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcddfbdc610 rid=5) CMD_CREATE: OK [201 = 0xc9] <<< gdp_gcl_create: OK [201 = 0xc9] >>> gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcde2b2fbd0 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK GDPLogCreate.js: create() Done! GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023, 1, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@4be64f90, 1, org.terraswarm.gdp.GDP_NAME@50aa8c52) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@4be64f90(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI), RO, org.terraswarm.gdp.GDP_NAME@50aa8c52(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcde2b2fbd0 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK _gdp_req_new: allocated new pdu @ 0x7fcddbb20490 >>> _gdp_invoke(req=0x7fcddfbdc610 rid=6): CMD_SUBSCRIBE (72), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddbb221e0: recno 0, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcddff47cc0 ACK_SUCCESS) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 5] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 5] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfbdc610 rid=6) CMD_SUBSCRIBE: OK [200 = 0xc8] Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023 GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023, 2, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@30a2a036, 2, org.terraswarm.gdp.GDP_NAME@4179d0bc) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@30a2a036(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI), AO, org.terraswarm.gdp.GDP_NAME@4179d0bc(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcde2b2fbd0 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK Append data: 1 GDPHelper.append(1) ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] gdp_datum_new => 0x7fcddbb221e0 >>> gdp_gcl_append ep_thr_mutex_lock gdp_api.c:465 0x7fcde2b2fbd0 (gcl) [0x7000107fd000] ep_thr_mutex_lock gdp_req.c:139 0x158c83070 (&ReqFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_req.c:144 0x158c83070 (&ReqFreeListMutex) [0x7000107fd000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_init gdp_req.c:161 0x7fcdd9507460 (&req->mutex) [0x7000107fd000] ep_thr_cond_init gdp_req.c:163 0x7fcdd95074b0 (&req->cond) [0x7000107fd000] _gdp_req_lock: req @ 0x7fcdd9507460 ep_thr_mutex_lock gdp_req.c:383 0x7fcdd9507460 (&req->mutex) [0x7000107fd000] ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] gdp_datum_new => 0x7fcde2b77390 _gdp_pdu_new => 0x7fcddff47cc0 _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 ep_thr_mutex_lock gdp_req.c:195 0x7fcddfee0690 (&chan->mutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_req.c:205 0x7fcddfee0690 (&chan->mutex) [0x7000107fd000] _gdp_req_new(gcl=0x7fcde2b2fbd0, cmd=CMD_APPEND) => 0x7fcdd9507460 (rid=0) >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_APPEND (71), gcl@0x7fcde2b2fbd0 datum @ 0x7fcde2b77390: recno 1, len 1, no timestamp 00000000 31 1 ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_lock ep_hash.c:169 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcdd9f8ae30 (&hp->mutex) [0x7000107fd000] _gdp_invoke: sending 71, retries=2 _gdp_req_send: req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=ACTIVE, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 6, reqs = 0x7fcddfbdc610, nrecs = 0 flags = 0xe cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=(none) rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 _gdp_req_send(0x7fcdd9507460) gcl=0x7fcde2b2fbd0 _gdp_req_send(0x7fcde2b2fbd0) adding to cache _gdp_gcl_cache_add(0x7fcde2b2fbd0): adding _gdp_gcl_cache_add(0x7fcde2b2fbd0): already cached _gdp_pdu_out, fd = 123, basemd = 0x0: PDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 _gdp_pdu_out: sending PDU: 00000000 03 0f 00 47 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b 00000010 e7 55 90 84 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 00000020 68 82 24 42 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000030 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000040 41 73 6f 82 00 00 00 00 00 00 02 02 00 00 00 01 00000050 00 00 00 00 00 00 00 01 00000058 31 1 _gdp_invoke: waiting on 0x7fcdd9507460 ep_thr_mutex_unlock gdp_proto.c:143 0x7fcde2b2fbd0 (req->gcl) [0x7000107fd000] ep_thr_cond_wait-cv gdp_proto.c:146 0x7fcdd95074b0 (&req->cond) [0x7000107fd000] ep_thr_cond-wait-mtx gdp_proto.c:146 0x7fcdd9507460 (&req->cond) [0x7000107fd000] gdp_read_cb: fd 123, 105 bytes ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] gdp_datum_new => 0x7fcddb924820 _gdp_pdu_new => 0x7fcddfbe9860 >>>>> _gdp_pdu_in >>>>> _gdp_pdu_in: fixed pdu header: 00000000 03 0f 00 85 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b 00000030 e7 55 90 84 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 00000040 68 82 24 42 00 00 00 06 00 00 06 0a 00 00 00 01 _gdp_pdu_in: read PDU header: 00000000 03 0f 00 85 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b 00000030 e7 55 90 84 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 00000040 68 82 24 42 00 00 00 06 00 00 06 0a 00 00 00 01 00000050 00 00 00 00 00 00 00 01 00 00 00 00 58 f6 ac 4c 00000060 00 82 9d 80 00 00 00 00 _gdp_pdu_in: reading 1 data bytes (1 available) 00000068 31 1 _gdp_pdu_in(ACK_DATA_CONTENT) => OK PDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=6, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=1 ts=2017-04-19 00:16:12.008560000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 ep_thr_mutex_lock ep_hash.c:169 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_gcl_cache.c:227 0x7fcde2b2fbd0 (gcl) [0x70000e766000] _gdp_gcl_touch(0x7fcde2b2fbd0) _gdp_gcl_incref(0x7fcde2b2fbd0): 7 gdp_gcl_cache_get: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U => 0x7fcde2b2fbd0 refcnt 7 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 gdp_pdu_proc_resp: searching gcl 0x7fcde2b2fbd0 for rid 6 _gdp_req_find(gcl=0x7fcde2b2fbd0, rid=6) _gdp_req_lock: req @ 0x7fcdd9507460 ep_thr_mutex_lock gdp_req.c:383 0x7fcdd9507460 (&req->mutex) [0x70000e766000] _gdp_req_unlock: req @ 0x7fcdd9507460 ep_thr_mutex_unlock gdp_req.c:404 0x7fcdd9507460 (&req->mutex) [0x70000e766000] _gdp_req_lock: req @ 0x7fcddfbdc610 ep_thr_mutex_lock gdp_req.c:383 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] _gdp_req_find(gcl=0x7fcde2b2fbd0, rid=6) => 0x7fcddfbdc610, state IDLE ... found req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:16:11.981942000Z flags=0x1d7 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcdd9507460, nrecs = 0 flags = 0xe cPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=6, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 ep_thr_mutex_unlock gdp_main.c:410 0x7fcde2b2fbd0 (gcl) [0x70000e766000] gdp_pdu_proc_resp: req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:16:11.981942000Z flags=0x1d7 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcdd9507460, nrecs = 0 flags = 0xa cPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=6, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=6, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=1 ts=2017-04-19 00:16:12.008560000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 7], req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:16:12.024079000Z flags=0x1d7 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcdd9507460, nrecs = 0 flags = 0xa cPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=6, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=6, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=1 ts=2017-04-19 00:16:12.008560000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 7] OK [205 = 0xcd] req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:16:12.024160000Z flags=0x1d7 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcdd9507460, nrecs = 1 flags = 0xa cPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=6, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=6, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=1 ts=2017-04-19 00:16:12.008560000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 acknak_from_estat: OK [205 = 0xcd] -> ACK_DATA_CONTENT gdp_pdu_proc_resp(ACK_DATA_CONTENT for CMD_SUBSCRIBE): OK [205 = 0xcd] req@0x7fcddfbdc610: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=IDLE, stat=OK [200 = 0xc8] act_ts=2017-04-19 00:16:12.024160000Z flags=0x1d7 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 7, reqs = 0x7fcdd9507460, nrecs = 1 flags = 0xa cPDU@0x7fcddbb20490: v=3, ttl=15, rsvd1=0, cmd=72=CMD_SUBSCRIBE dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=6, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=133=ACK_DATA_CONTENT dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=6, olen=24, chan=0x7fcddfee0690, seqno=0 flags=0xa datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=1 ts=2017-04-19 00:16:12.008560000Z sigmdalg=0x0, siglen=0, sig=0x0 total header=128 ep_thr_mutex_lock gdp_event.c:72 0x158c81a20 (&FreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:75 0x158c81a20 (&FreeListMutex) [0x70000e766000] _gdp_event_new => 0x7fcddb905b00 ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] gdp_datum_new => 0x7fcddffa9400 _gdp_event_trigger: adding event 0x7fcddb905b00 (1) to active list ep_thr_mutex_lock gdp_event.c:201 0x158c81a80 (&ActiveListMutex) [0x70000e766000] ep_thr_cond_broadcast gdp_event.c:203 0x158c81ae0 (&ActiveListSig) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:204 0x158c81a80 (&ActiveListMutex) [0x70000e766000] _gdp_pdu_free(0x7fcddfbe9860) gdp_datum_free(0x7fcddb924820) ... draining 1 bytes ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddb924820 (&datum->mutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddb924820 (&datum->mutex) [0x70000e766000] gdp_event_next: ep_thr_cond_wait => 0 ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_event.c:175 0x158c81a80 (&ActiveListMutex) [0x70000e6e0000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] gdp_event_next => 0x7fcddb905b00 ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] _gdp_req_unlock: req @ 0x7fcddfbdc610 ep_thr_mutex_unlock gdp_req.c:404 0x7fcddfbdc610 (&req->mutex) [0x70000e766000] gdp_pdu_proc_resp <<< done gdp_read_cb: fd 123, 88 bytes ep_thr_mutex_lock gdp_pdu.c:780 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_pdu.c:789 0x158c81f60 (&PduFreeListMutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:64 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:69 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] gdp_datum_new => 0x7fcddb924820 _gdp_pdu_new => 0x7fcddfbe9860 >>>>> _gdp_pdu_in >>>>> _gdp_pdu_in: fixed pdu header: 00000000 03 0f 00 81 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b 00000030 e7 55 90 84 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 00000040 68 82 24 42 00 00 00 00 00 00 02 02 00 00 00 00 _gdp_pdu_in: read PDU header: 00000000 03 0f 00 81 e9 f0 cb 52 38 c4 15 26 23 5e e6 a1 00000010 a6 0d a3 a5 76 55 ce 7a 54 a4 d4 d3 99 d4 0c 5c 00000020 41 73 6f 82 f5 16 bf d6 5f c2 46 a4 6d d3 dc 5b 00000030 e7 55 90 84 72 97 22 9a 3b 1f 2f 05 10 b4 de 11 00000040 68 82 24 42 00 00 00 00 00 00 02 02 00 00 00 00 00000050 00 00 00 00 00 00 00 01 _gdp_pdu_in: reading 0 data bytes (0 available) _gdp_pdu_in(ACK_DATA_CREATED) => OK PDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 ep_thr_mutex_lock ep_hash.c:169 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_unlock ep_hash.c:175 0x7fcde0506030 (&hp->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_gcl_cache.c:227 0x7fcde2b2fbd0 (gcl) [0x70000e766000] _gdp_gcl_touch(0x7fcde2b2fbd0) _gdp_gcl_incref(0x7fcde2b2fbd0): 8 gdp_gcl_cache_get: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U => 0x7fcde2b2fbd0 refcnt 8 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 gdp_pdu_proc_resp: searching gcl 0x7fcde2b2fbd0 for rid 0 _gdp_req_find(gcl=0x7fcde2b2fbd0, rid=0) _gdp_req_lock: req @ 0x7fcdd9507460 ep_thr_mutex_lock gdp_req.c:383 0x7fcdd9507460 (&req->mutex) [0x70000e766000] _gdp_req_find(gcl=0x7fcde2b2fbd0, rid=0) => 0x7fcdd9507460, state WAITING ... found req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xe cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 ep_thr_mutex_unlock gdp_main.c:410 0x7fcde2b2fbd0 (gcl) [0x70000e766000] gdp_pdu_proc_resp: req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=1970-01-01 00:00:00.000000000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 8], req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:16:12.025005000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=1 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=88 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcddb924820, recno=1, dbuf=0x7fcde490d050, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 ack_success: received ACK_DATA_CREATED for CMD_APPEND ack_success: reusing old datum for req 0x7fcdd9507460 datum @ 0x7fcde2b77390: recno 1, len 1, no timestamp 00000000 31 1 gdp_datum_free(0x7fcddb924820) ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddb924820 (&datum->mutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddb924820 (&datum->mutex) [0x70000e766000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70000e766000] _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 8] OK [201 = 0xc9] req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:16:12.025136000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 acknak_from_estat: OK [201 = 0xc9] -> ACK_DATA_CREATED gdp_pdu_proc_resp(ACK_DATA_CREATED for CMD_APPEND): OK [201 = 0xc9] req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK act_ts=2017-04-19 00:16:12.025136000Z flags=0x100 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 gdp_event_free(0x7fcddb905b00) gdp_pdu_proc_resp: signaling gdp_datum_free(0x7fcddffa9400) req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=WAITING, stat=OK [201 = 0xc9] act_ts=2017-04-19 00:16:12.025136000Z flags=0x103 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xa cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 ... draining 1 bytes ep_thr_cond_signal gdp_main.c:497 0x7fcdd95074b0 (&req->cond) [0x70000e766000] ep_thr_mutex_trylock gdp_datum.c:117 0x7fcddffa9400 (&datum->mutex) [0x70000e6e0000] ep_thr_yield gdp_main.c:501 0x0 ((null)) [0x70000e766000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcddffa9400 (&datum->mutex) [0x70000e6e0000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x70000e6e0000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x70000e6e0000] ep_thr_mutex_lock gdp_event.c:104 0x158c81a20 (&FreeListMutex) [0x70000e6e0000] ep_thr_mutex_unlock gdp_event.c:106 0x158c81a20 (&FreeListMutex) [0x70000e6e0000] _gdp_req_unlock: req @ 0x7fcdd9507460 ep_thr_mutex_unlock gdp_req.c:404 0x7fcdd9507460 (&req->mutex) [0x70000e766000] gdp_pdu_proc_resp <<< done _gdp_req_unlock: req @ 0x7fcdd9507460 ep_thr_mutex_unlock gdp_req.c:404 0x7fcdd9507460 (&req->mutex) [0x7000107fd000] ep_thr_mutex_lock gdp_proto.c:153 0x7fcde2b2fbd0 (req->gcl) [0x7000107fd000] _gdp_req_lock: req @ 0x7fcdd9507460 ep_thr_mutex_lock gdp_req.c:383 0x7fcdd9507460 (&req->mutex) [0x7000107fd000] _gdp_invoke wait: got 0, done=1, state=2, stat=OK [201 = 0xc9] _gdp_event_trigger_pending(0x7fcdd9507570): empty <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_APPEND: OK [201 = 0xc9] req@0x7fcdd9507460: nextrec=0, numrecs=0, chan=0x7fcddfee0690 postproc=0x0, sub_cb=0x0, udata=0x0 state=ACTIVE, stat=OK [201 = 0xc9] act_ts=2017-04-19 00:16:12.025136000Z flags=0x103 GCL@0x7fcde2b2fbd0: m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U iomode = 3, refcnt = 8, reqs = 0x7fcddfbdc610, nrecs = 1 flags = 0xe cPDU@0x7fcddff47cc0: v=3, ttl=15, rsvd1=0, cmd=71=CMD_APPEND dst=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI src=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I rid=0, olen=0, chan=0x0, seqno=0 flags=0 datum=0x0 total header=80 rPDU@0x7fcddfbe9860: v=3, ttl=15, rsvd1=0, cmd=129=ACK_DATA_CREATED dst=6fDLUjjEFSYjXuahpg2jpXZVznpUpNTTmdQMXEFzb4I src=9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI rid=0, olen=8, chan=0x7fcddfee0690, seqno=0 flags=0x2 datum=0x7fcde2b77390, recno=1, dbuf=0x7fcde4935e70, dlen=0 ts=(none) sigmdalg=0x0, siglen=0, sig=0x0 total header=96 _gdp_req_free(0x7fcdd9507460) state=1, gcl=0x7fcde2b2fbd0 ep_thr_mutex_lock gdp_req.c:272 0x7fcddfee0690 (&req->chan->mutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_req.c:275 0x7fcddfee0690 (&req->chan->mutex) [0x7000107fd000] _gdp_pdu_free(0x7fcddfbe9860) gdp_datum_free(0x7fcde2b77390) ... draining 0 bytes ep_thr_mutex_trylock gdp_datum.c:117 0x7fcde2b77390 (&datum->mutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_datum.c:122 0x7fcde2b77390 (&datum->mutex) [0x7000107fd000] ep_thr_mutex_lock gdp_datum.c:123 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_datum.c:126 0x158c81ce0 (&DatumFreeListMutex) [0x7000107fd000] ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] _gdp_pdu_free(0x7fcddff47cc0) ep_thr_mutex_lock gdp_pdu.c:813 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_pdu.c:815 0x158c81f60 (&PduFreeListMutex) [0x7000107fd000] ep_thr_mutex_lock gdp_req.c:313 0x158c83070 (&ReqFreeListMutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_req.c:316 0x158c83070 (&ReqFreeListMutex) [0x7000107fd000] _gdp_req_unlock: req @ 0x7fcdd9507460 ep_thr_mutex_unlock gdp_req.c:404 0x7fcdd9507460 (&req->mutex) [0x7000107fd000] ep_thr_mutex_unlock gdp_api.c:467 0x7fcde2b2fbd0 (gcl) [0x7000107fd000] <<< gdp_gcl_append: OK [201 = 0xc9] gdp_event_next: gcl 0x7fcde2b2fbd0 ep_thr_mutex_lock gdp_event.c:132 0x158c81a80 (&ActiveListMutex) [0x70000e6e0000] gdp_event_next: empty ActiveList; waiting ep_thr_cond_wait-cv gdp_event.c:141 0x158c81ae0 (&ActiveListSig) [0x70000e6e0000] ep_thr_cond-wait-mtx gdp_event.c:141 0x158c81a80 (&ActiveListSig) [0x70000e6e0000] GDPHelper.subscribe(): about to call _notifyIncoming {recno=1, data=[B@5dc7f265, ts=EP_TIME_SPEC(auto-allocated@0x7fcdd95cdb50 (16 bytes)) { long tv_sec@0=58f6ac4c int tv_nsec@8=829d80 float tv_accuracy@c=0.0 }} ****** received: 1 ****** sent data: 1 GDPLogRead.read(0): start GDPLogRead.read(0): About to call new GDP.GDP() GDPHelper.GDPHelper(ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023, 1, edu.berkeley.eecs.gdp-01.gdplogd): GDPManager: Using configuration files in /Users/cxh/.ep_adm_params GDPManager: gdp settings: swarm.gdp.routers=gdp-03.eecs.berkeley.edu; gdp-02.eecs.berkeley.edu GDP_GCL.java: newGCL(org.terraswarm.gdp.GDP_NAME@69669e66, 1, org.terraswarm.gdp.GDP_NAME@2f2f8415) GDP_GCL.java: GDP_GCL(org.terraswarm.gdp.GDP_NAME@69669e66(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI), RO, org.terraswarm.gdp.GDP_NAME@2f2f8415(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) >>> gdp_gcl_open(9Ra_1l_CRqRt09xb51WQhHKXIpo7Hy8FELTeEWiCJEI) gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): using existing GCL @ 0x7fcde2b2fbd0 <<< gdp_gcl_open(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK GDPLogRead.read(0): recno was 0, sending nil Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023 Append data: 2 GDPHelper.append(2) _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_APPEND (71), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddffa9400: recno 2, len 1, no timestamp 00000000 32 2 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 10] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 10] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 11] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 11] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=2, data=[B@2740687c, ts=EP_TIME_SPEC(auto-allocated@0x7fcddfec8ac0 (16 bytes)) { long tv_sec@0=58f6ac4c int tv_nsec@8=375e7fe0 float tv_accuracy@c=0.0 }} ****** received: 2 ****** sent data: 2 GDPLogRead.read(1): start _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_READ (70), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddfee0da0: recno 1, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 12] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 12] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(1): sending 1 Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023 Append data: 3 GDPHelper.append(3) _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_APPEND (71), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddb924820: recno 2, len 1, no timestamp 00000000 33 3 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 13] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 13] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 14] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 14] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=2, data=[B@6ab2c21c, ts=EP_TIME_SPEC(auto-allocated@0x7fcddff74020 (16 bytes)) { long tv_sec@0=58f6ac4d int tv_nsec@8=378f6b50 float tv_accuracy@c=0.0 }} ****** received: 3 ****** sent data: 3 GDPLogRead.read(2): start _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_READ (70), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddffaede0: recno 2, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 15] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 15] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(2): sending 3 Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023 Append data: 4 GDPHelper.append(4) _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_APPEND (71), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddffaf6e0: recno 3, len 1, no timestamp 00000000 34 4 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 16] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 16] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 17] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 17] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=3, data=[B@d00c3d4, ts=EP_TIME_SPEC(auto-allocated@0x7fcdd948f4f0 (16 bytes)) { long tv_sec@0=58f6ac4e int tv_nsec@8=373d1530 float tv_accuracy@c=0.0 }} ****** received: 4 ****** sent data: 4 GDPLogRead.read(3): start _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_READ (70), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddfd7a430: recno 3, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 18] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 18] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(3): sending 4 Append to log named: ptolemy.actor.lib.jjs.modules.gdp.test.auto.GDPLogAppendRead.0.3704672703275.-955030023 Append data: 5 GDPHelper.append(5) _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_APPEND (71), gcl@0x7fcde2b2fbd0 datum @ 0x7fcde2b005f0: recno 4, len 1, no timestamp 00000000 35 5 _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_APPEND _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 19] ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 19] OK [205 = 0xcd] _gdp_pdu_in(ACK_DATA_CREATED) => OK *** Processing ack/nak 129=ACK_DATA_CREATED from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CREATED) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CREATED (129) [gcl->refcnt 20] ack_success: received ACK_DATA_CREATED for CMD_APPEND _gdp_req_dispatch <<< ACK_DATA_CREATED [gcl->refcnt 20] OK [201 = 0xc9] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_APPEND: OK [201 = 0xc9] GDPHelper.subscribe(): about to call _notifyIncoming {recno=4, data=[B@419947c5, ts=EP_TIME_SPEC(auto-allocated@0x7fcddfdb1ac0 (16 bytes)) { long tv_sec@0=58f6ac4f int tv_nsec@8=37922a70 float tv_accuracy@c=0.0 }} ****** received: 5 ****** sent data: 5 GDPLogRead.read(4): start _gdp_req_new: allocated new pdu @ 0x7fcddff47cc0 >>> _gdp_invoke(req=0x7fcdd9507460 rid=0): CMD_READ (70), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddfd70800: recno 4, len 0, no timestamp _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_READ _gdp_pdu_in(ACK_DATA_CONTENT) => OK *** Processing ack/nak 133=ACK_DATA_CONTENT from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_DATA_CONTENT) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 21] ack_success: received ACK_DATA_CONTENT for CMD_READ _gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 21] OK [205 = 0xcd] <<< _gdp_invoke(0x7fcdd9507460 rid=0) CMD_READ: OK [205 = 0xcd] GDPLogRead.read(4): sending 5 >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK >>> gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) <<< gdp_gcl_close(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U): OK 7249 ms. Memory: 889344K Free: 793300K (89%) >>> _gdp_invoke(req=0x7fcddfee1930 rid=3): CMD_SUBSCRIBE (72), gcl@0x7fcddfee2110 datum @ 0x7fcddfd70800: recno 3, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcddff47cc0 ACK_SUCCESS) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 17] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 17] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfee1930 rid=3) CMD_SUBSCRIBE: OK [200 = 0xc8] subscr_resub(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) -> OK [200 = 0xc8] >>> _gdp_invoke(req=0x7fcddfbdc610 rid=6): CMD_SUBSCRIBE (72), gcl@0x7fcde2b2fbd0 datum @ 0x7fcddfd70800: recno 5, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcde2b775d0 ACK_SUCCESS) gcl 0x7fcde2b2fbd0 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 22] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 22] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfbdc610 rid=6) CMD_SUBSCRIBE: OK [200 = 0xc8] subscr_resub(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) -> OK [200 = 0xc8] >>> _gdp_invoke(req=0x7fcddfee1930 rid=3): CMD_SUBSCRIBE (72), gcl@0x7fcddfee2110 datum @ 0x7fcddfd70800: recno 3, len 4, no timestamp 00000000 00 00 00 00 ? ? ? ? _gdp_pdu_out, fd = 123, basemd = 0x0: CMD_SUBSCRIBE _gdp_pdu_in(ACK_SUCCESS) => OK *** Processing ack/nak 128=ACK_SUCCESS from socket 123 gdp_pdu_proc_resp(0x7fcddfbe9860 ACK_SUCCESS) gcl 0x7fcddfee2110 _gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 18] ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE _gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 18] OK [200 = 0xc8] <<< _gdp_invoke(0x7fcddfee1930 rid=3) CMD_SUBSCRIBE: OK [200 = 0xc8] subscr_resub(m5FiAV65ufV8Oe3SinfrOZPcbzXtlNOG-lmD-KSsE1U) -> OK [200 = 0xc8]