Я работаю над повышением веб-сокетов для асинхронная связь между клиентом и сервером.
Теперь я печатаю прошедшее время во время выполнения программы с помощью boost::timer::auto_cpu_timer
. Он отображает прошедшее время в секундах.
Фрагмент моей программы приведен ниже:
Эта функция отправляет данные в веб-сокет:
void WebSocketSession::WriteSocket(beast::error_code ec) {
if (ec)
return fail(ec, "ssl_handshake");
cout << "Authorised" <<endl;
//Start the timer
BoostTimer.start();
// Send the Data message
ws_.async_write(net::buffer(DATAMSG),
bind(&WebSocketSession::ReadSocket, shared_from_this(), placeholders::_1,placeholders::_2));
}
Эта функция читает ответ веб-сокета
void WebSocketSession::ReadSocket(beast::error_code ec, size_t bytes_transferred) {
boost::ignore_unused(bytes_transferred);
if (ec)
return fail(ec, "WriteSocket Failed");
cout << "Time Elapsed before reading WS : " << TimeElapsed() << endl;
try {
ws_.read(ReadBuffer_);
} catch (exception *e) {
cerr << "Error: " << e->what() << endl;
}
cout << "Time Elapsed after reading WS : " << TimeElapsed() << endl;
// Display the buffer into stringstream
cout << beast::buffers(ReadBuffer_.data());
// Clear the websocket buffer
ReadBuffer_.consume(ReadBuffer_.size());
cout << "Time Elapsed before moving ahead : " << TimeElapsed() << endl;
// Decision tree
// IsGstFileWriteDone() gives "true" when the file is written... that file is not related to this context. An event is pushed saying FILE_WRITE_DONE
if (mIbmWatsonobj->IsGstFileWriteDone()){
cout<< "Going to CloseSocket" << endl;
WebSocketSession::CloseSocket(ec, 0);
}else{
cout<< "Going to ReadSocket" << endl;
WebSocketSession::ReadSocket(ec, 0);
}
}
Эта функция закрывает веб-сокет
void WebSocketSession::CloseSocket(beast::error_code ec, size_t bytes_transferred) {
boost::ignore_unused(bytes_transferred);
if (ec)
return fail(ec, "ReadSocket Failed");
cout << "CLOSING" <<endl;
// Close the WebSocket connection
ws_.close(websocket::close_code::normal);
}
Вот как выглядит вывод моей программы: ответ, полученный от веб-сокета, показан серым цветом (вывод cout << beast::buffers(ReadBuffer_.data());
), остальные — это couts, напечатанные в разных местах программы. Истекшее время указано в секундах
IBM Authorized
Время, прошедшее до чтения WS : 0
Время, прошедшее после чтения WS : 0,3{ "state": "listening" }
Время, прошедшее до перехода: 0,3
Переход к ReadSocket
Время, прошедшее до чтения WS: 0,3
Время, прошедшее после чтения WS: 2,1{ "results": [ { "alternatives": [ { "confidence": 0.89, "transcript": "several tornadoes touch down as a line of severe some " } ], "final": true } ], "result_index": 0 }
Время, прошедшее до перехода к следующему: 2.1
Переход к ReadSocket
Время, прошедшее до чтения WS: 2.1
Время, прошедшее после чтения WS: 2.1{ "state": "listening" }
Время, прошедшее до перехода: 2.1
Переход к ReadSocket
Время, прошедшее до чтения WS: 2.1Событие отправлено: FILE_WRITE_DONE
Время, прошедшее после чтения WS: 34
{ "error": "Session timed out." }
Время, прошедшее до перехода вперед: 34
// ПРОГРАММА ЗАВЕРШАЕТСЯ С -1
Вопрос:
Через 2.1
секунд программа снова переходит к ReadSocket, где ws_.read(ReadBuffer_);
блокирует выполнение почти на 32 секунды, пока не получит что-то из сокета, в этом случае он получает тайм-аут сеанса.
Как я могу перейти к CloseSocket, пока этот блок включен, скажем, на 5 секунд. То есть, если в какой-то момент у меня ws_.read
блокирует мой код более 5 секунд, я хочу указать свое поведение, скажем, CloseSocket.