From dff4e4e6d3a56123b00df48fdcd7a6de0a275aef Mon Sep 17 00:00:00 2001 From: Aris Adamantiadis Date: Tue, 22 Mar 2011 11:49:57 +0100 Subject: Implement ssh_blocking_flush() Based on code from Jan Willamowius --- src/session.c | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) (limited to 'src/session.c') diff --git a/src/session.c b/src/session.c index ab7cdff9..be428889 100644 --- a/src/session.c +++ b/src/session.c @@ -297,6 +297,31 @@ int ssh_is_blocking(ssh_session session){ return (session->flags&SSH_SESSION_FLAG_BLOCKING) ? 1 : 0; } +/** + * @brief Blocking flush of the outgoing buffer + * @param[in] session The SSH session + * @param[in] timeout Set an upper limit on the time for which this function + * will block, in milliseconds. Specifying a negative value + * means an infinite timeout. This parameter is passed to + * the poll() function. + * @returns SSH_OK on success, SSH_ERROR otherwise. + */ + +int ssh_blocking_flush(ssh_session session, int timeout){ + ssh_socket s; + if(session==NULL) + return SSH_ERROR; + + enter_function(); + s=session->socket; + while (ssh_socket_buffered_write_bytes(s) > 0 && session->alive) { + ssh_handle_packets(session, timeout); + } + + leave_function(); + return SSH_OK; +} + /** * @brief Check if we are connected. * -- cgit