| … | |
… | |
| 19 | * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
19 | * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA |
| 20 | * |
20 | * |
| 21 | * The authors can be reached via e-mail to <crossfire@schmorp.de> |
21 | * The authors can be reached via e-mail to <crossfire@schmorp.de> |
| 22 | */ |
22 | */ |
| 23 | |
23 | |
| 24 | /** |
|
|
| 25 | * \file |
|
|
| 26 | * Low-level socket-related functions. |
|
|
| 27 | * |
|
|
| 28 | * \date 2003-12-02 |
|
|
| 29 | * |
|
|
| 30 | * Contains some base functions that both the client and server |
|
|
| 31 | * can use. As such, depending what we are being compiled for will |
|
|
| 32 | * determine what we can include. the client is designed have |
|
|
| 33 | * CFCLIENT defined as part of its compile flags. |
|
|
| 34 | */ |
|
|
| 35 | |
|
|
| 36 | using namespace std; |
24 | using namespace std; |
| 37 | |
25 | |
| 38 | #include <global.h> |
26 | #include <global.h> |
| 39 | #include <sproto.h> |
27 | #include <sproto.h> |
| 40 | #include <cstdarg> |
28 | #include <cstdarg> |
| 41 | |
29 | |
| 42 | #ifdef __linux__ |
30 | #if HAVE_TCP_INFO |
| 43 | # include <sys/types.h> |
31 | # include <sys/types.h> |
| 44 | # include <sys/socket.h> |
32 | # include <sys/socket.h> |
| 45 | # include <netinet/in.h> |
33 | # include <netinet/in.h> |
| 46 | # include <netinet/tcp.h> |
34 | # include <netinet/tcp.h> |
| 47 | #endif |
35 | #endif |
| 48 | |
36 | |
| 49 | // use a really low timeout, as it doesn't cost any bandwidth, and you can |
37 | // disconnect a socket after this many seconds without an ack |
| 50 | // easily die in 20 seconds... |
|
|
| 51 | #define SOCKET_TIMEOUT1 10 * 1000 |
38 | #define SOCKET_TIMEOUT 8. |
| 52 | #define SOCKET_TIMEOUT2 20 * 1000 |
39 | |
|
|
40 | // force a packet when idle for more than this many seconds, |
|
|
41 | // forcing an ack regularly. |
|
|
42 | #define IDLE_PING 2. |
| 53 | |
43 | |
| 54 | void |
44 | void |
| 55 | client::flush () |
45 | client::flush () |
| 56 | { |
46 | { |
| 57 | if (destroyed ()) |
47 | if (destroyed ()) |
| 58 | return; |
48 | return; |
| 59 | |
49 | |
| 60 | #ifdef __linux__ |
50 | #if HAVE_TCP_INFO |
|
|
51 | // check about once per second, spread evenly over all clients |
|
|
52 | // do this only when player is active |
|
|
53 | if (!((pticks + fd) & 7) && pl && pl->active) |
|
|
54 | { |
| 61 | // check time of last ack, and, if too old, kill connection |
55 | // check time of last ack, and, if too old, kill connection |
| 62 | struct tcp_info tcpi; |
56 | struct tcp_info tcpi; |
| 63 | socklen_t len = sizeof (tcpi); |
57 | socklen_t len = sizeof (tcpi); |
| 64 | |
58 | |
| 65 | if (!getsockopt (fd, IPPROTO_TCP, TCP_INFO, &tcpi, &len) && len == sizeof (tcpi)) |
59 | if (!getsockopt (fd, IPPROTO_TCP, TCP_INFO, &tcpi, &len) && len == sizeof (tcpi)) |
| 66 | { |
60 | { |
| 67 | unsigned int diff = tcpi.tcpi_last_ack_recv - tcpi.tcpi_last_data_sent; |
61 | if (tcpi.tcpi_snd_mss) |
|
|
62 | mss = tcpi.tcpi_snd_mss; |
| 68 | |
63 | |
| 69 | rtt = tcpi.tcpi_rtt; |
64 | rtt = tcpi.tcpi_rtt; |
| 70 | rttvar = tcpi.tcpi_rttvar; |
65 | rttvar = tcpi.tcpi_rttvar; |
| 71 | |
66 | |
| 72 | if (tcpi.tcpi_unacked && SOCKET_TIMEOUT1 < diff && diff < 0x80000000UL // ack delayed for 20s |
67 | if (tcpi.tcpi_last_ack_recv > int (SOCKET_TIMEOUT * 1000)) |
| 73 | && SOCKET_TIMEOUT2 < tcpi.tcpi_last_data_sent) // no data sent for 10s |
|
|
| 74 | { |
68 | { |
|
|
69 | send_msg (NDI_RED, "connection-timeout", "safety disconnect due to tcp/ip timeout (no packets received)"); |
|
|
70 | write_outputbuffer (); |
|
|
71 | |
| 75 | LOG (llevDebug, "Connection on fd %d closed due to ack timeout (%u/%u/%u)\n", fd, |
72 | LOG (llevDebug, "connection on fd %d closed due to ack timeout (%u/%u/%u)\n", fd, |
| 76 | (unsigned) tcpi.tcpi_last_ack_recv, (unsigned) tcpi.tcpi_last_data_sent, (unsigned) tcpi.tcpi_unacked); |
73 | (unsigned)tcpi.tcpi_last_ack_recv, (unsigned)tcpi.tcpi_last_data_sent, (unsigned)tcpi.tcpi_unacked); |
| 77 | destroy (); |
74 | destroy (); |
|
|
75 | } |
| 78 | } |
76 | } |
| 79 | } |
77 | } |
| 80 | #endif |
78 | #endif |
| 81 | |
79 | |
| 82 | /** |
80 | /** |
| … | |
… | |
| 84 | * |
82 | * |
| 85 | * When the socket is clear to write, and we have backlogged data, this |
83 | * When the socket is clear to write, and we have backlogged data, this |
| 86 | * is called to write it out. |
84 | * is called to write it out. |
| 87 | */ |
85 | */ |
| 88 | |
86 | |
| 89 | if (!outputbuffer.len || socket_ev.poll () & PE_W) |
87 | // write a nop to the socket at least every IDLE_NOP seconds. |
|
|
88 | if (!outputbuffer.len) |
|
|
89 | { |
|
|
90 | if (last_send + IDLE_PING <= NOW && pl && pl->active) |
|
|
91 | { |
|
|
92 | // this is a bit ugly, but map1/map1a seem to be the only |
|
|
93 | // nop'able commands and they are quite small. |
|
|
94 | packet sl (mapmode == Map1Cmd ? "map1" : "map1a"); |
|
|
95 | send_packet (sl); |
|
|
96 | } |
|
|
97 | else |
|
|
98 | return; |
|
|
99 | } |
|
|
100 | |
|
|
101 | if (socket_ev.poll () & PE_W) |
| 90 | return; |
102 | return; |
| 91 | |
103 | |
|
|
104 | last_send = NOW; |
| 92 | write_outputbuffer (); |
105 | write_outputbuffer (); |
| 93 | } |
106 | } |
| 94 | |
107 | |
| 95 | void |
108 | void |
| 96 | client::write_outputbuffer () |
109 | client::write_outputbuffer () |
| … | |
… | |
| 106 | /* wrap back to start of buffer */ |
119 | /* wrap back to start of buffer */ |
| 107 | if (outputbuffer.start == SOCKETBUFSIZE) |
120 | if (outputbuffer.start == SOCKETBUFSIZE) |
| 108 | outputbuffer.start = 0; |
121 | outputbuffer.start = 0; |
| 109 | |
122 | |
| 110 | outputbuffer.len -= res; |
123 | outputbuffer.len -= res; |
| 111 | #ifdef CS_LOGSTATS |
|
|
| 112 | cst_tot.obytes += res; |
|
|
| 113 | cst_lst.obytes += res; |
|
|
| 114 | #endif |
|
|
| 115 | } |
124 | } |
| 116 | else if (res == 0) |
125 | else if (res == 0) |
| 117 | { |
126 | { |
| 118 | LOG (llevError, "socket write failed, connection closed.\n"); |
127 | LOG (llevError, "socket write failed, connection closed.\n"); |
| 119 | destroy (); |
128 | destroy (); |
| … | |
… | |
| 376 | } |
385 | } |
| 377 | else |
386 | else |
| 378 | { |
387 | { |
| 379 | inbuf_len += amount; |
388 | inbuf_len += amount; |
| 380 | |
389 | |
| 381 | cst_tot.ibytes += amount; |
|
|
| 382 | cst_lst.ibytes += amount; |
|
|
| 383 | |
|
|
| 384 | cmd_ev.start (); |
390 | cmd_ev.start (); |
| 385 | } |
391 | } |
| 386 | } |
392 | } |
| 387 | } |
393 | } |
| 388 | |
394 | |
| … | |
… | |
| 606 | return reset (); |
612 | return reset (); |
| 607 | |
613 | |
| 608 | cur += len; |
614 | cur += len; |
| 609 | } |
615 | } |
| 610 | |
616 | |
| 611 | /****************************************************************************** |
|
|
| 612 | * |
|
|
| 613 | * statistics logging functions. |
|
|
| 614 | * |
|
|
| 615 | ******************************************************************************/ |
|
|
| 616 | |
|
|
| 617 | #ifdef CS_LOGSTATS |
|
|
| 618 | |
|
|
| 619 | /* cst_tot is for the life of the server, cst_last is for the last series of |
|
|
| 620 | * stats |
|
|
| 621 | */ |
|
|
| 622 | CS_Stats cst_tot, cst_lst; |
|
|
| 623 | |
|
|
| 624 | /** |
|
|
| 625 | * Writes out the gathered stats. We clear cst_lst. |
|
|
| 626 | */ |
|
|
| 627 | void |
|
|
| 628 | write_cs_stats (void) |
|
|
| 629 | { |
|
|
| 630 | time_t now = time (NULL); |
|
|
| 631 | |
|
|
| 632 | /* If no connections recently, don't both to log anything */ |
|
|
| 633 | if (cst_lst.ibytes == 0 && cst_lst.obytes == 0) |
|
|
| 634 | return; |
|
|
| 635 | |
|
|
| 636 | /* CSSTAT is put in so scripts can easily find the line */ |
|
|
| 637 | LOG (llevInfo, "CSSTAT: %.16s tot %d %d %d %d inc %d %d %d %d\n", |
|
|
| 638 | ctime (&now), cst_tot.ibytes, cst_tot.obytes, cst_tot.max_conn, |
|
|
| 639 | now - cst_tot.time_start, cst_lst.ibytes, cst_lst.obytes, cst_lst.max_conn, now - cst_lst.time_start); |
|
|
| 640 | cst_lst.ibytes = 0; |
|
|
| 641 | cst_lst.obytes = 0; |
|
|
| 642 | cst_lst.time_start = now; |
|
|
| 643 | } |
|
|
| 644 | #endif |
|
|
| 645 | |
|
|
