aboutsummaryrefslogtreecommitdiff
path: root/Minecraft.World/Connection.cpp
diff options
context:
space:
mode:
authorModMaker101 <119018978+ModMaker101@users.noreply.github.com>2026-03-07 21:56:03 -0500
committerGitHub <noreply@github.com>2026-03-08 09:56:03 +0700
commita9be52c41a02d207233199e98898fe7483d7e817 (patch)
tree71dfaec3a86b05e9ca409b97d8eb9d7f993bfdd0 /Minecraft.World/Connection.cpp
parent1be5faaea781402e7de06b263eeca4c688b7712c (diff)
Project modernization (#630)
* Fixed boats falling and a TP glitch #266 * Replaced every C-style cast with C++ ones * Replaced every C-style cast with C++ ones * Fixed boats falling and a TP glitch #266 * Updated NULL to nullptr and fixing some type issues * Modernized and fixed a few bugs - Replaced most instances of `NULL` with `nullptr`. - Replaced most `shared_ptr(new ...)` with `make_shared`. - Removed the `nullptr` macro as it was interfering with the actual nullptr keyword in some instances. * Fixing more conflicts * Replace int loops with size_t and start work on overrides
Diffstat (limited to 'Minecraft.World/Connection.cpp')
-rw-r--r--Minecraft.World/Connection.cpp62
1 files changed, 31 insertions, 31 deletions
diff --git a/Minecraft.World/Connection.cpp b/Minecraft.World/Connection.cpp
index 09f72be0..4015d8f6 100644
--- a/Minecraft.World/Connection.cpp
+++ b/Minecraft.World/Connection.cpp
@@ -61,17 +61,17 @@ Connection::~Connection()
// These should all have been destroyed in close() but no harm in checking again
delete byteArrayDos;
- byteArrayDos = NULL;
+ byteArrayDos = nullptr;
delete baos;
- baos = NULL;
+ baos = nullptr;
if( bufferedDos )
{
bufferedDos->deleteChildStream();
delete bufferedDos;
- bufferedDos = NULL;
+ bufferedDos = nullptr;
}
delete dis;
- dis = NULL;
+ dis = nullptr;
}
Connection::Connection(Socket *socket, const wstring& id, PacketListener *packetListener) // throws IOException
@@ -111,7 +111,7 @@ Connection::Connection(Socket *socket, const wstring& id, PacketListener *packet
sprintf(readThreadName,"%s read\n",szId);
sprintf(writeThreadName,"%s write\n",szId);
- readThread = new C4JThread(runRead, (void*)this, readThreadName, READ_STACK_SIZE);
+ readThread = new C4JThread(runRead, static_cast<void *>(this), readThreadName, READ_STACK_SIZE);
writeThread = new C4JThread(runWrite, this, writeThreadName, WRITE_STACK_SIZE);
readThread->SetProcessor(CPU_CORE_CONNECTIONS);
writeThread->SetProcessor(CPU_CORE_CONNECTIONS );
@@ -185,7 +185,7 @@ bool Connection::writeTick()
bool didSomething = false;
// 4J Stu - If the connection is closed and the output stream has been deleted
- if(bufferedDos==NULL || byteArrayDos==NULL)
+ if(bufferedDos==nullptr || byteArrayDos==nullptr)
return didSomething;
// try {
@@ -318,14 +318,14 @@ bool Connection::readTick()
bool didSomething = false;
// 4J Stu - If the connection has closed and the input stream has been deleted
- if(dis==NULL)
+ if(dis==nullptr)
return didSomething;
//try {
shared_ptr<Packet> packet = Packet::readPacket(dis, packetListener->isServerPacketListener());
- if (packet != NULL)
+ if (packet != nullptr)
{
readSizes[packet->getId()] += packet->getEstimatedSize() + 1;
EnterCriticalSection(&incoming_cs);
@@ -341,7 +341,7 @@ bool Connection::readTick()
// printf("Con:0x%x readTick close EOS\n",this);
// 4J Stu - Remove this line
- // Fix for #10410 - UI: If the player is removed from a splitscreened host’s game, the next game that player joins will produce a message stating that the host has left.
+ // Fix for #10410 - UI: If the player is removed from a splitscreened host�s game, the next game that player joins will produce a message stating that the host has left.
//close(DisconnectPacket::eDisconnect_EndOfStream);
}
@@ -377,8 +377,8 @@ void Connection::close(DisconnectPacket::eDisconnectReason reason, ...)
disconnectReason = reason;//va_arg( input, const wstring );
vector<void *> objs = vector<void *>();
- void *i = NULL;
- while (i != NULL)
+ void *i = nullptr;
+ while (i != nullptr)
{
i = va_arg( input, void* );
objs.push_back(i);
@@ -390,7 +390,7 @@ void Connection::close(DisconnectPacket::eDisconnectReason reason, ...)
}
else
{
- disconnectReasonObjects = NULL;
+ disconnectReasonObjects = nullptr;
}
// int count = 0, sum = 0, i = first;
@@ -407,7 +407,7 @@ void Connection::close(DisconnectPacket::eDisconnectReason reason, ...)
// return( sum ? (sum / count) : 0 );
-// CreateThread(NULL, 0, runClose, this, 0, &closeThreadID);
+// CreateThread(nullptr, 0, runClose, this, 0, &closeThreadID);
running = false;
@@ -419,24 +419,24 @@ void Connection::close(DisconnectPacket::eDisconnectReason reason, ...)
writeThread->WaitForCompletion(INFINITE);
delete dis;
- dis = NULL;
+ dis = nullptr;
if( bufferedDos )
{
bufferedDos->close();
bufferedDos->deleteChildStream();
delete bufferedDos;
- bufferedDos = NULL;
+ bufferedDos = nullptr;
}
if( byteArrayDos )
{
byteArrayDos->close();
delete byteArrayDos;
- byteArrayDos = NULL;
+ byteArrayDos = nullptr;
}
if( socket )
{
socket->close(packetListener->isServerPacketListener());
- socket = NULL;
+ socket = nullptr;
}
}
@@ -473,7 +473,7 @@ void Connection::tick()
tickCount++;
if (tickCount % 20 == 0)
{
- send( shared_ptr<KeepAlivePacket>( new KeepAlivePacket() ) );
+ send(std::make_shared<KeepAlivePacket>());
}
// 4J Stu - 1.8.2 changed from 100 to 1000
@@ -498,7 +498,7 @@ void Connection::tick()
LeaveCriticalSection(&incoming_cs);
// MGH - moved the packet handling outside of the incoming_cs block, as it was locking up sometimes when disconnecting
- for(int i=0; i<packetsToHandle.size();i++)
+ for(size_t i = 0; i < packetsToHandle.size(); i++)
{
PIXBeginNamedEvent(0,"Handling packet %d\n",packetsToHandle[i]->getId());
packetsToHandle[i]->handle(packetListener);
@@ -552,22 +552,22 @@ void Connection::sendAndQuit()
close(DisconnectPacket::eDisconnect_Closed);
}
#else
- CreateThread(NULL, 0, runSendAndQuit, this, 0, &saqThreadID);
+ CreateThread(nullptr, 0, runSendAndQuit, this, 0, &saqThreadID);
#endif
}
int Connection::countDelayedPackets()
{
- return (int)outgoing_slow.size();
+ return static_cast<int>(outgoing_slow.size());
}
int Connection::runRead(void* lpParam)
{
ShutdownManager::HasStarted(ShutdownManager::eConnectionReadThreads);
- Connection *con = (Connection *)lpParam;
+ Connection *con = static_cast<Connection *>(lpParam);
- if (con == NULL)
+ if (con == nullptr)
{
#ifdef __PS3__
ShutdownManager::HasFinished(ShutdownManager::eConnectionReadThreads);
@@ -615,9 +615,9 @@ int Connection::runRead(void* lpParam)
int Connection::runWrite(void* lpParam)
{
ShutdownManager::HasStarted(ShutdownManager::eConnectionWriteThreads);
- Connection *con = dynamic_cast<Connection *>((Connection *) lpParam);
+ Connection *con = dynamic_cast<Connection *>(static_cast<Connection *>(lpParam));
- if (con == NULL)
+ if (con == nullptr)
{
ShutdownManager::HasFinished(ShutdownManager::eConnectionWriteThreads);
return 0;
@@ -644,8 +644,8 @@ int Connection::runWrite(void* lpParam)
// TODO - 4J Stu - 1.8.2 changes these sleeps to 2L, but not sure whether we should do that as well
waitResult = con->m_hWakeWriteThread->WaitForSignal(100L);
- if (con->bufferedDos != NULL) con->bufferedDos->flush();
- //if (con->byteArrayDos != NULL) con->byteArrayDos->flush();
+ if (con->bufferedDos != nullptr) con->bufferedDos->flush();
+ //if (con->byteArrayDos != nullptr) con->byteArrayDos->flush();
}
@@ -660,9 +660,9 @@ int Connection::runWrite(void* lpParam)
int Connection::runClose(void* lpParam)
{
- Connection *con = dynamic_cast<Connection *>((Connection *) lpParam);
+ Connection *con = dynamic_cast<Connection *>(static_cast<Connection *>(lpParam));
- if (con == NULL) return 0;
+ if (con == nullptr) return 0;
//try {
@@ -683,10 +683,10 @@ int Connection::runClose(void* lpParam)
int Connection::runSendAndQuit(void* lpParam)
{
- Connection *con = dynamic_cast<Connection *>((Connection *) lpParam);
+ Connection *con = dynamic_cast<Connection *>(static_cast<Connection *>(lpParam));
// printf("Con:0x%x runSendAndQuit\n",con);
- if (con == NULL) return 0;
+ if (con == nullptr) return 0;
//try {