1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/*
* Copyright (C) Volition, Inc. 1999. All rights reserved.
*
* All source code herein is the property of Volition, Inc. You may not sell
* or otherwise commercially exploit the source or things you created based on the
* source.
*
*/
#include "network/multi.h"
#include "network/multi_ping.h"
#include "network/multimsgs.h"
#include "io/timer.h"
// ------------------------------------------------------------------------------------
// MULTIPLAYER PING DEFINES/VARS
//
// ------------------------------------------------------------------------------------
// MULTIPLAYER PING FUNCTIONS
//
// initialize all player ping times
void multi_ping_reset_players()
{
int idx;
// reset the pings for all players
for(idx=0;idx<MAX_PLAYERS;idx++){
multi_ping_reset(&Net_players[idx].s_info.ping);
}
}
// initialize the given ping struct
void multi_ping_reset(ping_struct *ps)
{
// blast the struct clear
memset(ps,0,sizeof(ping_struct));
ps->ping_add = 0;
// set the ping start to be -1
ps->ping_start = -1.0f;
ps->ping_avg = -1;
ps->num_pings = 0;
}
// evaluate a pong return on the given struct
void multi_ping_eval_pong(ping_struct *ps)
{
int idx;
float ping_sum;
// if the ping technically hasn't started,
if(ps->ping_start < 0.0f){
nprintf(("Network","Processing pong for ping which hasn't started yet!\n"));
return;
}
// if we still have room to add a ping
if(ps->num_pings < MAX_PINGS){
ps->ping_times[ps->ping_add++] = f2fl(timer_get_fixed_seconds()) - ps->ping_start;
ps->num_pings++;
}
// otherwise if we've wrapped around
else {
// increment the place to add the ping time
if(ps->ping_add >= MAX_PINGS - 1){
ps->ping_add = 0;
} else {
ps->ping_add++;
}
ps->ping_times[ps->ping_add] = f2fl(timer_get_fixed_seconds()) - ps->ping_start;
}
// calculate the average ping time
ping_sum = 0.0f;
for(idx=0;idx<ps->num_pings;idx++){
ping_sum += ps->ping_times[idx];
}
ps->ping_avg = (int)(1000.0f * (ping_sum / (float)ps->num_pings));
}
// start a ping - call this when sending a ping packet
void multi_ping_start(ping_struct *ps)
{
ps->ping_start = f2fl(timer_get_fixed_seconds());
}
// send a ping to a specific player
void multi_ping_send(net_player *p)
{
multi_ping_start(&p->s_info.ping);
send_ping(&p->p_info.addr);
}
// send a ping to the specified address
void multi_ping_send(net_addr *addr,ping_struct *ps)
{
multi_ping_start(ps);
send_ping(addr);
}
// send a ping to all players
void multi_ping_send_all()
{
int idx;
for(idx = 0;idx < MAX_PLAYERS;idx++){
if(MULTI_CONNECTED(Net_players[idx]) && (Net_player != NULL) && (Net_player->player_id != Net_players[idx].player_id)){
// start the ping
multi_ping_start(&Net_players[idx].s_info.ping);
// send the ping packet
send_ping(&Net_players[idx].p_info.addr);
}
}
}
|
