sync: export sync_wait() and sync_wake()

parent 74ce42b5
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
lxc_log_define(sync, lxc); lxc_log_define(sync, lxc);
static int __sync_wait(int fd, int sequence) int sync_wait(int fd, int sequence)
{ {
int sync = -1; int sync = -1;
ssize_t ret; ssize_t ret;
...@@ -41,7 +41,7 @@ static int __sync_wait(int fd, int sequence) ...@@ -41,7 +41,7 @@ static int __sync_wait(int fd, int sequence)
return 0; return 0;
} }
static int __sync_wake(int fd, int sequence) int sync_wake(int fd, int sequence)
{ {
int sync = sequence; int sync = sequence;
...@@ -53,10 +53,10 @@ static int __sync_wake(int fd, int sequence) ...@@ -53,10 +53,10 @@ static int __sync_wake(int fd, int sequence)
static int __sync_barrier(int fd, int sequence) static int __sync_barrier(int fd, int sequence)
{ {
if (__sync_wake(fd, sequence)) if (sync_wake(fd, sequence))
return -1; return -1;
return __sync_wait(fd, sequence + 1); return sync_wait(fd, sequence + 1);
} }
int lxc_sync_barrier_parent(struct lxc_handler *handler, int sequence) int lxc_sync_barrier_parent(struct lxc_handler *handler, int sequence)
...@@ -76,25 +76,25 @@ int lxc_sync_barrier_child(struct lxc_handler *handler, int sequence) ...@@ -76,25 +76,25 @@ int lxc_sync_barrier_child(struct lxc_handler *handler, int sequence)
int lxc_sync_wake_parent(struct lxc_handler *handler, int sequence) int lxc_sync_wake_parent(struct lxc_handler *handler, int sequence)
{ {
TRACE("Child waking parent with sequence %s", sync_to_string(sequence)); TRACE("Child waking parent with sequence %s", sync_to_string(sequence));
return __sync_wake(handler->sync_sock[0], sequence); return sync_wake(handler->sync_sock[0], sequence);
} }
int lxc_sync_wait_parent(struct lxc_handler *handler, int sequence) int lxc_sync_wait_parent(struct lxc_handler *handler, int sequence)
{ {
TRACE("Parent waiting for child with sequence %s", sync_to_string(sequence)); TRACE("Parent waiting for child with sequence %s", sync_to_string(sequence));
return __sync_wait(handler->sync_sock[0], sequence); return sync_wait(handler->sync_sock[0], sequence);
} }
int lxc_sync_wait_child(struct lxc_handler *handler, int sequence) int lxc_sync_wait_child(struct lxc_handler *handler, int sequence)
{ {
TRACE("Child waiting for parent with sequence %s", sync_to_string(sequence)); TRACE("Child waiting for parent with sequence %s", sync_to_string(sequence));
return __sync_wait(handler->sync_sock[1], sequence); return sync_wait(handler->sync_sock[1], sequence);
} }
int lxc_sync_wake_child(struct lxc_handler *handler, int sequence) int lxc_sync_wake_child(struct lxc_handler *handler, int sequence)
{ {
TRACE("Child waking parent with sequence %s", sync_to_string(sequence)); TRACE("Child waking parent with sequence %s", sync_to_string(sequence));
return __sync_wake(handler->sync_sock[1], sequence); return sync_wake(handler->sync_sock[1], sequence);
} }
int lxc_sync_init(struct lxc_handler *handler) int lxc_sync_init(struct lxc_handler *handler)
......
...@@ -58,5 +58,7 @@ __hidden extern int lxc_sync_wake_parent(struct lxc_handler *, int); ...@@ -58,5 +58,7 @@ __hidden extern int lxc_sync_wake_parent(struct lxc_handler *, int);
__hidden extern int lxc_sync_wait_parent(struct lxc_handler *, int); __hidden extern int lxc_sync_wait_parent(struct lxc_handler *, int);
__hidden extern int lxc_sync_barrier_parent(struct lxc_handler *, int); __hidden extern int lxc_sync_barrier_parent(struct lxc_handler *, int);
__hidden extern int lxc_sync_barrier_child(struct lxc_handler *, int); __hidden extern int lxc_sync_barrier_child(struct lxc_handler *, int);
__hidden extern int sync_wait(int fd, int sequence);
__hidden extern int sync_wake(int fd, int sequence);
#endif /* __LXC_SYNC_H */ #endif /* __LXC_SYNC_H */
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment