From 0cb97841ae390ae23430a418efa0af9afd9b5450 Mon Sep 17 00:00:00 2001 From: Sean Hefty Date: Fri, 7 Dec 2012 17:34:00 -0800 Subject: [PATCH] refresh (create temporary patch) --- meta | 5 +- patches/refresh-temp | 122 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 125 insertions(+), 2 deletions(-) create mode 100644 patches/refresh-temp diff --git a/meta b/meta index f246e363..5d7489d5 100644 --- a/meta +++ b/meta @@ -1,9 +1,10 @@ Version: 1 -Previous: c48686550089c23bde3518fd648d62cb210246d1 -Head: 3c7c899adc5a1cefd244be4f54b5be9b6cbc7d46 +Previous: 79c036478848bf99e48ea004ce4ff68333cc8cb3 +Head: a34b73fdb63ca45198632d2d5c8367ebb154ab0e Applied: dsocket: 320986faa492c17e8858885798b9da8afaad7551 udpong: 3c7c899adc5a1cefd244be4f54b5be9b6cbc7d46 + refresh-temp: a34b73fdb63ca45198632d2d5c8367ebb154ab0e Unapplied: test-udp: f6c78ad2a26f452cf166aff1baa7b76160bd8bf7 iom-dbg: 88434072d07f8edc58f454ac954d78bd39441eed diff --git a/patches/refresh-temp b/patches/refresh-temp new file mode 100644 index 00000000..29af44fb --- /dev/null +++ b/patches/refresh-temp @@ -0,0 +1,122 @@ +Bottom: 854184ce75f3902fa1b4d84530045ee2fb8fbb05 +Top: 3855a3afdaa94a3f44bd0f049eea2e89afa14c9a +Author: Sean Hefty +Date: 2012-12-07 17:34:00 -0800 + +Refresh of udpong + +--- + +diff --git a/examples/common.h b/examples/common.h +index 37dc79e..eaffb57 100644 +--- a/examples/common.h ++++ b/examples/common.h +@@ -62,7 +62,7 @@ extern int use_rs; + #define rs_recvfrom(s,b,l,f,a,al) \ + use_rs ? rrecvfrom(s,b,l,f,a,al) : recvfrom(s,b,l,f,a,al) + #define rs_sendto(s,b,l,f,a,al) \ +- use_rs ? rsendto(s,b,l,f,a,al) : sendto(s,b,l,fa,al) ++ use_rs ? rsendto(s,b,l,f,a,al) : sendto(s,b,l,f,a,al) + #define rs_poll(f,n,t) use_rs ? rpoll(f,n,t) : poll(f,n,t) + #define rs_fcntl(s,c,p) use_rs ? rfcntl(s,c,p) : fcntl(s,c,p) + #define rs_setsockopt(s,l,n,v,ol) \ +diff --git a/examples/udpong.c b/examples/udpong.c +index 4adec2f..d4f43ac 100644 +--- a/examples/udpong.c ++++ b/examples/udpong.c +@@ -48,11 +48,11 @@ + #include "common.h" + + static int test_size[] = { +- { 1 << 6 }, +- { 1 << 7 }, { (1 << 7) + (1 << 6) }, +- { 1 << 8 }, { (1 << 8) + (1 << 7) }, +- { 1 << 9 }, { (1 << 9) + (1 << 8) }, +- { 1 << 10 }, { (1 << 10) + (1 << 9) }, ++ (1 << 6), ++ (1 << 7), ((1 << 7) + (1 << 6)), ++ (1 << 8), ((1 << 8) + (1 << 7)), ++ (1 << 9), ((1 << 9) + (1 << 8)), ++ (1 << 10), ((1 << 10) + (1 << 9)), + }; + #define TEST_CNT (sizeof test_size / sizeof test_size[0]) + +@@ -78,7 +78,7 @@ struct client { + }; + + static struct client clients[256]; +-static int id; ++static uint8_t id; + + static int rs; + static int use_async; +@@ -106,13 +106,8 @@ static void show_perf(void) + int transfers; + + usec = (end.tv_sec - start.tv_sec) * 1000000 + (end.tv_usec - start.tv_usec); +- if (echo) { +- transfers = transfer_count; +- bytes = (long long) transfer_count * transfer_size * 2; +- } else { +- transfers = ntohl(msg.data); +- bytes = (long long) transfers * transfer_size; +- } ++ transfers = echo ? transfer_count * 2 : ntohl(msg.data); ++ bytes = (long long) transfers * transfer_size; + + /* name size transfers bytes seconds Gb/sec usec/xfer */ + printf("%-10s", test_name); +@@ -124,7 +119,7 @@ static void show_perf(void) + printf("%-8s", str); + printf("%8.2fs%10.2f%11.2f\n", + usec / 1000000., (bytes * 8) / (1000. * usec), +- (usec / iterations) / (transfers * 2)); ++ (usec / transfers)); + } + + static void init_latency_test(int size) +@@ -208,7 +203,7 @@ static ssize_t svr_recv(struct message *msg, size_t size, + + do { + if (use_async) { +- ret = do_poll(fds, poll_timeout); ++ ret = do_poll(&fds, poll_timeout); + if (ret) + return ret; + } +@@ -230,7 +225,7 @@ static int svr_process(struct message *msg, size_t size, + switch (msg->op) { + case msg_op_start: + memset(&clients[id], 0, sizeof clients[id]); +- msg.id = id++; ++ msg->id = id++; + break; + case msg_op_echo: + clients[msg->id].recvcnt++; +@@ -331,7 +326,7 @@ static ssize_t client_recv(struct message *msg, size_t size, int timeout) + fds.fd = rs; + fds.events = POLLIN; + +- ret = rs_poll(fds, 1, timeout); ++ ret = rs_poll(&fds, 1, timeout); + if (ret <= 0) + return ret; + } +@@ -360,7 +355,7 @@ static int client_send_recv(struct message *msg, size_t size) + + static int run_test(void) + { +- int ret, i, t; ++ int ret, i; + + msg.op = msg_op_start; + ret = client_send_recv(&msg, CTRL_MSG_SIZE); +@@ -396,7 +391,7 @@ static int client_connect(void) + + memset(&hints, 0, sizeof hints); + hints.ai_socktype = SOCK_DGRAM; +- ret = getaddrinfo(dst_addr, port, hints, &res); ++ ret = getaddrinfo(dst_addr, port, &hints, &res); + if (ret) { + perror("getaddrinfo"); + return ret; -- 2.41.0