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

packet: Reformat callback handling functions

Browse Source 
Signed-off-by: Jakub Jelen <jjelen@redhat.com>
Reviewed-by: Norbert Pocs <npocs@redhat.com>
Reviewed-by: Andreas Schneider <asn@cryptomilk.org>
This commit is contained in:
Jakub Jelen
2023-03-14 09:46:01 +01:00
committed by Andreas Schneider
parent e1be63d78d
commit d6bc4905ad
1 changed files with 24 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/packet.c
View File

@@ -1394,17 +1394,22 @@ error:
return processed; return processed;
} }
void ssh_packet_register_socket_callback(ssh_session session, ssh_socket s){ void ssh_packet_register_socket_callback(ssh_session session, ssh_socket s)
session->socket_callbacks.data=ssh_packet_socket_callback; {
session->socket_callbacks.connected=NULL; struct ssh_socket_callbacks_struct *callbacks = &session->socket_callbacks;
session->socket_callbacks.userdata=session;
ssh_socket_set_callbacks(s,&session->socket_callbacks); callbacks->data = ssh_packet_socket_callback;
callbacks->connected = NULL;
callbacks->userdata = session;
ssh_socket_set_callbacks(s, callbacks);
} }
/** @internal /** @internal
* @brief sets the callbacks for the packet layer * @brief sets the callbacks for the packet layer
*/ */
void ssh_packet_set_callbacks(ssh_session session, ssh_packet_callbacks callbacks){ void
ssh_packet_set_callbacks(ssh_session session, ssh_packet_callbacks callbacks)
{
if (session->packet_callbacks == NULL) { if (session->packet_callbacks == NULL) {
session->packet_callbacks = ssh_list_new(); session->packet_callbacks = ssh_list_new();
if (session->packet_callbacks == NULL) { if (session->packet_callbacks == NULL) {
@@ -1418,8 +1423,11 @@ void ssh_packet_set_callbacks(ssh_session session, ssh_packet_callbacks callback
/** @internal /** @internal
* @brief remove the callbacks from the packet layer * @brief remove the callbacks from the packet layer
*/ */
void ssh_packet_remove_callbacks(ssh_session session, ssh_packet_callbacks callbacks){ void
ssh_packet_remove_callbacks(ssh_session session, ssh_packet_callbacks callbacks)
{
struct ssh_iterator *it = NULL; struct ssh_iterator *it = NULL;
it = ssh_list_find(session->packet_callbacks, callbacks); it = ssh_list_find(session->packet_callbacks, callbacks);
if (it != NULL) { if (it != NULL) {
ssh_list_remove(session->packet_callbacks, it); ssh_list_remove(session->packet_callbacks, it);
@@ -1429,12 +1437,15 @@ void ssh_packet_remove_callbacks(ssh_session session, ssh_packet_callbacks callb
/** @internal /** @internal
* @brief sets the default packet handlers * @brief sets the default packet handlers
*/ */
void ssh_packet_set_default_callbacks(ssh_session session){ void ssh_packet_set_default_callbacks(ssh_session session)
session->default_packet_callbacks.start=1; {
session->default_packet_callbacks.n_callbacks=sizeof(default_packet_handlers)/sizeof(ssh_packet_callback); struct ssh_packet_callbacks_struct *c = &session->default_packet_callbacks;
session->default_packet_callbacks.user=session;
session->default_packet_callbacks.callbacks=default_packet_handlers; c->start = 1;
ssh_packet_set_callbacks(session, &session->default_packet_callbacks); c->n_callbacks = sizeof(default_packet_handlers) / sizeof(ssh_packet_callback);
c->user = session;
c->callbacks = default_packet_handlers;
ssh_packet_set_callbacks(session, c);
} }
/** @internal /** @internal