FMassBattleSnapshotTcpTransport

把全部字段复位到默认值并释放缓冲。

Resets all fields to defaults and releases buffers.

传输是否完成:占用中且位图置位数等于 ChunkCount。

Whether the transfer is complete: active and set-bit count equals ChunkCount.

在指定端口启动 TCP 监听(权威端调用)。非阻塞、可复用、监听队列 8、收发缓冲各 1 MiB。Port=0 时 OS 分配空闲端口并读回实际端口(GetServerPort 返回真实值供客户端连接)。已在运行时返回 false。由 UMassBattleNetworkSubsystem::InitializeSnapshotTcpTransport 调用(游戏端口 +100~+109 范围尝试,失败回退 Port=0)。

Starts the TCP listener on the given port (call on the authority). Non-blocking, reusable, backlog 8, 1 MiB receive/send buffers. With Port=0 the OS assigns a free port which is read back (GetServerPort returns the real value for clients). Returns false when already running. Called by UMassBattleNetworkSubsystem::InitializeSnapshotTcpTransport (tries game port +100~+109, falls back to Port=0).

注册玩家槽位,让服务器知道该期待该连接——仅将槽位加入 HandleClientAuth 白名单,不排队快照。由 AMassBattleNetworkGameModeBase::PostLogin 的 TCP 预连接握手调用:使客户端在首个大载荷 lockstep 命令(自动分流)或 resync 真正需要 TCP socket 之前就先建好连接。

Registers a player slot so the server knows to expect it — whitelists the slot for HandleClientAuth WITHOUT queueing a snapshot. Called by the PostLogin pre-connect handshake in AMassBattleNetworkGameModeBase so a client establishes its TCP socket before the first large-payload lockstep command (auto-flood) or resync actually needs it.

网络模拟设置(调试):进程级全局——本进程内所有传输实例(PIE 同时承载服务器 + 客户端传输)在发送时读取,一次调用覆盖全部出站 TCP 数据帧。包含 Latency/Jitter(到期队列,Tick 内按每 socket FIFO 冲刷)、DropPercent(帧级概率丢弃——压力测试缺块 → desync → resync 恢复链)、BandwidthLimitKBs(令牌桶限速)。丢失事件在冲刷时掷出;语义按 EMassBattleNetLossMode:RetransmitLate = 丢帧等待 RetransmitDelayMs 后重发,对其 socket 造成队头阻塞(真实的 Reliable/TCP——迟到而非丢失);PermanentDiscard = 永不到达(desync 恢复压力测试)。控制帧(认证/心跳/认证拒绝)永远直发——握手时序保持真实。TCP 刻意不提供重复/乱序旋钮:TCP 设计上就去重且保序,这类效果请用 UE-UDP 路径旋钮。镜像 cvar(仅 TCP 路径):MassBattle.NetEmulation.*;FuncLib 的 BP 封装(SetNetworkEmulation)同时设置 UE 的 net.PktLag 系列,两条传输一起受影响。

Network-emulation settings (debug): process-global — every transport instance in this process (PIE hosts server + client transports) reads them at send time, so one call covers all outbound TCP data frames. Applies Latency/Jitter (due-time queue, per-socket FIFO flush in Tick), DropPercent (frame-level probabilistic drop — stresses missing-block → desync → resync recovery), and BandwidthLimitKBs (token-bucket throttle). Loss events roll at flush time; semantics per EMassBattleNetLossMode: RetransmitLate = a lost frame waits RetransmitDelayMs then retries, head-of-line blocking its socket (realistic Reliable/TCP — late, not lost); PermanentDiscard = never arrives (desync-recovery stress). Control frames (auth / heartbeat / auth-reject) always bypass — handshake timing stays real. TCP deliberately has NO duplicate/reorder knobs: TCP dedupes and preserves order by design; use the UE-UDP path knobs for those effects. Mirror cvars (TCP path only): MassBattle.NetEmulation.*; the FuncLib BP wrapper (SetNetworkEmulation) also sets UE's net.PktLag family so both transports are impaired together.

