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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
/*
* recordclnt.c - client playback
*
* $Id: playback.c,v 1.5 2004/12/29 19:09:38 jon Exp $
*
* Copyright 1999-2004 Jon Trulson under the ARTISTIC LICENSE. (See LICENSE).
*/
#include "c_defs.h"
#include "global.h"
#include "conqdef.h"
#include "conqcom.h"
#include "context.h"
#include "conf.h"
#include "global.h"
#include "color.h"
#include "datatypes.h"
#include "protocol.h"
#include "packet.h"
#include "protocol.h"
#include "client.h"
#include "record.h"
#include "playback.h"
/* read in a header/data packet pair, and add them to our cmb. return
the packet type processed or RDATA_NONE if there is no more data or
other error. */
int pbProcessPackets(void)
{
Unsgn8 buf[PKT_MAXSIZE];
spFrame_t *frame;
int pkttype;
spMessage_t *smsg;
#if defined(DEBUG_REC)
clog("conqreply: processPacket ENTER");
#endif
if ((pkttype = recordReadPkt(buf, PKT_MAXSIZE)) != SP_NULL)
{
switch(pkttype)
{
case SP_SHIP:
procShip(buf);
break;
case SP_SHIPSML:
procShipSml(buf);
break;
case SP_SHIPLOC:
procShipLoc(buf);
break;
case SP_USER:
procUser(buf);
break;
case SP_PLANET:
procPlanet(buf);
break;
case SP_PLANETSML:
procPlanetSml(buf);
break;
case SP_PLANETLOC:
procPlanetLoc(buf);
break;
case SP_PLANETLOC2:
procPlanetLoc2(buf);
break;
case SP_PLANETINFO:
procPlanetInfo(buf);
break;
case SP_TORPEVENT:
procTorpEvent(buf);
break;
case SP_TORP:
procTorp(buf);
break;
case SP_TORPLOC:
procTorpLoc(buf);
break;
case SP_TEAM:
procTeam(buf);
break;
case SP_MESSAGE:
smsg = (spMessage_t *)buf;
memset((void *)&recMsg, 0, sizeof(Msg_t));
strncpy(recMsg.msgbuf, smsg->msg, MESSAGE_SIZE);
recMsg.msgfrom = (int)((Sgn16)ntohs(smsg->from));
recMsg.msgto = (int)((Sgn16)ntohs(smsg->to));
recMsg.flags = smsg->flags;
break;
case SP_FRAME:
frame = (spFrame_t *)buf;
/* endian correction*/
frame->time = (Unsgn32)ntohl(frame->time);
frame->frame = (Unsgn32)ntohl(frame->frame);
if (startTime == (time_t)0)
startTime = (time_t)frame->time;
currTime = (time_t)frame->time;
frameCount = (Unsgn32)frame->frame;
break;
case SP_DOOMSDAY:
procDoomsday(buf);
break;
default:
#ifdef DEBUG_REC
fprintf(stderr, "processPacket: Invalid rtype %d\n", pkttype);
#endif
break;
}
}
return pkttype;
}
/* seek around in a game. backwards seeks will be slooow... */
void pbFileSeek(time_t newtime)
{
if (newtime == currTime)
return; /* simple case */
if (newtime < currTime)
{ /* backward */
/* we have to reset everything and start from scratch. */
recordCloseInput();
if (!initReplay(rfname, NULL))
return; /* bummer */
currTime = startTime;
}
/* start searching */
/* just read packets until 1. currTime exceeds newtime, or 2. no
data is left */
Context.display = FALSE; /* don't display things while looking */
while (currTime < newtime)
if ((pbProcessPackets() == SP_NULL))
break; /* no more data */
Context.display = TRUE;
return;
}
/* read and process packets until a FRAME packet or EOD is found */
int pbProcessIter(void)
{
int rtype;
while(((rtype = pbProcessPackets()) != SP_NULL) && rtype != SP_FRAME)
;
return(rtype);
}
|
