socket_receive_data_buff.h

程序实现了在ip协议之上加一层RUDP协议

// SOCKET_Receive_Data_Buff.h: interface for the SOCKET_Receive_Data_Buff class.
//
//////////////////////////////////////////////////////////////////////

#if !defined(AFX_SOCKET_RECEIVE_DATA_BUFF_H__76E14E91_3466_47E7_B445_065EFE46EA31__INCLUDED_)
#define AFX_SOCKET_RECEIVE_DATA_BUFF_H__76E14E91_3466_47E7_B445_065EFE46EA31__INCLUDED_

#include <map>
#include <iostream>
#include"socket_data_struct.h"

using namespace std;
#define SEQ_BUFF_MOL  65535
#define MAXBUFLEN   1024

#if _MSC_VER > 1000
#pragma once
#endif // _MSC_VER > 1000

class SOCKET_Receive_Data_Buff  
{
public:
	SOCKET_Receive_Data_Buff();
	virtual ~SOCKET_Receive_Data_Buff();

	static SOCKET_Receive_Data_Buff* get_instance();
	bool  add(char* buf,int len);
	bool  remove(unsigned int rudpTag);
	Data_Queue_STR*  get_Data_Buff_item();
	void print();
	Data_Queue_STR data_queue_str;

private:
	static SOCKET_Receive_Data_Buff* pinstance;
	map<unsigned int, Data_Queue_STR> m_Data_queue;
	map<unsigned int, Data_Queue_STR>::iterator current_iter;
	int buflen;
	unsigned int seq_rudpTag;
	int current_item;
};

#endif // !defined(AFX_SOCKET_RECEIVE_DATA_BUFF_H__76E14E91_3466_47E7_B445_065EFE46EA31__INCLUDED_)