Skip to content

Commit

Permalink
sync: export sync_wait() and sync_wake()
Browse files Browse the repository at this point in the history
Signed-off-by: Christian Brauner <christian.brauner@ubuntu.com>
  • Loading branch information
Christian Brauner committed Feb 26, 2021
1 parent 3bc80ee commit b63bc64
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 8 deletions.
16 changes: 8 additions & 8 deletions src/lxc/sync.c
Expand Up @@ -17,7 +17,7 @@

lxc_log_define(sync, lxc);

static int __sync_wait(int fd, int sequence)
int sync_wait(int fd, int sequence)
{
int sync = -1;
ssize_t ret;
Expand All @@ -41,7 +41,7 @@ static int __sync_wait(int fd, int sequence)
return 0;
}

static int __sync_wake(int fd, int sequence)
int sync_wake(int fd, int sequence)
{
int sync = sequence;

Expand All @@ -53,10 +53,10 @@ static int __sync_wake(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 __sync_wait(fd, sequence + 1);
return sync_wait(fd, sequence + 1);
}

int lxc_sync_barrier_parent(struct lxc_handler *handler, int sequence)
Expand All @@ -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)
{
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)
{
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)
{
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)
{
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)
Expand Down
2 changes: 2 additions & 0 deletions src/lxc/sync.h
Expand Up @@ -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_barrier_parent(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 */

0 comments on commit b63bc64

Please sign in to comment.