The conference bridge resource. More...

#include <MprBridge.h>

Inheritance diagram for MprBridge:

Collaboration diagram for MprBridge:

Public Types
enum	AlgType { ALG_SIMPLE, ALG_LINEAR }
	Type of the bridge mix algorithm to use. More...

Public Types inherited from MpResource
enum	VisitState { NOT_VISITED, IN_PROGRESS, FINISHED }
	Graph traversal states that are used when running a topological sort to order resources within a flow graph. More...

enum	{ ASSOCIATED_LATENCY =-1, INF_LATENCY =-1 }

Public Member Functions
Creators
	MprBridge (const UtlString &rName, int maxInOutputs, UtlBoolean mixSilence=TRUE, AlgType algorithm=ALG_LINEAR)
	Default constructor. More...

virtual	~MprBridge ()
	Destructor. More...

Public Member Functions inherited from MpAudioResource
	MpAudioResource (const UtlString &rName, int minInputs, int maxInputs, int minOutputs, int maxOutputs)
	Constructor. More...

virtual	~MpAudioResource ()
	Destructor. More...

virtual UtlBoolean	processFrame (void)
	Wrapper around doProcessFrame(). More...

Public Member Functions inherited from MpResource
	MpResource (const UtlString &rName, int minInputs, int maxInputs, int minOutputs, int maxOutputs)
	Constructor. More...

virtual	~MpResource ()
	Destructor. More...

virtual UtlBoolean	disable ()
	Disable this resource. More...

virtual UtlBoolean	enable ()
	Enable this resource. More...

virtual void	reset ()
	This method is invoked for resources that care about stream discontinuities. More...

UtlBoolean	handleMessages (OsMsgQ &msgQ)
	Handles a queue full of incoming messages for this media processing object. More...

void	setVisitState (int newState)
	Sets the visit state for this resource. More...

OsStatus	sendNotification (MpResNotificationMsg::RNMsgType msgType)
	Send a notification with the given message type if notifications are enabled. More...

OsStatus	sendNotification (MpResNotificationMsg &msg)
	Send the given notification message if notifications are enabled. More...

virtual void	setConnectionId (MpConnectionID connectionId)
	Set the ID of a connection this resource belongs to. More...

virtual void	setStreamId (int streamId)
	Set the ID of a stream inside of the connection this resource belongs to. More...

virtual int	getStreamId (void)
	Get the ID of a stream within the connection this resource belongs to. More...

virtual OsStatus	pushBuffer (int inputPort, MpBufPtr &inputBuffer)
	Receive buffer asynchronously from resource at given input port. More...

virtual void	reassignSSRC (void)
	Broadcast announcement that we are changing our SSRC. More...

MpFlowGraphBase *	getFlowGraph () const
	Returns parent flowgraph. More...

void	getInputInfo (int inPortIdx, MpResource *&rpUpstreamResource, int &rUpstreamPortIdx)
	Returns information about the upstream end of a connection. More...

const UtlString &	getName () const
	Returns the name associated with this resource. More...

void	getOutputInfo (int outPortIdx, MpResource *&rpDownstreamResource, int &rDownstreamPortIdx)
	Returns information about the downstream end of a connection. More...

int	getVisitState ()
	Returns the current visit state for this resource. More...

int	maxInputs () const
	Returns the maximum number of inputs supported by this resource. More...

int	maxOutputs () const
	Returns the maximum number of outputs supported by this resource. More...

int	minInputs () const
	Returns the minimum number of inputs required by this resource. More...

int	minOutputs () const
	Returns the minimum number of outputs required by this resource. More...

int	numInputs () const
	Returns the number of resource inputs that are currently connected. More...

int	numOutputs () const
	Returns the number of resource outputs that are currently connected. More...

virtual MpConnectionID	getConnectionId (void) const
	Get the ID of a connection this resource belongs to. More...

int	reserveFirstUnconnectedInput ()
	Find the first unconnected input port and reserve it. More...

int	reserveFirstUnconnectedOutput ()
	Find the first unconnected output port and reserve it. More...

UtlContainableType	getContainableType () const
	Get the ContainableType for a UtlContainable derived class. More...

virtual OsStatus	getCurrentLatency (int &latency, int input=0, int output=0) const
	Get current input to output latency (in samples) More...

UtlBoolean	isEnabled () const
	Returns TRUE is this resource is currently enabled, FALSE otherwise. More...

UtlBoolean	isInputConnected (int portIdx)
	Returns TRUE if portIdx is valid and the indicated input is connected, FALSE otherwise. More...

