We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents acf6c0e + 7dc12bb commit 52d9f5dCopy full SHA for 52d9f5d
src/fmq_client.c
@@ -338,13 +338,21 @@ process_the_patch (client_t *self)
338
}
339
340
sub_t *subscr = (sub_t *) zlist_first (self->subs);
341
+ int found = 0;
342
while (subscr) {
343
if (!strncmp (filename, subscr->path, strlen (subscr->path))) {
344
filename += strlen (subscr->path);
345
zsys_debug ("subscription found for %s", filename);
346
+ found = 1;
347
break;
348
349
+ subscr = (sub_t *) zlist_next (self->subs);
350
351
+ if (!found) {
352
+ zsys_debug ("subscription not found for %s", filename);
353
+ return;
354
+ }
355
+
356
if ('/' == *filename) filename++;
357
358
if (fmq_msg_operation (self->message) == FMQ_MSG_FILE_CREATE) {
0 commit comments