goto error;
}
- ret = consumer_set_subdir(session->consumer, session->name);
- if (ret < 0) {
- ret = LTTCOMM_FATAL;
- goto error;
- }
-
/* Append correct directory to subdir */
strncat(consumer->subdir, dir_name,
sizeof(consumer->subdir) - strlen(consumer->subdir) - 1);
pthread_mutex_lock(&kconsumer_data.pid_mutex);
if (kconsumer_data.pid > 0) {
ret = LTTCOMM_KERN_CONSUMER_FAIL;
+ pthread_mutex_unlock(&kconsumer_data.pid_mutex);
goto error;
}
pthread_mutex_unlock(&kconsumer_data.pid_mutex);