stream->bytes_received - stream->backlog_size,
0);
client->state = Client::SENDING_DATA;
+ goto sending_data;
} else {
client->stream_pos = stream->bytes_received;
client->state = Client::WAITING_FOR_KEYFRAME;
}
- stream->put_client_to_sleep(client);
- return;
+ // Fall through.
}
case Client::WAITING_FOR_KEYFRAME: {
Stream *stream = client->stream;
// Fall through.
}
case Client::SENDING_DATA: {
+sending_data:
skip_lost_data(client);
Stream *stream = client->stream;