Почему разрывает соединение, при смене типа?

Question

[Pinkman]

Добрый день!
Я написал свой класс:

ft::Socket::Socket(int fd) : _socket(fd) {}
ft::Socket::operator int() { return _socket; }

Данные в нем я никак не меняю.
Есть такой цикл, он просматривает ивенты с помощью kevent. На сколько я вижу код работает (но если ваш зоркий глаз заметил не ладное, буду рад комментарию), соединение устанавливается и клиенты висят без проблем. Но как только меняю тип у переменной fd все ломается. Точнее работает, примет одного клиента отдаст ему порцию данных и все, никто больше не подключится, да и клиента отключает.

for (int i = 0; i < newEvents; i++) {
			// Если здесь поменять int на ft::Socket
			int fd(tEvent[i].ident);
			std::cerr << fd << "\n";
			if (tEvent[i].flags & EV_EOF) {
					std::cerr << "Connection close from remote host\n";
				close((int)fd);
			} else if (fd == _hostSock) {
				std::cerr << "New connection ";
				struct sockaddr_storage	remoteAdr;
				socklen_t size = sizeof(remoteAdr);
				int newSock = accept((int)fd, (struct sockaddr *)&remoteAdr, &size);
				if (newSock == -1)
					std::cerr << "error: Cant accept new connection\n";
				EV_SET(&event, newSock, EVFILT_READ, EV_ADD, 0, 0, NULL);
				kevent(kq, &event, 1, NULL, 0, NULL);
				std::cerr << "connection accepted\n";
				int flags = fcntl(newSock, F_GETFL, 0);
				if (fcntl(newSock, F_SETFL, flags | O_NONBLOCK) < 0)
					std::cerr << "Cant set socket to nonblock statement";
				EV_SET(&event, newSock, EVFILT_WRITE, EV_ADD | EV_ONESHOT, 0, 0, NULL);
				kevent(kq, &event, 1, NULL, 0, NULL);

Как это исправить?

Comments

[Sergio]

с чего на что меняется тип переменной? у сокетов должен быть int

[Pinkman]

Нашел где висит.

// Висит на этом месте
		int newEvents = kevent(kq, NULL, 0, tEvent, 32, NULL);
		for (int i = 0; i < newEvents; i++) { // цикл который я выше отправил

То есть сначала он принимает подключение, потом отправляет данные, а потом повисает на kevent. И в этот момент отключается клиент. Не понимаю из-за чего.

[Pinkman]

Sergio, так я же вроде написал выше, это и есть тип int. В том и проблема, что при нормальном инте все корректно работает, а при классе все ломается.

[Wataru]

Илья, приведите код с классом.

[Евгений Шатунов]

Илья, нет, ты довольно непонятно написал. При каком классе все ломается?

Но как только меняю тип у переменной fd все ломается.

Я смотрю в код:
ft::Socket::Socket(int fd) : _socket(fd) {}
и не понимаю зачем ты у fd меняешь тип и на что ты его меняешь.

Лично я что-то понять смог только после вот этого твоего комментария, по тексту вопроса понимания не возникает вообще.
Тебе нужно показать код еще выше твоего вызова kevent в обоих случаях: когда ты оперируешь сокетом и когда ты оперируешь оберткой сокета.
Тебе нужно показать весь код твоей обертки сокета.

[Pinkman]

Wataru

#include "../includes/Socket.hpp"
#include <iostream>
ft::Socket::Socket() : _socket(123) {} // check
ft::Socket::Socket(int fd) : _socket(fd) {}
ft::Socket::Socket(const Socket& ref) { *this = ref; }
ft::Socket::Socket(const std::string& adr, int port) {
	if ((_socket = socket(PF_INET, SOCK_STREAM, 0)) < 0)
		throw ft::Socket::FailOnSocket();
	_info.sin_addr.s_addr = inet_addr(adr.c_str());
	_info.sin_family = PF_INET;
	_info.sin_len = 0;
	if (_info.sin_addr.s_addr == static_cast<in_addr_t>(-1)) {
		close(_socket);
		throw ft::Socket::FailOnSocket();
	}
	_info.sin_port = static_cast<in_port_t>(htons(port));
	if (fcntl(_socket, F_SETFL, O_NONBLOCK) < 0) {
		close(_socket);
		throw ft::Socket::FailOnSocket();
	}
}

ft::Socket::~Socket() { close(_socket); }

ft::Socket&	ft::Socket::operator=(const Socket& ref) {
	if (this == &ref)
		return *this;
	close(_socket);
	_socket = ref._socket;
	memcpy(&_info, &ref._info, sizeof(ref._info));
	return *this;
}

ft::Socket&	ft::Socket::operator=(int fd) {
	_socket = fd;
	return *this;
}

ft::Socket*		ft::Socket::acceptConnection(int host) {
	ft::Socket* t = new ft::Socket;
	sockaddr_storage st;
	int flags = fcntl(*t, F_GETFL, 0);
	fcntl(*t, F_SETFL, flags | O_NONBLOCK);
	int len = sizeof(st);

	*t = accept(host, (struct sockaddr*)&st, (socklen_t*)&len);
	if (*t < 0)
		throw ft::Socket::FailOnSocket();
	return t;
}

void		ft::Socket::bindHost() {
	if (bind(_socket, (const sockaddr*)&_info, sizeof(_info)) == -1) {
		throw ft::Socket::FailOnSocket();
	}
}

void		ft::Socket::hostListen(unsigned queue) {
	if (listen(_socket, queue) < 0)
		throw ft::Socket::FailOnSocket();
}


ft::Socket::operator int() { return _socket; }

const char*	ft::Socket::FailOnSocket::what() const throw() {
	return "Broken socket";
}

int		ft::Socket::getFd() const {
	return this->_socket;
}

// bool	ft::operator==(const Socket& lhs, const Socket& rhs) {
// 	return lhs.getFd() == rhs.getFd();
// }

[Pinkman]

Но все что касается именно переменной в цикле я написал выше. В первом блоке кода.
Кстати, хочу отметить что класс сокет, который держит главный сокет(куда все соединения идут) у объявлен как класс, и с ним проблем нет.

[res2001]

Илья,

Нашел где висит.

Получается висит на вызове kevent?
Или все таки kevent возвращает значение? Может там -1 и в цикл просто не входит? Хорошо бы проанализировать ошибку - это всегда полезно делать, во избежании подобных не поняток.
Вообще тип tEvent[i].ident uintptr_t, а вовсе не int. Компилятор не ругается на подобные преобразования? Я бы ругался :-) В 64 битных системах указатель в 2 раза больше по размеру, чем int. Вы бы для интереса вывели значение ident и сравнили его со значением newSock.
У вас выставлен флаг EV_ONESHOT, на сколько я понимаю, после первого срабатывания дескриптор удаляется из очереди с этим флагом.

Ни когда не использовал kevent, просто то что в глаза бросилось.

[Евгений Шатунов]

Илья, а где содержимое ../includes/Socket.hpp?
Объявление класса важно в первую очередь, а не череда определений его методов.

Покажи код вокруг

int newEvents = kevent(kq, NULL, 0, tEvent, 32, NULL);

когда ты используешь свою обертку сокета.

[res2001]

Илья, Конструктор по умолчанию вообще не имеет смысла, я бы его запретил.
В конструктор где приниматеся fd может быть передан блокирующий сокет, тогда как в другом конструкторе ты создаешь не блокирующий сокет. А в остальных членах класса поведение типичное для блокирующего сокета.

Поведение всех функций, работающих с сокетом, для блокирующего и не блокирующего сокета различаются. А ты на все ошибки бросаешь одно и то же исключение, тогда как в неблокирующем варианте ошибка EAGAIN - это нормальная ситуация.

[Pinkman]

res2001, да висит на kevent. -1 не возвращается. то есть именно внутри kevent'а начинается зависания.
Нет, clang++ не ругается(компилирую с флагами -Wall -Wextra -Werror) я выводил идент, там числа типа 3, 5. Вроде как нормальные фд выдает. Сокет тоже самое хранит)

Конструктор по умолчанию не нужен, просто для проверки его сделал.
Да, очередь на запись создается один раз, но очередь на чтение остается.
Евгений Шатунов Заголовок:

class Socket {
public:
	Socket();
	Socket(int fd);
	Socket(const std::string& adr, int port);
	Socket(const Socket& ref);
	~Socket();

	operator int();
	Socket&			operator=(const Socket& rhs);
	Socket&			operator=(int fd);
	void			bindHost();
	int				getFd() const;
	void			hostListen(unsigned queue);
	static Socket*	acceptConnection(int host);
	class FailOnSocket : public std::exception {
		public:
			virtual const char*	what() const throw();
	};
protected:
	int			_socket;
	sockaddr_in	_info;
};

Может это связано как нибудь с временем жизни объекта?

[Евгений Шатунов]

Илья, да, это может быть связано со временем жизни объекта.

Давай, все-таки, еще посмотрим твой код вокруг описанного здесь места тогда, когда ты меняешь тип сокета.
Мне нужно увидеть как именно ты меняешь тип сокета. Где ты его меняешь, на какой тип и как это все выглядит.

[Pinkman]

Евгений Шатунов res2001 спасибо! Разобрался.

Answer 1

[Pinkman]

Все решил. У меня в деструкторе стоял close(fd). Соответственно при выходе из зоны видимости класс вызывает деструктор и все. Получается вроде как сокет находится в очереди, а он уже закрыт.