From 2fc4c7e3359f6e046faab7cf0089a9375f4b5350 Mon Sep 17 00:00:00 2001 From: Aris Adamantiadis Date: Fri, 8 Jan 2010 22:25:26 +0100 Subject: Dequeue the processed messages --- libssh/messages.c | 20 +++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) (limited to 'libssh/messages.c') diff --git a/libssh/messages.c b/libssh/messages.c index 8dfe482..e5d6c3a 100644 --- a/libssh/messages.c +++ b/libssh/messages.c @@ -711,7 +711,7 @@ ssh_message ssh_message_get(ssh_session session) { } msg=ssh_list_get_head(ssh_message, session->ssh_message_list); } while(msg==NULL); - + msg=ssh_message_pop_head(session); leave_function(); return msg; } @@ -790,6 +790,24 @@ void ssh_message_queue(ssh_session session, ssh_message message){ } } +/** @internal + * @brief Pops one message from the message list and dequeue it. + * @param session SSH session. + * @returns The head message, or NULL if it doesn't exist + */ +ssh_message ssh_message_pop_head(ssh_session session){ + ssh_message msg=NULL; + struct ssh_iterator *i; + if(session->ssh_message_list == NULL) + return NULL; + i=ssh_list_get_iterator(session->ssh_message_list); + if(i != NULL){ + msg=ssh_iterator_value(ssh_message,i); + ssh_list_remove(session->ssh_message_list,i); + } + return msg; +} + /** * @} */ -- cgit