cpp/openttd-patchpack/source Changeset - r25271:7c46b1dac9ec

Changeset - r25271:7c46b1dac9ec

Parent rev.

Child rev.

[Not reviewed]

master

0 2 0

Rubidium - 3 years ago 2021-04-18 12:56:25
rubidium@openttd.org

Change: use 32 KiB packets to transfer the savegame

2 files changed with 17 insertions and 3 deletions:

src/network/core/config.h

src/network/network_server.cpp

0 comments (0 inline, 0 general)

src/network/core/config.h

➞

Show inline comments

@@ @@ -31,7 +31,21 @@ static const uint16 NETWORK_ADMIN_PORT @@
 static const uint16 NETWORK_DEFAULT_DEBUGLOG_PORT = 3982;         ///< The default port debug-log is sent to (TCP)
 static const uint16 UDP_MTU                       = 1460;         ///< Number of bytes we can pack in a single UDP packet
 static const uint16 TCP_MTU                       = 1460;         ///< Number of bytes we can pack in a single TCP packet
 /*
  * Technically a TCP packet could become 64kiB, however the high bit is kept so it becomes possible in the future
  * to go to (significantly) larger packets if needed. This would entail a strategy such as employed for UTF-8.
+ *
  * Packets up to 32 KiB have the high bit not set:
  * 00000000 00000000 0bbbbbbb aaaaaaaa -> aaaaaaaa 0bbbbbbb
  * Send_uint16(GB(size, 0, 15)
+ *
  * Packets up to 1 GiB, first uint16 has high bit set so it knows to read a
  * next uint16 for the remaining bits of the size.
  * 00dddddd cccccccc bbbbbbbb aaaaaaaa -> cccccccc 10dddddd aaaaaaaa bbbbbbbb
  * Send_uint16(GB(size, 16, 14) | 0b10 << 14)
  * Send_uint16(GB(size,  0, 16))
  */
 static const uint16 TCP_MTU                       = 32767;        ///< Number of bytes we can pack in a single TCP packet
 static const uint16 COMPAT_MTU                    = 1460;         ///< Number of bytes we can pack in a single packet for backward compatibility
 static const byte NETWORK_GAME_ADMIN_VERSION      =    1;         ///< What version of the admin network do we use?

src/network/network_server.cpp

➞

Show inline comments

@@ @@ -158,7 +158,7 @@ struct PacketWriter : SaveFilter { @@
 		/* We want to abort the saving when the socket is closed. */
 		if (this->cs == nullptr) SlError(STR_NETWORK_ERROR_LOSTCONNECTION);
 		if (this->current == nullptr) this->current = new Packet(PACKET_SERVER_MAP_DATA);
+		if (this->current == nullptr) this->current = new Packet(PACKET_SERVER_MAP_DATA, TCP_MTU);
 		std::lock_guard<std::mutex> lock(this->mutex);
@@ @@ -169,7 +169,7 @@ struct PacketWriter : SaveFilter { @@
 			if (!this->current->CanWriteToPacket(1)) {
 				this->AppendQueue();
 				if (buf != bufe) this->current = new Packet(PACKET_SERVER_MAP_DATA);
+				if (buf != bufe) this->current = new Packet(PACKET_SERVER_MAP_DATA, TCP_MTU);
+			}
+		}

0 comments (0 inline, 0 general)