diff options
Diffstat (limited to 'server/red_channel.h')
-rw-r--r-- | server/red_channel.h | 22 |
1 files changed, 14 insertions, 8 deletions
diff --git a/server/red_channel.h b/server/red_channel.h index 676e1ef5..9e54dcec 100644 --- a/server/red_channel.h +++ b/server/red_channel.h @@ -612,14 +612,20 @@ int red_client_during_migrate_at_target(RedClient *client); void red_client_migrate(RedClient *client); -/* blocking function */ -void red_channel_client_wait_pipe_item_sent(RedChannelClient *rcc, - PipeItem *item); - -/* blocking function */ -void red_wait_outgoing_item(RedChannelClient *rcc); +/* + * blocking functions. + * + * timeout is in nano sec. -1 for no timeout. + * + * Return: TRUE if waiting succeeded. FALSE if timeout expired. + */ -/* blocking function */ -void red_channel_wait_all_sent(RedChannel *channel); +int red_channel_client_wait_pipe_item_sent(RedChannelClient *rcc, + PipeItem *item, + int64_t timeout); +int red_channel_client_wait_outgoing_item(RedChannelClient *rcc, + int64_t timeout); +int red_channel_wait_all_sent(RedChannel *channel, + int64_t timeout); #endif |