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/NetGram.cpp | |
| download | starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.zip starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.gz starshatter-e33e19d0587146859d48a134ec9fd94e7b7ba5cd.tar.bz2 | |
Initial upload
Diffstat (limited to 'NetEx/NetGram.cpp')
| -rw-r--r-- | NetEx/NetGram.cpp | 111 |
1 files changed, 111 insertions, 0 deletions
diff --git a/NetEx/NetGram.cpp b/NetEx/NetGram.cpp new file mode 100644 index 0000000..94e1ca2 --- /dev/null +++ b/NetEx/NetGram.cpp @@ -0,0 +1,111 @@ +/* Project nGenEx
+ Destroyer Studios LLC
+ Copyright © 1997-2004. All Rights Reserved.
+
+ SUBSYSTEM: NetEx.lib
+ FILE: NetGram.cpp
+ AUTHOR: John DiCamillo
+
+
+ OVERVIEW
+ ========
+ Generic Network Packet (Datagram) Implementation
+*/
+
+
+#include "MemDebug.h"
+#include "NetGram.h"
+#include "NetLayer.h"
+
+// +-------------------------------------------------------------------+
+
+static DWORD net_gram_sequence = 1;
+
+// +-------------------------------------------------------------------+
+
+/**
+ * NetGram constructor for ACK packets
+ */
+NetGram::NetGram()
+ : retries(0), packet_id(0), send_time(0)
+{ }
+
+/**
+ * NetGram constructor for receiving packets from remote hosts
+ */
+NetGram::NetGram(const NetAddr& src, Text msg)
+ : addr(src), retries(0), send_time(0)
+{
+ body = msg;
+
+ if (body.length() >= NET_GRAM_HEADER_SIZE) {
+ BYTE* data = (BYTE*) body.data();
+
+ packet_id = (((DWORD) data[0]) << 24) +
+ (((DWORD) data[1]) << 16) +
+ (((DWORD) data[2]) << 8) +
+ ((DWORD) data[3]);
+ }
+}
+
+/**
+ * NetGram constructor for composing packets to send to remote hosts
+ */
+NetGram::NetGram(const NetAddr& dst, Text user_data, int r)
+ : addr(dst), retries(r)
+{
+ send_time = NetLayer::GetTime();
+ packet_id = net_gram_sequence++;
+
+ if (retries)
+ packet_id |= NET_GRAM_RELIABLE;
+
+ static BYTE buf[NET_GRAM_MAX_SIZE];
+ buf[0] = (BYTE) (packet_id >> 24) & 0xff;
+ buf[1] = (BYTE) (packet_id >> 16) & 0xff;
+ buf[2] = (BYTE) (packet_id >> 8) & 0xff;
+ buf[3] = (BYTE) (packet_id) & 0xff;
+
+ int len = user_data.length();
+ if (len >= NET_GRAM_MAX_SIZE - NET_GRAM_HEADER_SIZE)
+ len = NET_GRAM_MAX_SIZE - NET_GRAM_HEADER_SIZE - 1;
+
+ CopyMemory(buf+NET_GRAM_HEADER_SIZE, user_data.data(), len);
+
+ body = Text((char*) buf, len+NET_GRAM_HEADER_SIZE);
+}
+
+// +--------------------------------------------------------------------+
+
+void
+NetGram::Retry()
+{
+ if (retries > 0) {
+ retries--;
+ send_time = NetLayer::GetTime();
+ }
+}
+
+// +--------------------------------------------------------------------+
+
+NetGram
+NetGram::Ack()
+{
+ NetGram ack;
+
+ ack.packet_id = packet_id | NET_GRAM_ACK;
+ ack.send_time = NetLayer::GetTime();
+
+ static BYTE buf[NET_GRAM_HEADER_SIZE];
+ buf[0] = (BYTE) (ack.packet_id >> 24) & 0xff;
+ buf[1] = (BYTE) (ack.packet_id >> 16) & 0xff;
+ buf[2] = (BYTE) (ack.packet_id >> 8) & 0xff;
+ buf[3] = (BYTE) (ack.packet_id) & 0xff;
+
+ ack.body = Text((char*) buf, NET_GRAM_HEADER_SIZE);
+
+ return ack;
+}
+
+
+
|