monitorcds.java

Myjxta的源代码 基于JXTA的P2P即时通信系统

/*
 * Copyright (c) 1996-2001 Sun Microsystems, Inc. All Rights Reserved.
 *
 * Sun grants you ("Licensee") a non-exclusive, royalty free, license to use,
 * modify and redistribute this software in source and binary code form,
 * provided that i) this copyright notice and license appear on all copies of
 * the software; and ii) Licensee does not utilize the software in a manner
 * which is disparaging to Sun.
 *
 * This software is provided "AS IS," without a warranty of any kind. ALL
 * EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND WARRANTIES, INCLUDING ANY
 * IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE OR
 * NON-INFRINGEMENT, ARE HEREBY EXCLUDED. SUN AND ITS LICENSORS SHALL NOT BE
 * LIABLE FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING
 * OR DISTRIBUTING THE SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL SUN OR ITS
 * LICENSORS BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR DIRECT,
 * INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR PUNITIVE DAMAGES, HOWEVER
 * CAUSED AND REGARDLESS OF THE THEORY OF LIABILITY, ARISING OUT OF THE USE OF
 * OR INABILITY TO USE SOFTWARE, EVEN IF SUN HAS BEEN ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGES.
 *
 * This software is not designed or intended for use in on-line control of
 * aircraft, air traffic, aircraft navigation or aircraft communications; or in
 * the design, construction, operation or maintenance of any nuclear
 * facility. Licensee represents and warrants that it will not use or
 * redistribute the Software for such purposes.
 */

package net.jxta.myjxta.plugins.vijxta;

import javax.media.*;
import javax.media.protocol.*;
import javax.media.control.*;
import java.io.IOException;


/**
 *   This custom data source acts as a delegate for proceessing on the 
 *   video stream. This class is taken from the jmf solutions page at SUN and 
 *   adapted for this myJxta video module.
 *      http://java.sun.com/products/java-media/jmf/2.1.1/solutions/JVidCap.html
 *   Without this example source it would have taken another week to figure out
 *   how JMF data source's interact.
 *@author  unknown@sun
 *@modified 2005-04-06 jamoore moded to fit viJxta
 */
public class MonitorCDS extends PushBufferDataSource implements CaptureDevice {

    private PushBufferDataSource delegate = null;
    private PushBufferStream [] delStreams = null;
    private MonitorStream monitorStream = null;
    private PushBufferStream [] monitorStreams = null;
    boolean delStarted = false; // variable used by MonitorStream also
    private Control [] controls;

    public MonitorCDS(DataSource ds) {
	// Get the stream from the actual datasource
	// and create a MonitorStream from it
	// Export the MonitorControl interface of the MonitorStream
	if (ds instanceof PushBufferDataSource) {
	    delegate = (PushBufferDataSource) ds;
	    delStreams = delegate.getStreams();
	    monitorStream = new MonitorStream(delStreams[0], this);
	    monitorStreams = new PushBufferStream[] {monitorStream};
	    controls = new Control[] {monitorStream};
	}
    }

    public Object [] getControls() {
	return controls;
    }

    public Object getControl(String value) {
        System.out.println("MonitorCDS.getCotrol : "+value);
	if (value.equals("jmfsample.MonitorStream") ||
	    value.equals("javax.media.control.MonitorControl")) {
            System.out.println("MonitorCDS.getCotrol : returning monitor " +value);
	    return monitorStream;
    }else{
            System.out.println("MonitorCDS.getCotrol : NOT returning monitor " +value);
	    return null;
    }
    }

    public javax.media.CaptureDeviceInfo getCaptureDeviceInfo() {
	return ((CaptureDevice)delegate).getCaptureDeviceInfo();
    }

    public FormatControl[] getFormatControls() {
	return ((CaptureDevice)delegate).getFormatControls();
    }

    public String getContentType() {
	return delegate.getContentType();
    }

    public void connect() throws IOException {
	if (delegate == null)
	    throw new IOException("Incompatible DataSource");
	// Delegate is already connected
    }

    public void disconnect() {
	monitorStream.setEnabled(false);
	delegate.disconnect();
    }

    public synchronized void start() throws IOException {
	startDelegate();
	delStarted = true;
    }

    public synchronized void stop() throws IOException {
	if (!monitorStream.isEnabled()) {
	    stopDelegate();
	}
	delStarted = false;
    }

    public Time getDuration() {
	return delegate.getDuration();
    }

    public PushBufferStream [] getStreams() {
	return monitorStreams;
    }

    void startDelegate() throws IOException {
	delegate.start();
    }

    void stopDelegate() throws IOException {
	delegate.stop();
    }

}