cadey
/
elemental-ircd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

linebuf -> rb_linebuf

This commit is contained in:
Valery Yatsko 2008-04-02 21:04:44 +04:00
parent dd9b6ee83a
commit 887b2f383e
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
include/common.h
View File

@ -64,5 +64,8 @@
/* Right out of the RFC */ /* Right out of the RFC */
#define IRCD_BUFSIZE 512 #define IRCD_BUFSIZE 512
/* readbuf size */
#define READBUF_SIZE 16384
#endif /* INCLUDED_common_h */ #endif /* INCLUDED_common_h */

10
src/packet.c
View File

@ -58,7 +58,7 @@ parse_client_queued(struct Client *client_p)
if(client_p->localClient->sent_parsed >= client_p->localClient->allow_read) if(client_p->localClient->sent_parsed >= client_p->localClient->allow_read)
break; break;
dolen = linebuf_get(&client_p->localClient-> dolen = rb_linebuf_get(&client_p->localClient->
buf_recvq, readBuf, READBUF_SIZE, buf_recvq, readBuf, READBUF_SIZE,
LINEBUF_COMPLETE, LINEBUF_PARSED); LINEBUF_COMPLETE, LINEBUF_PARSED);
@ -88,7 +88,7 @@ parse_client_queued(struct Client *client_p)
if(IsAnyServer(client_p) || IsExemptFlood(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, readBuf, READBUF_SIZE, LINEBUF_COMPLETE,
LINEBUF_PARSED)) > 0) 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)) else if(client_p->localClient->sent_parsed >= (4 * client_p->localClient->allow_read))
break; break;
dolen = linebuf_get(&client_p->localClient-> dolen = rb_linebuf_get(&client_p->localClient->
buf_recvq, readBuf, READBUF_SIZE, buf_recvq, readBuf, READBUF_SIZE,
LINEBUF_COMPLETE, LINEBUF_PARSED); LINEBUF_COMPLETE, LINEBUF_PARSED);
@ -386,7 +386,7 @@ read_packet(int fd, void *data)
if(IsHandshake(client_p) || IsUnknown(client_p)) if(IsHandshake(client_p) || IsUnknown(client_p))
binary = 1; 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; lclient_p->actually_read += lbuf_len;
@ -401,7 +401,7 @@ read_packet(int fd, void *data)
/* Check to make sure we're not flooding */ /* Check to make sure we're not flooding */
if(!IsAnyServer(client_p) && 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))) if(!(ConfigFileEntry.no_oper_flood && IsOper(client_p)))
{ {