diff --git a/source/server/SocketClient.cpp b/source/server/SocketClient.cpp index b1f7f94..2bac52f 100644 --- a/source/server/SocketClient.cpp +++ b/source/server/SocketClient.cpp @@ -253,8 +253,8 @@ bool SocketClient::recv() { Packet *packet = reinterpret_cast(packetBuf); - if(mPacketQueue.size() < maxBufSize - 1) { - mPacketQueue.pushBack(packet); + if(!mRecvQueue.isFull()) { + mRecvQueue.push((s64)packet, sead::MessageQueue::BlockType::NonBlocking); this->has_recv_udp = true; } else { free(packetBuf);