1 (* Copyright (C) Doom 2D: Forever Developers
3 * This program is free software: you can redistribute it and/or modify
4 * it under the terms of the GNU General Public License as published by
5 * the Free Software Foundation, version 3 of the License ONLY.
7 * This program is distributed in the hope that it will be useful,
8 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 * GNU General Public License for more details.
12 * You should have received a copy of the GNU General Public License
13 * along with this program. If not, see <http://www.gnu.org/licenses/>.
15 {$INCLUDE ../shared/a_modes.inc}
21 e_log
, e_msg
, ENet
, Classes
, md5
, MAPDEF
{$IFDEF USE_MINIUPNPC}, miniupnpc
;{$ELSE};{$ENDIF}
24 NET_PROTOCOL_VER
= 182;
30 NET_CHAN_IMPORTANT
= 1;
33 NET_CHAN_PLAYERPOS
= 4;
35 NET_CHAN_MONSTERPOS
= 6;
36 NET_CHAN_LARGEDATA
= 7;
38 NET_CHAN_DOWNLOAD
= 9;
40 NET_CHAN_DOWNLOAD_EX
= 11;
47 NET_PING_PORT
= $DF2D;
54 NET_DISC_NONE
: enet_uint32
= 0;
55 NET_DISC_PROTOCOL
: enet_uint32
= 1;
56 NET_DISC_VERSION
: enet_uint32
= 2;
57 NET_DISC_FULL
: enet_uint32
= 3;
58 NET_DISC_KICK
: enet_uint32
= 4;
59 NET_DISC_DOWN
: enet_uint32
= 5;
60 NET_DISC_PASSWORD
: enet_uint32
= 6;
61 NET_DISC_TEMPBAN
: enet_uint32
= 7;
62 NET_DISC_BAN
: enet_uint32
= 8;
63 NET_DISC_MAX
: enet_uint32
= 8;
64 NET_DISC_FILE_TIMEOUT
: enet_uint32
= 13;
70 NET_CONNECT_TIMEOUT
= 1000 * 10;
72 BANLIST_FILENAME
= 'banlist.txt';
73 NETDUMP_FILENAME
= 'netdump';
75 {$IF DEFINED(FREEBSD) OR DEFINED(DARWIN)}
82 TNetMapResourceInfo
= record
83 wadName
: AnsiString; // wad file name, without a path
84 size
: Integer; // wad file size (-1: size and hash are not known)
85 hash
: TMD5Digest
; // wad hash
88 TNetMapResourceInfoArray
= array of TNetMapResourceInfo
;
90 TNetFileTransfer
= record
94 size
: Integer; // file size in bytes
96 lastSentChunk
: Integer;
97 lastAckChunk
: Integer;
98 lastAckTime
: Int64; // msecs; if not "in progress", we're waiting for the first ack
100 diskBuffer
: PChar; // of `chunkSize` bytes
110 RequestedFullUpdate
: Boolean;
111 WaitForFirstSpawn
: Boolean; // set to `true` in server, used to spawn a player on first full state request
114 Transfer
: TNetFileTransfer
; // only one transfer may be active
115 NetOut
: array [0..1] of TMsg
;
121 pTNetClient
= ^TNetClient
;
123 AByte
= array of Byte;
126 NetInitDone
: Boolean = False;
127 NetMode
: Byte = NET_NONE
;
128 NetDump
: Boolean = False;
130 NetServerName
: string = 'Unnamed Server';
131 NetPassword
: string = '';
132 NetPort
: Word = 25666;
134 NetAllowRCON
: Boolean = False;
135 NetRCONPassword
: string = '';
137 NetTimeToUpdate
: Cardinal = 0;
138 NetTimeToReliable
: Cardinal = 0;
139 NetTimeToMaster
: Cardinal = 0;
141 NetHost
: pENetHost
= nil;
142 NetPeer
: pENetPeer
= nil;
144 NetAddr
: ENetAddress
;
146 NetPongAddr
: ENetAddress
;
147 NetPongSock
: ENetSocket
= ENET_SOCKET_NULL
;
149 NetUseMaster
: Boolean = True;
150 NetSlistAddr
: ENetAddress
;
151 NetSlistIP
: string = 'mpms.doom2d.org';
152 NetSlistPort
: Word = 25665;
154 NetClientIP
: string = '127.0.0.1';
155 NetClientPort
: Word = 25666;
158 NetBuf
: array [0..1] of TMsg
;
160 NetClients
: array of TNetClient
;
161 NetClientCount
: Byte = 0;
162 NetMaxClients
: Byte = 255;
163 NetBannedHosts
: array of TBanRecord
;
165 NetState
: Integer = NET_STATE_NONE
;
167 NetMyID
: Integer = -1;
168 NetPlrUID1
: Integer = -1;
169 NetPlrUID2
: Integer = -1;
171 NetInterpLevel
: Integer = 1;
172 NetUpdateRate
: Cardinal = 0; // as soon as possible
173 NetRelupdRate
: Cardinal = 18; // around two times a second
174 NetMasterRate
: Cardinal = 60000;
176 NetForcePlayerUpdate
: Boolean = False;
177 NetPredictSelf
: Boolean = True;
178 NetForwardPorts
: Boolean = False;
180 NetGotEverything
: Boolean = False;
181 NetGotKeys
: Boolean = False;
183 {$IFDEF USE_MINIUPNPC}
184 NetPortForwarded
: Word = 0;
185 NetPongForwarded
: Boolean = False;
186 NetIGDControl
: AnsiString;
187 NetIGDService
: TURLStr
;
190 NetPortThread
: TThreadID
= NilThreadId
;
192 NetDumpFile
: TStream
;
194 g_Res_received_map_start
: Integer = 0; // set if we received "map change" event
197 function g_Net_Init(): Boolean;
198 procedure g_Net_Cleanup();
199 procedure g_Net_Free();
200 procedure g_Net_Flush();
202 function g_Net_Host(IPAddr
: LongWord; Port
: enet_uint16
; MaxClients
: Cardinal = 16): Boolean;
203 procedure g_Net_Host_Die();
204 procedure g_Net_Host_Send(ID
: Integer; Reliable
: Boolean; Chan
: Byte = NET_CHAN_GAME
);
205 function g_Net_Host_Update(): enet_size_t
;
207 function g_Net_Connect(IP
: string; Port
: enet_uint16
): Boolean;
208 procedure g_Net_Disconnect(Forced
: Boolean = False);
209 procedure g_Net_Client_Send(Reliable
: Boolean; Chan
: Byte = NET_CHAN_GAME
);
210 function g_Net_Client_Update(): enet_size_t
;
211 function g_Net_Client_UpdateWhileLoading(): enet_size_t
;
213 function g_Net_Client_ByName(Name
: string): pTNetClient
;
214 function g_Net_Client_ByPlayer(PID
: Word): pTNetClient
;
215 function g_Net_ClientName_ByID(ID
: Integer): string;
217 procedure g_Net_SendData(Data
: AByte
; peer
: pENetPeer
; Reliable
: Boolean; Chan
: Byte = NET_CHAN_DOWNLOAD
);
218 //function g_Net_Wait_Event(msgId: Word): TMemoryStream;
219 //function g_Net_Wait_FileInfo (var tf: TNetFileTransfer; asMap: Boolean; out resList: TStringList): Integer;
221 function IpToStr(IP
: LongWord): string;
222 function StrToIp(IPstr
: string; var IP
: LongWord): Boolean;
224 function g_Net_IsHostBanned(IP
: LongWord; Perm
: Boolean = False): Boolean;
225 procedure g_Net_BanHost(IP
: LongWord; Perm
: Boolean = True); overload
;
226 procedure g_Net_BanHost(IP
: string; Perm
: Boolean = True); overload
;
227 function g_Net_UnbanHost(IP
: string): Boolean; overload
;
228 function g_Net_UnbanHost(IP
: LongWord): Boolean; overload
;
229 procedure g_Net_UnbanNonPermHosts();
230 procedure g_Net_SaveBanList();
232 procedure g_Net_DumpStart();
233 procedure g_Net_DumpSendBuffer();
234 procedure g_Net_DumpRecvBuffer(Buf
: penet_uint8
; Len
: LongWord);
235 procedure g_Net_DumpEnd();
237 function g_Net_ForwardPorts(ForwardPongPort
: Boolean = True): Boolean;
238 procedure g_Net_UnforwardPorts();
240 function g_Net_UserRequestExit
: Boolean;
242 function g_Net_Wait_MapInfo (var tf
: TNetFileTransfer
; var resList
: TNetMapResourceInfoArray
): Integer;
243 function g_Net_RequestResFileInfo (resIndex
: LongInt; out tf
: TNetFileTransfer
): Integer;
244 function g_Net_AbortResTransfer (var tf
: TNetFileTransfer
): Boolean;
245 function g_Net_ReceiveResourceFile (resIndex
: LongInt; var tf
: TNetFileTransfer
; strm
: TStream
): Integer;
247 function g_Net_IsNetworkAvailable (): Boolean;
248 procedure g_Net_InitLowLevel ();
249 procedure g_Net_DeinitLowLevel ();
256 e_input
, g_nethandler
, g_netmsg
, g_netmaster
, g_player
, g_window
, g_console
,
257 g_main
, g_game
, g_language
, g_weapons
, utils
, ctypes
, g_system
,
261 FILE_CHUNK_SIZE
= 8192;
264 enet_init_success
: Boolean = false;
265 g_Net_DownloadTimeout
: Single;
269 function g_Net_IsNetworkAvailable (): Boolean;
271 result
:= enet_init_success
;
274 procedure g_Net_InitLowLevel ();
276 if enet_init_success
then raise Exception
.Create('wuta?!');
277 enet_init_success
:= (enet_initialize() = 0);
280 procedure g_Net_DeinitLowLevel ();
282 if enet_init_success
then
285 enet_init_success
:= false;
290 //**************************************************************************
294 //**************************************************************************
296 procedure clearNetClientTransfers (var nc
: TNetClient
);
298 nc
.Transfer
.stream
.Free
;
299 nc
.Transfer
.diskName
:= ''; // just in case
300 if (nc
.Transfer
.diskBuffer
<> nil) then FreeMem(nc
.Transfer
.diskBuffer
);
301 nc
.Transfer
.stream
:= nil;
302 nc
.Transfer
.diskBuffer
:= nil;
306 procedure clearNetClient (var nc
: TNetClient
);
308 clearNetClientTransfers(nc
);
312 procedure clearNetClients (clearArray
: Boolean);
316 for f
:= Low(NetClients
) to High(NetClients
) do clearNetClient(NetClients
[f
]);
317 if (clearArray
) then SetLength(NetClients
, 0);
321 function g_Net_UserRequestExit (): Boolean;
323 Result
:= {e_KeyPressed(IK_SPACE) or}
324 e_KeyPressed(IK_ESCAPE
) or
325 e_KeyPressed(VK_ESCAPE
) or
326 e_KeyPressed(JOY0_JUMP
) or
327 e_KeyPressed(JOY1_JUMP
) or
328 e_KeyPressed(JOY2_JUMP
) or
329 e_KeyPressed(JOY3_JUMP
)
333 //**************************************************************************
335 // file transfer declaraions and host packet processor
337 //**************************************************************************
340 // server packet type
341 NTF_SERVER_DONE
= 10; // done with this file
342 NTF_SERVER_FILE_INFO
= 11; // sent after client request
343 NTF_SERVER_CHUNK
= 12; // next chunk; chunk number follows
344 NTF_SERVER_ABORT
= 13; // server abort
345 NTF_SERVER_MAP_INFO
= 14;
347 // client packet type
348 NTF_CLIENT_MAP_REQUEST
= 100; // map file request; also, returns list of additional wads to download
349 NTF_CLIENT_FILE_REQUEST
= 101; // resource file request (by index)
350 NTF_CLIENT_ABORT
= 102; // do not send requested file, or abort current transfer
351 NTF_CLIENT_START
= 103; // start transfer; client may resume download by sending non-zero starting chunk
352 NTF_CLIENT_ACK
= 104; // chunk ack; chunk number follows
355 // disconnect client due to some file transfer error
356 procedure killClientByFT (var nc
: TNetClient
);
358 e_LogWritefln('disconnected client #%d due to file transfer error', [nc
.ID
], TMsgType
.Warning
);
359 enet_peer_disconnect(nc
.Peer
, NET_DISC_FILE_TIMEOUT
);
360 clearNetClientTransfers(nc
);
364 // send file transfer message from server to client
365 function ftransSendServerMsg (var nc
: TNetClient
; var m
: TMsg
): Boolean;
370 if (m
.CurSize
< 1) then exit
;
371 pkt
:= enet_packet_create(m
.Data
, m
.CurSize
, ENET_PACKET_FLAG_RELIABLE
);
372 if not Assigned(pkt
) then begin killClientByFT(nc
); exit
; end;
373 if (enet_peer_send(nc
.Peer
, NET_CHAN_DOWNLOAD_EX
, pkt
) <> 0) then begin killClientByFT(nc
); exit
; end;
378 // send file transfer message from client to server
379 function ftransSendClientMsg (var m
: TMsg
): Boolean;
384 if (m
.CurSize
< 1) then exit
;
385 pkt
:= enet_packet_create(m
.Data
, m
.CurSize
, ENET_PACKET_FLAG_RELIABLE
);
386 if not Assigned(pkt
) then exit
;
387 if (enet_peer_send(NetPeer
, NET_CHAN_DOWNLOAD_EX
, pkt
) <> 0) then exit
;
393 procedure ProcessChunkSend (var nc
: TNetClient
);
395 tf
: ^TNetFileTransfer
;
401 if (tf
.stream
= nil) then exit
;
403 // arbitrary timeout number
404 if (ct
-tf
.lastAckTime
>= 5000) then
409 // check if we need to send something
410 if (not tf
.inProgress
) then exit
; // waiting for the initial ack
411 // ok, we're sending chunks
412 if (tf
.lastAckChunk
<> tf
.lastSentChunk
) then exit
;
413 Inc(tf
.lastSentChunk
);
414 // do it one chunk at a time; client ack will advance our chunk counter
415 chunks
:= (tf
.size
+tf
.chunkSize
-1) div tf
.chunkSize
;
417 if (tf
.lastSentChunk
> chunks
) then
424 if (tf
.lastSentChunk
= chunks
) then
426 // we're done with this file
427 e_LogWritefln('download: client #%d, DONE sending chunks #%d/#%d', [nc
.ID
, tf
.lastSentChunk
, chunks
]);
428 trans_omsg
.Write(Byte(NTF_SERVER_DONE
));
429 clearNetClientTransfers(nc
);
434 trans_omsg
.Write(Byte(NTF_SERVER_CHUNK
));
435 trans_omsg
.Write(LongInt(tf
.lastSentChunk
));
437 rd
:= tf
.size
-(tf
.lastSentChunk
*tf
.chunkSize
);
438 if (rd
> tf
.chunkSize
) then rd
:= tf
.chunkSize
;
439 trans_omsg
.Write(LongInt(rd
));
440 //e_LogWritefln('download: client #%d, sending chunk #%d/#%d (%d bytes)', [nc.ID, tf.lastSentChunk, chunks, rd]);
441 //FIXME: check for errors here
443 tf
.stream
.Seek(tf
.lastSentChunk
*tf
.chunkSize
, soFromBeginning
);
444 tf
.stream
.ReadBuffer(tf
.diskBuffer
^, rd
);
445 trans_omsg
.WriteData(tf
.diskBuffer
, rd
);
452 ftransSendServerMsg(nc
, trans_omsg
);
456 // server file transfer packet processor
457 // received packet is in `NetEvent`
458 procedure ProcessDownloadExPacket ();
465 tf
: ^TNetFileTransfer
;
475 // find client index by peer
476 for f
:= Low(NetClients
) to High(NetClients
) do
478 if (not NetClients
[f
].Used
) then continue
;
479 if (NetClients
[f
].Peer
= NetEvent
.peer
) then
485 //e_LogWritefln('RECEIVE: dlpacket; client=%d (datalen=%u)', [nid, NetEvent.packet^.dataLength]);
487 if (nid
< 0) then exit
; // wtf?!
488 nc
:= @NetClients
[nid
];
490 if (NetEvent
.packet
^.dataLength
= 0) then
496 tf
:= @NetClients
[nid
].Transfer
;
497 tf
.lastAckTime
:= GetTimerMS();
499 cmd
:= Byte(NetEvent
.packet
^.data
^);
500 //e_LogWritefln('RECEIVE: nid=%d; cmd=%u', [nid, cmd]);
502 NTF_CLIENT_FILE_REQUEST
: // file request
504 if (tf
.stream
<> nil) then
509 if (NetEvent
.packet
^.dataLength
< 2) then
514 // new transfer request; build packet
515 if not msg
.Init(NetEvent
.packet
^.data
+1, NetEvent
.packet
^.dataLength
-1, True) then
520 // get resource index
521 ridx
:= msg
.ReadLongInt();
522 if (ridx
< -1) or (ridx
>= length(gExternalResources
)) then
524 e_LogWritefln('Invalid resource index %d', [ridx
], TMsgType
.Warning
);
528 if (ridx
< 0) then fname
:= MapsDir
+gGameSettings
.WAD
else fname
:= {GameDir+'/wads/'+}gExternalResources
[ridx
].diskName
;
529 if (length(fname
) = 0) then
531 e_WriteLog('Invalid filename: '+fname
, TMsgType
.Warning
);
535 tf
.diskName
:= findDiskWad(fname
);
536 //if (length(tf.diskName) = 0) then tf.diskName := findDiskWad(GameDir+'/wads/'+fname);
537 if (length(tf
.diskName
) = 0) then
539 e_LogWritefln('NETWORK: file "%s" not found!', [fname
], TMsgType
.Fatal
);
544 //tf.hash := MD5File(tf.diskName);
545 if (ridx
< 0) then tf
.hash
:= gWADHash
else tf
.hash
:= gExternalResources
[ridx
].hash
;
546 // create file stream
547 tf
.diskName
:= findDiskWad(fname
);
549 tf
.stream
:= openDiskFileRO(tf
.diskName
);
553 if (tf
.stream
= nil) then
555 e_WriteLog(Format('NETWORK: file "%s" not found!', [fname
]), TMsgType
.Fatal
);
559 e_LogWritefln('client #%d requested resource #%d (file is `%s` : `%s`)', [nc
.ID
, ridx
, fname
, tf
.diskName
]);
560 tf
.size
:= tf
.stream
.size
;
561 tf
.chunkSize
:= FILE_CHUNK_SIZE
; // arbitrary
562 tf
.lastSentChunk
:= -1;
563 tf
.lastAckChunk
:= -1;
564 tf
.lastAckTime
:= GetTimerMS();
565 tf
.inProgress
:= False; // waiting for the first ACK or for the cancel
566 GetMem(tf
.diskBuffer
, tf
.chunkSize
);
567 // sent file info message
569 trans_omsg
.Write(Byte(NTF_SERVER_FILE_INFO
));
570 trans_omsg
.Write(tf
.hash
);
571 trans_omsg
.Write(tf
.size
);
572 trans_omsg
.Write(tf
.chunkSize
);
573 trans_omsg
.Write(ExtractFileName(fname
));
574 if not ftransSendServerMsg(nc
^, trans_omsg
) then exit
;
576 NTF_CLIENT_ABORT
: // do not send requested file, or abort current transfer
578 e_LogWritefln('client #%d aborted file transfer', [nc
.ID
]);
579 clearNetClientTransfers(nc
^);
581 NTF_CLIENT_START
: // start transfer; client may resume download by sending non-zero starting chunk
583 if not Assigned(tf
.stream
) then
588 if (tf
.lastSentChunk
<> -1) or (tf
.lastAckChunk
<> -1) or (tf
.inProgress
) then
590 // double ack, get lost
594 if (NetEvent
.packet
^.dataLength
< 2) then
600 if not msg
.Init(NetEvent
.packet
^.data
+1, NetEvent
.packet
^.dataLength
-1, True) then
605 chunk
:= msg
.ReadLongInt();
606 if (chunk
< 0) or (chunk
> (tf
.size
+tf
.chunkSize
-1) div tf
.chunkSize
) then
611 e_LogWritefln('client #%d started file transfer from chunk %d', [nc
.ID
, chunk
]);
612 // start sending chunks
613 tf
.inProgress
:= True;
614 tf
.lastSentChunk
:= chunk
-1;
615 tf
.lastAckChunk
:= chunk
-1;
616 ProcessChunkSend(nc
^);
618 NTF_CLIENT_ACK
: // chunk ack; chunk number follows
620 if not Assigned(tf
.stream
) then
625 if (tf
.lastSentChunk
< 0) or (not tf
.inProgress
) then
627 // double ack, get lost
631 if (NetEvent
.packet
^.dataLength
< 2) then
637 if not msg
.Init(NetEvent
.packet
^.data
+1, NetEvent
.packet
^.dataLength
-1, True) then
642 chunk
:= msg
.ReadLongInt();
643 if (chunk
< 0) or (chunk
> (tf
.size
+tf
.chunkSize
-1) div tf
.chunkSize
) then
648 // do it this way, so client may seek, or request retransfers for some reason
649 tf
.lastAckChunk
:= chunk
;
650 tf
.lastSentChunk
:= chunk
;
651 //e_LogWritefln('client #%d acked file transfer chunk %d', [nc.ID, chunk]);
652 ProcessChunkSend(nc
^);
654 NTF_CLIENT_MAP_REQUEST
:
656 e_LogWritefln('client #%d requested map info', [nc
.ID
]);
658 dfn
:= findDiskWad(MapsDir
+gGameSettings
.WAD
);
659 if (dfn
= '') then dfn
:= '!wad_not_found!.wad'; //FIXME
660 //md5 := MD5File(dfn);
662 if (not GetDiskFileInfo(dfn
, fi
)) then
664 e_LogWritefln('client #%d requested map info, but i cannot get file info', [nc
.ID
]);
670 st := openDiskFileRO(dfn);
671 if not assigned(st) then exit; //wtf?!
676 trans_omsg
.Write(Byte(NTF_SERVER_MAP_INFO
));
678 trans_omsg
.Write(gGameSettings
.WAD
);
680 trans_omsg
.Write(md5
);
682 trans_omsg
.Write(size
);
683 // number of external resources for map
684 trans_omsg
.Write(LongInt(length(gExternalResources
)));
685 // external resource names
686 for f
:= 0 to High(gExternalResources
) do
689 //trans_omsg.Write(ExtractFileName(gExternalResources[f])); // GameDir+'/wads/'+ResList.Strings[i]
691 trans_omsg
.Write('!');
692 trans_omsg
.Write(LongInt(gExternalResources
[f
].size
));
693 trans_omsg
.Write(gExternalResources
[f
].hash
);
694 trans_omsg
.Write(ExtractFileName(gExternalResources
[f
].diskName
));
697 if not ftransSendServerMsg(nc
^, trans_omsg
) then exit
;
708 //**************************************************************************
710 // file transfer crap (both client and server)
712 //**************************************************************************
714 function getNewTimeoutEnd (): Int64;
716 result
:= GetTimerMS();
717 if (g_Net_DownloadTimeout
<= 0) then
719 result
:= result
+1000*60*3; // 3 minutes
723 result
:= result
+trunc(g_Net_DownloadTimeout
*1000);
728 // send map request to server, and wait for "map info" server reply
730 // returns `false` on error or user abort
732 // diskName: map wad file name (without a path)
733 // hash: map wad hash
734 // size: map wad size
735 // chunkSize: set too
736 // resList: list of resource wads
742 // for maps, first `tf.diskName` name will be map wad name, and `tf.hash`/`tf.size` will contain map info
743 function g_Net_Wait_MapInfo (var tf
: TNetFileTransfer
; var resList
: TNetMapResourceInfoArray
): Integer;
749 freePacket
: Boolean = false;
754 ri
: ^TNetMapResourceInfo
;
756 SetLength(resList
, 0);
760 trans_omsg
.Write(Byte(NTF_CLIENT_MAP_REQUEST
));
761 if not ftransSendClientMsg(trans_omsg
) then begin result
:= -1; exit
; end;
763 FillChar(ev
, SizeOf(ev
), 0);
766 ett
:= getNewTimeoutEnd();
768 status
:= enet_host_service(NetHost
, @ev
, 300);
771 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' network error', True);
781 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' timeout reached', True);
790 ENET_EVENT_TYPE_RECEIVE
:
793 if (ev
.channelID
<> NET_CHAN_DOWNLOAD_EX
) then
795 //e_LogWritefln('g_Net_Wait_MapInfo: skip message from non-transfer channel', []);
797 g_Net_Client_HandlePacket(ev
.packet
, g_Net_ClientLightMsgHandler
);
798 if (g_Res_received_map_start
< 0) then begin result
:= -666; exit
; end;
802 ett
:= getNewTimeoutEnd();
803 if (ev
.packet
.dataLength
< 1) then
805 e_LogWritefln('g_Net_Wait_MapInfo: invalid server packet (no data)', []);
809 Ptr
:= ev
.packet
^.data
;
810 rMsgId
:= Byte(Ptr
^);
811 e_LogWritefln('g_Net_Wait_MapInfo: got message %u from server (dataLength=%u)', [rMsgId
, ev
.packet
^.dataLength
]);
812 if (rMsgId
= NTF_SERVER_FILE_INFO
) then
814 e_LogWritefln('g_Net_Wait_MapInfo: waiting for map info reply, but got file info reply', []);
818 else if (rMsgId
= NTF_SERVER_ABORT
) then
820 e_LogWritefln('g_Net_Wait_MapInfo: server aborted transfer', []);
824 else if (rMsgId
= NTF_SERVER_MAP_INFO
) then
826 e_LogWritefln('g_Net_Wait_MapInfo: creating map info packet...', []);
827 if not msg
.Init(ev
.packet
^.data
+1, ev
.packet
^.dataLength
-1, True) then exit
;
828 e_LogWritefln('g_Net_Wait_MapInfo: parsing map info packet (rd=%d; max=%d)...', [msg
.ReadCount
, msg
.MaxSize
]);
829 SetLength(resList
, 0); // just in case
831 tf
.diskName
:= msg
.ReadString();
832 e_LogWritefln('g_Net_Wait_MapInfo: map wad is `%s`', [tf
.diskName
]);
834 tf
.hash
:= msg
.ReadMD5();
836 tf
.size
:= msg
.ReadLongInt();
837 e_LogWritefln('g_Net_Wait_MapInfo: map wad size is %d', [tf
.size
]);
838 // number of external resources for map
839 rc
:= msg
.ReadLongInt();
840 if (rc
< 0) or (rc
> 1024) then
842 e_LogWritefln('g_Net_Wait_Event: invalid number of map external resources (%d)', [rc
]);
846 e_LogWritefln('g_Net_Wait_MapInfo: map external resource count is %d', [rc
]);
847 SetLength(resList
, rc
);
848 // external resource names
849 for f
:= 0 to rc
-1 do
852 s
:= msg
.ReadString();
853 if (length(s
) = 0) then begin result
:= -1; exit
; end;
857 ri
.size
:= msg
.ReadLongInt();
858 ri
.hash
:= msg
.ReadMD5();
859 ri
.wadName
:= ExtractFileName(msg
.ReadString());
860 if (length(ri
.wadName
) = 0) or (ri
.size
< 0) then begin result
:= -1; exit
; end;
864 // old-style packet, only name
865 ri
.wadName
:= ExtractFileName(s
);
866 if (length(ri
.wadName
) = 0) then begin result
:= -1; exit
; end;
867 ri
.size
:= -1; // unknown
870 e_LogWritefln('g_Net_Wait_MapInfo: got map info', []);
871 Result
:= 0; // success
876 e_LogWritefln('g_Net_Wait_Event: invalid server packet type', []);
882 ENET_EVENT_TYPE_DISCONNECT
:
884 if (ev
.data
<= NET_DISC_MAX
) then
885 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' ' + _lc
[TStrings_Locale(Cardinal(I_NET_DISC_NONE
) + ev
.data
)], True);
891 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' unknown ENet event ' + IntToStr(Ord(ev
.kind
)), True);
896 if (freePacket
) then begin freePacket
:= false; enet_packet_destroy(ev
.packet
); end;
899 if g_Net_UserRequestExit() then
901 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' user abort', True);
907 if (freePacket
) then enet_packet_destroy(ev
.packet
);
912 // send file request to server, and wait for server reply
914 // returns `false` on error or user abort
916 // diskName (actually, base name)
925 // for maps, first `tf.diskName` name will be map wad name, and `tf.hash`/`tf.size` will contain map info
926 function g_Net_RequestResFileInfo (resIndex
: LongInt; out tf
: TNetFileTransfer
): Integer;
932 freePacket
: Boolean = false;
938 trans_omsg
.Write(Byte(NTF_CLIENT_FILE_REQUEST
));
939 trans_omsg
.Write(resIndex
);
940 if not ftransSendClientMsg(trans_omsg
) then begin result
:= -1; exit
; end;
942 FillChar(ev
, SizeOf(ev
), 0);
945 ett
:= getNewTimeoutEnd();
947 status
:= enet_host_service(NetHost
, @ev
, 300);
950 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' network error', True);
960 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' timeout reached', True);
969 ENET_EVENT_TYPE_RECEIVE
:
972 if (ev
.channelID
<> NET_CHAN_DOWNLOAD_EX
) then
974 //e_LogWriteln('g_Net_Wait_Event: skip message from non-transfer channel');
976 g_Net_Client_HandlePacket(ev
.packet
, g_Net_ClientLightMsgHandler
);
977 if (g_Res_received_map_start
< 0) then begin result
:= -666; exit
; end;
981 ett
:= getNewTimeoutEnd();
982 if (ev
.packet
.dataLength
< 1) then
984 e_LogWriteln('g_Net_Wait_Event: invalid server packet (no data)');
988 Ptr
:= ev
.packet
^.data
;
989 rMsgId
:= Byte(Ptr
^);
990 e_LogWritefln('received transfer packet with id %d (%u bytes)', [rMsgId
, ev
.packet
^.dataLength
]);
991 if (rMsgId
= NTF_SERVER_FILE_INFO
) then
993 if not msg
.Init(ev
.packet
^.data
+1, ev
.packet
^.dataLength
-1, True) then exit
;
994 tf
.hash
:= msg
.ReadMD5();
995 tf
.size
:= msg
.ReadLongInt();
996 tf
.chunkSize
:= msg
.ReadLongInt();
997 tf
.diskName
:= ExtractFileName(msg
.readString());
998 if (tf
.size
< 0) or (tf
.chunkSize
<> FILE_CHUNK_SIZE
) or (length(tf
.diskName
) = 0) then
1000 e_LogWritefln('g_Net_RequestResFileInfo: invalid file info packet', []);
1004 e_LogWritefln('got file info for resource #%d: size=%d; name=%s', [resIndex
, tf
.size
, tf
.diskName
]);
1005 Result
:= 0; // success
1008 else if (rMsgId
= NTF_SERVER_ABORT
) then
1010 e_LogWriteln('g_Net_RequestResFileInfo: server aborted transfer');
1014 else if (rMsgId
= NTF_SERVER_MAP_INFO
) then
1016 e_LogWriteln('g_Net_RequestResFileInfo: waiting for map info reply, but got file info reply');
1022 e_LogWriteln('g_Net_RequestResFileInfo: invalid server packet type');
1028 ENET_EVENT_TYPE_DISCONNECT
:
1030 if (ev
.data
<= NET_DISC_MAX
) then
1031 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' ' + _lc
[TStrings_Locale(Cardinal(I_NET_DISC_NONE
) + ev
.data
)], True);
1037 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' unknown ENet event ' + IntToStr(Ord(ev
.kind
)), True);
1042 if (freePacket
) then begin freePacket
:= false; enet_packet_destroy(ev
.packet
); end;
1045 if g_Net_UserRequestExit() then
1047 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' user abort', True);
1053 if (freePacket
) then enet_packet_destroy(ev
.packet
);
1058 // call this to cancel file transfer requested by `g_Net_RequestResFileInfo()`
1059 function g_Net_AbortResTransfer (var tf
: TNetFileTransfer
): Boolean;
1062 e_LogWritefln('aborting file transfer...', []);
1065 trans_omsg
.Write(Byte(NTF_CLIENT_ABORT
));
1066 result
:= ftransSendClientMsg(trans_omsg
);
1067 if result
then enet_host_flush(NetHost
);
1071 // call this to start file transfer requested by `g_Net_RequestResFileInfo()`
1073 // returns `false` on error or user abort
1082 // 2 on server abort
1083 // for maps, first `tf.diskName` name will be map wad name, and `tf.hash`/`tf.size` will contain map info
1084 function g_Net_ReceiveResourceFile (resIndex
: LongInt; var tf
: TNetFileTransfer
; strm
: TStream
): Integer;
1090 freePacket
: Boolean = false;
1093 nextChunk
: Integer = 0;
1094 chunkTotal
: Integer;
1101 tf
.resumed
:= false;
1102 e_LogWritefln('file `%s`, size=%d (%d)', [tf
.diskName
, Integer(strm
.size
), tf
.size
], TMsgType
.Notify
);
1103 // check if we should resume downloading
1104 resumed
:= (strm
.size
> tf
.chunkSize
) and (strm
.size
< tf
.size
);
1107 trans_omsg
.Write(Byte(NTF_CLIENT_START
));
1108 if resumed
then chunk
:= strm
.size
div tf
.chunkSize
else chunk
:= 0;
1109 trans_omsg
.Write(LongInt(chunk
));
1110 if not ftransSendClientMsg(trans_omsg
) then begin result
:= -1; exit
; end;
1112 strm
.Seek(chunk
*tf
.chunkSize
, soFromBeginning
);
1113 chunkTotal
:= (tf
.size
+tf
.chunkSize
-1) div tf
.chunkSize
;
1114 e_LogWritefln('receiving file `%s` (%d chunks)', [tf
.diskName
, chunkTotal
], TMsgType
.Notify
);
1115 g_Game_SetLoadingText('downloading "'+ExtractFileName(tf
.diskName
)+'"', chunkTotal
, False);
1116 tf
.resumed
:= resumed
;
1118 if (chunk
> 0) then g_Game_StepLoading(chunk
);
1121 // wait for reply data
1122 FillChar(ev
, SizeOf(ev
), 0);
1124 GetMem(buf
, tf
.chunkSize
);
1126 ett
:= getNewTimeoutEnd();
1128 //stx := -GetTimerMS();
1129 status
:= enet_host_service(NetHost
, @ev
, 300);
1130 if (status
< 0) then
1132 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' network error', True);
1136 if (status
= 0) then
1138 // check for timeout
1142 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' timeout reached', True);
1151 ENET_EVENT_TYPE_RECEIVE
:
1154 if (ev
.channelID
<> NET_CHAN_DOWNLOAD_EX
) then
1156 //e_LogWritefln('g_Net_Wait_Event: skip message from non-transfer channel', []);
1157 freePacket
:= false;
1158 g_Net_Client_HandlePacket(ev
.packet
, g_Net_ClientLightMsgHandler
);
1159 if (g_Res_received_map_start
< 0) then begin result
:= -666; exit
; end;
1163 //stx := stx+GetTimerMS();
1164 //e_LogWritefln('g_Net_ReceiveResourceFile: stx=%d', [Integer(stx)]);
1165 //stx := -GetTimerMS();
1166 ett
:= getNewTimeoutEnd();
1167 if (ev
.packet
.dataLength
< 1) then
1169 e_LogWritefln('g_Net_ReceiveResourceFile: invalid server packet (no data)', []);
1173 Ptr
:= ev
.packet
^.data
;
1174 rMsgId
:= Byte(Ptr
^);
1175 if (rMsgId
= NTF_SERVER_DONE
) then
1177 e_LogWritefln('file transfer complete.', []);
1181 else if (rMsgId
= NTF_SERVER_CHUNK
) then
1183 if not msg
.Init(ev
.packet
^.data
+1, ev
.packet
^.dataLength
-1, True) then exit
;
1184 chunk
:= msg
.ReadLongInt();
1185 csize
:= msg
.ReadLongInt();
1186 if (chunk
<> nextChunk
) then
1188 e_LogWritefln('received chunk %d, but expected chunk %d', [chunk
, nextChunk
]);
1192 if (csize
< 0) or (csize
> tf
.chunkSize
) then
1194 e_LogWritefln('received chunk with size %d, but expected chunk size is %d', [csize
, tf
.chunkSize
]);
1198 //e_LogWritefln('got chunk #%d of #%d (csize=%d)', [chunk, (tf.size+tf.chunkSize-1) div tf.chunkSize, csize]);
1199 msg
.ReadData(buf
, csize
);
1200 strm
.WriteBuffer(buf
^, csize
);
1201 nextChunk
:= chunk
+1;
1202 g_Game_StepLoading();
1205 trans_omsg
.Write(Byte(NTF_CLIENT_ACK
));
1206 trans_omsg
.Write(LongInt(chunk
));
1207 if not ftransSendClientMsg(trans_omsg
) then begin result
:= -1; exit
; end;
1209 else if (rMsgId
= NTF_SERVER_ABORT
) then
1211 e_LogWritefln('g_Net_ReceiveResourceFile: server aborted transfer', []);
1217 e_LogWritefln('g_Net_ReceiveResourceFile: invalid server packet type', []);
1221 //stx := stx+GetTimerMS();
1222 //e_LogWritefln('g_Net_ReceiveResourceFile: process stx=%d', [Integer(stx)]);
1225 ENET_EVENT_TYPE_DISCONNECT
:
1227 if (ev
.data
<= NET_DISC_MAX
) then
1228 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' ' + _lc
[TStrings_Locale(Cardinal(I_NET_DISC_NONE
) + ev
.data
)], True);
1234 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' unknown ENet event ' + IntToStr(Ord(ev
.kind
)), True);
1239 if (freePacket
) then begin freePacket
:= false; enet_packet_destroy(ev
.packet
); end;
1242 if g_Net_UserRequestExit() then
1244 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CONN
] + ' user abort', True);
1251 if (freePacket
) then enet_packet_destroy(ev
.packet
);
1256 //**************************************************************************
1260 //**************************************************************************
1262 function g_Net_FindSlot(): Integer;
1271 for I
:= Low(NetClients
) to High(NetClients
) do
1273 if NetClients
[I
].Used
then
1282 if C
>= NetMaxClients
then
1290 if (Length(NetClients
) >= NetMaxClients
) then
1294 SetLength(NetClients
, Length(NetClients
) + 1);
1295 N
:= High(NetClients
);
1301 NetClients
[N
].Used
:= True;
1302 NetClients
[N
].ID
:= N
;
1303 NetClients
[N
].RequestedFullUpdate
:= False;
1304 NetClients
[N
].WaitForFirstSpawn
:= False;
1305 NetClients
[N
].RCONAuth
:= False;
1306 NetClients
[N
].Voted
:= False;
1307 NetClients
[N
].Player
:= 0;
1308 clearNetClientTransfers(NetClients
[N
]); // just in case
1315 function g_Net_Init(): Boolean;
1323 NetBuf
[NET_UNRELIABLE
].Clear();
1324 NetBuf
[NET_RELIABLE
].Clear();
1325 //SetLength(NetClients, 0);
1326 clearNetClients(true); // clear array
1332 NetAddr
.port
:= 25666;
1333 SetLength(NetBannedHosts
, 0);
1334 if FileExists(DataDir
+ BANLIST_FILENAME
) then
1336 Assign(F
, DataDir
+ BANLIST_FILENAME
);
1341 if StrToIp(IPstr
, IP
) then
1345 g_Net_SaveBanList();
1348 //Result := (enet_initialize() = 0);
1349 Result
:= enet_init_success
;
1352 procedure g_Net_Flush();
1356 F
, Chan
: enet_uint32
;
1360 Chan
:= NET_CHAN_GAME
;
1362 if NetMode
= NET_SERVER
then
1363 for T
:= NET_UNRELIABLE
to NET_RELIABLE
do
1365 if NetBuf
[T
].CurSize
> 0 then
1367 P
:= enet_packet_create(NetBuf
[T
].Data
, NetBuf
[T
].CurSize
, F
);
1368 if not Assigned(P
) then continue
;
1369 enet_host_broadcast(NetHost
, Chan
, P
);
1373 for I
:= Low(NetClients
) to High(NetClients
) do
1375 if not NetClients
[I
].Used
then continue
;
1376 if NetClients
[I
].NetOut
[T
].CurSize
<= 0 then continue
;
1377 P
:= enet_packet_create(NetClients
[I
].NetOut
[T
].Data
, NetClients
[I
].NetOut
[T
].CurSize
, F
);
1378 if not Assigned(P
) then continue
;
1379 enet_peer_send(NetClients
[I
].Peer
, Chan
, P
);
1380 NetClients
[I
].NetOut
[T
].Clear();
1383 // next and last iteration is always RELIABLE
1384 F
:= LongWord(ENET_PACKET_FLAG_RELIABLE
);
1385 Chan
:= NET_CHAN_IMPORTANT
;
1387 else if NetMode
= NET_CLIENT
then
1388 for T
:= NET_UNRELIABLE
to NET_RELIABLE
do
1390 if NetBuf
[T
].CurSize
> 0 then
1392 P
:= enet_packet_create(NetBuf
[T
].Data
, NetBuf
[T
].CurSize
, F
);
1393 if not Assigned(P
) then continue
;
1394 enet_peer_send(NetPeer
, Chan
, P
);
1397 // next and last iteration is always RELIABLE
1398 F
:= LongWord(ENET_PACKET_FLAG_RELIABLE
);
1399 Chan
:= NET_CHAN_IMPORTANT
;
1403 procedure g_Net_Cleanup();
1407 NetBuf
[NET_UNRELIABLE
].Clear();
1408 NetBuf
[NET_RELIABLE
].Clear();
1410 //SetLength(NetClients, 0);
1411 clearNetClients(true); // clear array
1412 NetClientCount
:= 0;
1416 g_Net_Slist_NetworkStopped();
1417 //g_Net_Slist_Disconnect(false); // do not spam console
1421 NetState
:= NET_STATE_NONE
;
1423 NetPongSock
:= ENET_SOCKET_NULL
;
1425 NetTimeToMaster
:= 0;
1426 NetTimeToUpdate
:= 0;
1427 NetTimeToReliable
:= 0;
1429 NetMode
:= NET_NONE
;
1431 if NetPortThread
<> NilThreadId
then
1432 WaitForThreadTerminate(NetPortThread
, 66666);
1434 NetPortThread
:= NilThreadId
;
1435 g_Net_UnforwardPorts();
1441 procedure g_Net_Free();
1445 //enet_deinitialize();
1446 NetInitDone
:= False;
1450 //**************************************************************************
1454 //**************************************************************************
1456 function ForwardThread(Param
: Pointer): PtrInt
;
1459 if not g_Net_ForwardPorts() then Result
:= -1;
1462 function g_Net_Host(IPAddr
: LongWord; Port
: enet_uint16
; MaxClients
: Cardinal = 16): Boolean;
1464 if NetMode
<> NET_NONE
then
1466 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_INGAME
]);
1473 g_Console_Add(_lc
[I_NET_MSG
] + Format(_lc
[I_NET_MSG_HOST
], [Port
]));
1474 if not NetInitDone
then
1476 if (not g_Net_Init()) then
1478 g_Console_Add(_lc
[I_NET_MSG_FERROR
] + _lc
[I_NET_ERR_ENET
]);
1483 NetInitDone
:= True;
1486 NetAddr
.host
:= IPAddr
;
1487 NetAddr
.port
:= Port
;
1489 if NetForwardPorts
then NetPortThread
:= BeginThread(ForwardThread
);
1491 NetHost
:= enet_host_create(@NetAddr
, NET_MAXCLIENTS
, NET_CHANS
, 0, 0);
1493 if (NetHost
= nil) then
1495 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + Format(_lc
[I_NET_ERR_HOST
], [Port
]));
1501 NetPongSock
:= enet_socket_create(ENET_SOCKET_TYPE_DATAGRAM
);
1502 if NetPongSock
<> ENET_SOCKET_NULL
then
1504 NetPongAddr
.host
:= IPAddr
;
1505 NetPongAddr
.port
:= NET_PING_PORT
;
1506 if enet_socket_bind(NetPongSock
, @NetPongAddr
) < 0 then
1508 enet_socket_destroy(NetPongSock
);
1509 NetPongSock
:= ENET_SOCKET_NULL
;
1512 enet_socket_set_option(NetPongSock
, ENET_SOCKOPT_NONBLOCK
, 1);
1515 NetMode
:= NET_SERVER
;
1517 NetBuf
[NET_UNRELIABLE
].Clear();
1518 NetBuf
[NET_RELIABLE
].Clear();
1524 procedure g_Net_Host_Die();
1528 if NetMode
<> NET_SERVER
then Exit
;
1530 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_HOST_DISCALL
]);
1531 for I
:= 0 to High(NetClients
) do
1532 if NetClients
[I
].Used
then
1533 enet_peer_disconnect(NetClients
[I
].Peer
, NET_DISC_DOWN
);
1535 while enet_host_service(NetHost
, @NetEvent
, 1000) > 0 do
1536 if NetEvent
.kind
= ENET_EVENT_TYPE_RECEIVE
then
1537 enet_packet_destroy(NetEvent
.packet
);
1539 for I
:= 0 to High(NetClients
) do
1540 if NetClients
[I
].Used
then
1542 FreeMemory(NetClients
[I
].Peer
^.data
);
1543 NetClients
[I
].Peer
^.data
:= nil;
1544 enet_peer_reset(NetClients
[I
].Peer
);
1545 NetClients
[I
].Peer
:= nil;
1546 NetClients
[I
].Used
:= False;
1547 NetClients
[I
].NetOut
[NET_UNRELIABLE
].Free();
1548 NetClients
[I
].NetOut
[NET_RELIABLE
].Free();
1551 clearNetClients(false); // don't clear array
1552 //if (g_Net_Slist_IsConnectionActive) then g_Net_Slist_Disconnect;
1553 g_Net_Slist_NetworkStopped();
1554 if NetPongSock
<> ENET_SOCKET_NULL
then
1555 enet_socket_destroy(NetPongSock
);
1557 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_HOST_DIE
]);
1558 enet_host_destroy(NetHost
);
1560 NetMode
:= NET_NONE
;
1563 e_WriteLog('NET: Server stopped', TMsgType
.Notify
);
1567 procedure g_Net_Host_Send(ID
: Integer; Reliable
: Boolean; Chan
: Byte = NET_CHAN_GAME
);
1574 T
:= NET_UNRELIABLE
;
1578 if ID
> High(NetClients
) then Exit
;
1579 if NetClients
[ID
].Peer
= nil then Exit
;
1581 NetClients
[ID
].NetOut
[T
].Write(Integer(NetOut
.CurSize
));
1582 NetClients
[ID
].NetOut
[T
].Write(NetOut
);
1587 NetBuf
[T
].Write(Integer(NetOut
.CurSize
));
1588 NetBuf
[T
].Write(NetOut
);
1591 if NetDump
then g_Net_DumpSendBuffer();
1595 procedure g_Net_Host_CheckPings();
1597 ClAddr
: ENetAddress
;
1601 Ping
: array [0..9] of Byte;
1604 if NetPongSock
= ENET_SOCKET_NULL
then Exit
;
1606 Buf
.data
:= Addr(Ping
[0]);
1607 Buf
.dataLength
:= 2+8;
1611 Len
:= enet_socket_receive(NetPongSock
, @ClAddr
, @Buf
, 1);
1612 if Len
< 0 then Exit
;
1614 if (Ping
[0] = Ord('D')) and (Ping
[1] = Ord('F')) then
1616 ClTime
:= Int64(Addr(Ping
[2])^);
1619 NetOut
.Write(Byte(Ord('D')));
1620 NetOut
.Write(Byte(Ord('F')));
1621 NetOut
.Write(NetPort
);
1622 NetOut
.Write(ClTime
);
1623 //g_Net_Slist_WriteInfo();
1624 TMasterHost
.writeInfo(NetOut
);
1626 if gPlayer1
<> nil then Inc(NPl
);
1627 if gPlayer2
<> nil then Inc(NPl
);
1629 NetOut
.Write(gNumBots
);
1631 Buf
.data
:= NetOut
.Data
;
1632 Buf
.dataLength
:= NetOut
.CurSize
;
1633 enet_socket_send(NetPongSock
, @ClAddr
, @Buf
, 1);
1640 function g_Net_Host_Update(): enet_size_t
;
1651 if NetUseMaster
then
1653 //g_Net_Slist_Check;
1654 g_Net_Slist_Pulse();
1656 g_Net_Host_CheckPings
;
1658 while (enet_host_service(NetHost
, @NetEvent
, 0) > 0) do
1660 case (NetEvent
.kind
) of
1661 ENET_EVENT_TYPE_CONNECT
:
1663 IP
:= IpToStr(NetEvent
.Peer
^.address
.host
);
1664 Port
:= NetEvent
.Peer
^.address
.port
;
1665 g_Console_Add(_lc
[I_NET_MSG
] +
1666 Format(_lc
[I_NET_MSG_HOST_CONN
], [IP
, Port
]));
1668 if (NetEvent
.data
<> NET_PROTOCOL_VER
) then
1670 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_HOST_REJECT
] +
1671 _lc
[I_NET_DISC_PROTOCOL
]);
1672 NetEvent
.peer
^.data
:= GetMemory(SizeOf(Byte));
1673 Byte(NetEvent
.peer
^.data
^) := 255;
1674 enet_peer_disconnect(NetEvent
.peer
, NET_DISC_PROTOCOL
);
1675 enet_host_flush(NetHost
);
1679 ID
:= g_Net_FindSlot();
1683 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_HOST_REJECT
] +
1684 _lc
[I_NET_DISC_FULL
]);
1685 NetEvent
.Peer
^.data
:= GetMemory(SizeOf(Byte));
1686 Byte(NetEvent
.peer
^.data
^) := 255;
1687 enet_peer_disconnect(NetEvent
.peer
, NET_DISC_FULL
);
1688 enet_host_flush(NetHost
);
1692 NetClients
[ID
].Peer
:= NetEvent
.peer
;
1693 NetClients
[ID
].Peer
^.data
:= GetMemory(SizeOf(Byte));
1694 Byte(NetClients
[ID
].Peer
^.data
^) := ID
;
1695 NetClients
[ID
].State
:= NET_STATE_AUTH
;
1696 NetClients
[ID
].RCONAuth
:= False;
1697 NetClients
[ID
].NetOut
[NET_UNRELIABLE
].Alloc(NET_BUFSIZE
*2);
1698 NetClients
[ID
].NetOut
[NET_RELIABLE
].Alloc(NET_BUFSIZE
*2);
1699 clearNetClientTransfers(NetClients
[ID
]); // just in case
1701 enet_peer_timeout(NetEvent
.peer
, ENET_PEER_TIMEOUT_LIMIT
* 2, ENET_PEER_TIMEOUT_MINIMUM
* 2, ENET_PEER_TIMEOUT_MAXIMUM
* 2);
1703 Inc(NetClientCount
);
1704 g_Console_Add(_lc
[I_NET_MSG
] + Format(_lc
[I_NET_MSG_HOST_ADD
], [ID
]));
1707 ENET_EVENT_TYPE_RECEIVE
:
1709 //e_LogWritefln('RECEIVE: chan=%u', [NetEvent.channelID]);
1710 if (NetEvent
.channelID
= NET_CHAN_DOWNLOAD_EX
) then
1712 ProcessDownloadExPacket();
1716 ID
:= Byte(NetEvent
.peer
^.data
^);
1717 if ID
> High(NetClients
) then Exit
;
1718 TC
:= @NetClients
[ID
];
1720 if NetDump
then g_Net_DumpRecvBuffer(NetEvent
.packet
^.data
, NetEvent
.packet
^.dataLength
);
1721 g_Net_Host_HandlePacket(TC
, NetEvent
.packet
, g_Net_HostMsgHandler
);
1725 ENET_EVENT_TYPE_DISCONNECT
:
1727 ID
:= Byte(NetEvent
.peer
^.data
^);
1728 if ID
> High(NetClients
) then Exit
;
1729 clearNetClient(NetClients
[ID
]);
1730 TC
:= @NetClients
[ID
];
1731 if TC
= nil then Exit
;
1733 if not (TC
^.Used
) then Exit
;
1735 TP
:= g_Player_Get(TC
^.Player
);
1740 TP
.Kill(K_SIMPLEKILL
, 0, HIT_DISCON
);
1741 g_Console_Add(Format(_lc
[I_PLAYER_LEAVE
], [TP
.Name
]), True);
1742 e_WriteLog('NET: Client ' + TP
.Name
+ ' [' + IntToStr(ID
) + '] disconnected.', TMsgType
.Notify
);
1743 g_Player_Remove(TP
.UID
);
1747 TC
^.State
:= NET_STATE_NONE
;
1750 TC
^.RequestedFullUpdate
:= False;
1751 TC
^.WaitForFirstSpawn
:= False;
1752 TC
^.NetOut
[NET_UNRELIABLE
].Free();
1753 TC
^.NetOut
[NET_RELIABLE
].Free();
1755 FreeMemory(NetEvent
.peer
^.data
);
1756 NetEvent
.peer
^.data
:= nil;
1757 g_Console_Add(_lc
[I_NET_MSG
] + Format(_lc
[I_NET_MSG_HOST_DISC
], [ID
]));
1758 Dec(NetClientCount
);
1760 if NetUseMaster
then
1762 //g_Net_Slist_Update;
1763 g_Net_Slist_Pulse();
1771 //**************************************************************************
1775 //**************************************************************************
1777 procedure g_Net_Disconnect(Forced
: Boolean = False);
1779 if NetMode
<> NET_CLIENT
then Exit
;
1780 if (NetHost
= nil) or (NetPeer
= nil) then Exit
;
1784 enet_peer_disconnect(NetPeer
, NET_DISC_NONE
);
1786 while (enet_host_service(NetHost
, @NetEvent
, 1500) > 0) do
1788 if (NetEvent
.kind
= ENET_EVENT_TYPE_DISCONNECT
) then
1794 if (NetEvent
.kind
= ENET_EVENT_TYPE_RECEIVE
) then
1795 enet_packet_destroy(NetEvent
.packet
);
1798 if NetPeer
<> nil then
1800 enet_peer_reset(NetPeer
);
1806 e_WriteLog('NET: Kicked from server: ' + IntToStr(NetEvent
.data
), TMsgType
.Notify
);
1807 if (NetEvent
.data
<= NET_DISC_MAX
) then
1808 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_KICK
] +
1809 _lc
[TStrings_Locale(Cardinal(I_NET_DISC_NONE
) + NetEvent
.data
)], True);
1812 if NetHost
<> nil then
1814 enet_host_destroy(NetHost
);
1817 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_CLIENT_DISC
]);
1820 e_WriteLog('NET: Disconnected', TMsgType
.Notify
);
1823 procedure g_Net_Client_Send(Reliable
: Boolean; Chan
: Byte = NET_CHAN_GAME
);
1830 T
:= NET_UNRELIABLE
;
1833 NetBuf
[T
].Write(Integer(NetOut
.CurSize
));
1834 NetBuf
[T
].Write(NetOut
);
1836 if NetDump
then g_Net_DumpSendBuffer();
1838 g_Net_Flush(); // FIXME: for now, send immediately
1841 function g_Net_Client_Update(): enet_size_t
;
1844 while (enet_host_service(NetHost
, @NetEvent
, 0) > 0) do
1846 case NetEvent
.kind
of
1847 ENET_EVENT_TYPE_RECEIVE
:
1849 if (NetEvent
.channelID
= NET_CHAN_DOWNLOAD_EX
) then continue
; // ignore all download packets, they're processed by separate code
1850 if NetDump
then g_Net_DumpRecvBuffer(NetEvent
.packet
^.data
, NetEvent
.packet
^.dataLength
);
1851 g_Net_Client_HandlePacket(NetEvent
.packet
, g_Net_ClientMsgHandler
);
1854 ENET_EVENT_TYPE_DISCONNECT
:
1856 g_Net_Disconnect(True);
1864 function g_Net_Client_UpdateWhileLoading(): enet_size_t
;
1867 while (enet_host_service(NetHost
, @NetEvent
, 0) > 0) do
1869 case NetEvent
.kind
of
1870 ENET_EVENT_TYPE_RECEIVE
:
1872 if (NetEvent
.channelID
= NET_CHAN_DOWNLOAD_EX
) then continue
; // ignore all download packets, they're processed by separate code
1873 if NetDump
then g_Net_DumpRecvBuffer(NetEvent
.packet
^.data
, NetEvent
.packet
^.dataLength
);
1874 g_Net_Client_HandlePacket(NetEvent
.packet
, g_Net_ClientLightMsgHandler
);
1877 ENET_EVENT_TYPE_DISCONNECT
:
1879 g_Net_Disconnect(True);
1888 function g_Net_Connect(IP
: string; Port
: enet_uint16
): Boolean;
1891 TimeoutTime
, T
: Int64;
1893 if NetMode
<> NET_NONE
then
1895 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_ERR_INGAME
], True);
1902 g_Console_Add(_lc
[I_NET_MSG
] + Format(_lc
[I_NET_MSG_CLIENT_CONN
],
1904 if not NetInitDone
then
1906 if (not g_Net_Init()) then
1908 g_Console_Add(_lc
[I_NET_MSG_FERROR
] + _lc
[I_NET_ERR_ENET
], True);
1913 NetInitDone
:= True;
1916 NetHost
:= enet_host_create(nil, 1, NET_CHANS
, 0, 0);
1918 if (NetHost
= nil) then
1920 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CLIENT
], True);
1926 enet_address_set_host(@NetAddr
, PChar(Addr(IP
[1])));
1927 NetAddr
.port
:= Port
;
1929 NetPeer
:= enet_host_connect(NetHost
, @NetAddr
, NET_CHANS
, NET_PROTOCOL_VER
);
1931 if (NetPeer
= nil) then
1933 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_CLIENT
], True);
1934 enet_host_destroy(NetHost
);
1940 // предупредить что ждем слишком долго через N секунд
1941 TimeoutTime
:= sys_GetTicks() + NET_CONNECT_TIMEOUT
;
1946 while (enet_host_service(NetHost
, @NetEvent
, 0) > 0) do
1948 if (NetEvent
.kind
= ENET_EVENT_TYPE_CONNECT
) then
1950 g_Console_Add(_lc
[I_NET_MSG
] + _lc
[I_NET_MSG_CLIENT_DONE
]);
1951 NetMode
:= NET_CLIENT
;
1953 enet_peer_timeout(NetPeer
, ENET_PEER_TIMEOUT_LIMIT
* 2, ENET_PEER_TIMEOUT_MINIMUM
* 2, ENET_PEER_TIMEOUT_MAXIMUM
* 2);
1955 NetClientPort
:= Port
;
1962 T
:= sys_GetTicks();
1963 if T
> TimeoutTime
then
1965 TimeoutTime
:= T
+ NET_CONNECT_TIMEOUT
* 100; // одного предупреждения хватит
1966 g_Console_Add(_lc
[I_NET_MSG_TIMEOUT_WARN
], True);
1967 g_Console_Add(Format(_lc
[I_NET_MSG_PORTS
], [Integer(Port
), Integer(NET_PING_PORT
)]), True);
1970 ProcessLoading(true);
1972 if e_KeyPressed(IK_SPACE
) or e_KeyPressed(IK_ESCAPE
) or e_KeyPressed(VK_ESCAPE
) or
1973 e_KeyPressed(JOY0_JUMP
) or e_KeyPressed(JOY1_JUMP
) or e_KeyPressed(JOY2_JUMP
) or e_KeyPressed(JOY3_JUMP
) then
1977 g_Console_Add(_lc
[I_NET_MSG_ERROR
] + _lc
[I_NET_ERR_TIMEOUT
], True);
1978 g_Console_Add(Format(_lc
[I_NET_MSG_PORTS
], [Integer(Port
), Integer(NET_PING_PORT
)]), True);
1979 if NetPeer
<> nil then enet_peer_reset(NetPeer
);
1980 if NetHost
<> nil then
1982 enet_host_destroy(NetHost
);
1989 function IpToStr(IP
: LongWord): string;
1994 Result
:= IntToStr(PByte(Ptr
+ 0)^) + '.';
1995 Result
:= Result
+ IntToStr(PByte(Ptr
+ 1)^) + '.';
1996 Result
:= Result
+ IntToStr(PByte(Ptr
+ 2)^) + '.';
1997 Result
:= Result
+ IntToStr(PByte(Ptr
+ 3)^);
2000 function StrToIp(IPstr
: string; var IP
: LongWord): Boolean;
2004 Result
:= enet_address_set_host(@EAddr
, PChar(@IPstr
[1])) = 0;
2008 function g_Net_Client_ByName(Name
: string): pTNetClient
;
2014 for a
:= Low(NetClients
) to High(NetClients
) do
2015 if (NetClients
[a
].Used
) and (NetClients
[a
].State
= NET_STATE_GAME
) then
2017 pl
:= g_Player_Get(NetClients
[a
].Player
);
2018 if pl
= nil then continue
;
2019 if Copy(LowerCase(pl
.Name
), 1, Length(Name
)) <> LowerCase(Name
) then continue
;
2020 if NetClients
[a
].Peer
<> nil then
2022 Result
:= @NetClients
[a
];
2028 function g_Net_Client_ByPlayer(PID
: Word): pTNetClient
;
2033 for a
:= Low(NetClients
) to High(NetClients
) do
2034 if (NetClients
[a
].Used
) and (NetClients
[a
].State
= NET_STATE_GAME
) then
2035 if NetClients
[a
].Player
= PID
then
2037 Result
:= @NetClients
[a
];
2042 function g_Net_ClientName_ByID(ID
: Integer): string;
2048 if ID
= NET_EVERYONE
then
2050 for a
:= Low(NetClients
) to High(NetClients
) do
2051 if (NetClients
[a
].ID
= ID
) and (NetClients
[a
].Used
) and (NetClients
[a
].State
= NET_STATE_GAME
) then
2053 pl
:= g_Player_Get(NetClients
[a
].Player
);
2054 if pl
= nil then Exit
;
2059 procedure g_Net_SendData(Data
: AByte
; peer
: pENetPeer
; Reliable
: Boolean; Chan
: Byte = NET_CHAN_DOWNLOAD
);
2063 dataLength
: Cardinal;
2065 dataLength
:= Length(Data
);
2068 F
:= LongWord(ENET_PACKET_FLAG_RELIABLE
)
2072 if (peer
<> nil) then
2074 P
:= enet_packet_create(@Data
[0], dataLength
, F
);
2075 if not Assigned(P
) then Exit
;
2076 enet_peer_send(peer
, Chan
, P
);
2080 P
:= enet_packet_create(@Data
[0], dataLength
, F
);
2081 if not Assigned(P
) then Exit
;
2082 enet_host_broadcast(NetHost
, Chan
, P
);
2085 enet_host_flush(NetHost
);
2088 function g_Net_IsHostBanned(IP
: LongWord; Perm
: Boolean = False): Boolean;
2093 if NetBannedHosts
= nil then
2095 for I
:= 0 to High(NetBannedHosts
) do
2096 if (NetBannedHosts
[I
].IP
= IP
) and ((not Perm
) or (NetBannedHosts
[I
].Perm
)) then
2103 procedure g_Net_BanHost(IP
: LongWord; Perm
: Boolean = True); overload
;
2109 if g_Net_IsHostBanned(IP
, Perm
) then
2113 for I
:= Low(NetBannedHosts
) to High(NetBannedHosts
) do
2114 if NetBannedHosts
[I
].IP
= 0 then
2122 SetLength(NetBannedHosts
, Length(NetBannedHosts
) + 1);
2123 P
:= High(NetBannedHosts
);
2126 NetBannedHosts
[P
].IP
:= IP
;
2127 NetBannedHosts
[P
].Perm
:= Perm
;
2130 procedure g_Net_BanHost(IP
: string; Perm
: Boolean = True); overload
;
2135 b
:= StrToIp(IP
, a
);
2137 g_Net_BanHost(a
, Perm
);
2140 procedure g_Net_UnbanNonPermHosts();
2144 if NetBannedHosts
= nil then
2146 for I
:= Low(NetBannedHosts
) to High(NetBannedHosts
) do
2147 if (NetBannedHosts
[I
].IP
> 0) and not NetBannedHosts
[I
].Perm
then
2149 NetBannedHosts
[I
].IP
:= 0;
2150 NetBannedHosts
[I
].Perm
:= True;
2154 function g_Net_UnbanHost(IP
: string): Boolean; overload
;
2158 Result
:= StrToIp(IP
, a
);
2160 Result
:= g_Net_UnbanHost(a
);
2163 function g_Net_UnbanHost(IP
: LongWord): Boolean; overload
;
2170 if NetBannedHosts
= nil then
2172 for I
:= 0 to High(NetBannedHosts
) do
2173 if NetBannedHosts
[I
].IP
= IP
then
2175 NetBannedHosts
[I
].IP
:= 0;
2176 NetBannedHosts
[I
].Perm
:= True;
2178 // no break here to clear all bans of this host, perm and non-perm
2182 procedure g_Net_SaveBanList();
2187 Assign(F
, DataDir
+ BANLIST_FILENAME
);
2189 if NetBannedHosts
<> nil then
2190 for I
:= 0 to High(NetBannedHosts
) do
2191 if NetBannedHosts
[I
].Perm
and (NetBannedHosts
[I
].IP
> 0) then
2192 Writeln(F
, IpToStr(NetBannedHosts
[I
].IP
));
2196 procedure g_Net_DumpStart();
2198 if NetMode
= NET_SERVER
then
2199 NetDumpFile
:= createDiskFile(NETDUMP_FILENAME
+ '_server')
2201 NetDumpFile
:= createDiskFile(NETDUMP_FILENAME
+ '_client');
2204 procedure g_Net_DumpSendBuffer();
2206 writeInt(NetDumpFile
, gTime
);
2207 writeInt(NetDumpFile
, LongWord(NetOut
.CurSize
));
2208 writeInt(NetDumpFile
, Byte(1));
2209 NetDumpFile
.WriteBuffer(NetOut
.Data
^, NetOut
.CurSize
);
2212 procedure g_Net_DumpRecvBuffer(Buf
: penet_uint8
; Len
: LongWord);
2214 if (Buf
= nil) or (Len
= 0) then Exit
;
2215 writeInt(NetDumpFile
, gTime
);
2216 writeInt(NetDumpFile
, Len
);
2217 writeInt(NetDumpFile
, Byte(0));
2218 NetDumpFile
.WriteBuffer(Buf
^, Len
);
2221 procedure g_Net_DumpEnd();
2227 function g_Net_ForwardPorts(ForwardPongPort
: Boolean = True): Boolean;
2228 {$IFDEF USE_MINIUPNPC}
2233 LanAddr
: array [0..255] of Char;
2234 StrPort
: AnsiString;
2239 if NetPortForwarded
= NetPort
then
2245 NetPongForwarded
:= False;
2246 NetPortForwarded
:= 0;
2248 DevList
:= upnpDiscover(1000, nil, nil, 0, 0, 2, Addr(Err
));
2249 if DevList
= nil then
2251 conwritefln('port forwarding failed: upnpDiscover() failed: %d', [Err
]);
2255 I
:= UPNP_GetValidIGD(DevList
, @Urls
, @Data
, Addr(LanAddr
[0]), 256);
2259 conwriteln('port forwarding failed: could not find an IGD device on this LAN');
2260 FreeUPNPDevList(DevList
);
2261 FreeUPNPUrls(@Urls
);
2265 StrPort
:= IntToStr(NetPort
);
2266 I
:= UPNP_AddPortMapping(
2267 Urls
.controlURL
, Addr(data
.first
.servicetype
[1]),
2268 PChar(StrPort
), PChar(StrPort
), Addr(LanAddr
[0]), PChar('D2DF'),
2269 PChar('UDP'), nil, PChar('0')
2274 conwritefln('forwarding port %d failed: error %d', [NetPort
, I
]);
2275 FreeUPNPDevList(DevList
);
2276 FreeUPNPUrls(@Urls
);
2280 if ForwardPongPort
then
2282 StrPort
:= IntToStr(NET_PING_PORT
);
2283 I
:= UPNP_AddPortMapping(
2284 Urls
.controlURL
, Addr(data
.first
.servicetype
[1]),
2285 PChar(StrPort
), PChar(StrPort
), Addr(LanAddr
[0]), PChar('D2DF'),
2286 PChar('UDP'), nil, PChar('0')
2291 conwritefln('forwarding port %d failed: error %d', [NetPort
+ 1, I
]);
2292 NetPongForwarded
:= False;
2296 conwritefln('forwarded port %d successfully', [NetPort
+ 1]);
2297 NetPongForwarded
:= True;
2301 conwritefln('forwarded port %d successfully', [NetPort
]);
2302 NetIGDControl
:= AnsiString(Urls
.controlURL
);
2303 NetIGDService
:= data
.first
.servicetype
;
2304 NetPortForwarded
:= NetPort
;
2306 FreeUPNPDevList(DevList
);
2307 FreeUPNPUrls(@Urls
);
2316 procedure g_Net_UnforwardPorts();
2317 {$IFDEF USE_MINIUPNPC}
2320 StrPort
: AnsiString;
2322 if NetPortForwarded
= 0 then Exit
;
2324 conwriteln('unforwarding ports...');
2326 StrPort
:= IntToStr(NetPortForwarded
);
2327 I
:= UPNP_DeletePortMapping(
2328 PChar(NetIGDControl
), Addr(NetIGDService
[1]),
2329 PChar(StrPort
), PChar('UDP'), nil
2331 conwritefln(' port %d: %d', [NetPortForwarded
, I
]);
2333 if NetPongForwarded
then
2335 NetPongForwarded
:= False;
2336 StrPort
:= IntToStr(NetPortForwarded
+ 1);
2337 I
:= UPNP_DeletePortMapping(
2338 PChar(NetIGDControl
), Addr(NetIGDService
[1]),
2339 PChar(StrPort
), PChar('UDP'), nil
2341 conwritefln(' port %d: %d', [NetPortForwarded
+ 1, I
]);
2344 NetPortForwarded
:= 0;
2353 conRegVar('cl_downloadtimeout', @g_Net_DownloadTimeout
, 0.0, 1000000.0, '', 'timeout in seconds, 0 to disable it');
2354 SetLength(NetClients
, 0);
2355 g_Net_DownloadTimeout
:= 60;
2356 NetIn
.Alloc(NET_BUFSIZE
);
2357 NetOut
.Alloc(NET_BUFSIZE
);
2358 NetBuf
[NET_UNRELIABLE
].Alloc(NET_BUFSIZE
*2);
2359 NetBuf
[NET_RELIABLE
].Alloc(NET_BUFSIZE
*2);
2360 trans_omsg
.Alloc(NET_BUFSIZE
);
2364 NetBuf
[NET_UNRELIABLE
].Free();
2365 NetBuf
[NET_RELIABLE
].Free();