Lines Matching refs:outMessages
81 /* used in lowering the outMessages queue period */
165 /* how long the outMessages batch should be allowed to grow before
189 struct evbuffer * outMessages; /* all the non-piece messages */
202 /* when we started batching the outMessages */
285 dbgmsg( msgs, "outMessage size is now %zu", evbuffer_get_length( msgs->outMessages ) );
291 struct evbuffer * out = msgs->outMessages;
308 struct evbuffer * out = msgs->outMessages;
324 struct evbuffer * out = msgs->outMessages;
340 struct evbuffer * out = msgs->outMessages;
351 struct evbuffer * out = msgs->outMessages;
367 struct evbuffer * out = msgs->outMessages;
383 struct evbuffer * out = msgs->outMessages;
396 struct evbuffer * out = msgs->outMessages;
411 struct evbuffer * out = msgs->outMessages;
651 struct evbuffer * out = msgs->outMessages;
795 struct evbuffer * out = msgs->outMessages;
1003 struct evbuffer * out = msgs->outMessages;
1011 /* write it out as a LTEP message to our outMessages buffer */
1718 struct evbuffer * out = msgs->outMessages;
1728 /* write it out as a LTEP message to our outMessages buffer */
1773 const bool haveMessages = evbuffer_get_length( msgs->outMessages ) != 0;
1782 dbgmsg( msgs, "started an outMessages batch (length is %zu)", evbuffer_get_length( msgs->outMessages ) );
1787 const size_t len = evbuffer_get_length( msgs->outMessages );
1789 dbgmsg( msgs, "flushing outMessages... to %p (length is %zu)", msgs->peer->io, len );
1790 tr_peerIoWriteBuf( msgs->peer->io, msgs->outMessages, false );
1813 struct evbuffer * out = msgs->outMessages;
1822 /* write it out as a LTEP message to our outMessages buffer */
1842 struct evbuffer * out = msgs->outMessages;
1850 /* write it out as a LTEP message to our outMessages buffer */
1940 evbuffer_add_uint32( msgs->outMessages, 0 );
1989 struct evbuffer * out = msgs->outMessages;
2197 struct evbuffer * out = msgs->outMessages;
2347 m->outMessages = evbuffer_new( );
2394 evbuffer_free( msgs->outMessages );