InetWvIn.h

#include "Mutex.h"
#ifdef STK_MUTEXT_SUPPORTED
 
#ifndef STK_INETWVIN_H
#define STK_INETWVIN_H
 
#include "WvIn.h"
#include "TcpServer.h"
#include "UdpSocket.h"
#include "Thread.h"
#include "Mutex.h"
 
namespace stk {
 
/***************************************************/
/***************************************************/
 
typedef struct {
  bool finished;
  void *object;
} ThreadInfo;
 
class InetWvIn : public WvIn
{
public:
 
  InetWvIn( unsigned long bufferFrames = 1024, unsigned int nBuffers = 8 );
 
  ~InetWvIn();
 
 
  void listen( int port = 2006, unsigned int nChannels = 1,
               Stk::StkFormat format = STK_SINT16,
               Socket::ProtocolType protocol = Socket::PROTO_TCP );
 
 
  bool isConnected( void );
 
 
  StkFloat lastOut( unsigned int channel = 0 );
 
 
  StkFloat tick( unsigned int channel = 0 );
 
 
  StkFrames& tick( StkFrames& frames, unsigned int channel = 0 );
 
  // Called by the thread routine to receive data via the socket connection
  // and fill the socket buffer.  This is not intended for general use but
  // must be public for access from the thread.
  void receive( void );
 
protected:
 
  // Read buffered socket data into the data buffer ... will block if none available.
  int readData( void );
 
  Socket *soket_;
  Thread thread_;
  Mutex mutex_;
  char *buffer_;
  unsigned long bufferFrames_;
  unsigned long bufferBytes_;
  unsigned long bytesFilled_;
  unsigned int nBuffers_;
  unsigned long writePoint_;
  unsigned long readPoint_;
  long bufferCounter_;
  int dataBytes_;
  bool connected_;
  int fd_;
  ThreadInfo threadInfo_;
  Stk::StkFormat dataType_;
 
};
 
inline StkFloat InetWvIn :: lastOut( unsigned int channel )
{
#if defined(_STK_DEBUG_)
  if ( channel >= data_.channels() ) {
    oStream_ << "InetWvIn::lastOut(): channel argument and data stream are incompatible!";
    handleError( StkError::FUNCTION_ARGUMENT );
  }
#endif
 
  // If no connection and we've output all samples in the queue, return.
  if ( !connected_ && bytesFilled_ == 0 && bufferCounter_ == 0 ) return 0.0;
 
  return lastFrame_[channel];
}
 
} // stk namespace
 
#endif
#endif