X-Git-Url: https://jfr.im/git/irc/rqf/shadowircd.git/blobdiff_plain/03d18a46b12cab6358d58033569ab2302ad9a543..8ad278b08812c06f7c7f97a7346f99319ba134a3:/src/send.c diff --git a/src/send.c b/src/send.c index 68d6ee6..d948fa8 100644 --- a/src/send.c +++ b/src/send.c @@ -149,12 +149,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 +204,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()