- /* Get the right path name destination */
- if (consumer->type == CONSUMER_DST_LOCAL) {
- /* Set application path to the destination path */
- ret = snprintf(tmp_path, sizeof(tmp_path), "%s/%s/%s",
- consumer->dst.trace_path, consumer->subdir, usess->path);
- if (ret < 0) {
- PERROR("snprintf stream path");
- goto error;
- }
- pathname = tmp_path;
- DBG3("UST local consumer tracefile path: %s", pathname);
- } else {
- ret = snprintf(tmp_path, sizeof(tmp_path), "%s/%s",
- consumer->subdir, usess->path);
- if (ret < 0) {
- PERROR("snprintf stream path");
- goto error;
- }
- pathname = tmp_path;
- DBG3("UST network consumer subdir path: %s", pathname);
- }
-
- cds_list_for_each_entry_safe(stream, tmp, &uchan->streams.head, list) {
- if (!stream->obj->shm_fd) {
- continue;
- }
-
- ret = send_channel_stream(sock, uchan, usess, stream, consumer,
- pathname);
- if (ret < 0) {
- goto error;
- }
- }
-
- DBG("UST consumer channel streams sent");
-
- return 0;
-