UtlBoolean	isInputUnconnected (int portIdx)
	Returns TRUE if portIdx is valid and the indicated input is not connected, FALSE otherwise. More...

UtlBoolean	isOutputConnected (int portIdx)
	Returns TRUE if portIdx is valid and the indicated output is connected, FALSE otherwise. More...

UtlBoolean	isOutputUnconnected (int portIdx)
	Returns TRUE if portIdx is valid and the indicated output is not connected, FALSE otherwise. More...

UtlBoolean	areNotificationsEnabled () const
	Returns TRUE if notification sending is enabled on this resource. More...

virtual UtlBoolean	isAsynchInput (int inputIndex)
	Takes asynchronous input (pushBuffer). More...

Protected Types
enum	AddlMsgTypes { SET_WEIGHTS_FOR_INPUT = MpFlowGraphMsg::RESOURCE_SPECIFIC_START, SET_WEIGHTS_FOR_OUTPUT }

Protected Member Functions
OsStatus	setFlowGraph (MpFlowGraphBase *pFlowGraph)
	Associates this resource with the indicated flow graph. More...

UtlBoolean	doMix (MpBufPtr inBufs[], int inBufsSize, MpBufPtr outBufs[], int outBufsSize, int samplesPerFrame)
	Mix together inputs onto outputs according to mpGainMatrix matrix. More...

virtual UtlBoolean	doProcessFrame (MpBufPtr inBufs[], MpBufPtr outBufs[], int inBufsSize, int outBufsSize, UtlBoolean isEnabled, int samplesPerFrame, int samplesPerSecond)
	This method does the real work for the media processing resource and must be defined in each class derived from this one. More...

virtual UtlBoolean	handleMessage (MpFlowGraphMsg &rMsg)
	Handle flowgraph messages for this resource. More...

virtual UtlBoolean	handleMessage (MpResourceMsg &rMsg)
	Handle resource messages for this resource. More...

virtual UtlBoolean	handleSetMixWeightsForOutput (int bridgeOutputPort, int numWeights, const MpBridgeGain gain[])
	Actually set mix weights for inputs to given output on bridge. More...

virtual UtlBoolean	handleSetMixWeightsForInput (int bridgeInputPort, int numWeights, const MpBridgeGain gain[])
	Actually set mix weights for one input to given number of outputs. More...

Protected Member Functions inherited from MpResource
virtual UtlBoolean	handleEnable ()
	perform the enable operation on the resource More...

virtual UtlBoolean	handleDisable ()
	perform the disable operation on the resource More...

void	setInputBuffer (int inPortIdx, const MpBufPtr &pBuf)
	If there already is a buffer stored for this input port, delete it. Then store `pBuf` for the indicated input port. More...

OsStatus	postMessage (MpFlowGraphMsg &rMsg)
	Post a message from this resource. More...

OsStatus	postMessage (MpResourceMsg &rMsg)
	Post a message for this resource. More...

UtlBoolean	pushBufferDownsream (int outPortIdx, const MpBufPtr &pBuf)
	Makes `pBuf` available to resource connected to the `outPortIdx` output port of this resource. More...

virtual OsStatus	setNotificationsEnabled (UtlBoolean enable)
	Sets whether or not this resource should send notifications. More...

virtual UtlBoolean	connectInput (MpResource &rFrom, int fromPortIdx, int toPortIdx)
	Connects the `toPortIdx` input port on this resource to the `fromPortIdx` output port of the `rFrom` resource. More...

virtual UtlBoolean	connectOutput (MpResource &rTo, int toPortIdx, int fromPortIdx)
	Connects the `fromPortIdx` output port on this resource to the `toPortIdx` input port of the `rTo` resource. More...

virtual UtlBoolean	disconnectInput (int inPortIdx)
	Removes the connection to the `inPortIdx` input port of this resource. More...

virtual UtlBoolean	disconnectOutput (int outPortIdx)
	Removes the connection to the `outPortIdx` output port of this resource. More...

void	setName (const UtlString &rName)
	Sets the name that is associated with this resource. More...

Protected Attributes
AlgType	mAlgType
	Type of the bridge algorithm to use. More...

MpBridgeAlgBase *	mpBridgeAlg
	Instance of algorithm, used to mix data. More...

UtlBoolean	mMixSilence
	Should Bridge ignore or mix frames marked as silence? More...

Protected Attributes inherited from MpResource
MpFlowGraphBase *	mpFlowGraph
	flow graph this resource belongs to More...

MpConnectionID	mConnectionId
	The ID of connection this resource belongs to. More...

int	mStreamId

UtlBoolean	mIsEnabled
	TRUE if resource is enabled, FALSE otherwise. More...

