Home    News    Components    Get ViTooKi    Documentation    Community    Developers    @sf.net  

Info

Last update:
12 Feb 2007

Documentation

Doxygen LXR

DataChannel.hpp

/***********************************************************************
 *                                                                      *
 * ViTooKi                                                              *
 *                                                                      *
 * title:       DataChannel.hpp                                               *
 *                                                                      *
 *                                                                      *
 *                                                                      *
 * ITEC institute of the University of Klagenfurt (Austria)             *
 * http://www.itec.uni-klu.ac.at                                        *
 *                                                                      *
 *                                                                      *
 * For more information visit the ViTooKi homepage:                     *
 * http://ViTooKi.sourceforge.net                                       *
 * vitooki-user@lists.sourceforge.net                                   *
 * vitooki-devel@lists.sourceforge.net                                  *
 *                                                                      *
 * This file is part of ViTooKi, a free video toolkit.                  *
 * ViTooKi is free software; you can redistribute it and/or             *
 * modify it under the terms of the GNU General Public License          *
 * as published by the Free Software Foundation; either version 2       *
 * of the License, or (at your option) any later version.               *
 *                                                                      *
 * This program is distributed in the hope that it will be useful,      *
 * but WITHOUT ANY WARRANTY; without even the implied warranty of       *
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the         *
 * GNU General Public License for more details.                         *
 *                                                                      *
 * You should have received a copy of the GNU General Public License    *
 * along with this program; if not, write to the Free Software          *
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston,               *
 * MA  02111-1307, USA.                                                 *
 *                                                                      *
 ***********************************************************************/

/***********************************************************************
 *                                                                      *
 *  REVISION HISTORY:                                                   *
 *                                                                      *
 *                                                                      *
 *                                                                      *
 ***********************************************************************/

#ifndef _PS_DATACHANNEL_HPP_
#define _PS_DATACHANNEL_HPP_

#include "global.hpp"
#include "VMutex.hpp"
#include "ESInfo.hpp"
#include "Statistics.hpp"

class IO;
class DataSink;
class Adaptor;
class Frame;
class Url;

class DataChannel:public VThread {
public:
        DataChannel(IO * input, ESInfo * es);

        DataChannel(IO * input, ESInfo * es, Adaptor * adapt);

        ~DataChannel();


        void setAdaptor(Adaptor * adapt);

        void setESInfo(ESInfo *new_es);

        void setFinalFrameNumber(long frameNumber);

        void initiateThreadStop(bool forceTearDown);

        /* changes the connected input IO
         * @param new_es: the new ESInfo, that fits the according IO *new_io
         */
        void setInput(IO *new_io);

        bool play(u32 clientId,double prefetch);

        bool mute(u32 clientId);
                
        bool unmute(u32 clientId);
                
        bool pause(u32 clientId);
                
        bool insert(DataSink* c);

        char *enableCaching(bool omitHeader, const char* outDir, bool proxyMode=true, const Url* url=NULL);

        void visualizeCaching();

        bool teardown(u32 clientId, bool immediate=false);
        
        bool tearDownFlagSet() const { return tearDown; };

        int getNumberOfActiveDataSinks(); 
        
        IO* getInput() { return input;};

  Adaptor *getAdaptor() const { return adaptor; }

        void run();

        void setSessionId(int i) {
                sessionId = i;
        };

        uint getSessionId() const {
                return sessionId;
        };

        const ESInfo *getESInfo() const {
                return es;
        };
        
        DataSink* getDataSink(u32 clientId);

        const DataSink* getActiveDataSink(u32 clientId);
        
        list <u32> getListOfActiveClientIds();

        list <u32> getListOfPausedClientIds();


        void setOutputStatistics(Statistics *stats);

        Statistics *getOutputStatistics();

private:
        void init(IO * &input, ESInfo * &es, Adaptor * &adapt);
        void deleteInput();
        void closeAllClients(bool immediateClose);

protected:
        int sessionId;

        IO *input;

        list < DataSink * >active;

        list < DataSink * >paused;

        DataSink *localViewer;
        
        VMutex lockDataSink;

        VMutex lockInput;

        VMutex lockAdaptor;
        
 
        Adaptor *adaptor;
    
        list < Frame * >sendQueue;

        bool channelOpen;

        bool tearDown;
        bool immediateClose;
        ESInfo *es;
        Statistics *outstats;

        long currentFrameNumber;
  long finalFrameNumber;
};


#endif

© ViTooKi 2003 :: [Lite version] Created with Doxygen