X-Git-Url: https://jfr.im/git/irc/rqf/shadowircd.git/blobdiff_plain/8e43b0b4146cdbacec61e83e8b8251c0b5a090c9..887b2f383e1dc4f8d42d2c2523bda507b380d82d:/src/packet.c diff --git a/src/packet.c b/src/packet.c index 038ddca..6d203a1 100644 --- a/src/packet.c +++ b/src/packet.c @@ -58,7 +58,7 @@ parse_client_queued(struct Client *client_p) if(client_p->localClient->sent_parsed >= client_p->localClient->allow_read) break; - dolen = linebuf_get(&client_p->localClient-> + dolen = rb_linebuf_get(&client_p->localClient-> buf_recvq, readBuf, READBUF_SIZE, LINEBUF_COMPLETE, LINEBUF_PARSED); @@ -88,7 +88,7 @@ parse_client_queued(struct Client *client_p) if(IsAnyServer(client_p) || IsExemptFlood(client_p)) { - while (!IsAnyDead(client_p) && (dolen = linebuf_get(&client_p->localClient->buf_recvq, + while (!IsAnyDead(client_p) && (dolen = rb_linebuf_get(&client_p->localClient->buf_recvq, readBuf, READBUF_SIZE, LINEBUF_COMPLETE, LINEBUF_PARSED)) > 0) { @@ -132,7 +132,7 @@ parse_client_queued(struct Client *client_p) else if(client_p->localClient->sent_parsed >= (4 * client_p->localClient->allow_read)) break; - dolen = linebuf_get(&client_p->localClient-> + dolen = rb_linebuf_get(&client_p->localClient-> buf_recvq, readBuf, READBUF_SIZE, LINEBUF_COMPLETE, LINEBUF_PARSED); @@ -374,8 +374,8 @@ read_packet(int fd, void *data) call_hook(h_iorecv_id, &hdata); #endif - if(client_p->localClient->lasttime < CurrentTime) - client_p->localClient->lasttime = CurrentTime; + if(client_p->localClient->lasttime < rb_current_time()) + client_p->localClient->lasttime = rb_current_time(); client_p->flags &= ~FLAGS_PINGSENT; /* @@ -386,7 +386,7 @@ read_packet(int fd, void *data) if(IsHandshake(client_p) || IsUnknown(client_p)) binary = 1; - lbuf_len = linebuf_parse(&client_p->localClient->buf_recvq, readBuf, length, binary); + lbuf_len = rb_linebuf_parse(&client_p->localClient->buf_recvq, readBuf, length, binary); lclient_p->actually_read += lbuf_len; @@ -401,7 +401,7 @@ read_packet(int fd, void *data) /* Check to make sure we're not flooding */ if(!IsAnyServer(client_p) && - (linebuf_alloclen(&client_p->localClient->buf_recvq) > ConfigFileEntry.client_flood)) + (rb_linebuf_alloclen(&client_p->localClient->buf_recvq) > ConfigFileEntry.client_flood)) { if(!(ConfigFileEntry.no_oper_flood && IsOper(client_p))) {