src/Network/Packet.cc
changeset 186 0738f2949a2b
parent 185 25becd2cb026
child 200 2dbf40661580
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/Network/Packet.cc	Wed Dec 03 19:30:54 2008 +0000
@@ -0,0 +1,144 @@
+
+#include <cassert>
+#include <cstring>
+
+#include "Packet.hh"
+
+
+NetworkPacket::NetworkPacket (void) :
+    buf_size(NETWORK_PACKET_SIZE), data_size(0), offset(0) {
+    
+    // nothing
+}
+
+void NetworkPacket::check_write_size (size_t item_size) {
+     if (offset + item_size > buf_size)
+        throw NetworkPacketError("not enough space to write");
+
+}
+        
+void NetworkPacket::check_read_size (size_t item_size) {
+    if (offset + item_size > data_size)
+        throw NetworkPacketError("not enough data to read");
+}
+
+void NetworkPacket::write (const void *ptr, size_t len) {
+    // check buffer overflow
+    check_write_size(len);
+
+    // set value
+    memcpy(buf + offset, ptr, len);
+
+    // update offset and size
+    offset += len;
+    data_size += len;
+}
+
+void NetworkPacket::read (void *ptr, size_t len) {
+    // check buffer underflow
+    check_read_size(len);
+
+    // set value
+    memcpy(ptr, buf + offset, len);
+
+    // update offset
+    offset += len;
+}
+
+template <typename T> T NetworkPacket::read_val (void) {
+    T val;
+
+    // read
+    read(&val, sizeof(T));
+
+    // return
+    return val;
+}
+
+template <typename T> void NetworkPacket::write_val (const T &val) {
+    // write
+    write(&val, sizeof(T));
+}
+
+uint32_t NetworkPacket::read_uint32 (void) {
+    return ntohl(read_val<uint32_t>());
+}
+
+uint16_t NetworkPacket::read_uint16 (void) {
+    return ntohs(read_val<uint16_t>());
+}
+
+uint8_t NetworkPacket::read_uint8 (void) {
+    return read_val<uint8_t>();
+}
+
+int32_t NetworkPacket::read_int32 (void) {
+    return ntohl(read_val<int32_t>());
+}
+
+int16_t NetworkPacket::read_int16 (void) {
+    return ntohs(read_val<int16_t>());
+}
+
+int8_t NetworkPacket::read_int8 (void) {
+    return read_val<int8_t>();
+}
+        
+float NetworkPacket::read_float32 (void) {
+    int32_t ival = read_int32();
+
+    return *((float *) &ival);
+}
+
+Vector NetworkPacket::read_vector (void) {
+    float fx = read_float32();
+    float fy = read_float32();
+
+    return Vector(fx, fy);
+}
+
+void NetworkPacket::write_uint32 (uint32_t val) {
+    write_val<uint32_t>(htonl(val));
+}
+
+void NetworkPacket::write_uint16 (uint16_t val) {
+    write_val<uint16_t>(htons(val));
+}
+
+void NetworkPacket::write_uint8 (uint8_t val) {
+    write_val<uint8_t>(val);
+}
+
+void NetworkPacket::write_int32 (int32_t val) {
+    write_val<int32_t>(htonl(val));
+}
+
+void NetworkPacket::write_int16 (int16_t val) {
+    write_val<int16_t>(htons(val));
+}
+
+void NetworkPacket::write_int8 (int8_t val) {
+    write_val<int8_t>(val);
+}
+        
+void NetworkPacket::write_float32 (float val) {
+    write_int32(*((int32_t *) &val));
+}
+
+void NetworkPacket::write_vector (const Vector &vec) {
+    write_float32(vec.x);
+    write_float32(vec.y);
+}
+
+void NetworkPacket::write_packet (const NetworkPacket &pkt) {
+    // check buffer size
+    check_write_size(pkt.get_data_size());
+
+    // copy
+    memcpy(buf + offset, pkt.get_buf(), pkt.get_data_size());
+
+    // update offset/data_size
+    offset += pkt.get_data_size();
+    data_size += pkt.get_data_size();
+}
+