Отладка стабильности работы

Author: anyks

include/lib.hpp

@@ -8,7 +8,7 @@
  */
 
 // Версия приложения
-#define AWH_VERSION "1.1.1"
+#define AWH_VERSION "1.1.2"
 // Короткое название библиотеки
 #define AWH_SHORT_NAME "AWH"
 // Название библиотеки
@@ -50,7 +50,7 @@
 // Интервал времени для получения данных с сервера в секундах
 #define READ_TIMEOUT 30
 // Интервал времени для записи данных на сервере в секундах
-#define WRITE_TIMEOUT 30
+#define WRITE_TIMEOUT 0
 // Интервал времени на проверку подключения с сервером в милисекундах
 #define PING_INTERVAL 120000
 // Интервал времени на получение сообщений с сервера в милисекундах

sample/ws.cpp

@@ -110,7 +110,7 @@ int main(int argc, char * argv[]) noexcept {
 		// Если данные пришли в виде текста, выводим
 		if(utf8){
 			// Создаём объект JSON
-			json data = json::parse(string(buffer.begin(), buffer.end()));
+			json data = json::parse(buffer.begin(), buffer.end());
 			// Выводим полученный результат
 			cout << " +++++++++++++ " << data.dump(4) << endl;
 		// Сообщаем количество полученных байт

src/client/core.cpp

@@ -120,6 +120,19 @@ void awh::CoreClient::event(struct bufferevent * bev, const short events, void *
 					if(wrk->connectProxyFn != nullptr) wrk->connectProxyFn(adj->aid, const_cast <core_t *> (wrk->core), wrk->ctx);
 				// Выполняем функцию обратного вызова
 				} else if(wrk->connectFn != nullptr) wrk->connectFn(adj->aid, const_cast <core_t *> (wrk->core), wrk->ctx);
+				// Если флаг ожидания входящих сообщений, активирован
+				if(wrk->wait){
+					// Устанавливаем таймаут ожидания поступления данных
+					struct timeval read = {adj->timeRead, 0};
+					// Устанавливаем таймаут ожидания записи данных
+					struct timeval write = {adj->timeWrite, 0};
+					// Устанавливаем таймаут на отправку/получение данных
+					bufferevent_set_timeouts(
+						adj->bev,
+						(adj->timeRead > 0 ? &read : nullptr),
+						(adj->timeWrite > 0 ? &write : nullptr)
+					);
+				}
 			// Если это ошибка или завершение работы
 			} else if(events & (BEV_EVENT_ERROR | BEV_EVENT_EOF | BEV_EVENT_TIMEOUT)) {
 				// Если это ошибка
@@ -128,6 +141,8 @@ void awh::CoreClient::event(struct bufferevent * bev, const short events, void *
 					adj->log->print("closing server [%s:%d] %s", log_t::flag_t::WARNING, host.c_str(), url.port, evutil_socket_error_to_string(EVUTIL_SOCKET_ERROR()));
 				// Если - это таймаут, выводим сообщение в лог
 				else if(events & BEV_EVENT_TIMEOUT) adj->log->print("timeout server [%s:%d]", log_t::flag_t::WARNING, host.c_str(), url.port);
+				// Запрещаем чтение запись данных серверу
+				bufferevent_disable(bev, EV_WRITE | EV_READ);
 				// Выполняем отключение от сервера
 				const_cast <core_t *> (wrk->core)->close(adj->aid);
 			}
@@ -279,15 +294,6 @@ void awh::CoreClient::tuning(const size_t aid) noexcept {
 		bufferevent_setcb(it->second->bev, &read, &write, &event, (void *) it->second);
 		// Очищаем буферы событий при завершении работы
 		bufferevent_flush(it->second->bev, EV_READ | EV_WRITE, BEV_FINISHED);
-		// Если флаг ожидания входящих сообщений, активирован
-		if(wrk->wait){
-			// Устанавливаем таймаут ожидания поступления данных
-			struct timeval read = {it->second->timeRead, 0};
-			// Устанавливаем таймаут ожидания записи данных
-			struct timeval write = {it->second->timeWrite, 0};
-			// Устанавливаем таймаут получения данных
-			bufferevent_set_timeouts(it->second->bev, &read, &write);
-		}
 		/**
 		 * Водяной знак на N байт (чтобы считывать данные когда они действительно приходят)
 		 */
@@ -401,6 +407,10 @@ void awh::CoreClient::close(const size_t aid) noexcept {
 			// Устанавливаем что событие удалено
 			const_cast <worker_t::adj_t *> (it->second)->bev = nullptr;
 		}
+		// Если прокси-сервер активирован но уже переключён на работу с сервером
+		if((wrk->proxy.type != proxy_t::type_t::NONE) && !wrk->isProxy())
+			// Выполняем переключение обратно на прокси-сервер
+			wrk->switchConnect();
 		// Выполняем удаление контекста SSL
 		this->ssl->clear(wrk->ssl);
 		// Удаляем адъютанта из списка адъютантов

src/client/rest.cpp

@@ -43,10 +43,6 @@ void awh::Rest::closeCallback(const size_t wid, core_t * core, void * ctx) noexc
 		// Если нужно произвести запрос заново
 		if((web->res.code == 301) || (web->res.code == 308) ||
 		   (web->res.code == 401) || (web->res.code == 407)){
-			// Если прокси-сервер активирован но уже переключён на работу с сервером
-			if((web->worker.proxy.type != proxy_t::type_t::NONE) && !web->worker.isProxy())
-				// Выполняем переключение обратно на прокси-сервер
-				web->worker.switchConnect();
 			// Выполняем запрос заново
 			core->open(web->worker.wid);
 			// Выходим из функции

src/client/ws.cpp

@@ -49,10 +49,6 @@ void awh::WebSocketClient::closeCallback(const size_t wid, core_t * core, void *
 		// Если нужно произвести запрос заново
 		if((ws->code == 301) || (ws->code == 308) ||
 		   (ws->code == 401) || (ws->code == 407)){
-			// Если прокси-сервер активирован но уже переключён на работу с сервером
-			if((ws->worker.proxy.type != proxy_t::type_t::NONE) && !ws->worker.isProxy())
-				// Выполняем переключение обратно на прокси-сервер
-				ws->worker.switchConnect();
 			// Выполняем запрос заново
 			core->open(ws->worker.wid);
 			// Выходим из функции