Skip to content

Commit a8b3a75

Browse files
rebasing with updated client command
Signed-off-by: Sarthak Aggarwal <[email protected]>
1 parent 11c10cf commit a8b3a75

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

src/networking.c

+6-6
Original file line numberDiff line numberDiff line change
@@ -3747,24 +3747,24 @@ static int clientMatchesFlagFilter(client *c, const char *flag_filter) {
37473747
}
37483748

37493749
static int clientSubscribedToChannel(client *client, robj *channel) {
3750-
if (client == NULL || client->pubsub_channels == NULL) {
3750+
if (client == NULL || client->pubsub_data == NULL || client->pubsub_data->pubsub_channels == NULL) {
37513751
return 0;
37523752
}
3753-
return dictFind(client->pubsub_channels, channel) != NULL;
3753+
return dictFind(client->pubsub_data->pubsub_channels, channel) != NULL;
37543754
}
37553755

37563756
static int clientSubscribedToShardChannel(client *client, robj *channel) {
3757-
if (client == NULL || client->pubsubshard_channels == NULL) {
3757+
if (client == NULL || client->pubsub_data == NULL || client->pubsub_data->pubsubshard_channels == NULL) {
37583758
return 0;
37593759
}
3760-
return dictFind(client->pubsubshard_channels, channel) != NULL;
3760+
return dictFind(client->pubsub_data->pubsubshard_channels, channel) != NULL;
37613761
}
37623762

37633763
static int clientSubscribedToPattern(client *client, robj *pattern) {
3764-
if (client == NULL || client->pubsub_patterns == NULL) {
3764+
if (client == NULL || client->pubsub_data == NULL || client->pubsub_data->pubsub_patterns == NULL) {
37653765
return 0;
37663766
}
3767-
return dictFind(client->pubsub_patterns, pattern) != NULL;
3767+
return dictFind(client->pubsub_data->pubsub_patterns, pattern) != NULL;
37683768
}
37693769

37703770

0 commit comments

Comments
 (0)