crash-log.txt

TRACE:mio::poll: registering with poller
TRACE:mio::poll: registering with poller
TRACE:mio::event_loop: event loop tick
INFO:zookeeper::io: Connecting to new server V4(172.x.x.x:2181)
INFO:zookeeper::io: Connected to V4(172.x.x.x:2181)
TRACE:mio::poll: registering with poller
TRACE:mio::event_loop: event loop tick
TRACE:zookeeper::io: notify Auth
TRACE:mio::timer: tick_to; now=0; tick=0
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 49 bytes
TRACE:zookeeper::io: Written 34 bytes
TRACE:mio::timer: inserted timout; slot=51; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 41 bytes
TRACE:zookeeper::io: Response chunk len = 37 buf len is 41
DEBUG:zookeeper::io: handle_response in Connecting state [37]
INFO:zookeeper::io: Connected: ConnectResponse { protocol_version: 0, timeout: 5000, session_id: 94332400970788574, passwd: [228, 23, 58, 154, 93, 45, 61, 219, 112, 141, 254, 143, 150, 164, 172, 26], read_only: false }
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 20 bytes
TRACE:zookeeper::io: Response chunk len = 16 buf len is 20
DEBUG:zookeeper::io: handle_response in Connected state [16]
DEBUG:zookeeper::io: send_response Opcode is Auth
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
authenticated -> Ok(())
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify Create
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 58 bytes
TRACE:mio::timer: unlinking timeout; slot=51; token=Token(0)
TRACE:mio::timer: inserted timout; slot=34; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 29 bytes
TRACE:zookeeper::io: Response chunk len = 25 buf len is 29
DEBUG:zookeeper::io: handle_response in Connected state [25]
DEBUG:zookeeper::io: send_response Opcode is Create
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
created -> Ok("/test")
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify Exists
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 22 bytes
TRACE:mio::timer: unlinking timeout; slot=34; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::timer: tick_to; now=1; tick=0
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 88 bytes
TRACE:zookeeper::io: Response chunk len = 84 buf len is 88
DEBUG:zookeeper::io: handle_response in Connected state [84]
DEBUG:zookeeper::io: send_response Opcode is Exists
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
exists -> Ok(Some(Stat { czxid: 12885254391, mzxid: 12885254391, ctime: 1441996261522, mtime: 1441996261522, version: 0, cversion: 0, aversion: 0, ephemeral_owner: 94332400970788574, data_length: 2, num_children: 0, pzxid: 12885254391 }))
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify Exists
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 24 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=0; tick=1
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 20 bytes
TRACE:zookeeper::io: Response chunk len = 16 buf len is 20
DEBUG:zookeeper::io: handle_response in Connected state [16]
DEBUG:zookeeper::io: send_response Opcode is Exists
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=1
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
don't exists path -> Ok(None)
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetAcl
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 21 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 115 bytes
TRACE:zookeeper::io: Response chunk len = 111 buf len is 115
DEBUG:zookeeper::io: handle_response in Connected state [111]
DEBUG:zookeeper::io: send_response Opcode is GetAcl
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
get_acl -> Ok(([Acl { perms: 31, scheme: "world", id: "anyone" }], Stat { czxid: 12885254391, mzxid: 12885254391, ctime: 1441996261522, mtime: 1441996261522, version: 0, cversion: 0, aversion: 0, ephemeral_owner: 94332400970788574, data_length: 2, num_children: 0, pzxid: 12885254391 }))
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify SetAcl
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 52 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 88 bytes
TRACE:zookeeper::io: Response chunk len = 84 buf len is 88
DEBUG:zookeeper::io: handle_response in Connected state [84]
DEBUG:zookeeper::io: send_response Opcode is SetAcl
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
set_acl -> Ok(Stat { czxid: 12885254391, mzxid: 12885254391, ctime: 1441996261522, mtime: 1441996261522, version: 0, cversion: 0, aversion: 1, ephemeral_owner: 94332400970788574, data_length: 2, num_children: 0, pzxid: 12885254391 })
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 18 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 177 bytes
TRACE:zookeeper::io: Response chunk len = 173 buf len is 177
DEBUG:zookeeper::io: handle_response in Connected state [173]
DEBUG:zookeeper::io: send_response Opcode is GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
children of / -> Ok(["test", "hbase", "sandbox-discovery", "zookeeper", "distributed-config", "sandbox", "consumers", "kafka", "discovery", "data-versions", "service-paths"])
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify SetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 33 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=35; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 125 bytes
TRACE:zookeeper::io: Response chunk len = 33 buf len is 125
DEBUG:zookeeper::io: handle_response in Connected state [33]
DEBUG:zookeeper::io: handle_response Got a watch event!
TRACE:zookeeper::io: Response chunk len = 84 buf len is 88
DEBUG:zookeeper::io: handle_response in Connected state [84]
DEBUG:zookeeper::io: send_response Opcode is SetData
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:mio::poll: registering with poller
INFO:zookeeper::watch: Event thread got response ReplyHeader { xid: -1, zxid: -1, err: 0 }
set_data -> Ok(Stat { czxid: 12885254391, mzxid: 12885254393, ctime: 1441996261522, mtime: 1441996261631, version: 1, cversion: 0, aversion: 1, ephemeral_owner: 94332400970788574, data_length: 4, num_children: 0, pzxid: 12885254391 })
TRACE:mio::timer: tick_to; now=1; tick=2
DEBUG:zookeeper::watch: WatchedEvent { event_type: NodeDataChanged, keeper_state: SyncConnected, path: Some("/test") }
INFO:zookeeper_example: WatchedEvent { event_type: NodeDataChanged, keeper_state: SyncConnected, path: Some("/test") }
TRACE:mio::event_loop: event loop tick
TRACE:mio::timer: tick_to; now=2; tick=2
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 22 bytes
TRACE:mio::timer: unlinking timeout; slot=35; token=Token(0)
TRACE:mio::timer: inserted timout; slot=36; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=1; tick=2
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 96 bytes
TRACE:zookeeper::io: Response chunk len = 92 buf len is 96
DEBUG:zookeeper::io: handle_response in Connected state [92]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=2
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
get_data -> Ok(([6, 5, 4, 3], Stat { czxid: 12885254391, mzxid: 12885254393, ctime: 1441996261522, mtime: 1441996261631, version: 1, cversion: 0, aversion: 1, ephemeral_owner: 94332400970788574, data_length: 4, num_children: 0, pzxid: 12885254391 }))
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 18 bytes
TRACE:mio::timer: unlinking timeout; slot=36; token=Token(0)
TRACE:mio::timer: inserted timout; slot=36; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 177 bytes
TRACE:zookeeper::io: Response chunk len = 173 buf len is 177
DEBUG:zookeeper::io: handle_response in Connected state [173]
DEBUG:zookeeper::io: send_response Opcode is GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:mio::timerwatch children -> Ok(["test", "hbase", "sandbox-discovery", "zookeeper", "distributed-config", "sandbox", "consumers", "kafka", "discovery", "data-versions", "service-paths"])
: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify Create
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 52 bytes
TRACE:mio::timer: unlinking timeout; slot=36; token=Token(0)
TRACE:mio::timer: inserted timout; slot=36; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 20 bytes
TRACE:zookeeper::io: Response chunk len = 16 buf len is 20
DEBUG:zookeeper::io: handle_response in Connected state [16]
DEBUG:zookeeper::io: send_response Opcode is Create
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
cache started
DEBUG:zookeeper::recipes::cache: handling op Refresh(ForceGetDataAndStat)
DEBUG:zookeeper::recipes::cache: getting children
DEBUG:zookeeper::recipes::cache: getting children "/"
press enter to close client
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 18 bytes
TRACE:mio::timer: unlinking timeout; slot=36; token=Token(0)
TRACE:mio::timer: inserted timout; slot=36; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 177 bytes
TRACE:zookeeper::io: Response chunk len = 173 buf len is 177
DEBUG:zookeeper::io: handle_response in Connected state [173]
DEBUG:zookeeper::io: send_response Opcode is GetChildren
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
DEBUG:zookeeper::recipes::cache: getting data "/test"
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 22 bytes
TRACE:mio::timer: unlinking timeout; slot=36; token=Token(0)
TRACE:mio::timer: inserted timout; slot=36; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 96 bytes
TRACE:zookeeper::io: Response chunk len = 92 buf len is 96
DEBUG:zookeeper::io: handle_response in Connected state [92]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
DEBUG:zookeeper::recipes::cache: getting data "/hbase"
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 23 bytes
TRACE:mio::timer: unlinking timeout; slot=36; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
DEBUG:zookeeper::recipes::cache: getting data "/sandbox-discovery"
TRACE:mio::timer: tick_to; now=3; tick=3
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 35 bytes
TRACE:mio::timer: unlinking timeout; slot=37; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=2; tick=3
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=3
TRACE:mio::timer: ticking; curr=Token(18446744073709551615)
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
DEBUG:zookeeper::recipes::cache: getting data "/zookeeper"
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 27 bytes
TRACE:mio::timer: unlinking timeout; slot=37; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
DEBUG:zookeeper::recipes::cache: getting data "/distributed-config"
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 36 bytes
TRACE:mio::timer: unlinking timeout; slot=37; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
DEBUG:zookeeper::recipes::cache: getting data "/sandbox"
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 25 bytes
TRACE:mio::timer: unlinking timeout; slot=37; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
DEBUG:zookeeper::recipes::cache: getting data "/consumers"
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:zookeeper::io: notify GetData
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Writable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Writable
TRACE:zookeeper::io: Written 27 bytes
TRACE:mio::timer: unlinking timeout; slot=37; token=Token(0)
TRACE:mio::timer: inserted timout; slot=37; token=Token(0)
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4
TRACE:mio::event_loop: event loop tick
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(1) }
TRACE:zookeeper::io: ready Token(1) Readable
TRACE:zookeeper::io: Read 92 bytes
TRACE:zookeeper::io: Response chunk len = 88 buf len is 92
DEBUG:zookeeper::io: handle_response in Connected state [88]
DEBUG:zookeeper::io: send_response Opcode is GetData
TRACE:mio::event_loop: event=IoEvent { kind: Readable, token: Token(18446744073709551615) }
TRACE:mio::poll: registering with poller
TRACE:mio::timer: tick_to; now=3; tick=4