projects
/
ust.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
set the reader side of the buffer-ready pipe non-blocking (experimental)
[ust.git]
/
libust
/
relay.c
diff --git
a/libust/relay.c
b/libust/relay.c
index 3259adee432da29fb1b063605b1d7bab01be3255..a31cdf7a1ca3ad4b6dc5ff69eeba7da8e2b88b4f 100644
(file)
--- a/
libust/relay.c
+++ b/
libust/relay.c
@@
-26,6
+26,7
@@
#include <sys/mman.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/mman.h>
#include <sys/ipc.h>
#include <sys/shm.h>
+#include <fcntl.h>
//#include "list.h"
#include "relay.h"
#include "channels.h"
//#include "list.h"
#include "relay.h"
#include "channels.h"
@@
-1503,6
+1504,12
@@
static int ltt_relay_create_buffer(struct ltt_trace_struct *trace,
ltt_buf->data_ready_fd_read = fds[0];
ltt_buf->data_ready_fd_write = fds[1];
ltt_buf->data_ready_fd_read = fds[0];
ltt_buf->data_ready_fd_write = fds[1];
+ /* FIXME: do we actually need this? */
+ result = fcntl(fds[0], F_SETFL, O_NONBLOCK);
+ if(result == -1) {
+ PERROR("fcntl");
+ }
+
//ust// ltt_buf->commit_seq = malloc(sizeof(ltt_buf->commit_seq) * n_subbufs);
//ust// if(!ltt_buf->commit_seq) {
//ust// return -1;
//ust// ltt_buf->commit_seq = malloc(sizeof(ltt_buf->commit_seq) * n_subbufs);
//ust// if(!ltt_buf->commit_seq) {
//ust// return -1;
This page took
0.022933 seconds
and
4
git commands to generate.