against unix

against-unix/Makefile

@@ -0,0 +1,10 @@
+
+
+run:
+	gcc -O3 fatal.c -o fatal
+	gcc -O3 client.c -o client
+	(./fatal 256 1021 &);
+	@sleep 10
+	./client
+	kill `pidof fatal`
+

against-unix/client.c

@@ -0,0 +1,60 @@
+#include <arpa/inet.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <getopt.h>
+#include <netinet/in.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include <time.h>
+
+#define TIMESPEC_NSEC(ts) ((ts)->tv_sec * 1000000000ULL + (ts)->tv_nsec)
+
+uint64_t realtime_now()
+{
+        struct timespec now_ts;
+        clock_gettime(CLOCK_MONOTONIC, &now_ts);
+        return TIMESPEC_NSEC(&now_ts);
+}
+
+int main()
+{
+	struct sockaddr_in sin4;
+	memset(&sin4, 0, sizeof(sin4));
+	sin4.sin_family = AF_INET;
+	sin4.sin_port = 0;
+//	sin4.sin_addr = INADDR_ANY;
+	struct sockaddr *sockaddr = (struct sockaddr*)&sin4;
+	int sockaddr_len = sizeof(sin4);
+
+
+	int sd = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
+	int one = 1;
+	setsockopt(sd, SOL_SOCKET, SO_REUSEADDR, (char *)&one,
+		   sizeof(one));
+
+	sin4.sin_port = htons(1 + 1024);
+	connect(sd, sockaddr, sockaddr_len);
+
+
+	uint64_t ta = realtime_now();
+	uint64_t best_td = (uint64_t)-1LL;
+	int i;
+	for (i = 0; i < 16; i++) {
+		uint64_t t0 = realtime_now();
+		char buf[1024];
+		send(sd, buf, sizeof(buf), 0);
+		uint64_t td = realtime_now()- t0;
+		recv(sd, buf, sizeof(buf), 0);
+		if (best_td > td)
+			best_td = td;
+	}
+	uint64_t tdd = realtime_now()- ta;
+	printf("min=%.3fms tot=%.3fms\n", best_td/1000000., tdd / 1000000.);
+
+	return 0;
+}

against-unix/fatal.c

@@ -0,0 +1,106 @@
+#include <arpa/inet.h>
+#include <errno.h>
+#include <signal.h>
+#include <fcntl.h>
+#include <getopt.h>
+#include <netinet/in.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/socket.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <unistd.h>
+
+
+int main(int argc, char **argv)
+{
+	int forks = 0;
+	int fd_max = 1;
+	if (argc > 1) {
+		forks = atoi(argv[1]);
+		if (forks < 0 || forks > 10000) {
+			forks = 0;
+		}
+	}
+	if (argc > 2) {
+		fd_max = atoi(argv[2]);
+		if (fd_max < 0 || fd_max > 10000) {
+			fd_max = 1;
+		}
+	}
+	printf("forks = %d, open sockets = %d\n", forks, fd_max);
+	int *list_of_sd = calloc(1, sizeof(int) * fd_max);
+	int *list_of_pids = calloc(1, sizeof(int) * fd_max);
+
+	struct sockaddr_in sin4;
+	memset(&sin4, 0, sizeof(sin4));
+	sin4.sin_family = AF_INET;
+	sin4.sin_port = 0;
+//	sin4.sin_addr = INADDR_ANY;
+	struct sockaddr *sockaddr = (struct sockaddr*)&sin4;
+	int sockaddr_len = sizeof(sin4);
+
+
+	int i;
+	for (i = 0; i < fd_max; i++) {
+		if (i > 0) {
+			list_of_sd[i] = dup(list_of_sd[0]);
+			continue;
+		}
+		int sd = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
+		int one = 1;
+		setsockopt(sd, SOL_SOCKET, SO_REUSEADDR, (char *)&one,
+			   sizeof(one));
+
+		sin4.sin_port = htons(i + 1024+1);
+		bind(sd, sockaddr, sockaddr_len);
+
+		int flags = fcntl(sd, F_GETFL, 0);
+		fcntl(sd, F_SETFL, flags | O_NONBLOCK);
+
+		list_of_sd[i] = sd;
+	}
+
+	for(i=0; i < forks; i++) {
+		int r = fork();
+		if (r == 0) {
+			break;
+		}
+		list_of_pids[i] = r;
+	}
+
+	if (i == forks) {
+		printf("started\n");
+		while (1) {
+			sleep(100);
+		}
+		return 0;
+	}
+
+	while (1) {
+		fd_set rfds;
+		FD_ZERO(&rfds);
+		for (i = 0; i < fd_max; i++) {
+			int sd = list_of_sd[i];
+			FD_SET(sd, &rfds);
+		}
+		int r = select(list_of_sd[fd_max-1]+1, &rfds, NULL, NULL, NULL);
+		for (i = 0; i < fd_max; i++) {
+			int sd = list_of_sd[i];
+			if (FD_ISSET(sd, &rfds)) {
+				char buf[1024];
+				struct sockaddr_in sin;
+				int sal = sizeof(sin);
+				int l = recvfrom(sd, buf, sizeof(buf), 0,
+						 (struct sockaddr*)&sin, &sal);
+				if (l > 0) {
+					sendto(sd, buf, l, 0, (struct sockaddr*)&sin, sal);
+				}
+//				break;
+			}
+		}
+	}
+
+	return 0;
+}

how-to-receive-a-million-packets/udpsender.c

@@ -36,7 +36,7 @@ void thread_loop(void *userdata) {
 		iovec->iov_base = (void*)state->payload;
 		iovec->iov_len = state->payload_sz;
 	}
-
+	
 	while (1) {
 		int r = sendmmsg(fd, messages, state->packets_in_buf, 0);
 		if (r <= 0) {

ufo.py

@@ -65,7 +65,7 @@
 
 items = [Item(*k) for k in raw_items]
 
-q
+
 def str_time(t):
     if not t: t = 0
     d = t / days