OpenSDN source code
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
etcd::etcdql::EtcdIf::EtcdAsyncWatchCall Struct Reference
Inheritance diagram for etcd::etcdql::EtcdIf::EtcdAsyncWatchCall:
Collaboration diagram for etcd::etcdql::EtcdIf::EtcdAsyncWatchCall:

Public Member Functions

void WaitForWatchResponse (WatchCb cb)
 

Public Attributes

std::unique_ptr
< ClientAsyncReaderWriter
< WatchRequest, WatchResponse > > 
watch_reader_
 
bool watch_active_
 
int wtag
 
WatchResponse watch_resp_
 
- Public Attributes inherited from etcd::etcdql::EtcdIf::EtcdAsyncCall
Status status_
 
ClientContext ctx_
 
CompletionQueue cq_
 

Detailed Description

For watch operation

Definition at line 165 of file eql_if.h.

Member Function Documentation

void EtcdIf::EtcdAsyncWatchCall::WaitForWatchResponse ( WatchCb  cb)

Waiting here for the notification of the next change

The tag is the memory location of the call object

Verify that the request was completed successfully. Note that "ok" corresponds solely to the request for updates introduced by Finish(). Also, stop watching if watch has been cancelled.

Read the Watch response. First time around, we won't have anything to read.

Got a change. Process it, populate the EtcdResponse and invoke the callback.

Invoke config client cb with watch response.

Continue watching for subsequent changes.

Definition at line 353 of file eql_if.cc.

Here is the call graph for this function:

Member Data Documentation

bool etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_active_

Definition at line 167 of file eql_if.h.

std::unique_ptr<ClientAsyncReaderWriter<WatchRequest,WatchResponse> > etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_reader_

Definition at line 166 of file eql_if.h.

WatchResponse etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_resp_

Definition at line 169 of file eql_if.h.

int etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::wtag

Definition at line 168 of file eql_if.h.


The documentation for this struct was generated from the following files: