diff options
| author | michael-grunder <michael.grunder@gmail.com> | 2014-06-14 04:12:56 +0400 |
|---|---|---|
| committer | michael-grunder <michael.grunder@gmail.com> | 2015-05-06 01:00:51 +0300 |
| commit | 8890994857b19ec07d4b8b374ab6f0b7dd43c2ee (patch) | |
| tree | 4ea8d3aaa150544f6028ddbd0723747e6178bbaf /cluster_library.c | |
| parent | 2451c75ed8fbb11d4f444a2c68dc69e5941f8e95 (diff) | |
UNWATCH command.
Added the UNWATCH command which will deliver this command only to
nodes that we think we're watching.
Diffstat (limited to 'cluster_library.c')
| -rw-r--r-- | cluster_library.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cluster_library.c b/cluster_library.c index de407f43..3cb55238 100644 --- a/cluster_library.c +++ b/cluster_library.c @@ -1097,6 +1097,7 @@ PHPAPI int cluster_abort_exec(redisCluster *c TSRMLS_DC) { return -1; } SLOT_SOCK(c,fi->slot)->mode = ATOMIC; + SLOT_SOCK(c,fi->slot)->watching = 0; } fi = fi->next; } @@ -1129,10 +1130,9 @@ static int cluster_send_multi(redisCluster *c, short slot TSRMLS_DC) { return 0; } -/* Send a command to a specific node (without falling back), in addition we - * can check for a reply type if not sent as TYPE_EOF */ -PHPAPI int cluster_send_direct(redisCluster *c, short slot, char *cmd, - int cmd_len, REDIS_REPLY_TYPE rtype TSRMLS_DC) +/* Send a command to a specific slot */ +PHPAPI int cluster_send_slot(redisCluster *c, short slot, char *cmd, + int cmd_len, REDIS_REPLY_TYPE rtype TSRMLS_DC) { // Try only this node if(cluster_sock_write(c, slot, cmd, cmd_len, 1 TSRMLS_CC)==-1) { |