summaryrefslogtreecommitdiff
path: root/include
diff options
context:
space:
mode:
authorZheng Chao <[email protected]>2022-11-08 20:55:25 +0800
committerZheng Chao <[email protected]>2022-11-08 20:55:25 +0800
commitfc7db0fcb1c50d489611dd19a245223b2eb69902 (patch)
tree9216440024d4aa4514b9fc5cce4257cf089d33b8 /include
parent7e3367635c4030ca2a0d5c967b8b25bad38281e9 (diff)
Bugfix: node_t is not initialized in node_init_from_sockaddr(). The snet_thr selection should based on IP but not IP:port.
Diffstat (limited to 'include')
-rw-r--r--include/swarmkv/swarmkv.h28
1 files changed, 14 insertions, 14 deletions
diff --git a/include/swarmkv/swarmkv.h b/include/swarmkv/swarmkv.h
index c7b0785..8379bad 100644
--- a/include/swarmkv/swarmkv.h
+++ b/include/swarmkv/swarmkv.h
@@ -64,28 +64,28 @@ void swarmkv_close(struct swarmkv * db);
struct swarmkv_reply *swarmkv_command(struct swarmkv *db, const char *target, const char *format, ...);
//Non-blocking function
-typedef void swarmkv_cmd_callback_func_t(const struct swarmkv_reply *reply, void * arg);
-void swarmkv_command_async(struct swarmkv *db, swarmkv_cmd_callback_func_t * cb, void *cb_arg, const char *target, const char *format, ...);
+typedef void swarmkv_on_reply_callback_t(const struct swarmkv_reply *reply, void * arg);
+void swarmkv_command_async(struct swarmkv *db, swarmkv_on_reply_callback_t * cb, void *cb_arg, const char *target, const char *format, ...);
void swarmkv_get(struct swarmkv * db,
- const char * key, size_t keylen, swarmkv_cmd_callback_func_t * cb, void * arg);
+ const char * key, size_t keylen, swarmkv_on_reply_callback_t * cb, void * arg);
void swarmkv_set(struct swarmkv * db,
- const char * key, size_t keylen, const char * value, size_t vallen, swarmkv_cmd_callback_func_t * cb, void * arg);
+ const char * key, size_t keylen, const char * value, size_t vallen, swarmkv_on_reply_callback_t * cb, void * arg);
-void swarmkv_del(struct swarmkv * db, const char * key, size_t keylen, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_incrby(struct swarmkv * db, const char * key, size_t keylen, long long delta, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
+void swarmkv_del(struct swarmkv * db, const char * key, size_t keylen, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_incrby(struct swarmkv * db, const char * key, size_t keylen, long long delta, swarmkv_on_reply_callback_t *cb, void *cb_arg);
-void swarmkv_expire(struct swarmkv *db, const char *key, size_t keylen, int seconds, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_ttl(struct swarmkv *db, const char *key, size_t keylen, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_persist(struct swarmkv *db, const char *key, size_t keylen, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
+void swarmkv_expire(struct swarmkv *db, const char *key, size_t keylen, int seconds, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_ttl(struct swarmkv *db, const char *key, size_t keylen, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_persist(struct swarmkv *db, const char *key, size_t keylen, swarmkv_on_reply_callback_t *cb, void *cb_arg);
-void swarmkv_sadd(struct swarmkv *db, const char* key, size_t keylen, const char *member[], const size_t member_len[], size_t n_member, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_srem(struct swarmkv *db, const char* key, size_t keylen, const char *member[], const size_t member_len[], size_t n_member, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_sismember(struct swarmkv *db, const char* key, size_t keylen, const char *member, size_t member_len, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_smembers(struct swarmkv *db, const char* key, size_t keylen, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
-void swarmkv_scard(struct swarmkv *db, const char* key, size_t keylen, swarmkv_cmd_callback_func_t *cb, void *cb_arg);
+void swarmkv_sadd(struct swarmkv *db, const char* key, size_t keylen, const char *member[], const size_t member_len[], size_t n_member, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_srem(struct swarmkv *db, const char* key, size_t keylen, const char *member[], const size_t member_len[], size_t n_member, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_sismember(struct swarmkv *db, const char* key, size_t keylen, const char *member, size_t member_len, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_smembers(struct swarmkv *db, const char* key, size_t keylen, swarmkv_on_reply_callback_t *cb, void *cb_arg);
+void swarmkv_scard(struct swarmkv *db, const char* key, size_t keylen, swarmkv_on_reply_callback_t *cb, void *cb_arg);
//Used by swarmkv-cli