diff options
| author | FWoltermann@gmail.com <FWoltermann@gmail.com@076cb2c4-205e-83fd-5cf3-1be9aa105544> | 2011-12-08 14:53:40 +0000 |
|---|---|---|
| committer | FWoltermann@gmail.com <FWoltermann@gmail.com@076cb2c4-205e-83fd-5cf3-1be9aa105544> | 2011-12-08 14:53:40 +0000 |
| commit | e33e19d0587146859d48a134ec9fd94e7b7ba5cd (patch) | |
| tree | 69d048c8801858d2756ab3a487090a7a1b74bf14 /NetEx/NetLink.h | |
| download | starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.zip starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.gz starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.bz2 | |
Initial upload
Diffstat (limited to 'NetEx/NetLink.h')
| -rw-r--r-- | NetEx/NetLink.h | 113 |
1 files changed, 113 insertions, 0 deletions
diff --git a/NetEx/NetLink.h b/NetEx/NetLink.h new file mode 100644 index 0000000..8d83ced --- /dev/null +++ b/NetEx/NetLink.h @@ -0,0 +1,113 @@ +/* Project nGenEx
+ Destroyer Studios LLC
+ Copyright © 1997-2004. All Rights Reserved.
+
+ SUBSYSTEM: NetEx.lib
+ FILE: NetLink.h
+ AUTHOR: John DiCamillo
+
+
+ OVERVIEW
+ ========
+ Network Link for Remote Player
+*/
+
+
+#ifndef NetLink_h
+#define NetLink_h
+
+#include <windows.h>
+#include "NetAddr.h"
+#include "NetSock.h"
+#include "List.h"
+#include "ThreadSync.h"
+
+// +-------------------------------------------------------------------+
+
+class NetGram;
+class NetMsg;
+class NetPeer;
+
+// +-------------------------------------------------------------------+
+
+class NetLink
+{
+public:
+ static const char* TYPENAME() { return "NetLink"; }
+
+ NetLink();
+ NetLink(NetAddr& a);
+ virtual ~NetLink();
+
+ int operator == (const NetLink& that) const { return this == &that; }
+
+ const NetAddr& GetAddress() const { return addr; }
+
+ DWORD AddPeer(const char* a, WORD p=12345);
+ DWORD AddPeer(DWORD a, WORD p=12345);
+ DWORD AddPeer(const NetAddr& a);
+
+ bool SendMessage(DWORD nid, void* d, int l, BYTE f=0);
+ bool SendMessage(DWORD nid, BYTE type, const char* text, int len, BYTE f=0);
+ bool SendMessage(NetMsg* msg);
+
+ NetMsg* GetMessage();
+ NetMsg* GetMessage(DWORD netid);
+
+ virtual void Shutdown();
+ DWORD DoSendRecv();
+
+ DWORD GetResendInterval() const { return resend_time; }
+ void SetResendInterval(DWORD t) { resend_time = t; }
+ DWORD GetTrafficInterval() const { return traffic_time; }
+ void SetTrafficInterval(DWORD t) { traffic_time = t; }
+
+ DWORD GetPacketsSent() const { return packets_sent; }
+ DWORD GetPacketsRecv() const { return packets_recv; }
+ DWORD GetBytesSent() const { return bytes_sent; }
+ DWORD GetBytesRecv() const { return bytes_recv; }
+ DWORD GetRetries() const { return retries; }
+ DWORD GetDrops() const { return drops; }
+ DWORD GetLag() const { return lag; }
+
+ NetPeer* FindPeer(const NetAddr& a);
+ NetPeer* FindPeer(DWORD netid);
+
+protected:
+ void SendNetGram(NetGram* g);
+ NetGram* RecvNetGram();
+ void AckNetGram(NetGram* gram);
+ void ProcessAck(NetGram* gram);
+ void QueueNetGram(NetGram* gram);
+
+ void ReadPackets();
+ void SendPackets();
+ void DoRetries();
+
+ NetAddr addr;
+ NetSock sock;
+ List<NetGram> send_list;
+ List<NetMsg> recv_list;
+ List<NetPeer> peer_list;
+
+ HANDLE hnet;
+ bool shutdown;
+ ThreadSync sync;
+
+ DWORD resend_time;
+ DWORD traffic_time;
+
+ DWORD packets_sent;
+ DWORD packets_recv;
+ DWORD bytes_sent;
+ DWORD bytes_recv;
+ DWORD retries;
+ DWORD drops;
+ DWORD lag;
+
+ DWORD lag_samples[10];
+ int lag_index;
+};
+
+
+#endif NetLink_h
\ No newline at end of file |