// RTPAudioSource.h: interface for the RTPAudioSource class.
|
//
|
//////////////////////////////////////////////////////////////////////
|
|
#ifndef AFX_RTPAUDIOSOURCE_H__9A0DE2C0_90A9_4F86_B13C_58D1181EB505__INCLUDED_
|
#define AFX_RTPAUDIOSOURCE_H__9A0DE2C0_90A9_4F86_B13C_58D1181EB505__INCLUDED_
|
|
#include "AudioSource.h"
|
#include "Parameters.h"
|
|
enum Modes {ACTIVE_MODE=0, PASSIVE_MODE};
|
|
class RTPAudioSource : public AudioSource
|
{
|
public:
|
RTPAudioSource();
|
virtual ~RTPAudioSource();
|
int SetReceivePort(unsigned short receivePort);
|
int GetReceivePort(unsigned short *receivePort); // returns the currently bound receive port
|
int SourceStarted();
|
int SourceStopped();
|
int SourceThreadStarted(HANDLE sourceThreadHandle, DWORD sourceThreadID);
|
int SourceThreadStopped(HANDLE sourceThreadHandle, DWORD sourceThreadID);
|
int UnprepareSource(); // if the filter is in ACTIVE_MODE, then it waits on a socket
|
// so user needs to call UnprepareSource (which closes the socket)
|
// before the SourceThreadProc can end. Hence this method is public
|
protected:
|
int GenerateData(AudioSample **ppAudioSample);
|
int SetTraceLevel();
|
private:
|
int CreateSockets();
|
int CloseSockets();
|
int PrepareSource();
|
int ReceiveUDPPacket();
|
int BindSocketToPort(SOCKET socket, unsigned short port);
|
private:
|
SOCKET rtpSocket;
|
SOCKET rtcpSocket;
|
unsigned short receivePort;
|
unsigned short boundReceivePort;
|
char receiveBuffer[RTPAUDIOSOURCE_RECEIVEBUFFER_SIZE];
|
int mode;
|
bool bRunning;
|
CRITICAL_SECTION filterMutex;
|
};
|
|
#endif // !defined(AFX_RTPAUDIOSOURCE_H__9A0DE2C0_90A9_4F86_B13C_58D1181EB505__INCLUDED_)
|