作为客户端连接指定 host:port(远程客户端调用)。残留死 socket(SCS_NotConnected/SCS_ConnectionError)先销毁再建新连接;非阻塞 connect,EINPROGRESS 为预期。保存端点供 Tick 节流自动重连,设置 5s 连接/认证截止。已在连接中返回 false。

Connects as a client to the given host:port (call on remote clients). Stale sockets (SCS_NotConnected/SCS_ConnectionError) are destroyed before establishing a fresh connection; non-blocking connect with EINPROGRESS expected. The endpoint is saved for Tick's throttled auto-reconnect and a 5s connect/auth deadline is set. Returns false when already connected.

关闭并释放全部 socket:客户端、已认证玩家、待认证(销毁而非仅丢弃——堵住 FD 泄漏)、监听;清空全部状态与重组槽。析构函数调用。

Shuts down and releases all sockets: client, authenticated players, pending-auth (destroyed, not just dropped — plugs FD leaks), and the listener; clears all state and reassembly slots. Called by the destructor.

释放玩家槽位持有的全部 transport 资源(由 GameMode::FreePlayerSlot 调用):移除预期认证注册、槽位进入 FreedPlayerSlots、移除挂起快照、清理该槽位 socket。迟到的 SendSnapshot 对已释放槽位变为无操作而不是重新注册。

Releases all transport resources owned by a player slot (called by GameMode::FreePlayerSlot): removes the expected-auth registration, adds the slot to FreedPlayerSlots, removes pending snapshots, and cleans up the slot's socket. Late SendSnapshot calls no-op for freed slots instead of re-registering them.

重新注册被重新分配给新玩家的槽位(由 GameMode::AllocatePlayerSlot 调用):清除 FreedPlayerSlots 守卫,使 SendSnapshot 重新加入预期认证注册、认证得以再次通过。

Re-registers a slot re-allocated to a new player (called by GameMode::AllocatePlayerSlot): clears the FreedPlayerSlots guard so SendSnapshot re-adds the slot to expected auth and auth can succeed again.

服务 tick(由 UMassBattleNetworkSubsystem::TickSnapshotTcpTransport 调用):服务器侧——accept 新连接(挂起认证上限 16,超出先 accept 再立即关闭,审计 H5)、轮询已认证与待认证 socket(drain 数据、recv 探测 FIN/RST、认证超时 10s、心跳广播 15s、半开检测 60s)、驱逐过期挂起快照(30s);客户端侧——认证拒绝之外的节流自动重连(1s)、连接状态机(连接错误/超截止/已连接:认证发送、drain 全部数据、探测、心跳、对端超时)、驱逐过期重组槽(快照 30s / lockstep 30s / 上行 30s)。网络模拟开启时,本 tick 还按每 socket FIFO 冲刷到期延迟帧并执行令牌桶限速。

Service tick (called by UMassBattleNetworkSubsystem::TickSnapshotTcpTransport): server side — accepts connections (pending-auth cap 16; excess accepted then immediately closed, audit H5), polls authenticated and pending-auth sockets (drain, recv FIN/RST probe, 10s auth timeout, 15s heartbeat broadcast, 60s half-open detection), evicts stale pending snapshots (30s); client side — throttled auto-reconnect except after auth rejection (1s), the connection state machine (connection error / deadline / connected: auth send, full drain, probe, heartbeat, peer timeout), and eviction of stale reassembly slots (30s each for snapshot / lockstep / uplink). When network emulation is active, this tick also flushes due delayed frames per socket (FIFO) and applies the token-bucket bandwidth limit.

向指定玩家发送或排队 snapshot 负载,内部自动分块。槽位已释放则 no-op(返回新 SnapshotId,不重新注册);socket 未认证时挂起队列等待认证后 FlushPendingSnapshotForPlayer 补发。发送失败:清理死 socket + 挂起快照并返回成功——RPC 照发,客户端重连认证替换 socket 后补发,自愈闭环。挂起用 latest-wins(乱序异步派发回调不得覆盖更新的排队快照)。

