From 5ca7b8d6dc836e7956f66c0e9115d4ea303bf519 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Adrien=20B=C3=A9raud?= <>
Date: Tue, 7 Nov 2023 09:15:08 -0500
Subject: [PATCH] python: add cancelPut
---
python/opendht.pyx | 4 ++++
python/opendht_cpp.pxd | 1 +
2 files changed, 5 insertions(+)
diff --git a/python/opendht.pyx b/python/opendht.pyx
index b251197d..e9170bd1 100644
--- a/python/opendht.pyx
+++ b/python/opendht.pyx
@@ -636,6 +636,10 @@ cdef class DhtRunner(_WithID):
while pending > 0:
lock.wait()
return ok
+
+ def cancelPut(self, InfoHash key, Value val):
+ self.thisptr.get().cancelPut(key._infohash, val._value)
+
def listen(self, InfoHash key, value_cb):
t = ListenToken()
t._h = key._infohash
diff --git a/python/opendht_cpp.pxd b/python/opendht_cpp.pxd
index 0a5b88a6..e07084a1 100644
--- a/python/opendht_cpp.pxd
+++ b/python/opendht_cpp.pxd
@@ -267,6 +267,7 @@ cdef extern from "opendht/dhtrunner.h" namespace "dht":
string getSearchesLog(sa_family_t af) const
void get(InfoHash key, GetCallback get_cb, DoneCallback done_cb, nullptr_t f, Where w)
void put(InfoHash key, shared_ptr[Value] val, DoneCallback done_cb, time_point created, bool permanent)
+ void cancelPut(InfoHash key, shared_ptr[Value] val)
ListenToken listen(InfoHash key, ValueCallback get_cb)
void cancelListen(InfoHash key, SharedListenToken token)
vector[unsigned] getNodeMessageStats(bool i)
--
GitLab