Skip to content

Instantly share code, notes, and snippets.

@davidwilemski
Created February 26, 2019 05:02
Show Gist options
  • Save davidwilemski/caa2edb9dd08dd1115d9813a0a63602f to your computer and use it in GitHub Desktop.
Save davidwilemski/caa2edb9dd08dd1115d9813a0a63602f to your computer and use it in GitHub Desktop.
rust-zookeeper reconnect works!
[2019-02-26T04:59:10Z DEBUG zookeeper::zookeeper] Initiating connection to 127.0.0.1:2181
[2019-02-26T04:59:10Z TRACE zookeeper::watch] ZkWatch::new
[2019-02-26T04:59:10Z TRACE zookeeper::io] ZkIo::new
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] Returning a ZooKeeper
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] ZooKeeper::add_listener
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper_ext] ensure_path /discovery/test
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] ZooKeeper::create
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] request opcode=Create xid=1
[2019-02-26T04:59:10Z TRACE zookeeper::io] Written 49 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(3) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] ready_channel Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:10Z TRACE zookeeper::io] Written 61 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] Read 41 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] Response chunk len = 37 buf len is 41
[2019-02-26T04:59:10Z TRACE zookeeper::io] handle_response in Connecting state [37]
[2019-02-26T04:59:10Z INFO zookeeper::io] Connected: ConnectResponse { protocol_version: 0, timeout: 10000, session_id: 72086866627985421, passwd: [217, 152, 143, 251, 122, 48, 1, 195, 155, 25, 6, 35, 242, 140, 157, 15], read_only: false }
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] Read 20 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] Response chunk len = 16 buf len is 20
[2019-02-26T04:59:10Z TRACE zookeeper::io] handle_response in Connected state [16]
[2019-02-26T04:59:10Z TRACE zookeeper::io] send_response Opcode is Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] start_timeout: Ping
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] ZooKeeper::create
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] request opcode=Create xid=2
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(3) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] ready_channel Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:10Z TRACE zookeeper::io] clear_timeout: Ping
[2019-02-26T04:59:10Z TRACE zookeeper::io] Written 66 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] Read 20 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] Response chunk len = 16 buf len is 20
[2019-02-26T04:59:10Z TRACE zookeeper::io] handle_response in Connected state [16]
[2019-02-26T04:59:10Z TRACE zookeeper::io] send_response Opcode is Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] start_timeout: Ping
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] ZooKeeper::create
[2019-02-26T04:59:10Z TRACE zookeeper::zookeeper] request opcode=Create xid=3
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(3) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] ready_channel Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:10Z TRACE zookeeper::io] clear_timeout: Ping
[2019-02-26T04:59:10Z TRACE zookeeper::io] Written 171 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:10Z TRACE zookeeper::io] Read 57 bytes
[2019-02-26T04:59:10Z TRACE zookeeper::io] Response chunk len = 53 buf len is 57
[2019-02-26T04:59:10Z TRACE zookeeper::io] handle_response in Connected state [53]
[2019-02-26T04:59:10Z TRACE zookeeper::io] send_response Opcode is Create
[2019-02-26T04:59:10Z TRACE zookeeper::io] start_timeout: Ping
[2019-02-26T04:59:17Z TRACE zookeeper::io] event token=Token(2) ready=Readable
[2019-02-26T04:59:17Z TRACE zookeeper::io] ready_timer thread=ThreadId(2)
[2019-02-26T04:59:17Z TRACE zookeeper::io] handle ping timeout
[2019-02-26T04:59:17Z TRACE zookeeper::io] clear_timeout: Ping
[2019-02-26T04:59:17Z TRACE zookeeper::io] Pinging V4(127.0.0.1:2181)
[2019-02-26T04:59:17Z TRACE zookeeper::io] event token=Token(3) ready=Readable
[2019-02-26T04:59:17Z TRACE zookeeper::io] ready_channel Ping
[2019-02-26T04:59:17Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:17Z TRACE zookeeper::io] Written 12 bytes
[2019-02-26T04:59:25Z TRACE zookeeper::io] event token=Token(1) ready=Readable | Hup
[2019-02-26T04:59:25Z WARN zookeeper::io] Connection closed: read
[2019-02-26T04:59:25Z TRACE zookeeper::io] reconnect
[2019-02-26T04:59:25Z INFO zookeeper::io] Establishing Zk connection
[2019-02-26T04:59:25Z INFO zookeeper::io] Connecting to new server V4(127.0.0.1:2181)
[2019-02-26T04:59:25Z INFO zookeeper::io] Started connecting to V4(127.0.0.1:2181)
[2019-02-26T04:59:25Z TRACE zookeeper::io] start_timeout: Connect
[2019-02-26T04:59:25Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:25Z TRACE zookeeper::io] Written 49 bytes
[2019-02-26T04:59:25Z TRACE zookeeper::io] event token=Token(1) ready=Readable | Hup
[2019-02-26T04:59:25Z TRACE zookeeper::io] Read 41 bytes
[2019-02-26T04:59:25Z TRACE zookeeper::io] Response chunk len = 37 buf len is 41
[2019-02-26T04:59:25Z TRACE zookeeper::io] handle_response in Connecting state [37]
[2019-02-26T04:59:25Z INFO zookeeper::io] session 72086866627985421 expired
[2019-02-26T04:59:25Z INFO zookeeper::io] Reconnect due to HUP
[2019-02-26T04:59:25Z TRACE zookeeper::io] reconnect
[2019-02-26T04:59:25Z INFO zookeeper::io] Establishing Zk connection
[2019-02-26T04:59:25Z TRACE zookeeper::io] clear_timeout: Connect
[2019-02-26T04:59:25Z INFO zookeeper::io] Connecting to new server V4(127.0.0.1:2181)
[2019-02-26T04:59:25Z INFO zookeeper::io] Started connecting to V4(127.0.0.1:2181)
[2019-02-26T04:59:25Z TRACE zookeeper::io] start_timeout: Connect
[2019-02-26T04:59:25Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:25Z TRACE zookeeper::io] Written 49 bytes
[2019-02-26T04:59:25Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:25Z TRACE zookeeper::io] Read 41 bytes
[2019-02-26T04:59:25Z TRACE zookeeper::io] Response chunk len = 37 buf len is 41
[2019-02-26T04:59:25Z TRACE zookeeper::io] handle_response in Connecting state [37]
[2019-02-26T04:59:25Z INFO zookeeper::io] Connected: ConnectResponse { protocol_version: 0, timeout: 10000, session_id: 72086866627985422, passwd: [160, 53, 161, 251, 154, 77, 99, 244, 187, 80, 208, 160, 119, 242, 95, 168], read_only: false }
[2019-02-26T04:59:25Z TRACE zookeeper::io] start_timeout: Ping
[2019-02-26T04:59:27Z TRACE zookeeper::io] event token=Token(2) ready=Readable
[2019-02-26T04:59:27Z TRACE zookeeper::io] ready_timer thread=ThreadId(2)
[2019-02-26T04:59:27Z TRACE zookeeper::io] handle connection timeout
[2019-02-26T04:59:27Z TRACE zookeeper::io] clear_timeout: Connect
[2019-02-26T04:59:27Z TRACE zookeeper::io] Spurious timer
[2019-02-26T04:59:32Z TRACE zookeeper::io] event token=Token(2) ready=Readable
[2019-02-26T04:59:32Z TRACE zookeeper::io] ready_timer thread=ThreadId(2)
[2019-02-26T04:59:32Z TRACE zookeeper::io] handle ping timeout
[2019-02-26T04:59:32Z TRACE zookeeper::io] clear_timeout: Ping
[2019-02-26T04:59:32Z TRACE zookeeper::io] Pinging V4(127.0.0.1:2181)
[2019-02-26T04:59:32Z TRACE zookeeper::io] event token=Token(3) ready=Readable
[2019-02-26T04:59:32Z TRACE zookeeper::io] ready_channel Ping
[2019-02-26T04:59:32Z TRACE zookeeper::io] event token=Token(1) ready=Writable
[2019-02-26T04:59:32Z TRACE zookeeper::io] Written 12 bytes
[2019-02-26T04:59:32Z TRACE zookeeper::io] event token=Token(1) ready=Readable
[2019-02-26T04:59:32Z TRACE zookeeper::io] Read 20 bytes
[2019-02-26T04:59:32Z TRACE zookeeper::io] Response chunk len = 16 buf len is 20
[2019-02-26T04:59:32Z TRACE zookeeper::io] handle_response in Connected state [16]
[2019-02-26T04:59:32Z TRACE zookeeper::io] Got ping response in 3.990355ms
[2019-02-26T04:59:32Z TRACE zookeeper::io] start_timeout: Ping
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment