cleanup_exit(0);
}
noise_ultralight(len);
- if (connopen && back->socket(backhandle) != NULL) {
+ if (connopen && back->connected(backhandle)) {
if (len > 0) {
return back->send(backhandle, data, len);
} else {
(h == stdout_handle ? "output" : "error"));
cleanup_exit(0);
}
- if (connopen && back->socket(backhandle) != NULL) {
+ if (connopen && back->connected(backhandle)) {
back->unthrottle(backhandle, (handle_backlog(stdout_handle) +
handle_backlog(stderr_handle)));
}
* (The input one we leave until we're through the
* authentication process.)
*/
- stdout_handle = handle_output_new(outhandle, stdouterr_sent);
- stderr_handle = handle_output_new(errhandle, stdouterr_sent);
+ stdout_handle = handle_output_new(outhandle, stdouterr_sent, NULL);
+ stderr_handle = handle_output_new(errhandle, stdouterr_sent, NULL);
main_thread_id = GetCurrentThreadId();
DWORD ticks;
if (!sending && back->sendok(backhandle)) {
- stdin_handle = handle_input_new(inhandle, stdin_gotdata);
+ stdin_handle = handle_input_new(inhandle, stdin_gotdata, NULL);
sending = TRUE;
}
if (sending)
handle_unthrottle(stdin_handle, back->sendbuffer(backhandle));
- if ((!connopen || back->socket(backhandle) == NULL) &&
+ if ((!connopen || !back->connected(backhandle)) &&
handle_backlog(stdout_handle) + handle_backlog(stderr_handle) == 0)
break; /* we closed the connection */
}