assert(consumer);
/* Get the right path name destination */
- if (consumer->type == CONSUMER_DST_LOCAL) {
+ if (consumer->type == CONSUMER_DST_LOCAL ||
+ (consumer->type == CONSUMER_DST_NET &&
+ consumer->relay_major_version == 2 &&
+ consumer->relay_minor_version >= 11)) {
pathname = strdup(consumer->domain_subdir);
if (!pathname) {
PERROR("Failed to copy domain subdirectory string %s",
channel->channel->attr.tracefile_count,
monitor,
channel->channel->attr.live_timer_interval,
+ ksession->is_live_session,
channel_attr_extended->monitor_timer_interval,
ksession->current_trace_chunk);
consumer = ksession->consumer;
/* Prep channel message structure */
- consumer_init_add_channel_comm_msg(&lkm,
- ksession->metadata->key,
- ksession->id,
- DEFAULT_KERNEL_TRACE_DIR,
- ksession->uid,
- ksession->gid,
- consumer->net_seq_index,
- DEFAULT_METADATA_NAME,
- 1,
+ consumer_init_add_channel_comm_msg(&lkm, ksession->metadata->key,
+ ksession->id, "", ksession->uid, ksession->gid,
+ consumer->net_seq_index, DEFAULT_METADATA_NAME, 1,
DEFAULT_KERNEL_CHANNEL_OUTPUT,
- CONSUMER_CHANNEL_TYPE_METADATA,
- 0, 0,
- monitor, 0, 0, ksession->current_trace_chunk);
+ CONSUMER_CHANNEL_TYPE_METADATA, 0, 0, monitor, 0,
+ ksession->is_live_session, 0,
+ ksession->current_trace_chunk);
health_code_update();