source: svn/newcon3bcm2_21bu/nexus/lib/playback_ip/apps/ip_streamer.h

/******************************************************************************
 *    (c)2008-2011 Broadcom Corporation
 * 
 * This program is the proprietary software of Broadcom Corporation and/or its licensors,
 * and may only be used, duplicated, modified or distributed pursuant to the terms and
 * conditions of a separate, written license agreement executed between you and Broadcom
 * (an "Authorized License").  Except as set forth in an Authorized License, Broadcom grants
 * no license (express or implied), right to use, or waiver of any kind with respect to the
 * Software, and Broadcom expressly reserves all rights in and to the Software and all
 * intellectual property rights therein.  IF YOU HAVE NO AUTHORIZED LICENSE, THEN YOU
 * HAVE NO RIGHT TO USE THIS SOFTWARE IN ANY WAY, AND SHOULD IMMEDIATELY
 * NOTIFY BROADCOM AND DISCONTINUE ALL USE OF THE SOFTWARE.  
 *  
 * Except as expressly set forth in the Authorized License,
 *  
 * 1.     This program, including its structure, sequence and organization, constitutes the valuable trade
 * secrets of Broadcom, and you shall use all reasonable efforts to protect the confidentiality thereof,
 * and to use this information only in connection with your use of Broadcom integrated circuit products.
 *  
 * 2.     TO THE MAXIMUM EXTENT PERMITTED BY LAW, THE SOFTWARE IS PROVIDED "AS IS" 
 * AND WITH ALL FAULTS AND BROADCOM MAKES NO PROMISES, REPRESENTATIONS OR 
 * WARRANTIES, EITHER EXPRESS, IMPLIED, STATUTORY, OR OTHERWISE, WITH RESPECT TO 
 * THE SOFTWARE.  BROADCOM SPECIFICALLY DISCLAIMS ANY AND ALL IMPLIED WARRANTIES 
 * OF TITLE, MERCHANTABILITY, NONINFRINGEMENT, FITNESS FOR A PARTICULAR PURPOSE, 
 * LACK OF VIRUSES, ACCURACY OR COMPLETENESS, QUIET ENJOYMENT, QUIET POSSESSION 
 * OR CORRESPONDENCE TO DESCRIPTION. YOU ASSUME THE ENTIRE RISK ARISING OUT OF 
 * USE OR PERFORMANCE OF THE SOFTWARE.
 * 
 * 3.     TO THE MAXIMUM EXTENT PERMITTED BY LAW, IN NO EVENT SHALL BROADCOM OR ITS 
 * LICENSORS BE LIABLE FOR (i) CONSEQUENTIAL, INCIDENTAL, SPECIAL, INDIRECT, OR 
 * EXEMPLARY DAMAGES WHATSOEVER ARISING OUT OF OR IN ANY WAY RELATING TO YOUR 
 * USE OF OR INABILITY TO USE THE SOFTWARE EVEN IF BROADCOM HAS BEEN ADVISED OF 
 * THE POSSIBILITY OF SUCH DAMAGES; OR (ii) ANY AMOUNT IN EXCESS OF THE AMOUNT 
 * ACTUALLY PAID FOR THE SOFTWARE ITSELF OR U.S. $1, WHICHEVER IS GREATER. THESE 
 * LIMITATIONS SHALL APPLY NOTWITHSTANDING ANY FAILURE OF ESSENTIAL PURPOSE OF 
 * ANY LIMITED REMEDY.
 *
 * $brcm_Workfile: ip_streamer.h $
 * $brcm_Revision: 46 $
 * $brcm_Date: 12/19/11 12:56a $
 * 
 * Module Description:
 *  ip streamer include file
 * 
 * Revision History:
 * 
 * $brcm_Log: /nexus/lib/playback_ip/apps/ip_streamer.h $
 * 
 * 46   12/19/11 12:56a ssood
 * SW7231-516: raaga encoding support: added changes to support running
 *  raaga based xcode alongside the local decode on BMC
 * 
 * 45   12/8/11 7:40p ssood
 * SW7231-516: enhance ip_streamer to stream out raaga encoded TS streams
 *  from live or file sources
 * 
 * 44   10/18/11 7:25a ssood
 * SW7425-889: enabled audio in the live xcoded streams for streaming to
 *  iOS devices
 * 
 * 43   10/14/11 10:18a ssood
 * SW7425-889: initial check-in for enabling audio in the live xcoded
 *  streams
 * 
 * 42   9/26/11 10:22a ssood
 * SW7346-341: Add PVR Decryption support for file streaming
 * 
 * 41   8/27/11 7:37p ssood
 * SW7425-1077: lowered the number of recpumps for streaming to allow 4
 *  FCC clients on VMS
 * 
 * 40   8/5/11 3:13p ssood
 * SW7425-1040: add fast channel change support to IP Sessions
 * 
 * 39   7/15/11 2:13p ssood
 * SW7346-309: move MAX_PROGRAMS_PER_FREQUENCY out of LIVE_STREAMING flag
 * 
 * 38   7/14/11 12:01p ssood
 * SW7346-309: Add support for Streaming from Satellite Source
 * 
 * 37   6/18/11 11:52a ssood
 * SW7425-718: 3128 related changes: use different frontend resources for
 *  each streaming session even though it is same channel
 * 
 * 36   4/29/11 2:10p ssood
 * SW7425-175: more changes to handle stop/start condition on xcoded
 *  sessions
 * 
 * 35   3/18/11 6:44p ssood
 * SW7420-1616: allow app to pass-in dma handle
 * 
 * 34   3/16/11 4:55p ssood
 * SW7420-1616: initial check-in for pvr encryption support
 * 
 * 33   2/17/11 6:24p ssood
 * SW7425-59: initial check-in for audio passthru support for transcoded
 *  channels
 * 
 * 32   1/20/11 3:28p ssood
 * SW7425-59: switch decode to live mode in xcode path + all ces related
 *  changes + support for 2nd xcode client
 * 
 * 31   12/31/10 3:25p ssood
 * SW7425-59: add change to support clean stop/stop sequence w/ 7425
 *  xcoder + insert PAT/PMT into outgoing stream
 * 
 * 30   12/30/10 1:06p ssood
 * SW7425-59: surround all 7425 transcoder changes w/
 *  NEXUS_HAS_VIDEO_ENCODER compile flag
 * 
 * 29   12/30/10 12:55p ssood
 * SW7425-59: initial 7425 transcoder support on h/w platform (no PSI, no
 *  PCRs, no Audio in xcoded stream)
 * 
 * 28   12/28/10 12:28p ssood
 * SW7425-59: Add support for using HDMI-in as the source for
 *  transcoding+streaming out
 * 
 * 27   12/26/10 10:45p ssood
 * SW7425-59: Add support for 7425 transcoder
 * 
 * 26   9/2/10 3:11p garetht
 * SW7420-1046: Add support for sending 6xQAM256 streams to the cablecard
 * 
 * 25   8/12/10 11:28a ssood
 * SW7420-883: fixed compiler error for non-transcode case
 * 
 * 24   8/12/10 11:24a ssood
 * SW7420-883: added support for streaming same transcoding session to
 *  multiple clients
 * 
 * 23   7/27/10 2:08p ssood
 * SW7420-883: add transcoding support to IP Streamer (no audio
 *  transcoding yet)
 * 
 * 22   1/27/10 10:18a ssood
 * SW7420-454: conditionally compile Live Streaming Code using
 *  LIVE_STREAMING_SUPPORT
 * 
 * 21   1/14/10 6:41p ssood
 * SW7408-47: Add support to compile IP Streamer App on platforms w/ no
 *  frontend support
 * 
 * 20   12/22/09 11:03a ssood
 * SW7420-454: add timeshift support for live streaming
 * 
 * 19   12/15/09 9:38a ssood
 * SW7420-454: Add support to share a parser band among clients using same
 *  frequency & channel numbers
 * 
 * 18   11/20/09 1:35p jrubio
 * SW7335-537: change number of recpumps
 * 
 * 17   11/17/09 2:58p ssood
 * SW7420-454: Enhance IP Streamer to stream files from local disk
 * 
 * 16   11/2/09 3:56p ssood
 * SW7420-340: add support for recording a live stream
 * 
 * 15   10/20/09 6:33p ssood
 * SW7420-340: remove nexus playback, audio, video decoder dependencies
 *  for SMS compilation
 * 
 * 14   10/11/09 8:52p ssood
 * SW7420-340: added support to bind ip_streamer to a particular network
 *  interface
 * 
 * 13   10/10/09 10:49p ssood
 * SW7420-340: Changes to allow non-Broadcom DLNA clients play live
 *  content
 * 
 * 12   10/9/09 12:29p ssood
 * SW7420-340: add support to play live streams on non-Broadcom clients
 * 
 * 11   10/7/09 3:46p ssood
 * SW7420-340: added STANDL
 * 
 * 10   10/6/09 12:18p ssood
 * SW7420-340: Add DTCP/IP support to ip_streamer & IP Applib
 * 
 * 9   10/2/09 5:08p ssood
 * SW7420-340: Adapt number of resources as per # of video decoders needed
 *  for SMS/VMS differentiation
 * 
 * 8   10/2/09 4:12p ssood
 * SW7420-340: add logic to recover from buffer overflow condition (caused
 *  by client backing up)
 * 
 * 7   10/2/09 11:54a ssood
 * SW7420-340: increased the max programs per channels to 24
 * 
 * 6   9/29/09 11:01p ssood
 * SW7420-340: return error to client if PSI acquisition fails + wait for
 *  signal lock
 * 
 * 5   9/25/09 6:31p ismailk
 * SW7405-3080: Add a field for the serverIp addr in the
 *  IpStreamerGlobalCfg structure.
 * 
 * 4   9/25/09 5:15p ssood
 * SW7420-340: Add support for VSB frontend
 * 
 * 3   9/17/09 2:25p ssood
 * SW7420-340: include nexus files pertaining to ip streaming only
 * 
 * 2   9/16/09 2:33p ssood
 * SW7420-340: print debug stats
 * 
 * 1   9/16/09 10:50a ssood
 * SW7420-340: Adding example apps for demonstrating IP Streaming & Client
 *  features of IP Applib
 * 
 ******************************************************************************/