OsRWMutex	mRWMutex
	reader/writer lock for synchronization More...

MpBufPtr *	mpInBufs
	input buffers for this resource More...

MpBufPtr *	mpOutBufs
	output buffers for this resource More...

Conn *	mpInConns
	input connections for this resource More...

Conn *	mpOutConns
	output connections for this resource More...

int	mMaxInputs
	maximum number of inputs More...

int	mMaxOutputs
	maximum number of outputs More...

int	mMinInputs
	number of required inputs More...

int	mMinOutputs
	number of required outputs More...

int	mNumActualInputs
	actual number of connected inputs More...

int	mNumActualOutputs
	actual number of connected outputs More...

int	mVisitState
	(used by flow graph topological sort alg.) More...

UtlBoolean	mNotificationsEnabled
	Whether we should send notifications or not. More...

OsBSem	mLock
	used mainly to make safe changes to ports More...

Private Member Functions
	MprBridge (const MprBridge &rMprBridge)
	Copy constructor (not implemented for this class) More...

MprBridge &	operator= (const MprBridge &rhs)
	Assignment operator (not implemented for this class) More...

Manipulators
OsStatus	setMixWeightsForOutput (int bridgeOutputPort, int numWeights, const MpBridgeGain gain[])
	Send message to set mix weights for inputs to given output on bridge. More...

OsStatus	setMixWeightsForInput (int bridgeInputPort, int numWeights, const MpBridgeGain gain[])
	Send message to set mix weights for one input to given number of outputs. More...

static OsStatus	setMixWeightsForOutput (const UtlString &namedResource, OsMsgQ &fgQ, int bridgeOutputPort, int numWeights, const MpBridgeGain gains[])
	Send message to set mix weights for inputs to given output on bridge. More...

static OsStatus	setMixWeightsForInput (const UtlString &namedResource, OsMsgQ &fgQ, int bridgeInputPort, int numWeights, const MpBridgeGain gains[])
	Send message to set mix weights for one input to given number of outputs. More...

Additional Inherited Members
Static Public Member Functions inherited from MpResource
static OsStatus	disable (const UtlString &namedResource, OsMsgQ &fgQ)
	Post a message to disable the resource named. More...

static OsStatus	enable (const UtlString &namedResource, OsMsgQ &fgQ)
	Post a message to enable the resource named. More...

static OsStatus	setNotificationsEnabled (UtlBoolean enable, const UtlString &namedResource, OsMsgQ &fgQ)
	Post a message to enable or disable resource notifications on the named resource. More...

static void	resourceInfo (MpResource *pResource, int index)
	Displays information on the console about the specified resource. More...

Static Public Attributes inherited from MpResource
static const UtlContainableType	TYPE = "MpResource"
	Class name, used for run-time checks. More...

Static Protected Attributes inherited from MpResource
static const OsTime	sOperationQueueTimeout = OsTime::OS_INFINITY
	The timeout for message operations for all resources when posting to the flowgraph queue. More...

Detailed Description

The conference bridge resource.

Local input and output should be connected to the first input and output ports. Remote connections will be binded to the second input/output ports, third input/output ports, and so on.

Enabled behaviour

Mix together local and remote inputs onto outputs, according to mix matrix. By deafault matrix is defined so that no output receive its own input.

Disabled behaviour

Drop all input data, do not produce any data on output.

Member Enumeration Documentation

enum AlgType

Type of the bridge mix algorithm to use.

Enumerator
ALG_SIMPLE	Simple O(n^2) algorithm (MpBridgeAlgSimple)
ALG_LINEAR	Linear O(n) algorithm (MpBridgeAlgLinear)

enum AddlMsgTypes

protected

Enumerator
SET_WEIGHTS_FOR_INPUT
SET_WEIGHTS_FOR_OUTPUT

Constructor & Destructor Documentation

MprBridge	(	const UtlString &	rName,
		int	maxInOutputs,
		UtlBoolean	mixSilence = `TRUE`,
		AlgType	algorithm = `ALG_LINEAR`
	)

Default constructor.

~MprBridge ( )

virtual

Destructor.

MprBridge ( const MprBridge & rMprBridge )

private

Copy constructor (not implemented for this class)

Member Function Documentation

OsStatus setMixWeightsForOutput	(	int	bridgeOutputPort,
		int	numWeights,
		const MpBridgeGain	gain[]
	)

Send message to set mix weights for inputs to given output on bridge.

Set the mix weights for the inputs (indices 0 to numWeights) going to the output port: bridgeOutputPort of the named bridge.

Parameters

