source: Sophya/trunk/AddOn/TAcq/burawstream.h@ 3728

// This may look like C code, but it is really -*- C++ -*-

#ifndef BUFFRAWSTREAM_H_SEEN
#define BUFFRAWSTREAM_H_SEEN

// Classe de flot brut sur socket - pour utilisation par les streams PPersist
// R. Ansari      LAL IN2P3/CNRS  11/2005

#include "machdefs.h"
#include "rawstream.h"


namespace SOPHYA {

// Input flow over a socket
class RawInOutBuffStream : public RawInOutStream {
public:
                      RawInOutBuffStream(const char * nom);
  virtual             ~RawInOutBuffStream();

  // Lecture 
  virtual int_8       tellg();
  virtual RawInOutStream& read(char* s, uint_8 n); 
  // Ecriture 
  virtual int_8       tellp();
  virtual RawInOutStream& write(const char* s, uint_8 n);

protected:
  size_t CopyToSendBuffer(const char* s, size_t n);
  size_t CopyFromRecvBuffer(char* s, size_t n);
  void SendBuffer();
  void ReceiveBuffer();

  size_t Send(const char* s, size_t n);
  size_t Receive(char* s, size_t n);

  FILE * _fip;
  struct SRWBuff { char* buff; size_t sz, cpos; };
  SRWBuff _rdbuff;
  SRWBuff _wrbuff;
  size_t _totnwr;
  size_t _totnrd;
};


} // namespace SOPHYA

#endif