#ifndef __IP_STREAMER_H__
#define __IP_STREAMER_H__

#include <stdio.h>
#include "bstd.h"
#include "bkni.h"
#include "bkni_multi.h"
#include "nexus_file_fifo.h"

#ifdef NEXUS_HAS_7043_TRANSCODER
#include "nexus_transcoder.h"
#endif

#ifdef NEXUS_HAS_VIDEO_ENCODER
#include "b_os_lib.h"
#include "nexus_video_encoder.h"
#include "nexus_audio_encoder.h"
#endif
#if NEXUS_HAS_STREAM_MUX
#include "nexus_stream_mux.h"
#endif

#if NEXUS_HAS_HDMI_INPUT
#include "nexus_hdmi_input.h"
#endif

/* TODO: confirm what jitter we can have on DoCSYS/IP Path */
#define DOCSIS_IP_NETWORK_JITTER 100
#define IP_STREAMER_DEFAULT_SERVER_PORT 5000
#define IP_STREAMER_DEFAULT_DTCP_IP_PORT 8000

/* Max Number of concurrent sessions that need to be supported for a platform */
#define IP_STREAMER_MAX_THREADS 8

/* set only when no local decoding needs to be performed */
#ifdef B_RUN_STANDALONE
#undef NEXUS_NUM_VIDEO_DECODERS
#define NEXUS_NUM_VIDEO_DECODERS 0
#endif

