From c3cdcd52eb86f5ed96a515370e073e604ebb1a53 Mon Sep 17 00:00:00 2001 From: fcolin Date: Thu, 1 Feb 2007 12:53:58 +0000 Subject: Utilisateur : Fcolin Date : 16/06/00 Heure : 10:14 Créé (vss 1) --- Ivy/BufferedSocket.h | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 Ivy/BufferedSocket.h (limited to 'Ivy/BufferedSocket.h') diff --git a/Ivy/BufferedSocket.h b/Ivy/BufferedSocket.h new file mode 100644 index 0000000..5f104c6 --- /dev/null +++ b/Ivy/BufferedSocket.h @@ -0,0 +1,42 @@ +// BufferedSocket.h: interface for the CBufferedSocket class. +// +////////////////////////////////////////////////////////////////////// + +#if !defined(AFX_BUFFEREDSOCKET_H__ECAC808B_3B4D_11D3_8A1E_00A0245B298A__INCLUDED_) +#define AFX_BUFFEREDSOCKET_H__ECAC808B_3B4D_11D3_8A1E_00A0245B298A__INCLUDED_ + +#if _MSC_VER > 1000 +#pragma once +#endif // _MSC_VER > 1000 + +#include "ThreadedSocket.h" + +class CBufferedSocket : public CThreadedSocket +{ +// DECLARE_DYNAMIC(CBufferedSocket) +public: + CBufferedSocket(); + virtual ~CBufferedSocket(); + void OnReceive( int nErrorCode ); + void OnSend( int nErrorCode ); + void OnConnect(int nErrorCode); + void OnWakeup(); + virtual void OnReceive( char *line ); + virtual void Accept(CBufferedSocket& rConnectedSocket, + SOCKADDR* lpSockAddr = NULL, int* lpSockAddrLen = NULL); + void SetSeparator( char sep ); + void Send ( const char * data ); +protected: + bool connected; /* wait to be connected before sending any Data */ + char separator; + /* buffer de reception de l'application */ +#define MAX_BUFFER 2048 + // MAX_BUFFER +1 pour ajouter \0 a la fin + char buf[MAX_BUFFER+1]; + char *ptr; + // Buffer Emission + CRITICAL_SECTION m_CritSection; + list buf_out; +}; + +#endif // !defined(AFX_BUFFEREDSOCKET_H__ECAC808B_3B4D_11D3_8A1E_00A0245B298A__INCLUDED_) -- cgit v1.1