devilutionX/SourceX/dvlnet/frame_queue.h

#pragma once

#include <deque>

#include "dvlnet/abstract_net.h"

namespace dvl {
namespace net {

class frame_queue_exception : public dvlnet_exception {
public:
	const char *what() const throw() override
	{
		return "Incorrect frame size";
	}
};

typedef uint32_t framesize_t;

class frame_queue {
public:
	constexpr static framesize_t max_frame_size = 0xFFFF;

private:
	framesize_t current_size = 0;
	std::deque<buffer_t> buffer_deque;
	framesize_t nextsize = 0;

	framesize_t size();
	buffer_t read(framesize_t s);

public:
	bool packet_ready();
	buffer_t read_packet();
	void write(buffer_t buf);

	static buffer_t make_frame(buffer_t packetbuf);
};

} // namespace net
} // namespace dvl