Ignore:
Timestamp:
Nov 17, 2007, 5:49:30 PM (15 years ago)
Author:
charles
Message:

fix timeout error that caused us to drop connections prematurely

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/libtransmission/peer-io.c

    r3846 r3859  
    5151    int socket;
    5252    int encryptionMode;
     53    int timeout;
    5354    struct bufferevent * bufev;
    5455    uint8_t peerId[20];
     
    131132    c->socket = socket;
    132133    c->isIncoming = isIncoming ? 1 : 0;
     134    c->timeout = IO_TIMEOUT_SECS;
    133135    c->bufev = bufferevent_new( c->socket,
    134136                                canReadWrapper,
     
    136138                                gotErrorWrapper,
    137139                                c );
    138     bufferevent_settimeout( c->bufev, IO_TIMEOUT_SECS, IO_TIMEOUT_SECS );
     140    bufferevent_settimeout( c->bufev, c->timeout, c->timeout );
    139141    bufferevent_enable( c->bufev, EV_READ|EV_WRITE );
    140142    bufferevent_setwatermark( c->bufev, EV_READ, 0, TR_RDBUF );
     
    273275                                     canReadWrapper, NULL, gotErrorWrapper,
    274276                                     io );
    275         bufferevent_settimeout( io->bufev, IO_TIMEOUT_SECS, IO_TIMEOUT_SECS );
     277        bufferevent_settimeout( io->bufev, io->timeout, io->timeout );
    276278        bufferevent_enable( io->bufev, EV_READ|EV_WRITE );
    277279        bufferevent_setwatermark( io->bufev, EV_READ, 0, TR_RDBUF );
     
    286288tr_peerIoSetTimeoutSecs( tr_peerIo * io, int secs )
    287289{
    288     bufferevent_settimeout( io->bufev, secs, secs );
     290    io->timeout = secs;
     291    bufferevent_settimeout( io->bufev, io->timeout, io->timeout );
    289292}
    290293
     
    434437    return io!=NULL && io->encryptionMode==PEER_ENCRYPTION_RC4;
    435438}
     439
     440/**
     441***
     442**/
    436443
    437444void
     
    462469
    463470void
     471tr_peerIoWriteUint8( tr_peerIo        * io,
     472                     struct evbuffer  * outbuf,
     473                     uint8_t            writeme )
     474{
     475    tr_peerIoWriteBytes( io, outbuf, &writeme, sizeof(uint8_t) );
     476}
     477
     478void
    464479tr_peerIoWriteUint16( tr_peerIo        * io,
    465480                      struct evbuffer  * outbuf,
     
    471486
    472487void
    473 tr_peerIoWriteUint8( tr_peerIo        * io,
    474                      struct evbuffer  * outbuf,
    475                      uint8_t            writeme )
    476 {
    477     tr_peerIoWriteBytes( io, outbuf, &writeme, sizeof(uint8_t) );
    478 }
    479 
    480 void
    481488tr_peerIoWriteUint32( tr_peerIo        * io,
    482489                      struct evbuffer  * outbuf,
     
    486493    tr_peerIoWriteBytes( io, outbuf, &tmp, sizeof(uint32_t) );
    487494}
     495
     496/***
     497****
     498***/
    488499
    489500void
     
    512523
    513524void
     525tr_peerIoReadUint8( tr_peerIo         * io,
     526                    struct evbuffer   * inbuf,
     527                    uint8_t           * setme )
     528{
     529    tr_peerIoReadBytes( io, inbuf, setme, sizeof(uint8_t) );
     530}
     531
     532void
    514533tr_peerIoReadUint16( tr_peerIo         * io,
    515534                     struct evbuffer   * inbuf,
     
    522541
    523542void
    524 tr_peerIoReadUint8( tr_peerIo         * io,
    525                     struct evbuffer   * inbuf,
    526                     uint8_t           * setme )
    527 {
    528     tr_peerIoReadBytes( io, inbuf, setme, sizeof(uint8_t) );
    529 }
    530 
    531 void
    532543tr_peerIoReadUint32( tr_peerIo         * io,
    533544                     struct evbuffer   * inbuf,
Note: See TracChangeset for help on using the changeset viewer.