/* Resource allocation for SMS/VMS Platforms: tied to # of Video Decoders */
#ifdef NEXUS_HAS_VIDEO_ENCODER
/* For transcoding case, we need to reserve atleast one decoder and thus max of two video decoders are reserved for main/pip windows */
#define IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE 2
#else
#define IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE NEXUS_NUM_VIDEO_DECODERS
#endif

/* # of playback channels reserved for receiving Live IP content directly on the local client (from IP headend): 2 per decoder inorder to support Timeshifting case */
#ifdef NEXUS_HAS_VIDEO_ENCODER
/* for transcoding, 3 additional playback channels are reserved to allow mux to feed Audio, Video, and System data into playback for muxing purpose */
#define IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_LOCAL_DECODE (IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE*2 + 3*NEXUS_NUM_VIDEO_ENCODERS)
#else
#define IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_LOCAL_DECODE (IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE*2)
#endif
/* keep half reserved for local decode & recording purposes and other half for streaming purposes */
#define IP_STREAMER_NUM_RECPUMPS_RESERVED_FOR_LOCAL_DECODE (NEXUS_NUM_RECPUMPS/2 + 2) /* adding two more for local to allow 4 Primers for Fast Channel Change */
/* one parser band each for main & pip */
#define IP_STREAMER_NUM_PARSER_BANDS_RESERVED_FOR_LOCAL_DECODE IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE

