diff --git a/src/game/g_net.pas b/src/game/g_net.pas
index e935fc98eb68556f60e92a4be559b0419abb86ce..b71d541231d055004b2c919a1d04aae3cdee3e41 100644 (file)
--- a/src/game/g_net.pas
+++ b/src/game/g_net.pas
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*)
-{$MODE DELPHI}
+{$INCLUDE ../shared/a_modes.inc}
unit g_net;
interface
e_log, e_fixedbuffer, ENet, Classes;
const
- NET_PROTOCOL_VER = 169;
+ NET_PROTOCOL_VER = 171;
NET_MAXCLIENTS = 24;
NET_CHANS = 11;
NET_STATE_GAME = 2;
BANLIST_FILENAME = 'banlist.txt';
+ NETDUMP_FILENAME = 'netdump';
type
TNetClient = record
var
NetInitDone: Boolean = False;
NetMode: Byte = NET_NONE;
+ NetDump: Boolean = False;
NetServerName: string = 'Unnamed Server';
NetPassword: string = '';
NetGotEverything: Boolean = False;
+ NetDumpFile: TStream;
+
function g_Net_Init(): Boolean;
procedure g_Net_Cleanup();
procedure g_Net_Free();
procedure g_Net_UnbanNonPermHosts();
procedure g_Net_SaveBanList();
+procedure g_Net_DumpStart();
+procedure g_Net_DumpSendBuffer();
+procedure g_Net_DumpRecvBuffer(Buf: penet_uint8; Len: LongWord);
+procedure g_Net_DumpEnd();
+
implementation
uses
SysUtils,
e_input, g_nethandler, g_netmsg, g_netmaster, g_player, g_window, g_console,
- g_main, g_game, g_language, g_weapons;
+ g_main, g_game, g_language, g_weapons, utils;
{ /// SERVICE FUNCTIONS /// }
NetTimeToReliable := 0;
NetMode := NET_NONE;
+
+ if NetDump then
+ g_Net_DumpEnd();
end;
procedure g_Net_Free();
NetMode := NET_SERVER;
e_Buffer_Clear(@NetOut);
+
+ if NetDump then
+ g_Net_DumpStart();
end;
procedure g_Net_Host_Die();
enet_host_broadcast(NetHost, Chan, P);
end;
- g_Net_Flush();
+ if NetDump then g_Net_DumpSendBuffer();
+ // g_Net_Flush();
e_Buffer_Clear(@NetOut);
end;
if ID > High(NetClients) then Exit;
TC := @NetClients[ID];
+ if NetDump then g_Net_DumpRecvBuffer(NetEvent.packet^.data, NetEvent.packet^.dataLength);
g_Net_HostMsgHandler(TC, NetEvent.packet);
end;
if not Assigned(P) then Exit;
enet_peer_send(NetPeer, Chan, P);
- g_Net_Flush();
+ if NetDump then g_Net_DumpSendBuffer();
+ // g_Net_Flush();
e_Buffer_Clear(@NetOut);
end;
begin
case NetEvent.kind of
ENET_EVENT_TYPE_RECEIVE:
+ begin
+ if NetDump then g_Net_DumpRecvBuffer(NetEvent.packet^.data, NetEvent.packet^.dataLength);
g_Net_ClientMsgHandler(NetEvent.packet);
+ end;
ENET_EVENT_TYPE_DISCONNECT:
begin
begin
case NetEvent.kind of
ENET_EVENT_TYPE_RECEIVE:
+ begin
+ if NetDump then g_Net_DumpRecvBuffer(NetEvent.packet^.data, NetEvent.packet^.dataLength);
g_Net_ClientLightMsgHandler(NetEvent.packet);
+ end;
ENET_EVENT_TYPE_DISCONNECT:
begin
end;
end;
end;
- g_Net_Flush();
+ // g_Net_Flush();
end;
function g_Net_Connect(IP: string; Port: enet_uint16): Boolean;
enet_peer_timeout(NetPeer, ENET_PEER_TIMEOUT_LIMIT * 2, ENET_PEER_TIMEOUT_MINIMUM * 2, ENET_PEER_TIMEOUT_MAXIMUM * 2);
NetClientIP := IP;
NetClientPort := Port;
+ if NetDump then
+ g_Net_DumpStart();
Exit;
end;
end;
CloseFile(F);
end;
+procedure g_Net_DumpStart();
+begin
+ if NetMode = NET_SERVER then
+ NetDumpFile := createDiskFile(NETDUMP_FILENAME + '_server')
+ else
+ NetDumpFile := createDiskFile(NETDUMP_FILENAME + '_client');
+end;
+
+procedure g_Net_DumpSendBuffer();
+begin
+ writeInt(NetDumpFile, gTime);
+ writeInt(NetDumpFile, LongWord(NetOut.Len));
+ writeInt(NetDumpFile, Byte(1));
+ NetDumpFile.WriteBuffer(NetOut.Data[0], NetOut.Len);
+end;
+
+procedure g_Net_DumpRecvBuffer(Buf: penet_uint8; Len: LongWord);
+begin
+ if (Buf = nil) or (Len = 0) then Exit;
+ writeInt(NetDumpFile, gTime);
+ writeInt(NetDumpFile, Len);
+ writeInt(NetDumpFile, Byte(0));
+ NetDumpFile.WriteBuffer(Buf^, Len);
+end;
+
+procedure g_Net_DumpEnd();
+begin
+ NetDumpFile.Free();
+ NetDumpFile := nil;
+end;
+
end.