1 files changed, 98 insertions, 0 deletions
diff --git a/NetEx/NetPeer.h b/NetEx/NetPeer.h
new file mode 100644
index 0000000..b2ec882
--- /dev/null
+++ b/NetEx/NetPeer.h
@@ -0,0 +1,98 @@
+/*  Project nGenEx
+    Destroyer Studios LLC
+    Copyright © 1997-2004. All Rights Reserved.
+
+    SUBSYSTEM:    NetEx.lib
+    FILE:         NetPeer.h
+    AUTHOR:       John DiCamillo
+
+
+    OVERVIEW
+    ========
+    One side of a UDP net link connection
+*/
+
+
+#ifndef NetPeer_h
+#define NetPeer_h
+
+#include <windows.h>
+#include "NetAddr.h"
+#include "List.h"
+#include "ThreadSync.h"
+
+// +-------------------------------------------------------------------+
+
+class NetGram;
+class NetMsg;
+
+// +-------------------------------------------------------------------+
+
+class NetPeer
+{
+public:
+   static const char* TYPENAME() { return "NetPeer"; }
+
+   enum STATUS { OK, SEND_OVERFLOW, RECV_OVERFLOW };
+
+   NetPeer(const NetAddr& addr, DWORD id);
+   ~NetPeer();
+
+   int operator == (const NetPeer& p)  const { return netid == p.netid; }
+
+   bool              SendMessage(NetMsg* msg);
+   NetMsg*           GetMessage();
+
+   NetGram*          ComposeGram();
+   bool              ReceiveGram(NetGram* g, List<NetMsg>* q=0);
+
+   const NetAddr&    Address()         const { return addr;       }
+   DWORD             NetID()           const { return netid;      }
+   DWORD             Sequence()        const { return sequence;   }
+
+   int               GetMaxPPS()       const { return pps;        }
+   void              SetMaxPPS(int p)        { pps = p;           }
+   int               GetMaxBPS()       const { return bps;        }
+   void              SetMaxBPS(int b)        { bps = b;           }
+   int               GetMaxQSize()     const { return max_qsize;  }
+   void              SetMaxQSize(int q)      { max_qsize = q;     }
+
+   DWORD             GetChunkSize()    const { return chunk_size; }
+   void              SetChunkSize(DWORD s)   { chunk_size = s;    }
+
+   DWORD             LastReceiveTime() const { return last_recv_time; }
+   void              SetLastReceiveTime(DWORD t) { last_recv_time = t; }
+
+private:
+   bool              OKtoSend()        const;
+   void              CheckMultiRecv(List<NetMsg>* q);
+
+   NetAddr           addr;          // remote network address
+   DWORD             sequence;      // highest packet id received
+   DWORD             netid;         // unique id for this peer
+   int               pps;           // max packets per second
+   int               bps;           // max bits per second
+   int               max_qsize;     // max bytes in either queue
+   int               status;        // ok or error code
+   DWORD             chunk_size;    // size of multipart message chunk
+
+   enum HIST { HIST_SIZE=8 };
+
+   DWORD             last_recv_time;         // time of last received packet        
+   DWORD             hist_time[HIST_SIZE];   // history for pps check
+   DWORD             hist_size[HIST_SIZE];   // history for bps check
+   int               hist_indx;              // index into history
+
+   int               send_size;     // total bytes in send list
+   int               recv_size;     // total bytes in recv list
+   List<NetMsg>      send_list;     // queue of messages waiting to be sent
+   List<NetMsg>      recv_list;     // queue of messages waiting to be read
+
+   List<NetMsg>      multi_send_list;
+   List<NetMsg>      multi_recv_list;
+
+   ThreadSync        sync;
+};
+
+
+#endif NetPeer_h
+\ No newline at end of file