mirror/transmission
1
0
Fork 0
mirror of https://github.com/transmission/transmission synced 2025-03-04 02:28:03 +00:00
Code Issues Releases Wiki Activity

(trunk libT) more assertions to help find the cause of #2480

Browse source
This commit is contained in:
Charles Kerr 2009-10-10 17:37:34 +00:00
parent 9d84a36df3
commit 0fd817b757
2 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
libtransmission/handshake.c
View file

@ -1026,6 +1026,8 @@ canRead( struct tr_peerIo * io, void * arg, size_t * piece )
ReadState ret; ReadState ret;
tr_bool readyForMore = TRUE; tr_bool readyForMore = TRUE;
assert( tr_isPeerIo( io ) );
/* no piece data in handshake */ /* no piece data in handshake */
*piece = 0; *piece = 0;

11
libtransmission/peer-io.c
View file

@ -115,14 +115,18 @@ didWriteWrapper( tr_peerIo * io, size_t bytes_transferred )
static void static void
canReadWrapper( tr_peerIo * io ) canReadWrapper( tr_peerIo * io )
{ {
tr_bool done = 0;
tr_bool err = 0; tr_bool err = 0;
tr_session * session = io->session; tr_bool done = 0;
tr_session * session;
dbgmsg( io, "canRead" ); dbgmsg( io, "canRead" );
assert( tr_isPeerIo( io ) );
assert( tr_isSession( io->session ) );
tr_peerIoRef( io ); tr_peerIoRef( io );
session = io->session;
/* try to consume the input buffer */ /* try to consume the input buffer */
if( io->canRead ) if( io->canRead )
{ {
@ -160,6 +164,8 @@ canReadWrapper( tr_peerIo * io )
err = 1; err = 1;
break; break;
} }
assert( tr_isPeerIo( io ) );
} }
tr_globalUnlock( session ); tr_globalUnlock( session );
@ -171,6 +177,7 @@ canReadWrapper( tr_peerIo * io )
io->inbuf = evbuffer_new( ); io->inbuf = evbuffer_new( );
} }
assert( tr_isPeerIo( io ) );
tr_peerIoUnref( io ); tr_peerIoUnref( io );
} }