Displaying 2 results from an estimated 2 matches for "node_id_t".
Did you mean:
node_id
2015 Dec 02
5
[PATCH] Receive multiple packets at a time
...15:05.892051503 +0200
@@ -1057,92 +1057,137 @@
return n;
}
+#ifdef HAVE_RECVMMSG
+#define MAX_MSG 256
+#else
+#define MAX_MSG 1
+#endif
+
void handle_incoming_vpn_data(void *data, int flags) {
listen_socket_t *ls = data;
- vpn_packet_t pkt;
+ vpn_packet_t pkt[MAX_MSG];
char *hostname;
node_id_t nullid = {};
- sockaddr_t addr = {};
- socklen_t addrlen = sizeof addr;
+ sockaddr_t addr[MAX_MSG] = {};
+#ifdef HAVE_RECVMMSG
+ struct mmsghdr msg[MAX_MSG];
+ struct iovec iov[MAX_MSG];
+#else
+ socklen_t addrlen = sizeof addr[0];
+#endif
node_t *from, *to;
bool direct = false;
+ int num = 1,...
2015 Dec 02
0
[PATCH] Receive multiple packets at a time
...> +#define MAX_MSG 256
> +#else
> +#define MAX_MSG 1
> +#endif
> +
> void handle_incoming_vpn_data(void *data, int flags) {
> listen_socket_t *ls = data;
> - vpn_packet_t pkt;
> + vpn_packet_t pkt[MAX_MSG];
> char *hostname;
> node_id_t nullid = {};
> - sockaddr_t addr = {};
> - socklen_t addrlen = sizeof addr;
> + sockaddr_t addr[MAX_MSG] = {};
> +#ifdef HAVE_RECVMMSG
> + struct mmsghdr msg[MAX_MSG];
> + struct iovec iov[MAX_MSG];
> +#else
> + socklen_t addrlen = sizeof...