QSocketDataIO.h

/* This file is Copyright 2000-2008 Meyer Sound Laboratories Inc.  See the included LICENSE.txt file for details. */

#ifndef MuscleQSocketDataIO_h
#define MuscleQSocketDataIO_h

#include <qsocket.h>
#include "dataio/DataIO.h"

BEGIN_NAMESPACE(muscle);

class QSocketDataIO : public DataIO  
{
public: 
   QSocketDataIO(QSocket * newSocket) : _socket(newSocket), _socketRef(newSocket?GetSocketRefFromPool(newSocket, false):SocketRef()) {/* empty */}

   virtual ~QSocketDataIO() {Shutdown();}

   virtual int32 Read(void * buffer, uint32 size) {return _socket ? _socket->readBlock((char *) buffer, size) : -1;}

   virtual int32 Write(const void * buffer, uint32 size) {return _socket ? _socket->writeBlock((char *) buffer, size) : -1;}

   virtual status_t Seek(int64 /*offset*/, int /*whence*/) {return B_ERROR;}

   virtual int64 GetPosition() const {return -1;}

   virtual void FlushOutput() {if (_socket) _socket->flush();}

   virtual void Shutdown() {if (_socket) _socket->close(); delete _socket; _socket = NULL; _socketRef.Reset();}

   virtual const SocketRef & GetSelectSocket() const {return _socket ? _socketRef : GetNullSocket();}

   QSocket * GetSocket() {return _socket;}

   void ReleaseSocket() {_socket = NULL; _socketRef.Neutralize();}

private:
   SocketRef _socketRef;
   QSocket * _socket;
};

END_NAMESPACE(muscle);

#endif

---