--- deliantra/server/include/client.h 2007/07/12 08:40:14 1.60 +++ deliantra/server/include/client.h 2007/07/28 00:15:03 1.65 @@ -28,6 +28,43 @@ #include #include +#if HAVE_TCP_INFO +# include +#else + struct tcpi_info { + // dummy + char tcpi_state; + char tcpi_ca_state; + char tcpi_retransmits; + char tcpi_probes; + char tcpi_backoff; + char tcpi_options; + char tcpi_snd_wscale; + char tcpi_rcv_wscale; + char tcpi_rto; + char tcpi_ato; + char tcpi_snd_mss; + char tcpi_rcv_mss; + char tcpi_unacked; + char tcpi_sacked; + char tcpi_lost; + char tcpi_retrans; + char tcpi_fackets; + char tcpi_last_data_sent; + char tcpi_last_ack_sent; + char tcpi_last_data_recv; + char tcpi_last_ack_recv; + char tcpi_pmtu; + char tcpi_rcv_ssthresh; + char tcpi_rtt; + char tcpi_rttvar; + char tcpi_snd_ssthresh; + char tcpi_snd_cwnd; + char tcpi_advmss; + char tcpi_reordering; + }; +#endif + // (possibly) max. number of objects "per page" in the ground container #define FLOORBOX_PAGESIZE 50 @@ -87,6 +124,15 @@ PF_COMMAND6 = 0x08, // command starts at offset 6 }; +// face type.s bit 0 means "has meta info prepended" +enum { + FT_FACE = 0 * 2 + 0, // faces (images) + FT_MUSIC = 1 * 2 + 1, // background music + FT_SOUND = 2 * 2 + 1, // effects + FT_RSRC = 3 * 2 + 0, // generic data files + FT_NUM, +}; + struct packet_type { const char *name; @@ -157,7 +203,7 @@ bool ACC (RW, newmapcmd); /* Send newmap command when entering new map SMACFIGGEN */ bool ACC (RW, plugincmd); // extend the protocol through a plug-in */ bool ACC (RW, mapinfocmd); // return map info and send map change info - bool ACC (RW, extcmd); // call into extensions/plugins + uint8_t ACC (RW, extcmd); // call into extensions/plugins bool ACC (RW, extmap); // extend map comamnd with extra data bool ACC (RW, buggy_mapscroll); // client crashes on large mapscrolls bool ACC (RW, darkness); /* True if client wants darkness information */ @@ -191,13 +237,46 @@ tstamp ACC (RW, last_send); // last data send on socket. - int ACC (RW, rtt), ACC (RW, rttvar); /* round-trip time and -variance, if known */ - int ACC (RW, rate_avail); // current rate balance int ACC (RW, max_rate); // max. # of bytes to send per tick faceidx ACC (RW, scrub_idx); // which face to send next int ACC (RW, bg_scrub); // how many ticks till the next background face send + struct tcp_info tcpi; + tstamp next_rate_adjust; +#if FOR_PERL + // unfortunately, this emans that we *require* tcp_info now... + ACC (RW, tcpi.tcpi_state); + ACC (RW, tcpi.tcpi_ca_state); + ACC (RW, tcpi.tcpi_retransmits); + ACC (RW, tcpi.tcpi_probes); + ACC (RW, tcpi.tcpi_backoff); + ACC (RW, tcpi.tcpi_options); + ACC (RO, tcpi.tcpi_snd_wscale); + ACC (RO, tcpi.tcpi_rcv_wscale); + ACC (RW, tcpi.tcpi_rto); + ACC (RW, tcpi.tcpi_ato); + ACC (RW, tcpi.tcpi_snd_mss); + ACC (RW, tcpi.tcpi_rcv_mss); + ACC (RW, tcpi.tcpi_unacked); + ACC (RW, tcpi.tcpi_sacked); + ACC (RW, tcpi.tcpi_lost); + ACC (RW, tcpi.tcpi_retrans); + ACC (RW, tcpi.tcpi_fackets); + ACC (RW, tcpi.tcpi_last_data_sent); + ACC (RW, tcpi.tcpi_last_ack_sent); + ACC (RW, tcpi.tcpi_last_data_recv); + ACC (RW, tcpi.tcpi_last_ack_recv); + ACC (RW, tcpi.tcpi_pmtu); + ACC (RW, tcpi.tcpi_rcv_ssthresh); + ACC (RW, tcpi.tcpi_rtt); + ACC (RW, tcpi.tcpi_rttvar); + ACC (RW, tcpi.tcpi_snd_ssthresh); + ACC (RW, tcpi.tcpi_snd_cwnd); + ACC (RW, tcpi.tcpi_advmss); + ACC (RW, tcpi.tcpi_reordering); +#endif + struct ixsend { int16_t pri; // unused faceidx idx; @@ -220,6 +299,7 @@ struct Map lastmap; std::bitset anims_sent; std::bitset faces_sent; + std::bitset fx_want; // if we get an incomplete packet, this is used to hold the data. // we add 2 byte for the header, one for the trailing 0 byte @@ -262,21 +342,13 @@ void send_drawinfo (const char *msg, int flags = NDI_BLACK); - MTH bool must_send_face (faceidx facenum) - { - if (faces_sent[facenum]) - return false; - - faces_sent[facenum] = true; - return true; - } - - MTH void send_face (faceidx facenum); + MTH void send_face (faceidx facenum, int pri = 0); MTH void send_image (faceidx facenum); MTH void send_faces (object *ob); MTH void send_animation (short anim_num); void send_msg (int color, const char *type, const char *msg); + MTH void play_sound (faceidx sound, int dx = 0, int dy = 0); // called when something under the player changes MTH void floorbox_update () { update_look = 1; } // called when the player has been moved