0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-09-29 04:08:54 +02:00

[svn r26332] get rid of the zip ready stuff

This commit is contained in:
androsyn 2009-01-01 14:50:21 +03:00
parent 32eadd332e
commit 0bd120ed48
3 changed files with 2 additions and 39 deletions

View file

@ -892,7 +892,6 @@ server_estab(struct Client *client_p)
free_pre_client(client_p); free_pre_client(client_p);
if (!IsCapable(client_p, CAP_ZIP))
send_pop_queue(client_p); send_pop_queue(client_p);
return 0; return 0;

View file

@ -385,29 +385,6 @@ ssl_process_dead_fd(ssl_ctl_t * ctl, ssl_ctl_buf_t * ctl_buf)
exit_client(client_p, client_p, &me, reason); 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 static void
ssl_process_cmd_recv(ssl_ctl_t * ctl) ssl_process_cmd_recv(ssl_ctl_t * ctl)
{ {
@ -442,9 +419,6 @@ ssl_process_cmd_recv(ssl_ctl_t * ctl)
sendto_realops_snomask(SNO_GENERAL, L_ALL, no_ssl_or_zlib); sendto_realops_snomask(SNO_GENERAL, L_ALL, no_ssl_or_zlib);
ssl_killall(); ssl_killall();
break; break;
case 'R':
ssl_process_zip_ready(ctl, ctl_buf);
break;
case 'z': case 'z':
zlib_ok = 0; zlib_ok = 0;
break; break;

View file

@ -751,16 +751,6 @@ process_stats(mod_ctl_t * ctl, mod_ctl_buf_t * ctlb)
} }
#ifdef HAVE_LIBZ #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 static void
zlib_process(mod_ctl_t * ctl, mod_ctl_buf_t * ctlb) zlib_process(mod_ctl_t * ctl, mod_ctl_buf_t * ctlb)
{ {
@ -811,7 +801,7 @@ zlib_process(mod_ctl_t * ctl, mod_ctl_buf_t * ctlb)
deflateInit(&((zlib_stream_t *) conn->stream)->outstream, level); deflateInit(&((zlib_stream_t *) conn->stream)->outstream, level);
if(recvqlen > 0) if(recvqlen > 0)
common_zlib_inflate(conn, recvq_start, recvqlen); common_zlib_inflate(conn, recvq_start, recvqlen);
zlib_send_zip_ready(ctl, conn);
conn_mod_read_cb(conn->mod_fd, conn); conn_mod_read_cb(conn->mod_fd, conn);
conn_plain_read_cb(conn->plain_fd, conn); conn_plain_read_cb(conn->plain_fd, conn);
return; return;