Project

General

Profile

subclient.log

Subscription output with updated patch - Nitesh Mor, 06/22/2017 01:28 PM

Download (3.84 KB)

 
1
$ gdp-reader -D *=20 -f 0 -t -s -n 2 testlog
2
_gdp_lib_init(NULL)
3
    @(#)libgdp 0.7.2 (2017-06-22 10:57) 0134edaa283e25648edcc26d519ec6e47fcf4dca++
4
My GDP routing name = hbRWFfOPw25YKVFxV4sFYMzpQJoHU2oIqe-f2H0nQ9o
5
gdp_lib_init: OK
6
_gdp_chan_open(172.30.0.1)
7
Trying 172.30.0.1
8
_gdp_chan_open: trying host 172.30.0.1 port 8007
9
_gdp_chan_open: talking to router at 172.30.0.1:8007
10
gdp_event_loop: starting up I/O base loop
11
Inserted events:
12
  0x1664970 [fd 6] Read Persist
13
  0x16647a8 [fd 5] Read Persist
14
  0x1664d60 [fd 10] Signal Persist
15
  0x1665100 [fd 7] Read Persist
16
  0x1665188 [fd 7] Write Persist
17
_gdp_req_new: allocated new pdu @ 0x1665740
18
_gdp_pdu_out, fd = 7, basemd = (nil): CMD_ADVERTISE
19
gdp_init: OK
20
Reading GCL mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y
21

    
22
>>> gdp_gcl_open(mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y)
23
_gdp_req_new: allocated new pdu @ 0x1665740
24

    
25
>>> _gdp_invoke(req=0x1665630 rid=1): CMD_OPEN_RO (68), gcl@0x16658e0
26
    datum @ 0x16657c0: recno -1, len 0, no timestamp
27
_gdp_pdu_out, fd = 7, basemd = (nil): CMD_OPEN_RO
28
_gdp_pdu_in(ACK_SUCCESS) => OK
29

    
30
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
31
gdp_pdu_proc_resp(0x7f0a30000db0 ACK_SUCCESS) gcl 0x16658e0
32
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 1]
33
ack_success: received ACK_SUCCESS for CMD_OPEN_RO
34
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 1]
35
    OK [200 = 0xc8]
36
<<< _gdp_invoke(0x1665630 rid=1) CMD_OPEN_RO: OK [200 = 0xc8]
37
Opened GCL mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y
38
_gdp_req_new: allocated new pdu @ 0x1665740
39

    
40
>>> _gdp_invoke(req=0x1665630 rid=2): CMD_SUBSCRIBE (72), gcl@0x16658e0
41
    datum @ 0x16657c0: recno 0, len 4, no timestamp
42
00000000 00 00 00 02
43
         ⌧  ⌧  ⌧  ⌧ 
44
_gdp_pdu_out, fd = 7, basemd = (nil): CMD_SUBSCRIBE
45
_gdp_pdu_in(ACK_SUCCESS) => OK
46

    
47
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
48
gdp_pdu_proc_resp(0x7f0a30000db0 ACK_SUCCESS) gcl 0x16658e0
49
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 1]
50
ack_success: received ACK_SUCCESS for CMD_SUBSCRIBE
51
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 1]
52
    OK [200 = 0xc8]
53
<<< _gdp_invoke(0x1665630 rid=2) CMD_SUBSCRIBE: OK [200 = 0xc8]
54
Starting subscription poker thread
55
_gdp_pdu_in(ACK_DATA_CONTENT) => OK
56

    
57
*** Processing ack/nak 133=ACK_DATA_CONTENT from socket 7
58
gdp_pdu_proc_resp(0x7f0a30000db0 ACK_DATA_CONTENT) gcl 0x16658e0
59
_gdp_req_dispatch >>> ACK_DATA_CONTENT (133) [gcl->refcnt 1]
60
ack_success: received ACK_DATA_CONTENT for CMD_SUBSCRIBE
61
_gdp_req_dispatch <<< ACK_DATA_CONTENT [gcl->refcnt 1]
62
    OK [205 = 0xcd]
63
 >>> recno 115, len 5, ts 2017-06-22 20:26:22.839368000Z
64
hello
65

    
66
>>> gdp_gcl_close(mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y)
67
_gdp_req_new: allocated new pdu @ 0x7f0a30000db0
68

    
69
>>> _gdp_invoke(req=0x1666c20 rid=0): CMD_CLOSE (69), gcl@0x16658e0
70
    datum @ 0x7f0a30000e30: recno -1, len 0, no timestamp
71
_gdp_pdu_out, fd = 7, basemd = (nil): CMD_CLOSE
72
_gdp_pdu_in(ACK_SUCCESS) => OK
73

    
74
*** Processing ack/nak 128=ACK_SUCCESS from socket 7
75
gdp_pdu_proc_resp(0x7f0a30000f90 ACK_SUCCESS) gcl 0x16658e0
76
_gdp_req_dispatch >>> ACK_SUCCESS (128) [gcl->refcnt 1]
77
ack_success: received ACK_SUCCESS for CMD_CLOSE
78
_gdp_req_dispatch <<< ACK_SUCCESS [gcl->refcnt 1]
79
    OK [200 = 0xc8]
80
<<< _gdp_invoke(0x1666c20 rid=0) CMD_CLOSE: OK [200 = 0xc8]
81
sleeping for 100 seconds
82
_gdp_pdu_in(ACK_DATA_CONTENT) => OK
83

    
84
*** Processing ack/nak 133=ACK_DATA_CONTENT from socket 7
85
gdp_pdu_proc_resp(0x1665740 ACK_DATA_CONTENT) gcl (nil)
86
find_req_in_channel_list: searching
87
gdp_pdu_proc_resp: discarding 133 (ACK_DATA_CONTENT) PDU for unknown GCL
88
    mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y
89
_gdp_pdu_in(ACK_DATA_DEL) => OK
90

    
91
*** Processing ack/nak 130=ACK_DATA_DEL from socket 7
92
gdp_pdu_proc_resp(0x1665740 ACK_DATA_DEL) gcl (nil)
93
find_req_in_channel_list: searching
94
gdp_pdu_proc_resp: discarding 130 (ACK_DATA_DEL) PDU for unknown GCL
95
    mPLueaa7S37yGQ2wUo5GRNemSrIgKF7RXU7mqJJZt4Y
96
^C[WARN] gdp-reader: Exiting on signal 2
97