Mercurial > dropbear

comparison common-session.c @ 1025:02baa0b334e8 fastopen

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
async connections working
author Matt Johnston <matt@ucc.asn.au>
date Wed, 18 Feb 2015 22:46:15 +0800
parents 24135c8e1d46
children 64c0aa01e2b6
comparison
equal deleted inserted replaced
1024:aac0095dc3b4 1025:02baa0b334e8
165 FD_SET(ses.signal_pipe[0], &readfd); 165 FD_SET(ses.signal_pipe[0], &readfd);
166 166
167 /* set up for channels which can be read/written */ 167 /* set up for channels which can be read/written */
168 setchannelfds(&readfd, &writefd); 168 setchannelfds(&readfd, &writefd);
169 169
170 /* Pending connections to test */
171 set_connect_fds(&writefd);
172
170 val = select(ses.maxfd+1, &readfd, &writefd, NULL, &timeout); 173 val = select(ses.maxfd+1, &readfd, &writefd, NULL, &timeout);
171 174
172 if (exitflag) { 175 if (exitflag) {
173 dropbear_exit("Terminated by signal"); 176 dropbear_exit("Terminated by signal");
174 } 177 }
212 * will be ready for a new packet */ 215 * will be ready for a new packet */
213 if (ses.payload != NULL) { 216 if (ses.payload != NULL) {
214 process_packet(); 217 process_packet();
215 } 218 }
216 } 219 }
217 220
218 /* if required, flush out any queued reply packets that 221 /* if required, flush out any queued reply packets that
219 were being held up during a KEX */ 222 were being held up during a KEX */
220 maybe_flush_reply_queue(); 223 maybe_flush_reply_queue();
224
225 handle_connect_fds(&writefd);
221 226
222 /* process pipes etc for the channels, ses.dataallowed == 0 227 /* process pipes etc for the channels, ses.dataallowed == 0
223 * during rekeying ) */ 228 * during rekeying ) */
224 channelio(&readfd, &writefd); 229 channelio(&readfd, &writefd);
225 230