Как убрать зависания на сервере с помощью select?

Question

[Pinkman]

Я написал прокси сервер. Сервер однопоточный, работает через select. У меня появился участок кода который блокирует сервер:

bool closeConnect = false;
	std::string req = _getReq(closeConnect, fd);
	try {
		_dbSock->init();
		_dbSock->connectTo();
	} catch (std::exception &e) {
		std::cerr << "DB sock: " << e.what() << std::endl;
		closeConnect = true;
	}
	if (!closeConnect) {
		send(_dbSock->getSocket(), req.c_str(), req.size(), 0);
		bool tmp;
		req.erase();
		req = _getReq(tmp, _dbSock->getSocket());
		std::cerr << req.size();
		send(fd, req.c_str(), req.length(), 0);
	}

Знаю что блокируется на моменте общения с бд, но не понимаю как поправить это? Пробовал сначала открыть сокет для дб, и добавить его в fd_set но, скорее всего я делал это как то не правильно, потому что вообще все переставало работать.

Comments

[Сергей Горностаев]

Очевидно, нужна такая клиентская библиотека СУБД, API которой поддерживает асинхронность.

[Pinkman]

Сергей Горностаев, я без библиотек пока стараюсь обойтись. Ну кроме стандартных. Я думаю, что проблема в том, что я не до конца понимаю работу с select. Скорее всего все ломается(точнее висит пока бд не ответит) из-за того, что сокет бд не указан в select'e.

fdReady = select(maxFd + 1, &workingSet, NULL, NULL, NULL);

если я добавлю в workingSet сокет бд, то все вообще ломается. Как починить пока не придумал.

[Pinkman]

Если что, основной цикл приема соединения такой:

memcpy(&workingSet, &masterSet, sizeof(masterSet));
	std::cout << "Waiting new connection... max fd" << maxFd << std::endl;
		fdReady = select(maxFd + 1, &workingSet, NULL, NULL, NULL);
		if (fdReady < 0)
			break ;
		for (int fd = 0; fd <= maxFd && fdReady > 0; ++fd) {
			if (FD_ISSET(fd, &workingSet)) {
				fdReady--;
				if (fd == _hostSock->getSocket()) {
					do {
						newFd = accept(_hostSock->getSocket(), NULL, NULL);
						FD_SET(newFd, &masterSet);
						if (newFd > maxFd)
							maxFd = newFd;
					} while (newFd != -1);
				} else {
					_handleConnect(masterSet, fd, maxFd);
				}
			}

[Станислав Макаров]

Илья Что значит без библиотек? Вы сами пишете клиентский код для wire-протокола вашей СУБД? Что такое _dbSock?

[Pinkman]

Станислав Макаров, ну типа))) просто получаю набор байт от клиента, проверяю его на соотвествие протоколу и отсылаю.
_dbSock сокет под бд.

[res2001]

Илья, Все таки, что там у вас вместо базы данных? Что-то самописное?
Судя по коду приема соединений читающий сокет у вас не блокирующий. Но остальные, видимо, блокирующие.
Использовать select с блокирующими сокетами смысла нет, т.к. операции чтения/записи все равно будут блокирующими.
Если вы хотите работать в одном потоке с пачкой сокетов, вам надо все сокеты переводить в неблокирующий режим, со всеми вытекающими из этого последствиями. Если сокеты будут в блокирующем режиме, то поток будет всегда ждать завершения любой операции чтения/записи на любом сокете.

И как часто бывает, у вас нет обработки ошибок. Любая операция с сокетами может завершиться ошибкой.