X-Git-Url: https://jfr.im/git/irc/rqf/shadowircd.git/blobdiff_plain/03d18a46b12cab6358d58033569ab2302ad9a543..45be325cd2a8fcedc7fe71adbe70208d0d16aec2:/src/send.c diff --git a/src/send.c b/src/send.c index 68d6ee6..a3154c3 100644 --- a/src/send.c +++ b/src/send.c @@ -30,11 +30,10 @@ #include "class.h" #include "client.h" #include "common.h" -#include "irc_string.h" +#include "match.h" #include "ircd.h" #include "numeric.h" #include "s_serv.h" -#include "sprintf_irc.h" #include "s_conf.h" #include "s_newconf.h" #include "logger.h" @@ -149,12 +148,12 @@ send_queued(struct Client *to) if(IsIOError(to)) return; - /* Something wants us to not send anything currently */ - /* if(IsCork(to)) - return; */ - - /* try to flush later when the write event resets this */ - if(IsFlush(to)) + /* Something wants us to not send anything currently */ + /* if(IsCork(to)) + return; */ + + /* try to flush later when the write event resets this */ + if(IsFlush(to)) return; #ifdef USE_IODEBUG_HOOKS @@ -204,25 +203,25 @@ send_queued(struct Client *to) } } - if(rb_linebuf_len(&to->localClient->buf_sendq)) - { - SetFlush(to); - rb_setselect(to->localClient->F, RB_SELECT_WRITE, - send_queued_write, to); - } - else + if(rb_linebuf_len(&to->localClient->buf_sendq)) + { + SetFlush(to); + rb_setselect(to->localClient->F, RB_SELECT_WRITE, + send_queued_write, to); + } + else ClearFlush(to); } -void -send_pop_queue(struct Client *to) -{ - if(to->from != NULL) - to = to->from; - if(!MyConnect(to) || IsIOError(to)) - return; - if(rb_linebuf_len(&to->localClient->buf_sendq) > 0) - send_queued(to); +void +send_pop_queue(struct Client *to) +{ + if(to->from != NULL) + to = to->from; + if(!MyConnect(to) || IsIOError(to)) + return; + if(rb_linebuf_len(&to->localClient->buf_sendq) > 0) + send_queued(to); } /* send_queued_write()