mirror of
https://github.com/CraftyBoss/SuperMarioOdysseyOnline.git
synced 2024-12-22 16:30:20 +00:00
36f9343f83
Resend because: on server restarts the server will lose the stage and costume information. If only one client is connected to the server, the packets currently aren't resent, so the server doesn't know in which stage the client is and what costume it wears (which I'd like to display on the website). With more then one client connected it already works, because when another client joins the server, the client will send both packets.
78 lines
2.2 KiB
C++
78 lines
2.2 KiB
C++
#pragma once
|
|
|
|
#include "SocketBase.hpp"
|
|
#include "al/async/AsyncFunctorThread.h"
|
|
#include "heap/seadHeap.h"
|
|
#include "nn/result.h"
|
|
#include "sead/math/seadVector.h"
|
|
#include "sead/math/seadQuat.h"
|
|
#include "sead/container/seadPtrArray.h"
|
|
|
|
#include "al/util.hpp"
|
|
|
|
#include "nn/account.h"
|
|
|
|
#include "syssocket/sockdefines.h"
|
|
|
|
#include "thread/seadMessageQueue.h"
|
|
#include "thread/seadMutex.h"
|
|
#include "types.h"
|
|
|
|
#include "packets/Packet.h"
|
|
|
|
class Client;
|
|
|
|
class SocketClient : public SocketBase {
|
|
public:
|
|
SocketClient(const char* name, sead::Heap* heap, Client* client);
|
|
nn::Result init(const char* ip, u16 port) override;
|
|
bool tryReconnect();
|
|
bool closeSocket() override;
|
|
|
|
bool startThreads();
|
|
void endThreads();
|
|
|
|
bool send(Packet* packet);
|
|
bool recv();
|
|
|
|
bool queuePacket(Packet *packet);
|
|
void trySendQueue();
|
|
|
|
void sendFunc();
|
|
void recvFunc();
|
|
|
|
Packet *tryGetPacket(sead::MessageQueue::BlockType blockType = sead::MessageQueue::BlockType::Blocking);
|
|
|
|
void printPacket(Packet* packet);
|
|
bool isConnected() { return socket_log_state == SOCKET_LOG_CONNECTED; }
|
|
|
|
u32 getSendCount() { return mSendQueue.getCount(); }
|
|
u32 getSendMaxCount() { return mSendQueue.getMaxCount(); }
|
|
|
|
u32 getRecvCount() { return mRecvQueue.getCount(); }
|
|
u32 getRecvMaxCount() { return mRecvQueue.getMaxCount(); }
|
|
|
|
void setIsFirstConn(bool value) { mIsFirstConnect = value; }
|
|
|
|
private:
|
|
sead::Heap* mHeap = nullptr;
|
|
Client* client = nullptr;
|
|
|
|
al::AsyncFunctorThread* mRecvThread = nullptr;
|
|
al::AsyncFunctorThread* mSendThread = nullptr;
|
|
|
|
sead::MessageQueue mRecvQueue;
|
|
sead::MessageQueue mSendQueue;
|
|
|
|
int maxBufSize = 100;
|
|
bool mIsFirstConnect = true;
|
|
|
|
/**
|
|
* @param str a string containing an IPv4 address or a hostname that can be resolved via DNS
|
|
* @param out IPv4 address
|
|
* @return if this function was successfull and out contains a valid IP address
|
|
*/
|
|
bool stringToIPAddress(const char* str, in_addr* out);
|
|
};
|
|
|
|
typedef void (SocketClient::*SocketThreadFunc)(void);
|