Sends or queues a snapshot payload to a specific player, chunking internally. A freed slot no-ops (returns the new SnapshotId without re-registering); an unauthenticated socket queues the snapshot until auth completes and FlushPendingSnapshotForPlayer delivers it. On send failure: the dead socket is cleaned up, the snapshot hung, and success is still returned — the RPC goes out anyway, the client reconnects, auth replaces the socket, and the snapshot is delivered: a self-healing loop. Pending uses latest-wins (out-of-order async dispatch callbacks never overwrite a newer queued snapshot).

向所有已认证客户端广播大 lockstep 负载块(下行自动分流)。每次广播都暂存一份副本(FIFO,上限 16 条,最旧淘汰)——后认证的客户端从未见过该块,而引用命令(引擎复制)仍会到达:没有补发时加入端在 ExecuteTick 冻结 10 秒等一个从未发送的块,随后落入 resync 循环(beginplay 的 FF.RebuildFlowField 早于客户端 TCP 认证数秒是典型案例);每个新认证槽位都会冲刷收到的暂存块。BlockId 为权威 id;ExecuteTick 为匹配引用命令的触发 tick。无已认证客户端返回 false(暂存副本在认证时补给加入端);发送失败的 socket 清理(下次广播不再命中)。

Broadcasts a large lockstep-payload block to ALL authenticated clients (downlink auto-flood). Every broadcast parks a copy (FIFO, capped at 16, oldest evicted) — a client authenticating later never saw it, while the reference command (engine replication) still reaches it: without the backfill the joiner froze 10s at ExecuteTick waiting for a block that was never sent, then fell into the resync loop (beginplay-time FF.RebuildFlowField firing seconds before the client's TCP auth is the canonical case); every newly authenticated slot gets the parked blocks flushed to it. BlockId is the authoritative id; ExecuteTick is when the matching reference command fires. Returns false with no authenticated clients (the parked copy serves the joiner at auth); failed sockets are cleaned up (so the next broadcast skips them).

客户端向服务器上传大 lockstep 负载块(上行自动分流)。BlockId 为本地分配(AllocLocalBlockId),服务器汇聚时重映射为权威 ServerBlockId。

Uploads a large lockstep-payload block from client to server (uplink auto-flood). BlockId is locally allocated (AllocLocalBlockId); the server remaps it to the authoritative ServerBlockId on convergence.

zlib 压缩(FArchiveSaveCompressedProxy, NAME_Zlib);空输入返回空数组;压缩错误返回空数组。

zlib compression (FArchiveSaveCompressedProxy, NAME_Zlib); empty input returns an empty array; compression errors return an empty array.

zlib 解压。分配前限制声明未压缩大小(≤ 512MB)——恶意声明不得触发 OOM;空/非法输入返回空数组。

zlib decompression. Caps the declared uncompressed size (≤ 512MB) before allocating — hostile declarations must not OOM; empty/invalid input returns an empty array.

经 FMemoryWriter + SerializeItem 把 payload 序列化为字节(反射驱动)。

Serializes the payload to bytes via FMemoryWriter + SerializeItem (reflection-driven).

经 FMemoryReader + SerializeItem 反序列化;空输入或读取错误返回 false。

Deserializes via FMemoryReader + SerializeItem; empty input or read errors return false.

状态访问器:IsServerActive = 监听 socket 存在;IsClientConnected 仅当 socket 报告 SCS_Connected(UE 的 GetConnectionState 把连接中映射为 SCS_NotConnected、把对端优雅关闭映射为 SCS_Connected,无法检测远端关闭——由 Tick 的 recv 探测承担;为 false 时 RPC 处理器经 ConnectClient 重建,其会拆除残留死 socket);GetServerPort 返回实际端口;GetNextSnapshotId 递增分配传输 ID。

Status accessors: IsServerActive = listen socket exists; IsClientConnected only when the socket reports SCS_Connected (UE's GetConnectionState maps a pending connect to SCS_NotConnected and a gracefully-closed peer to SCS_Connected — it cannot detect remote closure; that duty belongs to Tick's recv probe; a false here makes RPC handlers re-establish via ConnectClient, which tears down stale sockets); GetServerPort returns the actual port; GetNextSnapshotId allocates transfer IDs incrementally.