Skip to content

Instantly share code, notes, and snippets.

@eric

eric/01_preamble.txt

Last active December 17, 2015 23:49
Show Gist options
  • Save eric/5691639 to your computer and use it in GitHub Desktop.
Save eric/5691639 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
01_preamble.txt
reader: zookeeper: initiating connection to localhost:2181
reader: zookeeper: #zkc_set_running_and_notify!
reader: zookeeper: #event_thread_body starting event thread
reader: zookeeper: init returned!
reader: zookeeper: event_thread waiting until running: true
reader: zookeeper: event_thread running: true
zookeeper_server: Accepted socket connection from /fe80:0:0:0:0:0:0:1%1:54365
zookeeper_server: Accepted socket connection from /127.0.0.1:54366
zookeeper_server: Session establishment request from client /fe80:0:0:0:0:0:0:1%1:54365 client's lastZxid is 0x0
zookeeper_server: Connection request from old client /fe80:0:0:0:0:0:0:1%1:54365; will be dropped if server is in r-o mode
zookeeper_server: Client attempting to establish new session at /fe80:0:0:0:0:0:0:1%1:54365
zookeeper_server: SessionTrackerImpl --- Adding session 0x13f012d120b0006 20001
zookeeper_server: :Psessionid:0x13f012d120b0006 type:createSession cxid:0x0 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: Session establishment request from client /127.0.0.1:54366 client's lastZxid is 0x0
zookeeper_server: Connection request from old client /127.0.0.1:54366; will be dropped if server is in r-o mode
zookeeper_server: SessionTrackerImpl --- Existing session 0x13f012d120b0006 20001
zookeeper_server: Client attempting to establish new session at /127.0.0.1:54366
zookeeper_server: SessionTrackerImpl --- Adding session 0x13f012d120b0007 20001
zookeeper_server: :Psessionid:0x13f012d120b0007 type:createSession cxid:0x0 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: SessionTrackerImpl --- Existing session 0x13f012d120b0007 20001
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:createSession cxid:0x0 zxid:0x1a0a0 txntype:-10 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:createSession cxid:0x0 zxid:0x1a0a0 txntype:-10 reqpath:n/a
zookeeper_server: SessionTrackerImpl --- Existing session 0x13f012d120b0006 20001
zookeeper_server: sessionid:0x13f012d120b0006 type:createSession cxid:0x0 zxid:0x1a0a0 txntype:-10 reqpath:n/a
zookeeper_server: Established session 0x13f012d120b0006 with negotiated timeout 20001 for client /fe80:0:0:0:0:0:0:1%1:54365
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:createSession cxid:0x0 zxid:0x1a0a1 txntype:-10 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0007 type:createSession cxid:0x0 zxid:0x1a0a1 txntype:-10 reqpath:n/a
zookeeper_server: SessionTrackerImpl --- Existing session 0x13f012d120b0007 20001
zookeeper_server: sessionid:0x13f012d120b0007 type:createSession cxid:0x0 zxid:0x1a0a1 txntype:-10 reqpath:n/a
zookeeper_server: Established session 0x13f012d120b0007 with negotiated timeout 20001 for client /127.0.0.1:54366
reader: zookeeper: #iterate_event_delivery got {:type=>-1, :path=>"", :req_id=>-1, :state=>3}
reader: zookeeper: starting dispatch thread
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>-1, :path=>"", :req_id=>-1, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"session", :req_id=>:global_session, :path=>"", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x10925f8c8 @type=-1, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="">
reader: zk: wait_until_connected_or_dying @last_cnx_state: 3, time_left? true, @client_state: :running
reader: zookeeper: async_args, meth: exists ary: [0, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x10925dcd0 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0006 type:getChildren2 cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:getChildren2 cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0006 type:getChildren2 cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: sessionid:0x13f012d120b0006 type:getChildren2 cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b64 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>0, :stat=>nil, :rc=>-101}
reader: zookeeper: continuation req_id 0, got hash: {:req_id=>0, :stat=>nil, :rc=>-101}
reader: zookeeper: delivering result [-101, nil]
zookeeper_server: :Psessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b65 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b65 zxid:0x1a0a2 txntype:2 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b65 zxid:0x1a0a2 txntype:2 reqpath:n/a
zookeeper_server: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b65 zxid:0x1a0a2 txntype:2 reqpath:n/a
zookeeper_server: :Psessionid:0x13f012d120b0006 type:create cxid:0x51aa5b66 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b66 zxid:0x1a0a3 txntype:1 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:create cxid:0x51aa5b66 zxid:0x1a0a3 txntype:1 reqpath:n/a
zookeeper_server: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b66 zxid:0x1a0a3 txntype:1 reqpath:n/a
Raw
01_run.txt
-- 1 --
CREATE
zookeeper_server: :Psessionid:0x13f012d120b0006 type:create cxid:0x51aa5b67 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b67 zxid:0x1a0a4 txntype:1 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:create cxid:0x51aa5b67 zxid:0x1a0a4 txntype:1 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>1, :path=>"/test/path/child", :req_id=>0, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b67 zxid:0x1a0a4 txntype:1 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>1, :path=>"/test/path/child", :req_id=>0, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"created", :req_id=>0, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x10925dcd0 @type=1, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {}>, :data=>#<Set: {}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x10925dcd0 @type=1, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_CREATED_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [1, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x109259400 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b65 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b65 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b65 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b65 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>1, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660], :rc=>0}
reader: zookeeper: continuation req_id 1, got hash: {:req_id=>1, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660], :rc=>0}
reader: zookeeper: delivering result [0, [106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660]]
CHILDREN
reader: zookeeper: async_args, meth: get_children ary: [2, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x1092572e0 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b66 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b66 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b66 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b66 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>2, :strings=>[], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660], :rc=>0}
reader: zookeeper: continuation req_id 2, got hash: {:req_id=>2, :strings=>[], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660], :rc=>0}
reader: zookeeper: delivering result [0, [], [106660, 106660, 1370119012700, 1370119012700, 0, 0, 0, 0, 17, 0, 106660]]
zookeeper_server: Processing request:: sessionid:0x13d906e108603d4 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: sessionid:0x13d906e108603d4 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
ADD_CHILD
zookeeper_server: :Psessionid:0x13f012d120b0006 type:create cxid:0x51aa5b68 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child/foo
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b68 zxid:0x1a0a5 txntype:1 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:create cxid:0x51aa5b68 zxid:0x1a0a5 txntype:1 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>4, :path=>"/test/path/child", :req_id=>2, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b68 zxid:0x1a0a5 txntype:1 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>4, :path=>"/test/path/child", :req_id=>2, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"child", :req_id=>2, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x1092572e0 @type=4, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {}>, :data=>#<Set: {"/test/path/child"}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x1092572e0 @type=4, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_CHILD_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [3, "/test/path/child", nil, nil], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b67 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b67 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b67 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b67 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>3, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661], :rc=>0}
reader: zookeeper: continuation req_id 3, got hash: {:req_id=>3, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661], :rc=>0}
reader: zookeeper: delivering result [0, [106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661]]
CHILDREN
reader: zookeeper: async_args, meth: get_children ary: [4, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x109250558 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b68 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b68 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b68 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b68 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>4, :strings=>["foo"], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661], :rc=>0}
reader: zookeeper: continuation req_id 4, got hash: {:req_id=>4, :strings=>["foo"], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661], :rc=>0}
reader: zookeeper: delivering result [0, ["foo"], [106660, 106660, 1370119012700, 1370119012700, 0, 1, 0, 0, 17, 1, 106661]]
DELETE_CHILD
zookeeper_server: :Psessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b69 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child/foo
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b69 zxid:0x1a0a6 txntype:2 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b69 zxid:0x1a0a6 txntype:2 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>4, :path=>"/test/path/child", :req_id=>4, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b69 zxid:0x1a0a6 txntype:2 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>4, :path=>"/test/path/child", :req_id=>4, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"child", :req_id=>4, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x109250558 @type=4, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {}>, :data=>#<Set: {"/test/path/child"}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x109250558 @type=4, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_CHILD_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [5, "/test/path/child", nil, nil], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b69 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b69 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b69 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b69 zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>5, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662], :rc=>0}
reader: zookeeper: continuation req_id 5, got hash: {:req_id=>5, :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662], :rc=>0}
reader: zookeeper: delivering result [0, [106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662]]
CHILDREN
reader: zookeeper: async_args, meth: get_children ary: [6, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x109249488 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6a zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6a zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6a zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6a zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>6, :strings=>[], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662], :rc=>0}
reader: zookeeper: continuation req_id 6, got hash: {:req_id=>6, :strings=>[], :stat=>[106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662], :rc=>0}
reader: zookeeper: delivering result [0, [], [106660, 106660, 1370119012700, 1370119012700, 0, 2, 0, 0, 17, 0, 106662]]
DELETE
zookeeper_server: :Psessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6a zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6a zxid:0x1a0a7 txntype:2 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6a zxid:0x1a0a7 txntype:2 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>2, :path=>"/test/path/child", :req_id=>6, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6a zxid:0x1a0a7 txntype:2 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>2, :path=>"/test/path/child", :req_id=>6, :state=>3}
reader: zookeeper: #iterate_event_delivery got {:type=>2, :path=>"/test/path/child", :req_id=>1, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"deleted", :req_id=>6, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x109249488 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>2, :path=>"/test/path/child", :req_id=>1, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"deleted", :req_id=>1, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x109259400 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {"/test/path/child"}>, :data=>#<Set: {}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x109249488 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_DELETED_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [7, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x109243178 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6b zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6b zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6b zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6b zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>7, :stat=>nil, :rc=>-101}
reader: zookeeper: continuation req_id 7, got hash: {:req_id=>7, :stat=>nil, :rc=>-101}
reader: zookeeper: delivering result [-101, nil]
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {"/test/path/child"}>, :data=>#<Set: {"/test/path/child"}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x109259400 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_DELETED_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [8, "/test/path/child", nil, nil], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6c zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6c zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6c zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6c zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>8, :stat=>nil, :rc=>-101}
reader: zookeeper: continuation req_id 8, got hash: {:req_id=>8, :stat=>nil, :rc=>-101}
reader: zookeeper: delivering result [-101, nil]
Raw
02_run.txt
-- 2 --
CREATE
zookeeper_server: :Psessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6b zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6b zxid:0x1a0a8 txntype:1 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6b zxid:0x1a0a8 txntype:1 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>1, :path=>"/test/path/child", :req_id=>7, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6b zxid:0x1a0a8 txntype:1 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>1, :path=>"/test/path/child", :req_id=>7, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"created", :req_id=>7, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x109243178 @type=1, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {"/test/path/child"}>, :data=>#<Set: {}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x109243178 @type=1, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_CREATED_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [9, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x10923bbd0 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6d zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6d zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6d zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6d zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>9, :stat=>[106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664], :rc=>0}
reader: zookeeper: continuation req_id 9, got hash: {:req_id=>9, :stat=>[106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664], :rc=>0}
reader: zookeeper: delivering result [0, [106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664]]
CHILDREN
reader: zookeeper: async_args, meth: get_children ary: [10, "/test/path/child", nil, nil], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6e zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6e zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6e zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:getChildren2 cxid:0x51aa5b6e zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>10, :strings=>[], :stat=>[106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664], :rc=>0}
reader: zookeeper: continuation req_id 10, got hash: {:req_id=>10, :strings=>[], :stat=>[106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664], :rc=>0}
reader: zookeeper: delivering result [0, [], [106664, 106664, 1370119016718, 1370119016718, 0, 0, 0, 0, 17, 0, 106664]]
ADD_CHILD
zookeeper_server: :Psessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6c zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child/foo
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6c zxid:0x1a0a9 txntype:1 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6c zxid:0x1a0a9 txntype:1 reqpath:n/a
zookeeper_server: sessionid:0x13f012d120b0006 type:create cxid:0x51aa5b6c zxid:0x1a0a9 txntype:1 reqpath:n/a
DELETE_CHILD
zookeeper_server: :Psessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6d zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child/foo
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6d zxid:0x1a0aa txntype:2 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6d zxid:0x1a0aa txntype:2 reqpath:n/a
zookeeper_server: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6d zxid:0x1a0aa txntype:2 reqpath:n/a
DELETE
zookeeper_server: :Psessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6e zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6e zxid:0x1a0ab txntype:2 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6e zxid:0x1a0ab txntype:2 reqpath:n/a
reader: zookeeper: #iterate_event_delivery got {:type=>2, :path=>"/test/path/child", :req_id=>9, :state=>3}
zookeeper_server: sessionid:0x13f012d120b0006 type:delete cxid:0x51aa5b6e zxid:0x1a0ab txntype:2 reqpath:n/a
reader: zookeeper: Zookeeper::Client#get_next_event delivering event {:type=>2, :path=>"/test/path/child", :req_id=>9, :state=>3}
reader: zookeeper: get_next_event returned: {:type=>"deleted", :req_id=>9, :path=>"/test/path/child", :state=>"connected"}
reader: zk: EventHandler#process dispatching event: #<Zookeeper::Callbacks::WatcherCallback:0x10923bbd0 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=false, @path="/test/path/child">
reader: zk: called #<ZK::EventHandlerSubscription::Base:0x10925e108 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:70>, @mutex=#<ZK::Monitor:0x10925e090 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 @orig_pid=9322, @outstanding_watches={:child=>#<Set: {"/test/path/child"}>, :data=>#<Set: {}>}, @mutex=#<ZK::Monitor:0x1092630e0 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @state=:running, @callbacks={:all_node_events=>[], "/test/path/child"=>[#<ZK::EventHandlerSubscription::Base:0x10925e108 ...>], :all_state_events=>[], "state_3"=>[#<ZK::EventHandlerSubscription::Base:0x10925c010 @interests=#<Set: {:changed, :created, :child, :deleted}>, @callable=#<Proc:[email protected]:83>, @mutex=#<ZK::Monitor:0x10925bf98 @mon_entering_queue=[], @mon_count=0, @mon_owner=nil, @mon_waiting_queue=[]>, @parent=#<ZK::EventHandler:0x1092633b0 ...>, @path="state_3">]}, @default_watcher_block=#<Proc:0x000000010938d808@/Users/eric/src/zk/lib/zk/event_handler.rb:251>, @thread_opt=:single, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>>, @path="/test/path/child"> with [#<Zookeeper::Callbacks::WatcherCallback:0x10923bbd0 @type=2, @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @state=3, @context=nil, @completed=true, @zk=#<ZK::Client::Threaded:2224233380 zk_session_id=0x13f012d120b0007 ...>, @path="/test/path/child">] on threadpool
ZOO_DELETED_EVENT: /test/path/child
STAT
reader: zookeeper: async_args, meth: exists ary: [11, "/test/path/child", nil, #<Zookeeper::Callbacks::WatcherCallback:0x109234e98 @proc=#<Proc:0x0000000108bbad38@/Users/eric/src/zk/vendor/bundle/gems/zookeeper-1.4.4/lib/zookeeper/callbacks.rb:24>, @completed=false>], 2
zookeeper_server: :Psessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6f zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6f zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: :Esessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6f zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
zookeeper_server: sessionid:0x13f012d120b0007 type:exists cxid:0x51aa5b6f zxid:0xfffffffffffffffe txntype:unknown reqpath:/test/path/child
reader: zookeeper: #iterate_event_delivery got {:req_id=>11, :stat=>nil, :rc=>-101}
reader: zookeeper: continuation req_id 11, got hash: {:req_id=>11, :stat=>nil, :rc=>-101}
reader: zookeeper: delivering result [-101, nil]
zookeeper_server: Processing request:: sessionid:0x13d906e108603d4 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: sessionid:0x13d906e108603d4 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
Raw
03_postamble.txt
DONE
reader: zookeeper: Zookeeper::Client#stop_dispatch_thread!
reader: zookeeper: Zookeeper::Common::QueueWithPipe#graceful_close! gracefully closing
reader: zookeeper: dispatch thread exiting, got shutdown exception
reader: zookeeper: dispatch thread exiting!
reader: zookeeper: #stop_event_thread
reader: zookeeper: #shut_down!
reader: zookeeper: we're in shutting down state, there are 0 in_flight completions
reader: zookeeper: finished completions
reader: zookeeper: there are 0 completions to awaken
reader: zookeeper: #event_thread_body exiting
reader: zookeeper: CALLING CLOSE HANDLE!!
zookeeper_server: caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x13f012d120b0006, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:220)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:224)
at java.lang.Thread.run(Thread.java:722)
zookeeper_server: :Psessionid:0x13f012d120b0006 type:closeSession cxid:0x51aa5b6f zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: Session closing: 0x13f012d120b0006
zookeeper_server: Processed session termination for sessionid: 0x13f012d120b0006
zookeeper_server: Closed socket connection for client /fe80:0:0:0:0:0:0:1%1:54365 which had sessionid 0x13f012d120b0006
zookeeper_server: Processing request:: sessionid:0x13f012d120b0006 type:closeSession cxid:0x51aa5b6f zxid:0x1a0ac txntype:-11 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0006 type:closeSession cxid:0x51aa5b6f zxid:0x1a0ac txntype:-11 reqpath:n/a
zookeeper_server: :Psessionid:0x13f012d120b0007 type:closeSession cxid:0x51aa5b70 zxid:0xfffffffffffffffe txntype:unknown reqpath:n/a
zookeeper_server: SessionTrackerImpl --- Removing session 0x13f012d120b0006
zookeeper_server: sessionid:0x13f012d120b0006 type:closeSession cxid:0x51aa5b6f zxid:0x1a0ac txntype:-11 reqpath:n/a
zookeeper_server: Unexpected Exception:
java.nio.channels.CancelledKeyException
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77)
at org.apache.zookeeper.server.NIOServerCnxn.sendBuffer(NIOServerCnxn.java:153)
at org.apache.zookeeper.server.NIOServerCnxn.sendResponse(NIOServerCnxn.java:1075)
at org.apache.zookeeper.server.FinalRequestProcessor.processRequest(FinalRequestProcessor.java:403)
at org.apache.zookeeper.server.SyncRequestProcessor.flush(SyncRequestProcessor.java:165)
at org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:101)
zookeeper_server: Add a buffer to outgoingBuffers, sk sun.nio.ch.SelectionKeyImpl@2ecca280 is valid: false
zookeeper_server: caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x13f012d120b0007, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:220)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:224)
at java.lang.Thread.run(Thread.java:722)
zookeeper_server: Session closing: 0x13f012d120b0007
zookeeper_server: Closed socket connection for client /127.0.0.1:54366 which had sessionid 0x13f012d120b0007
zookeeper_server: Processed session termination for sessionid: 0x13f012d120b0007
zookeeper_server: Processing request:: sessionid:0x13f012d120b0007 type:closeSession cxid:0x51aa5b70 zxid:0x1a0ad txntype:-11 reqpath:n/a
zookeeper_server: :Esessionid:0x13f012d120b0007 type:closeSession cxid:0x51aa5b70 zxid:0x1a0ad txntype:-11 reqpath:n/a
zookeeper_server: SessionTrackerImpl --- Removing session 0x13f012d120b0007
zookeeper_server: sessionid:0x13f012d120b0007 type:closeSession cxid:0x51aa5b70 zxid:0x1a0ad txntype:-11 reqpath:n/a
zookeeper_server: Unexpected Exception:
java.nio.channels.CancelledKeyException
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
at sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:77)
at org.apache.zookeeper.server.NIOServerCnxn.sendBuffer(NIOServerCnxn.java:153)
at org.apache.zookeeper.server.NIOServerCnxn.sendResponse(NIOServerCnxn.java:1075)
at org.apache.zookeeper.server.FinalRequestProcessor.processRequest(FinalRequestProcessor.java:403)
at org.apache.zookeeper.server.SyncRequestProcessor.flush(SyncRequestProcessor.java:165)
at org.apache.zookeeper.server.SyncRequestProcessor.run(SyncRequestProcessor.java:101)
zookeeper_server: Add a buffer to outgoingBuffers, sk sun.nio.ch.SelectionKeyImpl@75806022 is valid: false
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment