Created
October 28, 2016 06:57
-
-
Save algrebe/5d715eb031f110905b9b2335e0ca52fe to your computer and use it in GitHub Desktop.
output from script to reproduce gnsq bug for issue https://github.com/wtolson/gnsq/issues/12
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# output for https://github.com/wtolson/gnsq/issues/12 | |
$ bash run.sh nsq-0.3.8.linux-amd64.go1.6.2/bin/ | |
[nsqd] 2016/10/28 12:00:04.257878 nsqd v0.3.8 (built w/go1.6.2) | |
[nsqd] 2016/10/28 12:00:04.258187 ID: 433 | |
[nsqd] 2016/10/28 12:00:04.258302 NSQ: persisting topic/channel metadata to nsqd.433.dat | |
[nsqd] 2016/10/28 12:00:04.262666 TCP: listening on [::]:4150 | |
[nsqd] 2016/10/28 12:00:04.263643 HTTP: listening on [::]:4151 | |
2016/10/28 12:00:06 INF 1 [TestTopic/default] (127.0.0.1:4150) connecting to nsqd | |
[nsqd] 2016/10/28 12:00:06.256774 TCP: new client(127.0.0.1:53323) | |
[nsqd] 2016/10/28 12:00:06.256930 CLIENT(127.0.0.1:53323): desired protocol magic ' V2' | |
[nsqd] 2016/10/28 12:00:06.257644 PROTOCOL(V2): [127.0.0.1:53323] [IDENTIFY] | |
[nsqd] 2016/10/28 12:00:06.258368 PROTOCOL(V2): [127.0.0.1:53323] {ShortID:ant-Dell-n411z LongID:ant-Dell-n411z ClientID:ant-Dell-n411z Hostname:ant-Dell-n411z HeartbeatInterval:30000 OutputBufferSize:16384 OutputBufferTimeout:250 FeatureNegotiation:true TLSv1:false Deflate:false DeflateLevel:6 Snappy:false SampleRate:0 UserAgent:nsq_tail/0.3.8 go-nsq/1.0.5 MsgTimeout:0} | |
[nsqd] 2016/10/28 12:00:06.258489 [127.0.0.1:53323] IDENTIFY: {ShortID:ant-Dell-n411z LongID:ant-Dell-n411z ClientID:ant-Dell-n411z Hostname:ant-Dell-n411z HeartbeatInterval:30000 OutputBufferSize:16384 OutputBufferTimeout:250 FeatureNegotiation:true TLSv1:false Deflate:false DeflateLevel:6 Snappy:false SampleRate:0 UserAgent:nsq_tail/0.3.8 go-nsq/1.0.5 MsgTimeout:0} | |
[nsqd] 2016/10/28 12:00:06.259701 PROTOCOL(V2): [127.0.0.1:53323] [SUB TestTopic default] | |
[nsqd] 2016/10/28 12:00:06.260200 TOPIC(TestTopic): created | |
[nsqd] 2016/10/28 12:00:06.260590 NSQ: persisting topic/channel metadata to nsqd.433.dat | |
[nsqd] 2016/10/28 12:00:06.260692 TOPIC(TestTopic): new channel(default) | |
[nsqd] 2016/10/28 12:00:06.261209 PROTOCOL(V2): [127.0.0.1:53323] [RDY 200] | |
[nsqd] 2016/10/28 12:00:06.261511 [127.0.0.1:53323] state rdy: 0 inflt: 0 | |
[nsqd] 2016/10/28 12:00:06.262044 [127.0.0.1:53323] state rdy: 200 inflt: 0 | |
[nsqd] 2016/10/28 12:00:06.263987 NSQ: persisting topic/channel metadata to nsqd.433.dat | |
[nsqd] 2016/10/28 12:00:08.649399 200 GET /ping (127.0.0.1:56817) 5.292µs | |
[nsqd] 2016/10/28 12:00:08.652703 TCP: new client(127.0.0.1:53326) | |
[nsqd] 2016/10/28 12:00:08.653426 CLIENT(127.0.0.1:53326): desired protocol magic ' V2' | |
publising message 1 | |
successfully published message 1 | |
sleeping for 1 minute and 2 seconds | |
[nsqd] 2016/10/28 12:00:08.654558 PROTOCOL(V2): [127.0.0.1:53326] [PUB TestTopic] | |
[nsqd] 2016/10/28 12:00:08.655044 PROTOCOL(V2): writing msg(070155f1855b1000) to client(127.0.0.1:53323) - Did you get message 1? | |
[nsqd] 2016/10/28 12:00:08.655153 [127.0.0.1:53323] state rdy: 200 inflt: 1 | |
[nsqd] 2016/10/28 12:00:08.655323 [127.0.0.1:53323] state rdy: 200 inflt: 1 | |
Did you get message 1? | |
[nsqd] 2016/10/28 12:00:08.655820 PROTOCOL(V2): [127.0.0.1:53323] [FIN 070155f1855b1000] | |
[nsqd] 2016/10/28 12:00:08.655957 [127.0.0.1:53323] state rdy: 200 inflt: 0 | |
[nsqd] 2016/10/28 12:00:36.259505 [127.0.0.1:53323] state rdy: 200 inflt: 0 | |
[nsqd] 2016/10/28 12:00:36.259883 PROTOCOL(V2): [127.0.0.1:53323] [NOP] | |
[nsqd] 2016/10/28 12:01:06.259560 [127.0.0.1:53323] state rdy: 200 inflt: 0 | |
[nsqd] 2016/10/28 12:01:06.259778 PROTOCOL(V2): [127.0.0.1:53323] [NOP] | |
[nsqd] 2016/10/28 12:01:08.655200 PROTOCOL(V2): [127.0.0.1:53326] exiting ioloop | |
[nsqd] 2016/10/28 12:01:08.655677 ERROR: client(127.0.0.1:53326) - failed to read command - read tcp 127.0.0.1:4150->127.0.0.1:53326: i/o timeout | |
[nsqd] 2016/10/28 12:01:08.655987 PROTOCOL(V2): [127.0.0.1:53326] exiting messagePump | |
awake! | |
publishing message 2 | |
successfully published message 2 | |
publishing message 3 | |
closed... | |
Traceback (most recent call last): | |
File "test_gnsq.py", line 37, in <module> | |
conn.close() | |
File ".virtualenvs/gnsq/local/lib/python2.7/site-packages/gnsq/nsqd.py", line 470, in close | |
self.send(nsq.close()) | |
File ".virtualenvs/gnsq/local/lib/python2.7/site-packages/gnsq/nsqd.py", line 239, in send | |
return self.stream.send(data, async) | |
File ".virtualenvs/gnsq/local/lib/python2.7/site-packages/gnsq/stream/stream.py", line 90, in send | |
self.ensure_connection() | |
File ".virtualenvs/gnsq/local/lib/python2.7/site-packages/gnsq/stream/stream.py", line 49, in ensure_connection | |
raise NSQSocketError(ENOTCONN, 'Socket is not connected') | |
gnsq.errors.NSQSocketError: [Errno 107] Socket is not connected | |
% Total % Received % Xferd Average Speed Time Time Time Current | |
Dload Upload Total Spent Left Speed | |
0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0[nsqd] 2016/10/28 12:01:10.768068 200 GET /stats?format=json (127.0.0.1:56834) 179.607µs | |
100 971 100 971 0 0 44980 0 --:--:-- --:--:-- --:--:-- 46238 | |
{ | |
"data": { | |
"start_time": 1477636204, | |
"topics": [ | |
{ | |
"backend_depth": 0, | |
"channels": [ | |
{ | |
"backend_depth": 0, | |
"channel_name": "default", | |
"clients": [ | |
{ | |
"connect_ts": 1477636206, | |
"deflate": false, | |
"finish_count": 1, | |
"in_flight_count": 0, | |
"message_count": 1, | |
"ready_count": 200, | |
"remote_address": "127.0.0.1:53323", | |
"requeue_count": 0, | |
"sample_rate": 0, | |
"snappy": false, | |
"state": 3, | |
"tls": false, | |
"tls_cipher_suite": "", | |
"tls_negotiated_protocol": "", | |
"tls_negotiated_protocol_is_mutual": false, | |
"tls_version": "", | |
"user_agent": "nsq_tail/0.3.8 go-nsq/1.0.5", | |
"version": "V2" | |
} | |
], | |
"deferred_count": 0, | |
"depth": 0, | |
"e2e_processing_latency": { | |
"count": 0, | |
"percentiles": null | |
}, | |
"in_flight_count": 0, | |
"message_count": 1, | |
"paused": false, | |
"requeue_count": 0, | |
"timeout_count": 0 | |
} | |
], | |
"depth": 0, | |
"e2e_processing_latency": { | |
"count": 0, | |
"percentiles": null | |
}, | |
"message_count": 1, | |
"paused": false, | |
"topic_name": "TestTopic" | |
} | |
], | |
"version": "0.3.8" | |
}, | |
"status_code": 200, | |
"status_txt": "OK" | |
} | |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment