Merge 92ba6b439e6aed8557a315ebfcd350016159be52 into 0f1721d2c4ee2d135310aaa607be6902c243c547

nfq/nfqws.c

@@ -217,12 +217,10 @@ static bool nfq_init(struct nfq_handle **h,struct nfq_q_handle **qh)
 	if (!rawsend_preinit(params.bind_fix4,params.bind_fix6))
 		goto exiterr;
 
-	int yes=1, fd = nfq_fd(*h);
+	// increase socket buffer size. on slow systems reloading hostlist can take a while.
-
+	// if too many unhandled packets are received its possible to get "no buffer space available" error
-#if defined SOL_NETLINK && defined NETLINK_NO_ENOBUFS
+	if (!set_socket_buffers(nfq_fd(*h),Q_RCVBUF/2,Q_SNDBUF/2))
-	if (setsockopt(fd, SOL_NETLINK, NETLINK_NO_ENOBUFS, &yes, sizeof(yes)) == -1)
+		goto exiterr;
-		DLOG_PERROR("setsockopt(NETLINK_NO_ENOBUFS)");
-#endif
 
 	return true;
 exiterr:
@@ -269,7 +267,7 @@ static int nfq_main(void)
 		errno=e;
 		DLOG_PERROR("recv");
 		// do not fail on ENOBUFS
-	} while(e==ENOBUFS);
+	} while(errno==ENOBUFS);
 
 	nfq_deinit(&h,&qh);
 

tpws/tpws.c

@@ -711,12 +711,10 @@ void parse_params(int argc, char *argv[])
 	while ((v = getopt_long_only(argc, argv, "", long_options, &option_index)) != -1)
 	{
 		if (v)
-		{
 			if (bDry)
 				exit_clean(1);
 			else
 				exithelp_clean();
-		}
 		switch (option_index)
 		{
 		case 0: