diff options
| author | Aris Adamantiadis <aris@0xbadc0de.be> | 2011-09-02 13:46:10 +0300 |
|---|---|---|
| committer | Aris Adamantiadis <aris@0xbadc0de.be> | 2011-09-02 13:46:10 +0300 |
| commit | 6d8bb956c5caa48c2aba6713f067224650c3c1e1 (patch) | |
| tree | 00ab42ac7c63dc6e030f844f93cfb58999477bb2 /src/channels.c | |
| parent | 3eece8ac0b107a7df8d95325ef17ed19d6429e75 (diff) | |
| download | libssh-6d8bb956c5caa48c2aba6713f067224650c3c1e1.tar.gz libssh-6d8bb956c5caa48c2aba6713f067224650c3c1e1.tar.xz libssh-6d8bb956c5caa48c2aba6713f067224650c3c1e1.zip | |
channels: replaced bugged lists with ssh_list
cherry-picked from 0aef5f
Conflicts:
src/session.c
Diffstat (limited to 'src/channels.c')
| -rw-r--r-- | src/channels.c | 51 |
1 files changed, 17 insertions, 34 deletions
diff --git a/src/channels.c b/src/channels.c index 2cac14dc..54736a60 100644 --- a/src/channels.c +++ b/src/channels.c @@ -109,15 +109,9 @@ ssh_channel ssh_channel_new(ssh_session session) { channel->exit_status = -1; if(session->channels == NULL) { - session->channels = channel; - channel->next = channel->prev = channel; - return channel; + session->channels = ssh_list_new(); } - channel->next = session->channels; - channel->prev = session->channels->prev; - channel->next->prev = channel; - channel->prev->next = channel; - + ssh_list_prepend(session->channels, channel); return channel; } @@ -331,23 +325,20 @@ end: /* return channel with corresponding local id, or NULL if not found */ ssh_channel ssh_channel_from_local(ssh_session session, uint32_t id) { - ssh_channel initchan = session->channels; - ssh_channel channel = initchan; + struct ssh_iterator *it; + ssh_channel channel; - for (;;) { - if (channel == NULL) { - return NULL; - } - if (channel->local_channel == id) { - return channel; - } - if (channel->next == initchan) { - return NULL; - } - channel = channel->next; + for (it = ssh_list_get_iterator(session->channels); it != NULL ; it=it->next) { + channel = ssh_iterator_value(ssh_channel, it); + if (channel == NULL) { + continue; + } + if (channel->local_channel == id) { + return channel; } + } - return NULL; + return NULL; } /** @@ -1022,6 +1013,7 @@ error: */ void ssh_channel_free(ssh_channel channel) { ssh_session session; + struct ssh_iterator *it; if (channel == NULL) { return; @@ -1034,19 +1026,10 @@ void ssh_channel_free(ssh_channel channel) { ssh_channel_close(channel); } - /* handle the "my channel is first on session list" case */ - if (session->channels == channel) { - session->channels = channel->next; - } - - /* handle the "my channel is the only on session list" case */ - if (channel->next == channel) { - session->channels = NULL; - } else { - channel->prev->next = channel->next; - channel->next->prev = channel->prev; + it = ssh_list_find(session->channels, channel); + if(it != NULL){ + ssh_list_remove(session->channels, it); } - ssh_buffer_free(channel->stdout_buffer); ssh_buffer_free(channel->stderr_buffer); |
