#include "exceptions.h"
#include "util/serialize.h"
-NetworkPacket::NetworkPacket(u8 *data, u32 datasize, u16 peer_id):
-m_read_offset(0), m_peer_id(peer_id)
-{
- m_read_offset = 0;
- m_datasize = datasize - 2;
-
- // split command and datas
- m_command = readU16(&data[0]);
- m_data = std::vector<u8>(&data[2], &data[2 + m_datasize]);
-}
-
NetworkPacket::NetworkPacket(u16 command, u32 datasize, u16 peer_id):
m_datasize(datasize), m_read_offset(0), m_command(command), m_peer_id(peer_id)
{
m_data.clear();
}
+void NetworkPacket::checkReadOffset(u32 from_offset)
+{
+ if (from_offset >= m_datasize) {
+ std::stringstream ss;
+ ss << "Reading outside packet (offset: " <<
+ from_offset << ", packet size: " << getSize() << ")";
+ throw PacketError(ss.str());
+ }
+}
+
+void NetworkPacket::putRawPacket(u8 *data, u32 datasize, u16 peer_id)
+{
+ // If a m_command is already set, we are rewriting on same packet
+ // This is not permitted
+ assert(m_command == 0);
+
+ m_datasize = datasize - 2;
+ m_peer_id = peer_id;
+
+ // split command and datas
+ m_command = readU16(&data[0]);
+ m_data = std::vector<u8>(&data[2], &data[2 + m_datasize]);
+}
+
char* NetworkPacket::getString(u32 from_offset)
{
- if (from_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(from_offset);
return (char*)&m_data[from_offset];
}
void NetworkPacket::putRawString(const char* src, u32 len)
{
- if (m_read_offset + len * sizeof(char) >= m_datasize) {
- m_datasize += len * sizeof(char);
+ if (m_read_offset + len > m_datasize) {
+ m_datasize = m_read_offset + len;
m_data.resize(m_datasize);
}
dst.reserve(strLen);
dst.append((char*)&m_data[m_read_offset], strLen);
- m_read_offset += strLen * sizeof(char);
+ m_read_offset += strLen;
return *this;
}
*this << msgsize;
- if (m_read_offset + msgsize * sizeof(char) >= m_datasize) {
- m_datasize += msgsize * sizeof(char);
- m_data.resize(m_datasize);
- }
-
- memcpy(&m_data[m_read_offset], src.c_str(), msgsize);
- m_read_offset += msgsize;
+ putRawString(src.c_str(), (u32)msgsize);
return *this;
}
*this << msgsize;
- if (m_read_offset + msgsize * sizeof(char) >= m_datasize) {
- m_datasize += msgsize * sizeof(char);
- m_data.resize(m_datasize);
- }
-
- memcpy(&m_data[m_read_offset], src.c_str(), msgsize);
- m_read_offset += msgsize;
+ putRawString(src.c_str(), msgsize);
}
NetworkPacket& NetworkPacket::operator>>(std::wstring& dst)
dst.reserve(strLen);
dst.append((char*)&m_data[m_read_offset], strLen);
- m_read_offset += strLen*sizeof(char);
+ m_read_offset += strLen;
return dst;
}
NetworkPacket& NetworkPacket::operator>>(char& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU8(&m_data[m_read_offset]);
char NetworkPacket::getChar(u32 offset)
{
- if (offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(offset);
return readU8(&m_data[offset]);
}
NetworkPacket& NetworkPacket::operator>>(bool& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU8(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(u8& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU8(&m_data[m_read_offset]);
u8 NetworkPacket::getU8(u32 offset)
{
- if (offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(offset);
return readU8(&m_data[offset]);
}
return NULL;
}
- if (from_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(from_offset);
return (u8*)&m_data[from_offset];
}
NetworkPacket& NetworkPacket::operator>>(u16& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU16(&m_data[m_read_offset]);
u16 NetworkPacket::getU16(u32 from_offset)
{
- if (from_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(from_offset);
return readU16(&m_data[from_offset]);
}
NetworkPacket& NetworkPacket::operator>>(u32& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU32(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(u64& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readU64(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(float& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readF1000(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(v2f& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readV2F1000(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(v3f& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readV3F1000(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(s16& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readS16(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(s32& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readS32(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(v3s16& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readV3S16(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(v3s32& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readV3S32(&m_data[m_read_offset]);
NetworkPacket& NetworkPacket::operator>>(video::SColor& dst)
{
- if (m_read_offset >= m_datasize)
- throw SerializationError("Malformed packet read");
+ checkReadOffset(m_read_offset);
dst = readARGB8(&m_data[m_read_offset]);
Buffer<u8> NetworkPacket::oldForgePacket()
{
- SharedBuffer<u8> sb(m_datasize + 2);
+ Buffer<u8> sb(m_datasize + 2);
writeU16(&sb[0], m_command);
u8* datas = getU8Ptr(0);