Searched refs:publish (Results 1 – 5 of 5) sorted by relevance
| /redis-3.2.3/tests/unit/ |
| H A D | pubsub.tcl | 71 assert_equal 1 [r publish chan1 hello]
72 assert_equal 1 [r publish chan2 world]
78 assert_equal 0 [r publish chan1 hello]
79 assert_equal 1 [r publish chan2 world]
84 assert_equal 0 [r publish chan1 hello]
85 assert_equal 0 [r publish chan2 world]
97 assert_equal 2 [r publish chan1 hello]
110 assert_equal 0 [r publish chan1 hello]
111 assert_equal 0 [r publish chan2 hello]
112 assert_equal 0 [r publish chan3 hello]
[all …]
|
| H A D | obuf-limits.tcl | 12 r publish foo bar
34 r publish foo bar
60 r publish foo bar
|
| /redis-3.2.3/deps/lua/ |
| H A D | COPYRIGHT | 17 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
| /redis-3.2.3/src/ |
| H A D | cluster.h | 214 } publish; member
|
| H A D | cluster.c | 1582 ntohl(hdr->data.publish.msg.channel_len) + in clusterProcessPacket()
1583 ntohl(hdr->data.publish.msg.message_len); in clusterProcessPacket()
1914 channel_len = ntohl(hdr->data.publish.msg.channel_len); in clusterProcessPacket()
1915 message_len = ntohl(hdr->data.publish.msg.message_len); in clusterProcessPacket()
1917 (char*)hdr->data.publish.msg.bulk_data,channel_len); in clusterProcessPacket()
1919 (char*)hdr->data.publish.msg.bulk_data+channel_len, in clusterProcessPacket()
2348 hdr->data.publish.msg.channel_len = htonl(channel_len); in clusterSendPublish()
2349 hdr->data.publish.msg.message_len = htonl(message_len); in clusterSendPublish()
2360 memcpy(hdr->data.publish.msg.bulk_data,channel->ptr,sdslen(channel->ptr)); in clusterSendPublish()
2361 memcpy(hdr->data.publish.msg.bulk_data+sdslen(channel->ptr), in clusterSendPublish()
|