Maintain information about enabled/disabled I/O.
This commit is contained in:
parent
236fb3d9d6
commit
d347f5ada4
|
@ -583,6 +583,9 @@ tr_peerIoNew( tr_session * session,
|
|||
|
||||
}
|
||||
|
||||
io->write_enabled = 1;
|
||||
io->read_enabled = 1;
|
||||
|
||||
return io;
|
||||
}
|
||||
|
||||
|
@ -700,6 +703,11 @@ tr_peerIoSetEnabled( tr_peerIo * io,
|
|||
event_enable( io, event );
|
||||
else
|
||||
event_disable( io, event );
|
||||
|
||||
if( dir == TR_UP )
|
||||
io->write_enabled = isEnabled;
|
||||
else if( dir == TR_DOWN )
|
||||
io->read_enabled = isEnabled;
|
||||
}
|
||||
|
||||
/***
|
||||
|
|
|
@ -105,6 +105,9 @@ typedef struct tr_peerIo
|
|||
struct evbuffer * inbuf;
|
||||
struct evbuffer * outbuf;
|
||||
struct tr_list * outbuf_datatypes; /* struct tr_datatype */
|
||||
|
||||
tr_bool write_enabled;
|
||||
tr_bool read_enabled;
|
||||
|
||||
struct event * event_read;
|
||||
struct event * event_write;
|
||||
|
|
Loading…
Reference in New Issue