Skip to content

Instantly share code, notes, and snippets.

@algrebe
Created October 28, 2016 06:57
Show Gist options
  • Save algrebe/5d715eb031f110905b9b2335e0ca52fe to your computer and use it in GitHub Desktop.
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
# 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