shinys000114/libssh
1
0
Fork 0
mirror of https://git.libssh.org/projects/libssh.git synced 2026-02-09 09:54:25 +09:00
Code Issues Packages Projects Releases Wiki Activity

Renamed message_queue to ssh_message_queue

Browse Source
This commit is contained in:
Aris Adamantiadis
2010-01-08 22:16:00 +01:00
parent 12db7c4bc1
commit da8263b3f6
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/libssh/messages.h
View File

@@ -84,6 +84,6 @@ SSH_PACKET_CALLBACK(ssh_packet_userauth_request);
int message_handle_channel_request(ssh_session session, ssh_channel channel, ssh_buffer packet, int message_handle_channel_request(ssh_session session, ssh_channel channel, ssh_buffer packet,
const char *request, uint8_t want_reply); const char *request, uint8_t want_reply);
int ssh_execute_message_callbacks(ssh_session session); int ssh_execute_message_callbacks(ssh_session session);
void message_queue(ssh_session session, ssh_message message); void ssh_message_queue(ssh_session session, ssh_message message);
#endif /* MESSAGES_H_ */ #endif /* MESSAGES_H_ */

10
libssh/messages.c
View File

@@ -91,7 +91,7 @@ SSH_PACKET_CALLBACK(ssh_packet_service_request){
error: error:
string_free(service); string_free(service);
if(msg != NULL) if(msg != NULL)
message_queue(session,msg); ssh_message_queue(session,msg);
leave_function(); leave_function();
return SSH_PACKET_USED; return SSH_PACKET_USED;
} }
@@ -281,7 +281,7 @@ error:
leave_function(); leave_function();
return SSH_PACKET_USED; return SSH_PACKET_USED;
end: end:
message_queue(session,msg); ssh_message_queue(session,msg);
leave_function(); leave_function();
return SSH_PACKET_USED; return SSH_PACKET_USED;
} }
@@ -439,7 +439,7 @@ end:
string_free(type_s); string_free(type_s);
SAFE_FREE(type_c); SAFE_FREE(type_c);
if(msg != NULL) if(msg != NULL)
message_queue(session,msg); ssh_message_queue(session,msg);
leave_function(); leave_function();
return SSH_PACKET_USED; return SSH_PACKET_USED;
} }
@@ -656,7 +656,7 @@ int message_handle_channel_request(ssh_session session, ssh_channel channel, ssh
msg->channel_request.type = SSH_CHANNEL_UNKNOWN; msg->channel_request.type = SSH_CHANNEL_UNKNOWN;
end: end:
message_queue(session,msg); ssh_message_queue(session,msg);
leave_function(); leave_function();
return SSH_OK; return SSH_OK;
error: error:
@@ -781,7 +781,7 @@ void ssh_message_free(ssh_message msg){
* @param session SSH session * @param session SSH session
* @param message message to add to the queue * @param message message to add to the queue
*/ */
void message_queue(ssh_session session, ssh_message message){ void ssh_message_queue(ssh_session session, ssh_message message){
if(message){ if(message){
if(session->ssh_message_list == NULL){ if(session->ssh_message_list == NULL){
session->ssh_message_list=ssh_list_new(); session->ssh_message_list=ssh_list_new();