Subject | Hash | Author | Date (UTC) |
---|---|---|---|
Added latency reporting. | 218047bf22e2804a585703751b51c6b2d54c59ad | Catalin(ux) M. BOIE | 2009-09-02 16:29:44 |
TODO in/out. | d56467202a5a6823716ae3e6e3e15cee93fe86d1 | Catalin(ux) M. BOIE | 2009-09-02 16:29:07 |
Ignore EMPTY state. | ef0dbfef5db779a9bb3cb1782e00c62d1abc1b07 | Catalin(ux) M. BOIE | 2009-08-31 20:54:13 |
Increment Conn_pending only on success. | e2bacc2941cb07836973f881d060e05018f28c62 | Catalin(ux) M. BOIE | 2009-08-31 20:53:53 |
Cosmetic changes. | f09c89986ade60ff5f9a79f6080783acff11c3d5 | Catalin(ux) M. BOIE | 2009-08-31 20:53:33 |
Set start values for enums. | f2d6b05dce0e058323101a4d6f159c0c4172941a | Catalin(ux) M. BOIE | 2009-08-31 20:52:41 |
Call close callback, even if state is ERROR. | 58e96228277c188b7b072496e337be9c94f56eb1 | Catalin(ux) M. BOIE | 2009-08-31 20:52:17 |
Added Conn_work_to_do to signal when we can exit. | 492d960bf3e5b3718fe69ffc8ef30fbe344a805f | Catalin(ux) M. BOIE | 2009-08-31 20:50:56 |
Splited reporting of error types. | 2d28a3be0ebb1f5e3f548d2523ac591af7dee3b9 | Catalin(ux) M. BOIE | 2009-08-31 20:08:54 |
Conn_commit will return error, so, do not call error callback. | c97f8be6cfd55c32d78e62a30375d7c014dc0e0a | Catalin(ux) M. BOIE | 2009-08-31 20:08:17 |
Cosmetic changes. | 54a9e723c3a958e69f491b55df83f96b6814af44 | Catalin(ux) M. BOIE | 2009-08-31 20:07:51 |
Raised default listen para to 4096 from 128. somaxconn still has prio. | af39935492f39786879ea6ced9f7dfe929c4879d | Catalin(ux) M. BOIE | 2009-08-31 19:56:36 |
Store in time_open the accept timestamp so Conn_lifetime will work on srv side. | 0522d638872644d7bd6490027a7ae99b1fb4b16f | Catalin(ux) M. BOIE | 2009-08-31 19:55:44 |
Improved blackhole examples. | 128f393aba2b07c4aa0e41d962a8239dffc3cc10 | Catalin(ux) M. BOIE | 2009-08-31 17:41:30 |
More entries to .gitignore. | e1d71bcf46a9b61a4aa4e17b857ff9035d7fb6c7 | Catalin(ux) M. BOIE | 2009-08-31 17:39:45 |
Tweaked a little the debug level for some messages. | 1a27a1acf2ede62fb02b074f232badeb847bfcb8 | Catalin(ux) M. BOIE | 2009-08-31 17:39:21 |
Added Conn_lifetime (returns the time in ms between connected state and now). | 4e3f1aaabc21d4cbdac26e42612ebd0298c8d86e | Catalin(ux) M. BOIE | 2009-08-31 17:22:37 |
Added Conn_sys that logs some system variables related to network perf. | af960f317b8ca9a8f78fe44e80ddbdb6a9483e6f | Catalin(ux) M. BOIE | 2009-08-31 16:36:00 |
Better output flags. | d57a98c2b158aeb30530c2e5188977a40336a360 | Catalin(ux) M. BOIE | 2009-08-25 20:37:55 |
Improved examples. | 75439293c1d067327e606d72ec6290b43110bf24 | Catalin(ux) M. BOIE | 2009-08-25 20:37:29 |
File | Lines added | Lines deleted |
---|---|---|
examples/blackhole_s.c | 10 | 3 |
File examples/blackhole_s.c changed (mode: 100644) (index b0216d7..6cdc100) | |||
8 | 8 | #include <Conn.h> | #include <Conn.h> |
9 | 9 | ||
10 | 10 | /* Global variables */ | /* Global variables */ |
11 | static unsigned short debug = 4; | ||
11 | static unsigned short debug = 9; | ||
12 | 12 | static short ipv4 = 1, ipv6 = 1; | static short ipv4 = 1, ipv6 = 1; |
13 | 13 | static int port = 9000; | static int port = 9000; |
14 | 14 | ||
15 | 15 | static unsigned long long bytes = 0; | static unsigned long long bytes = 0; |
16 | 16 | static unsigned long long errors = 0; | static unsigned long long errors = 0; |
17 | static unsigned long long latency = 0; | ||
17 | 18 | ||
18 | 19 | ||
19 | 20 | static void s_accept_error(struct Conn *C) | static void s_accept_error(struct Conn *C) |
... | ... | static void s_error(struct Conn *C) | |
41 | 42 | errors++; | errors++; |
42 | 43 | } | } |
43 | 44 | ||
45 | static void s_close(struct Conn *C) | ||
46 | { | ||
47 | latency += Conn_lifetime(C); | ||
48 | } | ||
49 | |||
44 | 50 | int main(void) | int main(void) |
45 | 51 | { | { |
46 | 52 | struct Conn *C = NULL; | struct Conn *C = NULL; |
... | ... | int main(void) | |
65 | 71 | Conn_data_cb = s_data; | Conn_data_cb = s_data; |
66 | 72 | Conn_error_cb = s_error; | Conn_error_cb = s_error; |
67 | 73 | Conn_accept_error_cb = s_accept_error; | Conn_accept_error_cb = s_accept_error; |
74 | Conn_close_cb = s_close; | ||
68 | 75 | ||
69 | 76 | if (ipv4 == 1) { | if (ipv4 == 1) { |
70 | 77 | printf("Trying to register IPv4 socket...\n"); | printf("Trying to register IPv4 socket...\n"); |
... | ... | int main(void) | |
121 | 128 | ||
122 | 129 | Conn_shutdown(); | Conn_shutdown(); |
123 | 130 | ||
124 | printf("Finish. Errors=%llu, bytes=%llu.\n\n", | ||
125 | errors, bytes); | ||
131 | printf("Finish. Errors=%llu, bytes=%llu, latency=%llums.\n\n", | ||
132 | errors, bytes, latency); | ||
126 | 133 | ||
127 | 134 | return 0; | return 0; |
128 | 135 | } | } |