#ifdef B_HAS_VMS_GATEWAY
/* For VMS, IP Streamer controls all the frontends, local decode App (BMC) uses IP to talk w/ DMS & thus doesn't need Frontends */
#define IP_STREAMER_NUM_FRONTENDS_RESERVED_FOR_LOCAL_DECODE 0
#else
#define IP_STREAMER_NUM_FRONTENDS_RESERVED_FOR_LOCAL_DECODE IP_STREAMER_NUM_VIDEO_DECODERS_RESERVED_FOR_LOCAL_DECODE
#endif

#ifdef STREAMER_CABLECARD_SUPPORT
#define IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_MPOD 2
#define IP_STREAMER_NUM_RECPUMPS_RESERVED_FOR_MPOD 2
#else
#define IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_MPOD 0
#define IP_STREAMER_NUM_RECPUMPS_RESERVED_FOR_MPOD 0
#endif

/* Max Number of IP Frontends for a platforms (1 per HW playback channel, aka Nexus Playpump channel) */
#define IP_STREAMER_NUM_PLAYPUMPS ((NEXUS_NUM_PLAYPUMPS - IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_LOCAL_DECODE) - IP_STREAMER_NUM_PLAYPUMPS_RESERVED_FOR_MPOD)
/* recording sessions over IP */
#define IP_STREAMER_NUM_RECPUMPS_FOR_RECORD (2)
#define IP_STREAMER_NUM_RECPUMPS_FOR_STREAMING (NEXUS_NUM_RECPUMPS - IP_STREAMER_NUM_RECPUMPS_RESERVED_FOR_LOCAL_DECODE - IP_STREAMER_NUM_RECPUMPS_RESERVED_FOR_MPOD - IP_STREAMER_NUM_RECPUMPS_FOR_RECORD)
#define IP_STREAMER_NUM_PARSER_BANDS (NEXUS_NUM_PARSER_BANDS - IP_STREAMER_NUM_PARSER_BANDS_RESERVED_FOR_LOCAL_DECODE)
/* Max Number of Frontends for a platform */
#define IP_STREAMER_NUM_FRONTENDS NEXUS_MAX_FRONTENDS

#ifdef NEXUS_HAS_VIDEO_ENCODER
typedef struct TranscoderDst {
    /* nexus resources needed to setup the decode and re-encode pipe */
    NEXUS_Timebase timebase;
    int displayIndex; /* compositor to connect to the video encoder */
    int playpumpVideoIndex;
    int playpumpAudioIndex;
    int playpumpSystemDataIndex;
    NEXUS_StcChannelHandle decodeStcChannel;
    NEXUS_StcChannelHandle encodeStcChannel;
    NEXUS_VideoDecoderHandle videoDecoder;
    NEXUS_AudioDecoderHandle audioDecoder;
    NEXUS_DisplayHandle displayTranscode;
    NEXUS_VideoWindowHandle windowTranscode;
    NEXUS_DisplayHandle displayMain;
    NEXUS_VideoWindowHandle windowMain;

    NEXUS_VideoEncoderHandle videoEncoder;
    NEXUS_StreamMuxHandle streamMux;
    NEXUS_AudioMuxOutputHandle audioMuxOutput;
    NEXUS_AudioEncoderHandle audioEncoder;
    NEXUS_PlaypumpHandle playpumpTranscodeVideo;
    NEXUS_PlaypumpHandle playpumpTranscodeAudio;
    NEXUS_PlaypumpHandle playpumpTranscodeSystemData;

    NEXUS_PidChannelHandle transcodeVideoPidChannelCopy;
    NEXUS_PidChannelHandle transcodeAudioPidChannelCopy;

/* multi buffer to allow the background PSI packet to update CC while foreground one is waiting for TS mux pacing */
#define IP_STREAMER_PSI_QUEUE_CNT 4 /* every second insert a PSI, so it takes 4 secs to circle; hopefully its transfer won't be delay that far */
    void *pat[IP_STREAMER_PSI_QUEUE_CNT];
    void *pmt[IP_STREAMER_PSI_QUEUE_CNT];
    unsigned ccValue;
        B_MutexHandle mutexSystemData;
        B_SchedulerHandle schedulerSystemData;
        B_SchedulerTimerId systemDataTimer;
        B_ThreadHandle schedulerThread;
        bool systemDataTimerIsStarted;
    NEXUS_StreamMuxSystemData psi[2];
    BKNI_EventHandle finishEvent;  /* set when Finished callback is received from Mux mgr */
    bool inUse;
    int refCount;
    bool started; /* set when transcoding is started on this context */
    int contextId; /* transcoder context id */
} TranscoderDst; 
#endif /* NEXUS_HAS_VIDEO_ENCODER */

