|
|
@ -282,10 +282,13 @@ trans_check_wait_objs(struct trans *self)
|
|
|
|
if (self->trans_data_in != 0)
|
|
|
|
if (self->trans_data_in != 0)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
rv = self->trans_data_in(self);
|
|
|
|
rv = self->trans_data_in(self);
|
|
|
|
|
|
|
|
if (self->no_stream_init_on_data_in == 0)
|
|
|
|
|
|
|
|
{
|
|
|
|
init_stream(self->in_s, 0);
|
|
|
|
init_stream(self->in_s, 0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
if (send_waiting(self, 0) != 0)
|
|
|
|
if (send_waiting(self, 0) != 0)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
/* error */
|
|
|
|
/* error */
|
|
|
|