index 98f191cb232a2c78e7e056409789377136856325..2ecad14c74378d27d7f666bf9c7dc01c39d792d8 100644 (file)
--- a/src/game/g_netmaster.pas
+++ b/src/game/g_netmaster.pas
TNetServerTable = array of TNetServerRow;
var
TNetServerTable = array of TNetServerRow;
var
- NetMHost: pENetHost = nil;
- NetMPeer: pENetPeer = nil;
-
slCurrent: TNetServerList = nil;
slTable: TNetServerTable = nil;
slWaitStr: string = '';
slCurrent: TNetServerList = nil;
slTable: TNetServerTable = nil;
slWaitStr: 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();
+procedure g_Net_Slist_Update (immediateSend: Boolean=true);
procedure g_Net_Slist_Remove();
procedure g_Net_Slist_Remove();
-function g_Net_Slist_Connect(): Boolean;
+function g_Net_Slist_Connect(blocking: Boolean=True): Boolean;
procedure g_Net_Slist_Check();
procedure g_Net_Slist_Check();
-procedure g_Net_Slist_Disconnect();
+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;
+
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_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,
g_map, g_game, g_sound, g_gui, g_menu, g_options, g_language, g_basic,
implementation
uses
SysUtils, e_msg, 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;
+ wadreader, g_system;
var
var
- NetMEvent: ENetEvent;
- slSelection: Byte = 0;
- slFetched: Boolean = False;
- slDirPressed: Boolean = False;
- slReadUrgent: Boolean = False;
+ NetMHost: pENetHost = nil;
+ NetMPeer: pENetPeer = nil;
+ NetMEvent: ENetEvent;
+ slSelection: Byte = 0;
+ slFetched: Boolean = False;
+ slDirPressed: Boolean = False;
+ slReadUrgent: Boolean = False;
+ // 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;
+
+
+function GetTimerMS (): Int64;
+begin
+ Result := sys_GetTicks() {div 1000};
+end;
-function GetTimerMS(): Int64;
+
+// returns `false` if totally disconnected
+function g_Net_Slist_IsConnectionActive (): Boolean;
+begin
+ result := (NetMHost <> nil) and (NetMPeer <> nil);
+end;
+
+
+function g_Net_Slist_IsConnectionInProgress (): Boolean;
begin
begin
- Result := GetTimer() {div 1000};
+ if (NetMHost = nil) or (NetMPeer = nil) then begin result := false; exit; end;
+ result := (not NetHostConnected);
end;
end;
+
+// should be called only if host/peer is here
+// returns `false` if not connected/dead
+function ProcessPendingConnection (): Boolean;
+var
+ ct: Int64;
+begin
+ result := false;
+ if (NetMHost = nil) or (NetMPeer = nil) 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
+ begin
+ if (NetMEvent.kind = ENET_EVENT_TYPE_CONNECT) then
+ begin
+ NetHostConnected := true;
+ if NetUpdatePending then g_Net_Slist_Update(false);
+ g_Console_Add(_lc[I_NET_MSG]+_lc[I_NET_SLIST_CONN]);
+ result := true;
+ exit;
+ end;
+ if (NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE) then enet_packet_destroy(NetMEvent.packet);
+ end;
+ // check for connection timeout
+ if (not NetHostConnected) then
+ begin
+ ct := GetTimerMS();
+ if (ct < NetHostConReqTime) or (ct-NetHostConReqTime >= 3000) then
+ 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);
+ end;
+ exit;
+ end;
+ end;
+ result := true;
+end;
+
+
procedure PingServer(var S: TNetServer; Sock: ENetSocket);
var
Buf: ENetBuffer;
procedure PingServer(var S: TNetServer; Sock: ENetSocket);
var
Buf: ENetBuffer;
NetOut.Write(Byte(NetPassword <> ''));
end;
NetOut.Write(Byte(NetPassword <> ''));
end;
-procedure g_Net_Slist_Update;
-var
+procedure g_Net_Slist_Update (immediateSend: Boolean=true);
+var
P: pENetPacket;
P: pENetPacket;
-
begin
begin
- if (NetMHost = nil) or (NetMPeer = nil) then Exit;
+ if not ProcessPendingConnection() then
+ begin
+ NetUpdatePending := g_Net_Slist_IsConnectionInProgress();
+ exit;
+ end;
+
+ NetUpdatePending := false;
NetOut.Clear();
NetOut.Write(Byte(NET_MMSG_UPD));
NetOut.Clear();
NetOut.Write(Byte(NET_MMSG_UPD));
P := enet_packet_create(NetOut.Data, NetOut.CurSize, Cardinal(ENET_PACKET_FLAG_RELIABLE));
enet_peer_send(NetMPeer, NET_MCHAN_UPD, P);
P := enet_packet_create(NetOut.Data, NetOut.CurSize, Cardinal(ENET_PACKET_FLAG_RELIABLE));
enet_peer_send(NetMPeer, NET_MCHAN_UPD, P);
- enet_host_flush(NetMHost);
+ if (immediateSend) then enet_host_flush(NetMHost);
NetOut.Clear();
end;
NetOut.Clear();
end;
var
P: pENetPacket;
begin
var
P: pENetPacket;
begin
- if (NetMHost = nil) or (NetMPeer = nil) then Exit;
+ if not ProcessPendingConnection() then exit;
+
NetOut.Clear();
NetOut.Write(Byte(NET_MMSG_DEL));
NetOut.Write(NetAddr.port);
NetOut.Clear();
NetOut.Write(Byte(NET_MMSG_DEL));
NetOut.Write(NetAddr.port);
NetOut.Clear();
end;
NetOut.Clear();
end;
-function g_Net_Slist_Connect: Boolean;
+function g_Net_Slist_Connect (blocking: Boolean=True): Boolean;
+var
+ delay: Integer;
begin
Result := False;
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
NetMHost := enet_host_create(nil, 1, NET_MCHANS, 0, 0);
if (NetMHost = nil) then
begin
Exit;
end;
Exit;
end;
- if (enet_host_service(NetMHost, @NetMEvent, 3000) > 0) then
+ 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;
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
g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_CONN]);
Exit;
end
if NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE then
enet_packet_destroy(NetMEvent.packet);
if NetMEvent.kind = ENET_EVENT_TYPE_RECEIVE then
enet_packet_destroy(NetMEvent.packet);
- g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_SLIST_ERROR], True);
+ if (blocking) then
+ begin
+ g_Console_Add(_lc[I_NET_MSG_ERROR] + _lc[I_NET_SLIST_ERROR], True);
- NetMHost := nil;
- NetMPeer := nil;
+ 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;
end;
-procedure g_Net_Slist_Disconnect;
+procedure g_Net_Slist_Disconnect (spamConsole: Boolean=true);
begin
if (NetMHost = nil) and (NetMPeer = nil) then Exit;
begin
if (NetMHost = nil) and (NetMPeer = nil) then Exit;
- if NetMode = NET_SERVER then g_Net_Slist_Remove;
+ if (NetMode = NET_SERVER) and (NetHostConnected) then g_Net_Slist_Remove;
enet_peer_disconnect(NetMPeer, 0);
enet_host_flush(NetMHost);
enet_peer_disconnect(NetMPeer, 0);
enet_host_flush(NetMHost);
NetMPeer := nil;
NetMHost := nil;
NetMPeer := nil;
NetMHost := nil;
+ NetHostConnected := False;
+ NetHostConReqTime := 0;
+ NetUpdatePending := false;
- g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_DISC]);
+ if (spamConsole) then g_Console_Add(_lc[I_NET_MSG] + _lc[I_NET_SLIST_DISC]);
end;
procedure g_Net_Slist_Check;
begin
end;
procedure g_Net_Slist_Check;
begin
- if (NetMHost = nil) or (NetMPeer = nil) then Exit;
+ if not ProcessPendingConnection() then exit;
+
+ if (NetUpdatePending) then g_Net_Slist_Update(false);
while (enet_host_service(NetMHost, @NetMEvent, 0) > 0) do
begin
while (enet_host_service(NetMHost, @NetMEvent, 0) > 0) do
begin
if NetMHost <> nil then enet_host_destroy(NetMHost);
NetMPeer := nil;
NetMHost := nil;
if NetMHost <> nil then enet_host_destroy(NetMHost);
NetMPeer := nil;
NetMHost := nil;
+ NetHostConnected := False;
+ NetHostConReqTime := 0;
+ NetUpdatePending := false;
Break;
end
else
Break;
end
else
if gConsoleShow or gChatShow then
Exit;
if gConsoleShow or gChatShow then
Exit;
- qm := g_ProcessMessages(); // this updates kbd
+ qm := sys_HandleInput(); // this updates kbd
if qm or e_KeyPressed(IK_ESCAPE) or e_KeyPressed(VK_ESCAPE) or
e_KeyPressed(JOY0_JUMP) or e_KeyPressed(JOY1_JUMP) or
if qm or e_KeyPressed(IK_ESCAPE) or e_KeyPressed(VK_ESCAPE) or
e_KeyPressed(JOY0_JUMP) or e_KeyPressed(JOY1_JUMP) or
Exit;
end;
Exit;
end;
- // if there's a message on the screen,
+ // if there's a message on the screen,
if not slReadUrgent and (slUrgent <> '') then
begin
if e_KeyPressed(IK_RETURN) or e_KeyPressed(IK_KPRETURN) or e_KeyPressed(VK_FIRE) or e_KeyPressed(VK_OPEN) or
if not slReadUrgent and (slUrgent <> '') then
begin
if e_KeyPressed(IK_RETURN) or e_KeyPressed(IK_KPRETURN) or e_KeyPressed(VK_FIRE) or e_KeyPressed(VK_OPEN) or
slWaitStr := _lc[I_NET_SLIST_WAIT];
g_Game_Draw;
slWaitStr := _lc[I_NET_SLIST_WAIT];
g_Game_Draw;
- g_window.ReDrawWindow;
+ sys_Repaint;
if g_Net_Slist_Fetch(SL) then
begin
if g_Net_Slist_Fetch(SL) then
begin