if (ret < 0) {
goto error;
}
-
- /* Flag that at least the metadata has been sent to the consumer. */
- session->consumer_fds_sent = 1;
}
/* Send channel and streams of it */
DBG("Kernel consumer FDs of metadata and channel streams sent");
+ session->consumer_fds_sent = 1;
return 0;
error:
assert(channel);
assert(socket);
- assert(socket->fd >= 0);
DBG("Sending kernel consumer destroy channel key %d", channel->fd);
assert(metadata);
assert(socket);
- assert(socket->fd >= 0);
DBG("Sending kernel consumer destroy channel key %d", metadata->fd);