#define MAX_PROGRAMS_PER_FREQUENCY 24
#if B_HAS_LIVE_STREAMING
typedef struct QamSrc {
    NEXUS_FrontendHandle frontendHandle;
    int frequency;
    int refCount;   /* how many streaming sessions are using this frontend */
    B_PlaybackIpPsiInfo psi[MAX_PROGRAMS_PER_FREQUENCY];
    int numProgramsFound; /* how many sub-channels are found in this frequency */
    bool psiAcquiring; /* set if PSI info is been acquired */
    bool skipFrontendTuning; /* set if frontend tuner is already setup during PSI discovery */
    BKNI_EventHandle psiAcquiredEvent;  /* set when PSI aquisition is completed */
    BKNI_EventHandle signalLockedEvent;  /* set when tuner locks in to the frequency */
    bool started; /* set when Src is started */
    BKNI_MutexHandle lock;  /* lock to synchronize simultaneous access to one src when it shared between multiple clients */
#ifdef NEXUS_HAS_VIDEO_ENCODER
    bool transcodeEnabled;  /* set when the 1st transcoding session is started for this qam frontend */
#endif
} QamSrc;

typedef struct SatSrc {
    NEXUS_FrontendHandle frontendHandle;
    int frequency;
    int refCount;   /* how many streaming sessions are using this frontend */
    B_PlaybackIpPsiInfo psi[MAX_PROGRAMS_PER_FREQUENCY];
    int numProgramsFound; /* how many sub-channels are found in this frequency */
    bool psiAcquiring; /* set if PSI info is been acquired */
    bool skipFrontendTuning; /* set if frontend tuner is already setup during PSI discovery */
    BKNI_EventHandle psiAcquiredEvent;  /* set when PSI aquisition is completed */
    BKNI_EventHandle signalLockedEvent;  /* set when tuner locks in to the frequency */
    bool started; /* set when Src is started */
    BKNI_MutexHandle lock;  /* lock to synchronize simultaneous access to one src when it shared between multiple clients */
#ifdef NEXUS_HAS_VIDEO_ENCODER
    bool transcodeEnabled;  /* set when the 1st transcoding session is started for this qam frontend */
#endif
} SatSrc;

typedef struct IpSrc {
    B_PlaybackIpHandle playbackIp;
    NEXUS_PlaypumpHandle playpump;
    char srcIpAddress[64];     /* IP Address of Receiving Host */
    int srcPort;     /* Port # */
    B_PlaybackIpProtocol srcProtocol; /* Protocol: UDP/RTP */
    int refCount;   /* how many streaming sessions are using this frontend */
    B_PlaybackIpPsiInfo psi[MAX_PROGRAMS_PER_FREQUENCY];
    int numProgramsFound; /* how many sub-channels in this IP tuner */
    bool psiAcquiring; /* set if PSI info is been acquired */
    BKNI_EventHandle psiAcquiredEvent;  /* set when PSI aquisition is completed */
    bool started; /* set when Src is started */
    BKNI_MutexHandle lock;  /* lock to synchronize simultaneous access to one src when it shared between multiple clients */
} IpSrc;

typedef struct ParserBand {
    NEXUS_ParserBand parserBand;
    int frequency;
    int subChannel;
    int refCount;
    BKNI_MutexHandle lock;  /* lock to synchronize simultaneous access to one parser band when it shared between multiple clients */
    bool transcodeEnabled;  /* set when the 1st transcoding session is started for this parser band */
#ifdef NEXUS_HAS_7043_TRANSCODER
    IpStreamerTranscodeConfig transcode;
#endif
#ifdef NEXUS_HAS_VIDEO_ENCODER
    TranscoderDst *transcoderDst; /* handle to the transcoder context */
    IpStreamerTranscodeConfig transcode;
#endif
} ParserBand; 

