Changeset 3829
- Timestamp:
- Nov 15, 2007, 4:43:46 PM (15 years ago)
- Location:
- trunk/libtransmission
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/libtransmission/peer-io.c
r3775 r3829 404 404 int writeme_len ) 405 405 { 406 tr_bufferevent_write( io->handle, io->bufev, writeme, writeme_len ); 406 assert( tr_amInEventThread( io->handle ) ); 407 bufferevent_write( io->bufev, (void*)writeme, writeme_len ); 407 408 } 408 409 -
trunk/libtransmission/trevent.c
r3796 r3829 66 66 TR_EV_EVHTTP_MAKE_REQUEST, 67 67 TR_EV_BUFFEREVENT_SET, 68 TR_EV_BUFFEREVENT_WRITE,69 68 TR_EV_TIMER_ADD, 70 69 TR_EV_TIMER_DEL, … … 148 147 bufferevent_enable( cmd->bufev, cmd->enable ); 149 148 bufferevent_disable( cmd->bufev, cmd->disable ); 150 break;151 152 case TR_EV_BUFFEREVENT_WRITE:153 bufferevent_write( cmd->bufev, cmd->buf, cmd->buflen );154 tr_free( cmd->buf );155 149 break; 156 150 … … 256 250 } 257 251 252 int 253 tr_amInEventThread( struct tr_handle * handle ) 254 { 255 return tr_amInThread( handle->events->thread ); 256 } 257 258 258 259 void 259 260 tr_evhttp_make_request (tr_handle * handle, … … 273 274 cmd->evtype = type; 274 275 cmd->uri = uri; 275 pushList( handle->events, cmd );276 }277 }278 279 void280 tr_bufferevent_write( tr_handle * handle,281 struct bufferevent * bufev,282 const void * buf,283 size_t buflen )284 {285 if( tr_amInThread( handle->events->thread ) )286 bufferevent_write( bufev, (void*)buf, buflen );287 else {288 struct tr_event_command * cmd = tr_new0( struct tr_event_command, 1 );289 cmd->mode = TR_EV_BUFFEREVENT_WRITE;290 cmd->bufev = bufev;291 cmd->buf = tr_strndup( buf, buflen );292 cmd->buflen = buflen;293 276 pushList( handle->events, cmd ); 294 277 } -
trunk/libtransmission/trevent.h
r3457 r3829 38 38 char * uri); 39 39 40 void tr_bufferevent_write( struct tr_handle * tr_handle,41 struct bufferevent * bufferEvent,42 const void * buf,43 size_t buflen );44 45 46 40 void tr_setBufferEventMode( struct tr_handle * tr_handle, 47 41 struct bufferevent * bufferEvent, 48 42 short mode_enable, 49 43 short mode_disable ); 44 45 int tr_amInEventThread( struct tr_handle * handle ); 50 46 51 47 /**
Note: See TracChangeset
for help on using the changeset viewer.