Changeset 7790
- Timestamp:
- Jan 24, 2009, 2:49:35 PM (12 years ago)
- Location:
- trunk/libtransmission
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/libtransmission/peer-io.c
r7789 r7790 192 192 193 193 io->hasFinishedConnecting = TRUE; 194 io->pendingEvents &= ~EV_READ; 194 195 195 196 curlen = EVBUFFER_LENGTH( io->inbuf ); … … 274 275 275 276 io->hasFinishedConnecting = TRUE; 277 io->pendingEvents &= ~EV_WRITE; 276 278 277 279 dbgmsg( io, "libevent says this peer is ready to write" ); … … 835 837 event_enable( tr_peerIo * io, short event ) 836 838 { 837 if( event & EV_READ ) { 839 assert( event_initialized( &io->event_read ) ); 840 assert( event_initialized( &io->event_write ) ); 841 842 if( ( event & EV_READ ) && ! ( io->pendingEvents & EV_READ ) ) 843 { 838 844 dbgmsg( io, "enabling libevent ready-to-read polling" ); 839 845 event_add( &io->event_read, NULL ); 840 } 841 842 if( event & EV_WRITE ) { 846 io->pendingEvents |= EV_READ; 847 } 848 849 if( ( event & EV_WRITE ) && ! ( io->pendingEvents & EV_WRITE ) ) 850 { 843 851 dbgmsg( io, "enabling libevent ready-to-write polling" ); 844 852 event_add( &io->event_write, NULL ); 853 io->pendingEvents |= EV_WRITE; 845 854 } 846 855 } … … 849 858 event_disable( struct tr_peerIo * io, short event ) 850 859 { 851 if( event & EV_READ ) { 860 assert( event_initialized( &io->event_read ) ); 861 assert( event_initialized( &io->event_write ) ); 862 863 if( ( event & EV_READ ) && ( io->pendingEvents & EV_READ ) ) 864 { 852 865 dbgmsg( io, "disabling libevent ready-to-read polling" ); 853 866 event_del( &io->event_read ); 854 } 855 856 if( event & EV_WRITE ) { 867 io->pendingEvents &= ~EV_READ; 868 } 869 870 if( ( event & EV_WRITE ) && ( io->pendingEvents & EV_WRITE ) ) 871 { 857 872 dbgmsg( io, "disabling libevent ready-to-write polling" ); 858 873 event_del( &io->event_write ); 874 io->pendingEvents &= ~EV_WRITE; 859 875 } 860 876 } -
trunk/libtransmission/peer-io.h
r7789 r7790 70 70 tr_bool hasFinishedConnecting; 71 71 72 int pendingEvents; 73 72 74 int magicNumber; 73 75
Note: See TracChangeset
for help on using the changeset viewer.