typedef struct IpDst {
    NEXUS_RecpumpHandle recpumpHandle;
    NEXUS_RecordHandle recordHandle;
    NEXUS_FileRecordHandle fileRecordHandle;
    NEXUS_FifoRecordHandle fifoFileHandle;
    B_PlaybackIpLiveStreamingHandle liveStreamingHandle;
    bool inUse;
    BKNI_EventHandle dataReadyEvent; /* indicates when data is available in the recpump buffer */
} IpDst; 

typedef struct RecDst {
    NEXUS_RecpumpHandle recpumpHandle;
    NEXUS_RecordHandle recordHandle;
    NEXUS_FileRecordHandle fileRecordHandle;
    bool inUse;
} RecDst; 

#ifdef NEXUS_HAS_7043_TRANSCODER
typedef struct RemuxDst {
    NEXUS_RemuxHandle remuxHandle;
    NEXUS_Transcoder_OutputPortHandle transcoderOutputPortHandle;
    NEXUS_TranscoderHandle videoTranscoderHandle;
    NEXUS_TranscoderHandle audioTranscoderHandle;
    bool inUse;
    int refCount;
} RemuxDst; 
#endif
#ifdef NEXUS_HAS_HDMI_INPUT
typedef struct HdmiSrc {
    int hdmiInputId;
    NEXUS_Timebase timebase;
    NEXUS_HdmiInputHandle hdmiInput;
#ifdef NEXUS_HAS_VIDEO_ENCODER
    TranscoderDst *transcoderDst; /* handle to the transcoder context */
#endif
    bool inUse;
    int refCount;
} HdmiSrc; 
#endif
#endif /* B_HAS_LIVE_STREAMING */

typedef struct FileSrc {
#ifdef NEXUS_HAS_VIDEO_ENCODER
    TranscoderDst *transcoderDst; /* handle to the transcoder context */
#endif
    NEXUS_PlaypumpHandle playpumpHandle;
    NEXUS_PlaybackHandle playbackHandle;
    NEXUS_FilePlayHandle filePlayHandle;
    NEXUS_StcChannelHandle playbackStcChannel;
    NEXUS_PlaybackPidChannelSettings playbackPidSettings;
    B_PlaybackIpFileStreamingHandle fileStreamingHandle;
    bool inUse;
    int refCount;
} FileSrc; 

/* state info common to all threads */
typedef struct IpStreamerGlobalCtx {
    IpStreamerGlobalCfg globalCfg;
    void *dtcpCtx;

#if B_HAS_LIVE_STREAMING
    /* list of all available vsb sources: one per vsb tuner */
    BKNI_MutexHandle vsbSrcMutex;
    QamSrc vsbSrcList[NEXUS_MAX_FRONTENDS];

    /* list of all available qam sources: one per qam tuner */
    BKNI_MutexHandle qamSrcMutex;
    QamSrc qamSrcList[NEXUS_MAX_FRONTENDS];
    /* list of all available ip sources: one per playback channel */
    BKNI_MutexHandle ipSrcMutex; /* lock to synchronize access to the list of ip srcs */
    IpSrc ipSrcList[NEXUS_NUM_PLAYPUMPS];
    /* list of all available sat sources: one per qam tuner */
    BKNI_MutexHandle satSrcMutex;
    SatSrc satSrcList[NEXUS_MAX_FRONTENDS];

    /* list of all available pid parsers */
    BKNI_MutexHandle parserBandMutex;
    ParserBand parserBandList[NEXUS_NUM_PARSER_BANDS];
    /* list of all available Ip destinations: one per rave context */
    BKNI_MutexHandle ipDstMutex; /* lock to synchronize access to the list of ip srcs */
    IpDst ipDstList[NEXUS_NUM_RECPUMPS/2];

    /* list of all available record destinations: one per rave context */
    BKNI_MutexHandle recDstMutex;
    RecDst recDstList[NEXUS_NUM_RECPUMPS/2];

#if NEXUS_HAS_7043_TRANSCODER
    /* list of all available remux destinations */
    BKNI_MutexHandle remuxDstMutex;
    RemuxDst remuxDstList[NEXUS_NUM_REMUX];
#endif
#ifdef NEXUS_HAS_VIDEO_ENCODER
    /* list of all available remux destinations */
    BKNI_MutexHandle transcoderDstMutex;
    TranscoderDst transcoderDstList[NEXUS_NUM_VIDEO_ENCODERS];
#endif
#ifdef NEXUS_HAS_HDMI_INPUT
    BKNI_MutexHandle hdmiSrcMutex;
    HdmiSrc hdmiSrcList[NEXUS_NUM_HDMI_INPUTS];
#endif
#endif /* B_HAS_LIVE_STREAMING */

    /* following fields are only used when IP Streamer is used in the standalone mode (i.e. w/o DLNA DMS) */
    /* listening socket's fd */
    int listeningFd;
} IpStreamerGlobalCtx;

