|
|
@ -89,21 +89,21 @@ ioHandlerWrite(void * _this, TR_Event event) |
|
|
TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject; |
|
|
TR_CommEndPoint endpoint = (TR_CommEndPoint)event->subject; |
|
|
|
|
|
|
|
|
if (TR_cepWriteBuffered(endpoint)) { |
|
|
if (TR_cepWriteBuffered(endpoint)) { |
|
|
TR_Event event; |
|
|
|
|
|
|
|
|
TR_Event new_event; |
|
|
|
|
|
|
|
|
if (TR_cepHasPendingData(endpoint)) { |
|
|
if (TR_cepHasPendingData(endpoint)) { |
|
|
event = TR_eventSubjectEmit( |
|
|
|
|
|
|
|
|
new_event = TR_eventSubjectEmit( |
|
|
event->subject, |
|
|
event->subject, |
|
|
TR_CEP_EVENT_PENDING_DATA, |
|
|
TR_CEP_EVENT_PENDING_DATA, |
|
|
NULL); |
|
|
NULL); |
|
|
} else { |
|
|
} else { |
|
|
event = TR_eventSubjectEmit( |
|
|
|
|
|
|
|
|
new_event = TR_eventSubjectEmit( |
|
|
event->subject, |
|
|
event->subject, |
|
|
TR_CEP_EVENT_END_DATA, |
|
|
TR_CEP_EVENT_END_DATA, |
|
|
NULL); |
|
|
NULL); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
TR_eventHandlerIssueEvent((TR_EventHandler)_this, event); |
|
|
|
|
|
|
|
|
TR_eventHandlerIssueEvent((TR_EventHandler)_this, new_event); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
return TR_EVENT_DONE; |
|
|
return TR_EVENT_DONE; |
|
|
|