[in]	bridgeOutputPort	- index (starts at 0) of the output port to which the input weights are to be set.
[in]	numWeights	- number of elements in `gain` array. If less, then only first `numWeights` elements would be set.
[in]	gain	- the gain value or multiplier to apply to the corresponding input. MP_BRIDGE_GAIN_PASSTHROUGH will add the unchanged input to the output. MP_BRIDGE_GAIN_UNDEFINED will use the existing value of gain for the input.

Note: If gain is not set to MP_BRIDGE_GAIN_MUTED for the input corresponding to the output port, there will be echo.

See also: setMixWeightsForInput()

OsStatus setMixWeightsForOutput	(	const UtlString &	namedResource,
		OsMsgQ &	fgQ,
		int	bridgeOutputPort,
		int	numWeights,
		const MpBridgeGain	gains[]
	)

static

Send message to set mix weights for inputs to given output on bridge.

See also: setMixWeightsForOutput(int,int,MpBridgeGain[]) for description.

OsStatus setMixWeightsForInput	(	int	bridgeInputPort,
		int	numWeights,
		const MpBridgeGain	gain[]
	)

Send message to set mix weights for one input to given number of outputs.

See also: This function is full analog of setMixWeightsForOutput(), applied for one input to outputs instead of inputs to one output.

OsStatus setMixWeightsForInput	(	const UtlString &	namedResource,
		OsMsgQ &	fgQ,
		int	bridgeInputPort,
		int	numWeights,
		const MpBridgeGain	gains[]
	)

static

Send message to set mix weights for one input to given number of outputs.

See also: setMixWeightsForOutput(int,int,MpBridgeGain[]) for description.

OsStatus setFlowGraph ( MpFlowGraphBase * pFlowGraph )

protectedvirtual

Associates this resource with the indicated flow graph.

We use this overloaded method for initialization of some of our member variables, which depend on flowgraph's properties (like frame size).

Return values

OS_SUCCESS - for now, this method always returns success

Reimplemented from MpResource.

UtlBoolean doMix	(	MpBufPtr	inBufs[],
		int	inBufsSize,
		MpBufPtr	outBufs[],
		int	outBufsSize,
		int	samplesPerFrame
	)

protected

Mix together inputs onto outputs according to mpGainMatrix matrix.

UtlBoolean doProcessFrame	(	MpBufPtr	inBufs[],
		MpBufPtr	outBufs[],
		int	inBufsSize,
		int	outBufsSize,
		UtlBoolean	isEnabled,
		int	samplesPerFrame,
		int	samplesPerSecond
	)

protectedvirtual

This method does the real work for the media processing resource and must be defined in each class derived from this one.

Parameters

inBufs	(in) array of pointers to input buffers for the resource
outBufs	(out) array of pointers to output buffers produce by the resource
inBufsSize	(in) size of the inBufs array
outBufsSize	(in) size of the outBufs array
isEnabled	(in) indicates whether this resource has been enabled
samplesPerFrame	(in) samples to produce per frame processing interval
samplesPerSecond	(in) samples to produce per second

Returns: TRUE if successful, FALSE otherwise.

Implements MpAudioResource.

UtlBoolean handleMessage ( MpFlowGraphMsg & rMsg )

protectedvirtual

Handle flowgraph messages for this resource.

Reimplemented from MpResource.

UtlBoolean handleMessage ( MpResourceMsg & rMsg )

protectedvirtual

Handle resource messages for this resource.

Reimplemented from MpResource.

UtlBoolean handleSetMixWeightsForOutput	(	int	bridgeOutputPort,
		int	numWeights,
		const MpBridgeGain	gain[]
	)

protectedvirtual

Actually set mix weights for inputs to given output on bridge.

See also: setMixWeightsForOutput() for explanation of parameters.

UtlBoolean handleSetMixWeightsForInput	(	int	bridgeInputPort,
		int	numWeights,
		const MpBridgeGain	gain[]
	)

protectedvirtual

Actually set mix weights for one input to given number of outputs.

See also: setMixWeightsForOutput() for explanation of parameters.

MprBridge& operator= ( const MprBridge & rhs )

private

Assignment operator (not implemented for this class)

Member Data Documentation

AlgType mAlgType

protected

Type of the bridge algorithm to use.

MpBridgeAlgBase* mpBridgeAlg

protected

Instance of algorithm, used to mix data.

UtlBoolean mMixSilence

protected

Should Bridge ignore or mix frames marked as silence?

Public Types

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Member Functions

Manipulators

Additional Inherited Members

Detailed Description

Enabled behaviour

Disabled behaviour

Member Enumeration Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation