Skip to content

Commit 5220637

Browse files
committed
etcd - set watcher from-Index to the next revision to avoid current revision's event
1 parent f6d7111 commit 5220637

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/core/nixl_listener.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -360,7 +360,7 @@ class nixlEtcdClient {
360360

361361
// Get current index to watch from
362362
etcd::Response response = etcd->get(metadata_key);
363-
int64_t watch_index = response.index();
363+
int64_t watch_index = response.index() + 1;
364364
std::promise<nixl_status_t> ret_prom;
365365
auto future = ret_prom.get_future();
366366
std::atomic<bool> promise_set{false};

0 commit comments

Comments
 (0)