s_list<SOCKET, 1024> socket_arr = zero;
while(true) {

	WSAPOLLFD poll_arr[1025] = zero;
	poll_arr[0].fd = server_socket;
	poll_arr[0].events = POLLIN;
	for(int socket_i = 0; socket_i < socket_arr.count; socket_i += 1) {
		poll_arr[socket_i + 1].fd = socket_arr[socket_i];
		poll_arr[socket_i + 1].events = POLLIN;
	}

	int hot_socket_count = WSAPoll(poll_arr, socket_arr.count + 1, -1);
	if(hot_socket_count < 0) {
		error();
	}

	int handled_count = 0;
	int i = 0;
	while(handled_count < hot_socket_count && i < 1025) {
		SOCKET s = poll_arr[i].fd;
		int flags = poll_arr[i].revents;
		bool can_read = (flags & POLLRDNORM) || (flags & POLLRDBAND);
		bool has_error = (flags & POLLERR) || (flags & POLLNVAL);
		bool disconnected = flags & POLLHUP;
		check(!has_error);
		bool delete_socket = false;

		if(disconnected) {
			printf("connection %i closed\n", i);
			check(s != server_socket);
			handled_count += 1;
			delete_socket = true;
		}

		else if(can_read) {
			handled_count += 1;

			if(s == server_socket) {
				SOCKET new_socket = accept(server_socket, null, null);
				check(new_socket != INVALID_SOCKET);
				socket_arr.add(new_socket);
			}
			else {
				char buffer[65535 + 1];
				int bytes_read = recv(s, buffer, sizeof(buffer), 0);
				if(bytes_read > 0) {
				}
				else if(bytes_read == 0) {
					printf("connection clossed\n");
					delete_socket = true;
				}
				else {
					printf("recv failed\n");
					delete_socket = true;
				}
			}
		}

		if(delete_socket) {
			shutdown(s, SD_BOTH);
			closesocket(s);
			socket_arr.remove_and_swap(i - 1);
		}

		i += 1;
	}
}