diff options
| author | Zheng Chao <[email protected]> | 2022-11-08 20:55:25 +0800 |
|---|---|---|
| committer | Zheng Chao <[email protected]> | 2022-11-08 20:55:25 +0800 |
| commit | fc7db0fcb1c50d489611dd19a245223b2eb69902 (patch) | |
| tree | 9216440024d4aa4514b9fc5cce4257cf089d33b8 /include | |
| parent | 7e3367635c4030ca2a0d5c967b8b25bad38281e9 (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.h | 28 |
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 |
