00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036 #if !defined(AFX_BLOCKEDBUFFER_H__4E19668B_9B87_4EB0_8E29_2F6A25FA1F5E__INCLUDED_)
00037 #define AFX_BLOCKEDBUFFER_H__4E19668B_9B87_4EB0_8E29_2F6A25FA1F5E__INCLUDED_
00038
00039 #if _MSC_VER > 1000
00040 #pragma once
00041 #endif // _MSC_VER > 1000
00042
00043 #include "SpoofBase.h"
00044
00045 #include <deque>
00046
00047 KOMODIA_NAMESPACE_START
00048
00049 class CAsyncSocket;
00050 class CGenericCriticalSection;
00051
00052 class CBlockedBuffer : public CSpoofBase
00053 {
00054 public:
00055
00056 class CBlockedData
00057 {
00058 public:
00059
00060 int GetNumberOfCalls()const
00061 {
00062 return ++m_iCalls;
00063 }
00064
00065
00066 char* GetData()const
00067 {
00068 return m_pData;
00069 }
00070
00071
00072 int GetDataSize()const
00073 {
00074 return m_iDataSize;
00075 }
00076
00077
00078 CBlockedData(const char* pData,
00079 int iDataSize) : m_pData(NULL),
00080 m_iDataSize(iDataSize),
00081 m_iCalls(1)
00082 {
00083
00084 if (pData &&
00085 m_iDataSize)
00086 {
00087
00088 m_pData=new char[m_iDataSize];
00089 memcpy(m_pData,
00090 pData,
00091 m_iDataSize);
00092 }
00093 }
00094
00095 CBlockedData(const CBlockedData& rData) : m_pData(NULL),
00096 m_iDataSize(rData.m_iDataSize),
00097 m_iCalls(rData.m_iCalls)
00098 {
00099
00100 if (m_iDataSize && rData.m_pData)
00101 {
00102
00103 m_pData=new char[m_iDataSize];
00104 memcpy(m_pData,
00105 rData.m_pData,
00106 m_iDataSize);
00107 }
00108 }
00109
00110 virtual ~CBlockedData()
00111 {
00112
00113 delete [] m_pData;
00114 }
00115 private:
00116
00117 char* m_pData;
00118
00119
00120 int m_iDataSize;
00121
00122
00123 mutable int m_iCalls;
00124 };
00125 public:
00126
00127 void SendData();
00128
00129
00130 void AddRecord(const CBlockedData& rRecord);
00131
00132
00133
00134
00135 CBlockedBuffer(CAsyncSocket* pFather,
00136 int iMaxRetries=5);
00137 virtual ~CBlockedBuffer();
00138 private:
00139
00140 typedef std::deque<CBlockedData> BlockedBufferData;
00141 private:
00142
00143 CBlockedBuffer(const CBlockedBuffer& rBuffer);
00144
00145
00146 CBlockedBuffer& operator=(const CBlockedBuffer& rBuffer);
00147
00148
00149 CAsyncSocket* m_pFather;
00150
00151
00152 CGenericCriticalSection* m_pCSection;
00153
00154
00155 BlockedBufferData m_aData;
00156
00157
00158 int m_iMaxRetries;
00159 };
00160
00161 KOMODIA_NAMESPACE_END
00162
00163 #endif // !defined(AFX_BLOCKEDBUFFER_H__4E19668B_9B87_4EB0_8E29_2F6A25FA1F5E__INCLUDED_)