Я пишу свой небольшой HTTP-сервер. Пытаюсь ообработать заголовок Keep-Alive, чтоб можно было повтороно использовать соединение.
Я использую такой алгоритм: создаю соединение с помощью accept, читаю из него с помощью recv, обрабатываю запрос, отвечаю на него с помощью send, используя в ответе заголовок Keep-Alive, не закрыв соединение опять использую на него же recv, если recv вернуло 0, закрываю соединение. ПОдскажите что я делаю не так, и как правильно обрабатыват соединение, чтоб его можно было переиспользовать ? Зависает на любых данных второго запроса, если закрывать соединение и по новой открывать, все нормально
for(;;)
{
client *current = client::listen_port(cone.get_socket());//здесь вызывается accept
httpHandler worker(current);//этот класс занимается обработкой запросов, мы передаем в него указатель на объект класса, где содержится информация о клиенте
for(;;)
{
httpParser* temp = new httpParser(current->get_client());// происходит вызов recv и класс httpParser анализирует запрос
if (temp->get_recvByte() > 0)
worker.handle(temp);//если recv что то вернул, мы обрабатываем запрос и отвечаем на него
if (temp->get_recvByte() == 0)
break;
if (temp->get_recvByte())
std::cout << "error";
delete temp;
}
}
вот как проивходит вызов recv
httpParser::httpParser(int client_d)
{
char buffer[req_buff_size];
recvByte = recv(client_d, buffer,req_buff_size - 1, 0); // получаем сообщение из сокета
if (recvByte > 0)
{
buffer[recvByte] = '\0';
reqest = buffer;
std::cout << reqest <<std::endl; // для тестов
if (recvByte < 0)
throw std::invalid_argument( "error recv\n" );
if (reqest.find("GET") == 0)
{
type = GET;
GET_parse();
}
else if (reqest.find("POST") == 0)
{
type = POST;
POST_Parse();
}
else if (reqest.find("HEAD") == 0)
type = HEAD;
else
throw std::invalid_argument( "invalid REQ\n" );
requestedFile();
}
}
std::cout << "Calling recv() on socket " << client_d << std::endl;
прямо передrecvByte = recv(client_d, buffer,req_buff_size - 1, 0);
. Посмотрите, не меняется ли значение сокета, который вы читаете.