zookeeper-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephen Tyree <tyree...@gmail.com>
Subject Re: watcher semantics for session events in the C client
Date Fri, 25 Mar 2011 13:35:01 GMT
Yeah, it's a feature. You can think of those session events as notification
that the watcher will or will not be triggered in a given time period. Given
that watches are not triggered while you are not connected, and won't be
resent when you do become connected, having it so the watcher callbacks
receive session events as well is a way to allow consumers of Zookeeper to
prepare for and recover from situations where watches they expect to fire
might not. Also, if every time the network had a little blip your watchers
were reset that would get annoying quick. Blips in the connection could lead
to stampedes of resetting watches, which would be silly.

An example of the utility of this was in a notification system I set up.
Essentially, whenever I was notified in a watcher callback that I had just
been reconnected, I would check to see if my watcher should have fired in
the time I was disconnected. If it should have, I performed the notification
and reset the watch, otherwise I continued to wait.

On Thu, Mar 24, 2011 at 7:32 PM, Jeremy Stribling <strib@nicira.com> wrote:

> I'm using Zookeeper 3.3.3 and the multi-threaded C client, and ran into an
> issue where the same watch callback is being triggered twice, on two
> separate session events.  Here are the C client logs:
> 2011-03-23
> 17:25:10,180:10715(0x7f727b4cf710):ZOO_ERROR@handle_socket_error_msg@1603:
> Socket [] zk retcode=-4,
>  errno=112(Host is down): failed while receiving a server response
> 2011-03-23 17:25:10,180:10715(0x7f727b4cf710):ZOO_DEBUG@handle_error@1141:
> Calling a watcher for a ZOO_SESSION_EVENT and the state=CONNECTING_STATE
> 2011-03-23 17:25:10,180:10715(0x7f727b4cf710):ZOO_INFO@check_events@1585:
> initiated connection to server []
> 2011-03-23 17:25:10,181:10715(0x7f727b4cf710):ZOO_INFO@check_events@1632:
> session establishment complete on server [],
> sessionId=0xff2ee53bb56e0000, negotiated timeout=6000
> 2011-03-23 17:25:10,181:10715(0x7f727b4cf710):ZOO_DEBUG@send_set_watches@1312:
> Sending set watches request to
> 2011-03-23 17:25:10,181:10715(0x7f727b4cf710):ZOO_DEBUG@send_auth_info@1248:
> Sending all auth info request to
> 2011-03-23 17:25:10,181:10715(0x7f727b4cf710):ZOO_DEBUG@check_events@1638:
> Calling a watcher for a ZOO_SESSION_EVENT and the state=ZOO_CONNECTED_STATE
> 2011-03-23 17:25:10,181:10715(0x7f727acce710):ZOO_DEBUG@process_completions@1765:
> Calling a watcher for node [], type = -1 event=ZOO_SESSION_EVENT
> 2011-03-23 17:25:10,181:10715(0x7f727acce710):ZOO_DEBUG@process_completions@1765:
> Calling a watcher for node [], type = -1 event=ZOO_SESSION_EVENT
> You can see that one socket went down, it sent out a CONNECTING state
> change event, and then another socket came up, causing a CONNECTED state
> change event.  For each event, it looks like collectWatchers() just grabs
> all the watchers from the hashtable and queues them up in a list with the
> event.  Unlike with other non-session-related events, it looks like the
> watchers get left in the hashtable (collect_session_watchers() doesn't call
> hashtable_remove() like add_for_event() does), so both of these events have
> the same exact list of watchers in them.
> Looking at the documentation, it seems a bit ambiguous as to whether
> session events count toward the fire-exactly-one-time nature of watch
> events:
> > When a client connects to a new server, the watch will be triggered for
> any session events. Watches will not be received while disconnected from a
> server. When a client reconnects, any previously registered watches will be
> reregistered and triggered if needed.
> ...
> > Watches are one time triggers; if you get a watch event and you want to
> get notified of future changes, you must set another watch.
> ...
> > When you disconnect from a server (for example, when the server fails),
> you will not get any watches until the connection is reestablished. For this
> reason session events are sent to all outstanding watch handlers. Use
> session events to go into a safe mode: you will not be receiving events
> while disconnected, so your process should act conservatively in that mode.
> Should I expect to have a watch callback triggered more than once, if there
> are session events involved?  Thanks,
> Jeremy

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message