OpenSDN source code
|
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_ |
![]() | |
Status | status_ |
ClientContext | ctx_ |
CompletionQueue | cq_ |
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.
bool etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_active_ |
std::unique_ptr<ClientAsyncReaderWriter<WatchRequest,WatchResponse> > etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_reader_ |
WatchResponse etcd::etcdql::EtcdIf::EtcdAsyncWatchCall::watch_resp_ |