/* per thread state info */
typedef struct IpStreamerCtx
{
    IpStreamerGlobalCtx *globalCtx;
    IpStreamerConfig cfg;

    IpStreamerSrc srcType;
    B_PlaybackIpSocketState socketState;
#if B_HAS_LIVE_STREAMING
    NEXUS_PidChannelHandle videoPidChannel;
    NEXUS_PidChannelHandle audioPidChannel;
    NEXUS_PidChannelHandle pcrPidChannel;
    NEXUS_PidChannelHandle patPidChannel;
    NEXUS_PidChannelHandle pmtPidChannel;
#ifdef STREAMER_CABLECARD_SUPPORT
    NEXUS_PidChannelHandle caPidChannel;
#endif
    IpSrc *ipSrc;   /* either ipSrc or qamSrc point is valid based on srcType */
    QamSrc *qamSrc;
    QamSrc *vsbSrc;
    SatSrc *satSrc;
#ifdef NEXUS_HAS_HDMI_INPUT
    HdmiSrc *hdmiSrc;
#endif
    NEXUS_FrontendQamSettings qamSettings;
    NEXUS_FrontendSatelliteSettings satSettings;
    NEXUS_FrontendVsbSettings vsbSettings;
    ParserBand *parserBandPtr;
    RecDst *recDst;
    IpDst *ipDst;
#endif /* B_HAS_LIVE_STREAMING */
    FileSrc *fileSrc;
    uint64_t curBytesReceived;  /* # of bytes received from a live channel: either streamed on IP or recorded locally */
    int underflowWarningCount;  /* how many seconds we haven't received any new data in the streaming/recording buffer */

    bool ipStreamingInProgress; /* set when we are streaming a live channel to an IP client */
    bool fileStreamingInProgress; /* set when we are streaming a media file to an IP client */
    bool localRecordingInProgress; /* set when we are recording to local disk */
    bool overflow; /* set when we overflow happeneded */
    bool skipPsiAcquisition; /* if set, skip PSI acquisition, gets set when same channel is re-tuned */
#ifdef B_HAS_DTCP_IP
        void *AkeHandle;
        void *dtcpCtx;
#endif
    bool transcodeEnabled;
#ifdef NEXUS_HAS_7043_TRANSCODER
    RemuxDst *remuxDst;
    ParserBand *remuxParserBandPtr;
    NEXUS_PidChannelHandle remuxVideoPidChannel;
    NEXUS_PidChannelHandle remuxAudioPidChannel;
    NEXUS_PidChannelHandle remuxPcrPidChannel;
    bool transcodingInProgress; /* set when we are transcoding a session */
#endif
#ifdef NEXUS_HAS_VIDEO_ENCODER
    TranscoderDst *transcoderDst;
    NEXUS_PidChannelHandle transcodeVideoPidChannel;
    NEXUS_PidChannelHandle transcodeAudioPidChannel;
    NEXUS_PidChannelHandle transcodePcrPidChannel;
    NEXUS_PidChannelHandle transcodePatPidChannel;
    NEXUS_PidChannelHandle transcodePmtPidChannel;
    bool transcodingInProgress; /* set when we are transcoding a session */
#endif
#ifdef NEXUS_HAS_SECURITY
    NEXUS_KeySlotHandle pvrEncKeyHandle;
    NEXUS_KeySlotHandle pvrDecKeyHandle;
#endif
}IpStreamerCtx;
#endif /* __IP_STREAMER_H__ */