-
Notifications
You must be signed in to change notification settings - Fork 220
/
Copy pathServerSocket.h
86 lines (72 loc) · 2.8 KB
/
ServerSocket.h
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
//
// This file is part of the aMule Project.
//
// Copyright (c) 2003-2011 aMule Team ( [email protected] / http://www.amule.org )
// Copyright (c) 2002-2011 Merkur ( [email protected] / http://www.emule-project.net )
//
// Any parts of this program derived from the xMule, lMule or eMule project,
// or contributed by third-party developers are copyrighted by their
// respective authors.
//
// This program 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; either version 2 of the License, or
// (at your option) any later version.
//
// This program 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 this program; if not, write to the Free Software
// Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
//
//
// Client to Server communication
//
#ifndef SERVERSOCKET_H
#define SERVERSOCKET_H
#include "EMSocket.h" // Needed for CEMSocket
#include "ServerConnect.h"
//------------------------------------------------------------------------------
// CServerSocket
//------------------------------------------------------------------------------
class CServer;
class CServerSocket : public CEMSocket
{
friend class CServerConnect;
public:
CServerSocket(CServerConnect* in_serverconnect, const CProxyData *ProxyData = NULL);
virtual ~CServerSocket();
void ConnectToServer(CServer* server, bool bNoCrypt = false);
sint8 GetConnectionState() const { return connectionstate; }
uint32 GetLastTransmission() const { return m_dwLastTransmission; }
wxString info;
void OnClose(int nErrorCode);
void OnConnect(int nErrorCode);
void OnReceive(int nErrorCode);
void OnError(int nErrorCode);
bool PacketReceived(CPacket* packet);
void SendPacket(CPacket* packet, bool delpacket = true, bool controlpacket = true, uint32 actualPayloadSize = 0);
bool IsSolving() const { return m_IsSolving;};
void OnHostnameResolved(uint32 ip);
CServer *GetServerConnected() const { return serverconnect->GetCurrentServer(); }
uint32 GetServerIP() const;
private:
bool ProcessPacket(const uint8_t* packet, uint32 size, int8 opcode);
void SetConnectionState(sint8 newstate);
CServerConnect* serverconnect;
sint8 connectionstate;
CServer* cur_server;
bool m_bNoCrypt;
bool headercomplete;
int32 sizetoget;
int32 sizereceived;
char* rbuffer;
bool m_bIsDeleting; // true: socket is already in deletion phase, don't destroy it in ::StopConnectionTry
uint32 m_dwLastTransmission;
bool m_IsSolving;
};
#endif // SERVERSOCKET_H
// File_checked_for_headers