From 2304c541d7bdbf7de389437482ecdff37fc7fbd5 Mon Sep 17 00:00:00 2001 From: Ketmar Dark Date: Tue, 15 Oct 2019 19:22:01 +0300 Subject: [PATCH] net: started master-server communication rewrite (phase 1: master i/o moved to separate object) --- src/game/g_game.pas | 82 ++- src/game/g_net.pas | 21 +- src/game/g_netmaster.pas | 1018 +++++++++++++++++++++++++++----------- src/game/g_netmsg.pas | 6 +- 4 files changed, 830 insertions(+), 297 deletions(-) diff --git a/src/game/g_game.pas b/src/game/g_game.pas index aa4c189..7ad130f 100644 --- a/src/game/g_game.pas +++ b/src/game/g_game.pas @@ -2126,12 +2126,15 @@ begin if NetUseMaster then begin + { if (gTime >= NetTimeToMaster) or g_Net_Slist_IsConnectionInProgress then begin if (not g_Net_Slist_IsConnectionActive) then g_Net_Slist_Connect(false); // non-blocking connection to the master g_Net_Slist_Update; NetTimeToMaster := gTime + NetMasterRate; end; + } + g_Net_Slist_Pulse(); end; end else if (NetMode = NET_CLIENT) then @@ -4194,7 +4197,10 @@ begin gPlayer1.Respawn(False, True); if g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; Exit; @@ -4226,7 +4232,10 @@ begin gPlayer2.Respawn(False, True); if g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; Exit; @@ -4251,7 +4260,10 @@ begin g_Player_Remove(Pl.UID); if g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end else gPlayer2 := nil; Exit; @@ -4267,7 +4279,10 @@ begin g_Player_Remove(Pl.UID); if g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end else begin gPlayer1 := nil; @@ -4907,8 +4922,11 @@ begin // Ìàñòåðñåðâåð if NetUseMaster then begin + { if (not g_Net_Slist_IsConnectionActive) then g_Net_Slist_Connect(false); // non-blocking connection to the master g_Net_Slist_Update; + } + g_Net_Slist_Pulse(); end; if NetClients <> nil then @@ -5480,7 +5498,10 @@ begin if Length(NetServerName) > 64 then SetLength(NetServerName, 64); if g_Game_IsServer and g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; g_Console_Add(cmd + ' = "' + NetServerName + '"'); @@ -5493,7 +5514,10 @@ begin if Length(NetPassword) > 24 then SetLength(NetPassword, 24); if g_Game_IsServer and g_Game_IsNet and NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; g_Console_Add(cmd + ' = "' + AnsiLowerCase(NetPassword) + '"'); @@ -5519,7 +5543,10 @@ begin end; end; if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; end; @@ -5534,12 +5561,16 @@ begin begin if NetUseMaster then begin + { if (not g_Net_Slist_IsConnectionActive) then g_Net_Slist_Connect(false); // non-blocking connection to the master g_Net_Slist_Update(); + } + g_Net_Slist_Pulse(); end else begin - if (not g_Net_Slist_IsConnectionActive) then g_Net_Slist_Disconnect(); + //if (not g_Net_Slist_IsConnectionActive) then g_Net_Slist_Disconnect(); + g_Net_Slist_Private(); end; end; end; @@ -6197,7 +6228,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_KICK], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_KICK, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end else if gPlayers <> nil then for a := Low(gPlayers) to High(gPlayers) do if gPlayers[a] <> nil then @@ -6211,7 +6245,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_LEAVE], [gPlayers[a].Name]), True); g_Player_Remove(gPlayers[a].UID); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; // Åñëè íå ïåðåìåøàòü, ïðè äîáàâëåíèè íîâûõ áîòîâ ïîÿâÿòñÿ ñòàðûå g_Bot_MixNames(); end; @@ -6243,7 +6280,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_KICK], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_KICK, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; end; end else @@ -6273,7 +6313,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_BAN], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_BAN, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end else g_Console_Add(Format(_lc[I_NET_ERR_NAME404], [P[1]])); end else @@ -6304,7 +6347,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_BAN], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_BAN, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; end else g_Console_Add(_lc[I_MSG_SERVERONLY]); @@ -6334,7 +6380,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_BAN], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_BAN, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end else g_Console_Add(Format(_lc[I_NET_ERR_NAME404], [P[1]])); end else @@ -6366,7 +6415,10 @@ begin g_Console_Add(Format(_lc[I_PLAYER_BAN], [s])); MH_SEND_GameEvent(NET_EV_PLAYER_BAN, 0, s); if NetUseMaster then - g_Net_Slist_Update; + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; end else g_Console_Add(_lc[I_MSG_SERVERONLY]); diff --git a/src/game/g_net.pas b/src/game/g_net.pas index c01efd1..11acd5f 100644 --- a/src/game/g_net.pas +++ b/src/game/g_net.pas @@ -1385,7 +1385,8 @@ begin NetPeer := nil; NetHost := nil; - g_Net_Slist_Disconnect(false); // do not spam console + g_Net_Slist_NetworkStopped(); + //g_Net_Slist_Disconnect(false); // do not spam console NetMyID := -1; NetPlrUID1 := -1; NetPlrUID2 := -1; @@ -1520,7 +1521,8 @@ begin end; clearNetClients(false); // don't clear array - if (g_Net_Slist_IsConnectionActive) then g_Net_Slist_Disconnect; + //if (g_Net_Slist_IsConnectionActive) then g_Net_Slist_Disconnect; + g_Net_Slist_NetworkStopped(); if NetPongSock <> ENET_SOCKET_NULL then enet_socket_destroy(NetPongSock); @@ -1590,7 +1592,8 @@ begin NetOut.Write(Byte(Ord('F'))); NetOut.Write(NetPort); NetOut.Write(ClTime); - g_Net_Slist_WriteInfo(); + //g_Net_Slist_WriteInfo(); + TMasterHost.writeInfo(NetOut); NPl := 0; if gPlayer1 <> nil then Inc(NPl); if gPlayer2 <> nil then Inc(NPl); @@ -1617,7 +1620,11 @@ begin IP := ''; Result := 0; - if NetUseMaster then g_Net_Slist_Check; + if NetUseMaster then + begin + //g_Net_Slist_Check; + g_Net_Slist_Pulse(); + end; g_Net_Host_CheckPings; while (enet_host_service(NetHost, @NetEvent, 0) > 0) do @@ -1722,7 +1729,11 @@ begin g_Console_Add(_lc[I_NET_MSG] + Format(_lc[I_NET_MSG_HOST_DISC], [ID])); Dec(NetClientCount); - if NetUseMaster then g_Net_Slist_Update; + if NetUseMaster then + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; end; end; diff --git a/src/game/g_netmaster.pas b/src/game/g_netmaster.pas index 2ecad14..f8246d6 100644 --- a/src/game/g_netmaster.pas +++ b/src/game/g_netmaster.pas @@ -17,7 +17,8 @@ unit g_netmaster; interface -uses ENet; +uses + ENet, SysUtils, e_msg; const NET_MCHANS = 2; @@ -53,6 +54,65 @@ type pTNetServerList = ^TNetServerList; TNetServerTable = array of TNetServerRow; +type + TMasterHost = record + public + hostName: AnsiString; + hostPort: Word; + + public + //host: pENetHost; + peer: pENetPeer; + event: ENetEvent; + enetAddr: ENetAddress; + // inside the game, calling `connect()` is disasterous, as it is blocking. + // so we'll use this variable to indicate if "connected" event is received. + NetHostConnected: Boolean; + NetHostConReqTime: Int64; // to timeout `connect` + NetUpdatePending: Boolean; // should we send an update after connection completes? + updateSent: Boolean; + lastUpdateTime: Int64; + addressInited: Boolean; + + private + netmsg: TMsg; + + private + function processPendingConnection (timeout: Integer=0): Boolean; + + public + constructor Create (hostandport: AnsiString); + + procedure clear (); + + function setAddress (hostandport: AnsiString): Boolean; + + function isValid (): Boolean; + function isAlive (): Boolean; // not disconnected + function isConnecting (): Boolean; // is connection in progress? + function isConnected (): Boolean; + + // returns `false` if connection failed + function waitForConnection (): Boolean; + + // call as often as you want, the object will do the rest + // but try to call this at least once in 100 msecs + // returns `true` if we got a packet (it won't be parsed to TMsg) + function service (timeout: Integer=0): Boolean; + + procedure disconnect (spamConsole: Boolean=false); + function connect (): Boolean; + + procedure update (immediateSend: Boolean=true); + procedure remove (); + + class procedure writeInfo (var msg: TMsg); static; + + // call only if `service()` returned `true`! + procedure clearPacket (); + end; + + var slCurrent: TNetServerList = nil; slTable: TNetServerTable = nil; @@ -62,90 +122,394 @@ var slMOTD: string = ''; slUrgent: string = ''; -procedure g_Net_Slist_Set(IP: string; Port: Word); -function g_Net_Slist_Fetch(var SL: TNetServerList): Boolean; +procedure g_Net_Slist_Set (IP: string; Port: Word); +function g_Net_Slist_Fetch (var SL: TNetServerList): Boolean; + +{ procedure g_Net_Slist_Update (immediateSend: Boolean=true); -procedure g_Net_Slist_Remove(); -function g_Net_Slist_Connect(blocking: Boolean=True): Boolean; -procedure g_Net_Slist_Check(); +procedure g_Net_Slist_Remove (); +function g_Net_Slist_Connect (blocking: Boolean=True): Boolean; +procedure g_Net_Slist_Check (); procedure g_Net_Slist_Disconnect (spamConsole: Boolean=true); -procedure g_Net_Slist_WriteInfo(); +procedure g_Net_Slist_WriteInfo (); function g_Net_Slist_IsConnectionActive (): Boolean; // returns `false` if totally disconnected function g_Net_Slist_IsConnectionInProgress (): Boolean; +} + +// make this server private +procedure g_Net_Slist_Private (); + +// called on network mode init +procedure g_Net_Slist_NetworkStarted (); +// called on network mode shutdown +procedure g_Net_Slist_NetworkStopped (); -procedure g_Serverlist_GenerateTable(SL: TNetServerList; var ST: TNetServerTable); -procedure g_Serverlist_Draw(var SL: TNetServerList; var ST: TNetServerTable); -procedure g_Serverlist_Control(var SL: TNetServerList; var ST: TNetServerTable); +procedure g_Net_Slist_Pulse (); -function GetTimerMS(): Int64; +procedure g_Serverlist_GenerateTable (SL: TNetServerList; var ST: TNetServerTable); +procedure g_Serverlist_Draw (var SL: TNetServerList; var ST: TNetServerTable); +procedure g_Serverlist_Control (var SL: TNetServerList; var ST: TNetServerTable); + +function GetTimerMS (): Int64; implementation uses - SysUtils, e_msg, e_input, e_graphics, e_log, g_window, g_net, g_console, + e_input, e_graphics, e_log, g_window, g_net, g_console, g_map, g_game, g_sound, g_gui, g_menu, g_options, g_language, g_basic, - wadreader, g_system; + wadreader, g_system, utils; + +// make this server private +procedure g_Net_Slist_Private (); +begin +end; + + +// called on network mode init +procedure g_Net_Slist_NetworkStarted (); +begin +end; + +// called on network mode shutdown +procedure g_Net_Slist_NetworkStopped (); +begin +end; + var NetMHost: pENetHost = nil; - NetMPeer: pENetPeer = nil; - NetMEvent: ENetEvent; + mlist: array of TMasterHost = nil; + slSelection: Byte = 0; slFetched: Boolean = False; slDirPressed: Boolean = False; slReadUrgent: Boolean = False; + { + NetMHost: pENetHost = nil; + NetMPeer: pENetPeer = nil; + NetMEvent: ENetEvent; // inside the game, calling `g_Net_Slist_Connect()` is disasterous, as it is blocking. // so we'll use this variable to indicate if "connected" event is received. NetHostConnected: Boolean = false; NetHostConReqTime: Int64 = 0; // to timeout `connect` NetUpdatePending: Boolean = false; + } +//========================================================================== +// +// GetTimerMS +// +//========================================================================== function GetTimerMS (): Int64; begin Result := sys_GetTicks() {div 1000}; end; -// returns `false` if totally disconnected -function g_Net_Slist_IsConnectionActive (): Boolean; +//========================================================================== +// +// TMasterHost.Create +// +//========================================================================== +constructor TMasterHost.Create (hostandport: AnsiString); begin - result := (NetMHost <> nil) and (NetMPeer <> nil); + //host := nil; + peer := nil; + ZeroMemory(@event, sizeof(event)); + NetHostConnected := false; + NetHostConReqTime := 0; + NetUpdatePending := false; + updateSent := false; + hostName := ''; + hostPort := 25665; + netmsg.Alloc(NET_BUFSIZE); + setAddress(hostandport); end; -function g_Net_Slist_IsConnectionInProgress (): Boolean; +//========================================================================== +// +// TMasterHost.clear +// +//========================================================================== +procedure TMasterHost.clear (); begin - if (NetMHost = nil) or (NetMPeer = nil) then begin result := false; exit; end; - result := (not NetHostConnected); + updateSent := false; // do not send 'remove' + disconnect(); + hostName := ''; + hostPort := 25665; + netmsg.Free(); +end; + + +//========================================================================== +// +// TMasterHost.setAddress +// +//========================================================================== +function TMasterHost.setAddress (hostandport: AnsiString): Boolean; +var + cp, pp: Integer; +begin + result := false; + updateSent := false; // do not send 'remove' + disconnect(); + addressInited := false; + hostName := ''; + hostPort := 25665; + hostandport := Trim(hostandport); + if (length(hostandport) > 0) then + begin + hostName := hostandport; + cp := Pos(':', hostandport); + if (cp > 0) then + begin + hostName := Copy(hostandport, 1, cp-1); + Delete(hostandport, 1, cp); + if (length(hostandport) > 0) then + begin + try + pp := StrToInt(hostandport); + except + pp := -1; + end; + if (pp > 0) and (pp < 65536) then hostPort := pp else hostPort := 0; + end; + end; + end; + + if not isValid() then exit; + if (NetInitDone) then + begin + if (enet_address_set_host(@enetAddr, PChar(Addr(hostName[1]))) <> 0) then + begin + hostName := ''; + hostPort := 0; + end; + enetAddr.Port := hostPort; + end; + + result := isValid(); +end; + + +//========================================================================== +// +// TMasterHost.isValid +// +//========================================================================== +function TMasterHost.isValid (): Boolean; +begin + result := (length(hostName) > 0) and (hostPort > 0); +end; + + +//========================================================================== +// +// TMasterHost.isAlive +// +// not disconnected +// +//========================================================================== +function TMasterHost.isAlive (): Boolean; +begin + result := (NetMHost <> nil) and (peer <> nil); +end; + + +//========================================================================== +// +// TMasterHost.isConnecting +// +// is connection in progress? +// +//========================================================================== +function TMasterHost.isConnecting (): Boolean; +begin + result := isAlive() and (not NetHostConnected); +end; + + +//========================================================================== +// +// TMasterHost.isConnected +// +//========================================================================== +function TMasterHost.isConnected (): Boolean; +begin + result := isAlive() and (NetHostConnected); +end; + + +//========================================================================== +// +// TMasterHost.disconnect +// +//========================================================================== +procedure TMasterHost.disconnect (spamConsole: Boolean=false); +begin + if not isAlive() then exit; + if (NetMode = NET_SERVER) and isConnected() and updateSent then remove(); + + enet_peer_disconnect(peer, 0); + enet_host_flush(NetMHost); + + enet_peer_reset(peer); + //enet_host_destroy(NetMHost); + + peer := nil; + //NetMHost := nil; + NetHostConnected := False; + NetHostConReqTime := 0; + NetUpdatePending := false; + updateSent := false; + + if (spamConsole) then g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_DISC]); +end; + + +//========================================================================== +// +// TMasterHost.connect +// +//========================================================================== +function TMasterHost.connect (): Boolean; +var + res: Integer; +begin + updateSent := false; // do not send 'remove' + disconnect(); + result := false; + if not isValid() then exit; + + if (not NetInitDone) then exit; + + if (NetMHost = nil) then + begin + NetMHost := enet_host_create(nil, 1, NET_MCHANS, 0, 0); + if (NetMHost = nil) then + begin + g_Console_Add(_lc[I_NET_MSG_ERROR]+_lc[I_NET_ERR_CLIENT], True); + Exit; + end; + end; + + if (not addressInited) then + begin + if (enet_address_set_host(@enetAddr, PChar(Addr(hostName[1]))) <> 0) then + begin + hostName := ''; + hostPort := 0; + exit; + end; + enetAddr.Port := hostPort; + addressInited := true; + end; + + peer := enet_host_connect(NetMHost, @enetAddr, NET_MCHANS, 0); + if (peer = nil) then + begin + g_Console_Add(_lc[I_NET_MSG_ERROR]+_lc[I_NET_ERR_CLIENT], true); + //enet_host_destroy(NetMHost); + //NetMHost := nil; + exit; + end; + + res := enet_host_service(NetMHost, @event, 0); + if (res < 0) then + begin + enet_peer_reset(peer); + peer := nil; + exit; + end; + + result := true; + if (res > 0) then + begin + if (event.kind = ENET_EVENT_TYPE_CONNECT) then + begin + NetHostConnected := true; + g_Console_Add(_lc[I_NET_MSG]+_lc[I_NET_SLIST_CONN]); + exit; + end; + if (event.kind = ENET_EVENT_TYPE_RECEIVE) then enet_packet_destroy(event.packet); + end; + + if not NetHostConnected then NetHostConReqTime := GetTimerMS(); + + { + if (blocking) then + begin + g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_SLIST_ERROR], True); + + if NetMPeer <> nil then enet_peer_reset(NetMPeer); + if NetMHost <> nil then enet_host_destroy(NetMHost); + NetMPeer := nil; + NetMHost := nil; + NetHostConnected := False; + NetHostConReqTime := 0; + NetUpdatePending := false; + end + else + begin + NetHostConReqTime := GetTimerMS(); + g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_WCONN]); + end; + } end; -// should be called only if host/peer is here -// returns `false` if not connected/dead -function ProcessPendingConnection (): Boolean; +//========================================================================== +// +// TMasterHost.processPendingConnection +// +// should be called only if host/peer is here +// returns `false` if not connected or dead +// +//========================================================================== +function TMasterHost.processPendingConnection (timeout: Integer=0): Boolean; var ct: Int64; + cres: Integer; begin result := false; - if (NetMHost = nil) or (NetMPeer = nil) then exit; + if not isAlive() then exit; // are we waiting for connection? if (not NetHostConnected) then begin // check for connection event - if (enet_host_service(NetMHost, @NetMEvent, 0) > 0) then + cres := enet_host_service(NetMHost, @event, timeout); + if (cres < 0) then + begin + //TODO: reconnect here + updateSent := false; // do not send 'remove' + disconnect(); + exit; + end; + if (cres > 0) then begin - if (NetMEvent.kind = ENET_EVENT_TYPE_CONNECT) then + if (event.kind = ENET_EVENT_TYPE_CONNECT) then begin NetHostConnected := true; - if NetUpdatePending then g_Net_Slist_Update(false); + if NetUpdatePending then update(false); g_Console_Add(_lc[I_NET_MSG]+_lc[I_NET_SLIST_CONN]); result := true; exit; + end + else if (event.kind = ENET_EVENT_TYPE_DISCONNECT) then + begin + //TODO: reconnect here + updateSent := false; // do not send 'remove' + disconnect(); + exit; + end + else if (event.kind = ENET_EVENT_TYPE_RECEIVE) then + begin + enet_packet_destroy(event.packet); end; - if (NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE) then enet_packet_destroy(NetMEvent.packet); end; // check for connection timeout if (not NetHostConnected) then @@ -155,7 +519,7 @@ begin begin // do not spam with error messages, it looks like the master is down //g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_SLIST_ERROR], True); - g_Net_Slist_Disconnect(false); + disconnect(false); end; exit; end; @@ -164,7 +528,244 @@ begin end; -procedure PingServer(var S: TNetServer; Sock: ENetSocket); +//========================================================================== +// +// TMasterHost.writeInfo +// +//========================================================================== +class procedure TMasterHost.writeInfo (var msg: TMsg); +var + wad, map: string; +begin + wad := g_ExtractWadNameNoPath(gMapInfo.Map); + map := g_ExtractFileName(gMapInfo.Map); + + msg.Write(NetServerName); + + msg.Write(wad+':/'+map); + msg.Write(gGameSettings.GameMode); + + msg.Write(Byte(NetClientCount)); + + msg.Write(NetMaxClients); + + msg.Write(Byte(NET_PROTOCOL_VER)); + msg.Write(Byte(NetPassword <> '')); +end; + + +//========================================================================== +// +// TMasterHost.update +// +//========================================================================== +procedure TMasterHost.update (immediateSend: Boolean=true); +var + pkt: pENetPacket; +begin + if not processPendingConnection() then + begin + NetUpdatePending := isConnecting(); + exit; + end; + + NetUpdatePending := false; + + netmsg.Clear(); + netmsg.Write(Byte(NET_MMSG_UPD)); + netmsg.Write(NetAddr.port); + + writeInfo(netmsg); + + pkt := enet_packet_create(netmsg.Data, netmsg.CurSize, ENET_PACKET_FLAG_RELIABLE); + if assigned(pkt) then + begin + enet_peer_send(peer, NET_MCHAN_UPD, pkt); + if (immediateSend) then enet_host_flush(NetMHost); + end; + + netmsg.Clear(); +end; + + +//========================================================================== +// +// TMasterHost.remove +// +//========================================================================== +procedure TMasterHost.remove (); +var + pkt: pENetPacket; +begin + if not processPendingConnection() then exit; + + netmsg.Clear(); + netmsg.Write(Byte(NET_MMSG_DEL)); + netmsg.Write(NetAddr.port); + + pkt := enet_packet_create(netmsg.Data, netmsg.CurSize, ENET_PACKET_FLAG_RELIABLE); + if assigned(pkt) then + begin + enet_peer_send(peer, NET_MCHAN_MAIN, pkt); + enet_host_flush(NetMHost); + end; + + netmsg.Clear(); +end; + + +//========================================================================== +// +// TMasterHost.waitForConnection +// +// returns `false` if connection failed +// +//========================================================================== +function TMasterHost.waitForConnection (): Boolean; +begin + result := isAlive(); + if not result then exit; + while isAlive() and isConnecting() do + begin + if not processPendingConnection(300) then break; + end; + if not isConnected() then + begin + updateSent := false; // do not send 'remove' + disconnect(); + end; + result := isAlive(); +end; + + +//========================================================================== +// +// TMasterHost.service +// +// call as often as you want, the object will do the rest +// but try to call this at least once in 100 msecs +// +// returns `true` if we got a packet (it won't be parsed to TMsg) +// +//========================================================================== +function TMasterHost.service (timeout: Integer=0): Boolean; +var + ct: Int64; + hres: Integer; +begin + result := false; + if not isAlive() then exit; + if not processPendingConnection() then exit; + + ct := GetTimerMS(); + if (ct < lastUpdateTime) or (ct-lastUpdateTime >= 1000*60) then + begin + lastUpdateTime := ct; + update(false); + end; + + while true do + begin + hres := enet_host_service(NetMHost, @event, timeout); + if (hres < 0) then + begin + //TODO: reconnect here + updateSent := false; // do not send 'remove' + disconnect(); + exit; + end; + if (hres = 0) then break; + if (event.kind = ENET_EVENT_TYPE_CONNECT) then + begin + NetHostConnected := true; + if NetUpdatePending then update(false); + g_Console_Add(_lc[I_NET_MSG]+_lc[I_NET_SLIST_CONN]); + end + else if (event.kind = ENET_EVENT_TYPE_DISCONNECT) then + begin + //TODO: reconnect here + g_Console_Add(_lc[I_NET_MSG]+_lc[I_NET_SLIST_LOST], True); + updateSent := false; // do not send 'remove' + disconnect(); + exit; + end + else if (event.kind = ENET_EVENT_TYPE_RECEIVE) then + begin + //enet_packet_destroy(event.packet); + //if (timeout <> 0) then break; + result := true; + exit; + end; + end; +end; + + +//========================================================================== +// +// TMasterHost.clearPacket +// +//========================================================================== +procedure TMasterHost.clearPacket (); +begin + if (event.packet <> nil) then + begin + enet_packet_destroy(event.packet); + event.packet := nil; + end; +end; + + +//************************************************************************** +// +// other functions +// +//************************************************************************** + +procedure g_Net_Slist_Set (IP: string; Port: Word); +begin + if (length(mlist) = 0) then + begin + SetLength(mlist, 1); + mlist[0].Create(ip+':'+IntToStr(Port)); + end + else + begin + mlist[0].setAddress(ip+':'+IntToStr(Port)); + end; + e_LogWritefln('Masterserver address set to %s:%u', [IP, Port], TMsgType.Notify); + { + if NetInitDone then + begin + enet_address_set_host(@NetSlistAddr, PChar(Addr(IP[1]))); + NetSlistAddr.Port := Port; + e_WriteLog('Masterserver address set to ' + IP + ':' + IntToStr(Port), TMsgType.Notify); + end; + } +end; + + +//************************************************************************** +// +// main pulse +// +//************************************************************************** +procedure g_Net_Slist_Pulse (); +begin +end; + + +//************************************************************************** +// +// gui and server list +// +//************************************************************************** + +//========================================================================== +// +// PingServer +// +//========================================================================== +procedure PingServer (var S: TNetServer; Sock: ENetSocket); var Buf: ENetBuffer; Ping: array [0..9] of Byte; @@ -182,7 +783,13 @@ begin enet_socket_send(Sock, Addr(S.PingAddr), @Buf, 1); end; -procedure PingBcast(Sock: ENetSocket); + +//========================================================================== +// +// PingBcast +// +//========================================================================== +procedure PingBcast (Sock: ENetSocket); var S: TNetServer; begin @@ -194,7 +801,13 @@ begin PingServer(S, Sock); end; -function g_Net_Slist_Fetch(var SL: TNetServerList): Boolean; + +//========================================================================== +// +// g_Net_Slist_Fetch +// +//========================================================================== +function g_Net_Slist_Fetch (var SL: TNetServerList): Boolean; var Cnt: Byte; P: pENetPacket; @@ -208,7 +821,7 @@ var FromSL: Boolean; MyVer, Str: string; - procedure ProcessLocal(); + procedure ProcessLocal (); begin I := Length(SL); SetLength(SL, I + 1); @@ -229,7 +842,8 @@ var Bots := InMsg.ReadWord(); end; end; - procedure CheckLocalServers(); + + procedure CheckLocalServers (); begin SetLength(SL, 0); @@ -265,17 +879,24 @@ var if Length(SL) = 0 then SL := nil; end; + begin Result := False; SL := nil; - if (NetMHost <> nil) or (NetMPeer <> nil) then + if (length(mlist) > 0) and (mlist[0].isAlive()) then begin CheckLocalServers(); Exit; end; - if not g_Net_Slist_Connect then + if (length(mlist) = 0) or (not mlist[0].connect()) then + begin + CheckLocalServers(); + Exit; + end; + + if not mlist[0].waitForConnection() then begin CheckLocalServers(); Exit; @@ -292,70 +913,77 @@ begin NetOut.Write(MyVer); P := enet_packet_create(NetOut.Data, NetOut.CurSize, Cardinal(ENET_PACKET_FLAG_RELIABLE)); - enet_peer_send(NetMPeer, NET_MCHAN_MAIN, P); + enet_peer_send(mlist[0].peer, NET_MCHAN_MAIN, P); enet_host_flush(NetMHost); - while enet_host_service(NetMHost, @NetMEvent, 5000) > 0 do + while mlist[0].isAlive() do begin - if NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE then + if not mlist[0].service(5000) then continue; + if not InMsg.Init(mlist[0].event.packet^.data, mlist[0].event.packet^.dataLength, True) then begin - if not InMsg.Init(NetMEvent.packet^.data, NetMEvent.packet^.dataLength, True) then continue; + mlist[0].clearPacket(); + continue; + end; - MID := InMsg.ReadByte(); + MID := InMsg.ReadByte(); - if MID <> NET_MMSG_GET then continue; + if (MID <> NET_MMSG_GET) then + begin + mlist[0].clearPacket(); + continue; + end; - Cnt := InMsg.ReadByte(); - g_Console_Add(_lc[I_NET_MSG] + Format(_lc[I_NET_SLIST_RETRIEVED], [Cnt]), True); + Cnt := InMsg.ReadByte(); + g_Console_Add(_lc[I_NET_MSG]+Format(_lc[I_NET_SLIST_RETRIEVED], [Cnt]), True); - if Cnt > 0 then - begin - SetLength(SL, Cnt); + if (Cnt > 0) then + begin + SetLength(SL, Cnt); - for I := 0 to Cnt - 1 do - begin - SL[I].Number := I; - SL[I].IP := InMsg.ReadString(); - SL[I].Port := InMsg.ReadWord(); - SL[I].Name := InMsg.ReadString(); - SL[I].Map := InMsg.ReadString(); - SL[I].GameMode := InMsg.ReadByte(); - SL[I].Players := InMsg.ReadByte(); - SL[I].MaxPlayers := InMsg.ReadByte(); - SL[I].Protocol := InMsg.ReadByte(); - SL[I].Password := InMsg.ReadByte() = 1; - enet_address_set_host(Addr(SL[I].PingAddr), PChar(Addr(SL[I].IP[1]))); - SL[I].Ping := -1; - SL[I].PingAddr.port := NET_PING_PORT; - end; + for I := 0 to Cnt-1 do + begin + SL[I].Number := I; + SL[I].IP := InMsg.ReadString(); + SL[I].Port := InMsg.ReadWord(); + SL[I].Name := InMsg.ReadString(); + SL[I].Map := InMsg.ReadString(); + SL[I].GameMode := InMsg.ReadByte(); + SL[I].Players := InMsg.ReadByte(); + SL[I].MaxPlayers := InMsg.ReadByte(); + SL[I].Protocol := InMsg.ReadByte(); + SL[I].Password := InMsg.ReadByte() = 1; + enet_address_set_host(Addr(SL[I].PingAddr), PChar(Addr(SL[I].IP[1]))); + SL[I].Ping := -1; + SL[I].PingAddr.port := NET_PING_PORT; end; + end; - if InMsg.ReadCount < InMsg.CurSize then + if InMsg.ReadCount < InMsg.CurSize then + begin + // new master, supports version reports + Str := InMsg.ReadString(); + if (Str <> MyVer) then begin - // new master, supports version reports - Str := InMsg.ReadString(); - if (Str <> MyVer) then - begin - { TODO } - g_Console_Add('!!! UpdVer = `' + Str + '`'); - end; - // even newer master, supports extra info - if InMsg.ReadCount < InMsg.CurSize then - begin - slMOTD := b_Text_Format(InMsg.ReadString()); - Str := b_Text_Format(InMsg.ReadString()); - // check if the message has updated and the user has to read it again - if slUrgent <> Str then slReadUrgent := False; - slUrgent := Str; - end; + { TODO } + g_Console_Add('!!! UpdVer = `' + Str + '`'); + end; + // even newer master, supports extra info + if (InMsg.ReadCount < InMsg.CurSize) then + begin + slMOTD := b_Text_Format(InMsg.ReadString()); + Str := b_Text_Format(InMsg.ReadString()); + // check if the message has updated and the user has to read it again + if slUrgent <> Str then slReadUrgent := False; + slUrgent := Str; end; - - Result := True; - break; end; + + mlist[0].clearPacket(); + Result := True; + break; end; - g_Net_Slist_Disconnect; + mlist[0].disconnect(false); NetOut.Clear(); if Length(SL) = 0 then @@ -368,8 +996,7 @@ begin if Sock = ENET_SOCKET_NULL then Exit; enet_socket_set_option(Sock, ENET_SOCKOPT_NONBLOCK, 1); - for I := Low(SL) to High(SL) do - PingServer(SL[I], Sock); + for I := Low(SL) to High(SL) do PingServer(SL[I], Sock); enet_socket_set_option(Sock, ENET_SOCKOPT_BROADCAST, 1); PingBcast(Sock); @@ -425,193 +1052,13 @@ begin enet_socket_destroy(Sock); end; -procedure g_Net_Slist_WriteInfo(); -var - Wad, Map: string; - Cli: Byte; -begin - Wad := g_ExtractWadNameNoPath(gMapInfo.Map); - Map := g_ExtractFileName(gMapInfo.Map); - - NetOut.Write(NetServerName); - - NetOut.Write(Wad + ':\' + Map); - NetOut.Write(gGameSettings.GameMode); - - Cli := NetClientCount; - NetOut.Write(Cli); - - NetOut.Write(NetMaxClients); - - NetOut.Write(Byte(NET_PROTOCOL_VER)); - NetOut.Write(Byte(NetPassword <> '')); -end; - - -procedure g_Net_Slist_Update (immediateSend: Boolean=true); -var - P: pENetPacket; -begin - if not ProcessPendingConnection() then - begin - NetUpdatePending := g_Net_Slist_IsConnectionInProgress(); - exit; - end; - - NetUpdatePending := false; - - NetOut.Clear(); - NetOut.Write(Byte(NET_MMSG_UPD)); - NetOut.Write(NetAddr.port); - - g_Net_Slist_WriteInfo(); - - P := enet_packet_create(NetOut.Data, NetOut.CurSize, Cardinal(ENET_PACKET_FLAG_RELIABLE)); - enet_peer_send(NetMPeer, NET_MCHAN_UPD, P); - - if (immediateSend) then enet_host_flush(NetMHost); - NetOut.Clear(); -end; - -procedure g_Net_Slist_Remove; -var - P: pENetPacket; -begin - if not ProcessPendingConnection() then exit; - NetOut.Clear(); - NetOut.Write(Byte(NET_MMSG_DEL)); - NetOut.Write(NetAddr.port); - - P := enet_packet_create(NetOut.Data, NetOut.CurSize, Cardinal(ENET_PACKET_FLAG_RELIABLE)); - enet_peer_send(NetMPeer, NET_MCHAN_MAIN, P); - - enet_host_flush(NetMHost); - NetOut.Clear(); -end; - -function g_Net_Slist_Connect (blocking: Boolean=True): Boolean; -var - delay: Integer; -begin - Result := False; - - if g_Net_Slist_IsConnectionActive then - begin - if not blocking then exit; - g_Net_Slist_Disconnect(false); - end; - - NetHostConnected := False; // just in case - NetHostConReqTime := 0; // just in case - NetUpdatePending := false; - - NetMHost := enet_host_create(nil, 1, NET_MCHANS, 0, 0); - if (NetMHost = nil) then - begin - g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_ERR_CLIENT], True); - Exit; - end; - - NetMPeer := enet_host_connect(NetMHost, @NetSlistAddr, NET_MCHANS, 0); - if (NetMPeer = nil) then - begin - g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_ERR_CLIENT], True); - enet_host_destroy(NetMHost); - NetMHost := nil; - Exit; - end; - - if (blocking) then delay := 3000 else delay := 0; - if (enet_host_service(NetMHost, @NetMEvent, delay) > 0) then - if NetMEvent.kind = ENET_EVENT_TYPE_CONNECT then - begin - Result := True; - NetHostConnected := True; - g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_CONN]); - Exit; - end - else - if NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE then - enet_packet_destroy(NetMEvent.packet); - - if (blocking) then - begin - g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_SLIST_ERROR], True); - - if NetMPeer <> nil then enet_peer_reset(NetMPeer); - if NetMHost <> nil then enet_host_destroy(NetMHost); - NetMPeer := nil; - NetMHost := nil; - NetHostConnected := False; - NetHostConReqTime := 0; - NetUpdatePending := false; - end - else - begin - NetHostConReqTime := GetTimerMS(); - g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_WCONN]); - end; -end; - -procedure g_Net_Slist_Disconnect (spamConsole: Boolean=true); -begin - if (NetMHost = nil) and (NetMPeer = nil) then Exit; - - if (NetMode = NET_SERVER) and (NetHostConnected) then g_Net_Slist_Remove; - - enet_peer_disconnect(NetMPeer, 0); - enet_host_flush(NetMHost); - - enet_peer_reset(NetMPeer); - enet_host_destroy(NetMHost); - - NetMPeer := nil; - NetMHost := nil; - NetHostConnected := False; - NetHostConReqTime := 0; - NetUpdatePending := false; - - if (spamConsole) then g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_DISC]); -end; - -procedure g_Net_Slist_Check; -begin - if not ProcessPendingConnection() then exit; - - if (NetUpdatePending) then g_Net_Slist_Update(false); - - while (enet_host_service(NetMHost, @NetMEvent, 0) > 0) do - begin - if NetMEvent.kind = ENET_EVENT_TYPE_DISCONNECT then - begin - g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_LOST], True); - if NetMPeer <> nil then enet_peer_reset(NetMPeer); - if NetMHost <> nil then enet_host_destroy(NetMHost); - NetMPeer := nil; - NetMHost := nil; - NetHostConnected := False; - NetHostConReqTime := 0; - NetUpdatePending := false; - Break; - end - else - if NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE then - enet_packet_destroy(NetMEvent.packet); - end; -end; - -procedure g_Net_Slist_Set(IP: string; Port: Word); -begin - if NetInitDone then - begin - enet_address_set_host(@NetSlistAddr, PChar(Addr(IP[1]))); - NetSlistAddr.Port := Port; - e_WriteLog('Masterserver address set to ' + IP + ':' + IntToStr(Port), TMsgType.Notify); - end; -end; - -function GetServerFromTable(Index: Integer; SL: TNetServerList; ST: TNetServerTable): TNetServer; +//========================================================================== +// +// GetServerFromTable +// +//========================================================================== +function GetServerFromTable (Index: Integer; SL: TNetServerList; ST: TNetServerTable): TNetServer; begin Result.Number := 0; Result.Protocol := 0; @@ -634,7 +1081,13 @@ begin Result := SL[ST[Index].Indices[ST[Index].Current]]; end; -procedure g_Serverlist_Draw(var SL: TNetServerList; var ST: TNetServerTable); + +//========================================================================== +// +// g_Serverlist_Draw +// +//========================================================================== +procedure g_Serverlist_Draw (var SL: TNetServerList; var ST: TNetServerTable); var Srv: TNetServer; sy, i, y, mw, mx, l, motdh: Integer; @@ -780,7 +1233,13 @@ begin motdh-20+3, ip, gStdFont, 205, 205, 205, 1); end; -procedure g_Serverlist_GenerateTable(SL: TNetServerList; var ST: TNetServerTable); + +//========================================================================== +// +// g_Serverlist_GenerateTable +// +//========================================================================== +procedure g_Serverlist_GenerateTable (SL: TNetServerList; var ST: TNetServerTable); var i, j: Integer; @@ -868,7 +1327,13 @@ begin SortRows(); end; -procedure g_Serverlist_Control(var SL: TNetServerList; var ST: TNetServerTable); + +//========================================================================== +// +// g_Serverlist_Control +// +//========================================================================== +procedure g_Serverlist_Control (var SL: TNetServerList; var ST: TNetServerTable); var qm: Boolean; Srv: TNetServer; @@ -1023,4 +1488,5 @@ begin slDirPressed := False; end; + end. diff --git a/src/game/g_netmsg.pas b/src/game/g_netmsg.pas index 1c44aca..6133b00 100644 --- a/src/game/g_netmsg.pas +++ b/src/game/g_netmsg.pas @@ -476,7 +476,11 @@ begin if gState in [STATE_INTERCUSTOM, STATE_FOLD] then MH_SEND_GameEvent(NET_EV_MAPEND, 0, 'N', C^.ID); - if NetUseMaster then g_Net_Slist_Update; + if NetUseMaster then + begin + //g_Net_Slist_Update; + g_Net_Slist_Pulse(); + end; end; -- 2.29.2