free_pre_client(client_p);
- if (!IsCapable(client_p, CAP_ZIP))
- send_pop_queue(client_p);
+ send_pop_queue(client_p);
return 0;
}
exit_client(client_p, client_p, &me, reason);
}
-
-static void
-ssl_process_zip_ready(ssl_ctl_t * ctl, ssl_ctl_buf_t * ctl_buf)
-{
- struct Client *client_p;
- int32_t fd;
-
- if(ctl_buf->buflen < 5)
- return; /* bogus message..drop it.. XXX should warn here */
-
- fd = buf_to_int32(&ctl_buf->buf[1]);
- client_p = find_cli_fd_hash(fd);
- if(client_p == NULL)
- return;
-
- /* Now start sending the data that should be compressed. */
- // ClearCork(client_p);
- send_pop_queue(client_p);
- /* Start reading uncompressed data. */
- read_packet(client_p->localClient->F, client_p);
-}
-
-
static void
ssl_process_cmd_recv(ssl_ctl_t * ctl)
{
sendto_realops_snomask(SNO_GENERAL, L_ALL, no_ssl_or_zlib);
ssl_killall();
break;
- case 'R':
- ssl_process_zip_ready(ctl, ctl_buf);
- break;
case 'z':
zlib_ok = 0;
break;
}
#ifdef HAVE_LIBZ
-static void
-zlib_send_zip_ready(mod_ctl_t * ctl, conn_t * conn)
-{
- char buf[5];
-
- buf[0] = 'R';
- int32_to_buf(&buf[1], conn->id);
- mod_cmd_write_queue(conn->ctl, buf, sizeof(buf));
-}
-
static void
zlib_process(mod_ctl_t * ctl, mod_ctl_buf_t * ctlb)
{
deflateInit(&((zlib_stream_t *) conn->stream)->outstream, level);
if(recvqlen > 0)
common_zlib_inflate(conn, recvq_start, recvqlen);
- zlib_send_zip_ready(ctl, conn);
+
conn_mod_read_cb(conn->mod_fd, conn);
conn_plain_read_cb(conn->plain_fd, conn);
return;