Files
@ r28278:1fc682037ca2
Branch filter:
Location: cpp/openttd-patchpack/source/src/network/core/tcp_content.cpp - annotation
r28278:1fc682037ca2
7.7 KiB
text/x-c
Codechange: Use Ticks for BaseConsist timetable fields
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 | r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r12768:980ae0491352 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r21383:942c32fb8b0e r21383:942c32fb8b0e r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r12565:85802a7506e0 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r27259:59b91be38623 r19557:e98fb2ed9b46 r27259:59b91be38623 r19557:e98fb2ed9b46 r27259:59b91be38623 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19577:722935d7c623 r27391:048886674223 r27238:b62a71d9f1bd r19557:e98fb2ed9b46 r19577:722935d7c623 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r27259:59b91be38623 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r19557:e98fb2ed9b46 r25454:212b1b5e83b5 r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r17138:5078c9240593 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r25655:1030dcb7eb52 r10793:5ba2151e71e9 r25655:1030dcb7eb52 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r16213:0b4dd45d6d32 r20565:90fc925b267e r10793:5ba2151e71e9 r20565:90fc925b267e r10793:5ba2151e71e9 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r20545:f88170cf9108 r10793:5ba2151e71e9 r20565:90fc925b267e r20565:90fc925b267e r23607:36c15679007d r16618:d89f0c3f42e7 r10793:5ba2151e71e9 r20565:90fc925b267e r10793:5ba2151e71e9 r20565:90fc925b267e r20565:90fc925b267e r10793:5ba2151e71e9 r10793:5ba2151e71e9 r17619:8e40da35981c r10793:5ba2151e71e9 r17619:8e40da35981c r17619:8e40da35981c r17619:8e40da35981c r10793:5ba2151e71e9 r17619:8e40da35981c r17619:8e40da35981c r25655:1030dcb7eb52 r17649:87d1b9101ec8 r10793:5ba2151e71e9 r10793:5ba2151e71e9 r27942:f7389062d120 r27942:f7389062d120 r27942:f7389062d120 r27942:f7389062d120 r27942:f7389062d120 r27942:f7389062d120 r27942:f7389062d120 r10793:5ba2151e71e9 r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19537:6e0664ef363a r19719:47ec09575586 r19719:47ec09575586 r19537:6e0664ef363a r19537:6e0664ef363a | /*
* This file is part of OpenTTD.
* OpenTTD is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, version 2.
* OpenTTD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
* See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with OpenTTD. If not, see <http://www.gnu.org/licenses/>.
*/
/**
* @file tcp_content.cpp Basic functions to receive and send Content packets.
*/
#include "../../stdafx.h"
#include "../../textfile_gui.h"
#include "../../newgrf_config.h"
#include "../../base_media_base.h"
#include "../../ai/ai.hpp"
#include "../../game/game.hpp"
#include "../../fios.h"
#include "tcp_content.h"
#include "../../safeguards.h"
/**
* Is the state either selected or autoselected?
* @return true iff that's the case
*/
bool ContentInfo::IsSelected() const
{
switch (this->state) {
case ContentInfo::SELECTED:
case ContentInfo::AUTOSELECTED:
case ContentInfo::ALREADY_HERE:
return true;
default:
return false;
}
}
/**
* Is the information from this content info valid?
* @return true iff it's valid
*/
bool ContentInfo::IsValid() const
{
return this->state < ContentInfo::INVALID && this->type >= CONTENT_TYPE_BEGIN && this->type < CONTENT_TYPE_END;
}
/**
* Search a textfile file next to this file in the content list.
* @param type The type of the textfile to search for.
* @return The filename for the textfile.
*/
std::optional<std::string> ContentInfo::GetTextfile(TextfileType type) const
{
if (this->state == INVALID) return std::nullopt;
const char *tmp;
switch (this->type) {
default: NOT_REACHED();
case CONTENT_TYPE_AI:
tmp = AI::GetScannerInfo()->FindMainScript(this, true);
break;
case CONTENT_TYPE_AI_LIBRARY:
tmp = AI::GetScannerLibrary()->FindMainScript(this, true);
break;
case CONTENT_TYPE_GAME:
tmp = Game::GetScannerInfo()->FindMainScript(this, true);
break;
case CONTENT_TYPE_GAME_LIBRARY:
tmp = Game::GetScannerLibrary()->FindMainScript(this, true);
break;
case CONTENT_TYPE_NEWGRF: {
const GRFConfig *gc = FindGRFConfig(BSWAP32(this->unique_id), FGCM_EXACT, &this->md5sum);
tmp = gc != nullptr ? gc->filename.c_str() : nullptr;
break;
}
case CONTENT_TYPE_BASE_GRAPHICS:
tmp = TryGetBaseSetFile(this, true, BaseGraphics::GetAvailableSets());
break;
case CONTENT_TYPE_BASE_SOUNDS:
tmp = TryGetBaseSetFile(this, true, BaseSounds::GetAvailableSets());
break;
case CONTENT_TYPE_BASE_MUSIC:
tmp = TryGetBaseSetFile(this, true, BaseMusic::GetAvailableSets());
break;
case CONTENT_TYPE_SCENARIO:
case CONTENT_TYPE_HEIGHTMAP:
tmp = FindScenario(this, true);
break;
}
if (tmp == nullptr) return std::nullopt;
return ::GetTextfile(type, GetContentInfoSubDir(this->type), tmp);
}
/**
* Handle the given packet, i.e. pass it to the right
* parser receive command.
* @param p the packet to handle
* @return true if we should immediately handle further packets, false otherwise
*/
bool NetworkContentSocketHandler::HandlePacket(Packet *p)
{
PacketContentType type = (PacketContentType)p->Recv_uint8();
switch (this->HasClientQuit() ? PACKET_CONTENT_END : type) {
case PACKET_CONTENT_CLIENT_INFO_LIST: return this->Receive_CLIENT_INFO_LIST(p);
case PACKET_CONTENT_CLIENT_INFO_ID: return this->Receive_CLIENT_INFO_ID(p);
case PACKET_CONTENT_CLIENT_INFO_EXTID: return this->Receive_CLIENT_INFO_EXTID(p);
case PACKET_CONTENT_CLIENT_INFO_EXTID_MD5: return this->Receive_CLIENT_INFO_EXTID_MD5(p);
case PACKET_CONTENT_SERVER_INFO: return this->Receive_SERVER_INFO(p);
case PACKET_CONTENT_CLIENT_CONTENT: return this->Receive_CLIENT_CONTENT(p);
case PACKET_CONTENT_SERVER_CONTENT: return this->Receive_SERVER_CONTENT(p);
default:
if (this->HasClientQuit()) {
Debug(net, 0, "[tcp/content] Received invalid packet type {}", type);
} else {
Debug(net, 0, "[tcp/content] Received illegal packet");
}
return false;
}
}
/**
* Receive a packet at TCP level
* @return Whether at least one packet was received.
*/
bool NetworkContentSocketHandler::ReceivePackets()
{
/*
* We read only a few of the packets. This as receiving packets can be expensive
* due to the re-resolving of the parent/child relations and checking the toggle
* state of all bits. We cannot do this all in one go, as we want to show the
* user what we already received. Otherwise, it can take very long before any
* progress is shown to the end user that something has been received.
* It is also the case that we request extra content from the content server in
* case there is an unknown (in the content list) piece of content. These will
* come in after the main lists have been requested. As a result, we won't be
* getting everything reliably in one batch. Thus, we need to make subsequent
* updates in that case as well.
*
* As a result, we simple handle an arbitrary number of packets in one cycle,
* and let the rest be handled in subsequent cycles. These are ran, almost,
* immediately after this cycle so in speed it does not matter much, except
* that the user inferface will appear better responding.
*
* What arbitrary number to choose is the ultimate question though.
*/
Packet *p;
static const int MAX_PACKETS_TO_RECEIVE = 42;
int i = MAX_PACKETS_TO_RECEIVE;
while (--i != 0 && (p = this->ReceivePacket()) != nullptr) {
bool cont = this->HandlePacket(p);
delete p;
if (!cont) return true;
}
return i != MAX_PACKETS_TO_RECEIVE - 1;
}
/**
* Helper for logging receiving invalid packets.
* @param type The received packet type.
* @return Always false, as it's an error.
*/
bool NetworkContentSocketHandler::ReceiveInvalidPacket(PacketContentType type)
{
Debug(net, 0, "[tcp/content] Received illegal packet type {}", type);
return false;
}
bool NetworkContentSocketHandler::Receive_CLIENT_INFO_LIST(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_CLIENT_INFO_LIST); }
bool NetworkContentSocketHandler::Receive_CLIENT_INFO_ID(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_CLIENT_INFO_ID); }
bool NetworkContentSocketHandler::Receive_CLIENT_INFO_EXTID(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_CLIENT_INFO_EXTID); }
bool NetworkContentSocketHandler::Receive_CLIENT_INFO_EXTID_MD5(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_CLIENT_INFO_EXTID_MD5); }
bool NetworkContentSocketHandler::Receive_SERVER_INFO(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_SERVER_INFO); }
bool NetworkContentSocketHandler::Receive_CLIENT_CONTENT(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_CLIENT_CONTENT); }
bool NetworkContentSocketHandler::Receive_SERVER_CONTENT(Packet *) { return this->ReceiveInvalidPacket(PACKET_CONTENT_SERVER_CONTENT); }
/**
* Helper to get the subdirectory a #ContentInfo is located in.
* @param type The type of content.
* @return The subdirectory the content is located in.
*/
Subdirectory GetContentInfoSubDir(ContentType type)
{
switch (type) {
default: return NO_DIRECTORY;
case CONTENT_TYPE_AI: return AI_DIR;
case CONTENT_TYPE_AI_LIBRARY: return AI_LIBRARY_DIR;
case CONTENT_TYPE_GAME: return GAME_DIR;
case CONTENT_TYPE_GAME_LIBRARY: return GAME_LIBRARY_DIR;
case CONTENT_TYPE_NEWGRF: return NEWGRF_DIR;
case CONTENT_TYPE_BASE_GRAPHICS:
case CONTENT_TYPE_BASE_SOUNDS:
case CONTENT_TYPE_BASE_MUSIC:
return BASESET_DIR;
case CONTENT_TYPE_SCENARIO: return SCENARIO_DIR;
case CONTENT_TYPE_HEIGHTMAP: return HEIGHTMAP_DIR;
}
}
|