char path_trace[PATH_MAX];
int path_trace_len;
char *path_trace_ptr;
- int open_ret = 0;
+ int open_ret = 0;
if(channel_dir == NULL) {
perror(subchannel_name);
open_ret = ENOENT;
- goto end;
+ goto end;
}
printf("Creating trace subdirectory %s\n", subtrace_name);
if(ret == -1) {
if(errno != EEXIST) {
perror(subtrace_name);
- open_ret = -1;
+ open_ret = -1;
goto end;
}
}
} else {
printf("File %s exists, cannot open. Try append mode.\n", path_trace);
open_ret = -1;
- goto end;
+ goto end;
}
} else {
if(errno == ENOENT) {
printf("cookie : %u\n", consumed_old);
if(err != 0) {
ret = errno;
- perror("Reserving sub buffer failed (everything is normal)");
+ perror("Reserving sub buffer failed (everything is normal, it is due to concurrency)");
goto get_error;
}
err = ioctl(pair->channel, RELAYFS_PUT_SUBBUF, &consumed_old);
if(err != 0) {
ret = errno;
- if(errno == -EFAULT) {
+ if(errno == EFAULT) {
perror("Error in unreserving sub buffer\n");
- } else if(errno == -EIO) {
+ } else if(errno == EIO) {
perror("Reader has been pushed by the writer, last subbuffer corrupted.");
/* FIXME : we may delete the last written buffer if we wish. */
}
high_prio = 1;
/* it's ok to have an unavailable subbuffer */
ret = read_subbuffer(&fd_pairs->pair[i]);
- if(ret == -EAGAIN) ret = 0;
+ if(ret == EAGAIN) ret = 0;
ret = pthread_mutex_unlock(&fd_pairs->pair[i].mutex);
if(ret)
printf("Normal read on fd %d\n", pollfd[i].fd);
/* it's ok to have an unavailable subbuffer */
ret = read_subbuffer(&fd_pairs->pair[i]);
- if(ret == -EAGAIN) ret = 0;
+ if(ret == EAGAIN) ret = 0;
ret = pthread_mutex_unlock(&fd_pairs->pair[i].mutex);
if(ret)
if(daemon_mode) {
ret = daemon(0, 0);
-
- if(ret == -1) {
- perror("An error occured while daemonizing.");
- exit(-1);
- }
- }
+
+ if(ret == -1) {
+ perror("An error occured while daemonizing.");
+ exit(-1);
+ }
+ }
/* Connect the signal handlers */
act.sa_handler = handler;