PictureSource.java

/*
 * This RBNB object supplies a "psudo video" stream by sending
 * a series of JPG images.
 * 
 * Created on Feb 5, 2004
 *  Derived from Axis Source (Dec 12, 2003) by Jason P. Hanley
 */
package org.nees.rbnb;

import java.awt.Image;
import java.awt.Toolkit;
import java.awt.MediaTracker;
import java.awt.Component;
import java.net.URL;

import java.io.FileInputStream;
import java.io.File;
import java.io.IOException;

import java.net.URL;
import java.net.URLConnection;
import java.net.MalformedURLException;

import com.rbnb.sapi.ChannelMap;
import com.rbnb.sapi.Source;
import com.rbnb.sapi.SAPIException;

import COM.Creare.Utility.ArgHandler; //for argument parsing
import COM.Creare.Utility.RBNBProcess; //alternative to System.exit, so
                                       //don't bring down servlet engine

public class PictureSource{
    private byte[][] fileBuffer;
    private String[] text;
    private int current = 0;
    private Thread timerThread = null;
    private int channelId = -1;
    private Source source = null;   
    private ChannelMap cmap = null;

    private static final String SERVER = "localhost:3333";
    private static final String SOURCE_NAME = "FakeVideoSource";
    private static final String CHANNEL_NAME = "Duke";
    private static final String PICTURE_PATH = "./duke/Duke";
    private static final int PICTURE_COUNT = 10;
    private static final long TIMER_INTERVAL=1000;
    
    private String server = SERVER;
    private String sourceName = SOURCE_NAME;
    private String channelName = CHANNEL_NAME;
    private String picturePath = PICTURE_PATH;
    private int pictureCount = PICTURE_COUNT;
    private long timerInterval = TIMER_INTERVAL;

    private void printUsage() {
        System.out.println("PictureSource: usage is...");       
        System.out.print("PictureSource ");
        System.out.print("[-s server_hostname *localhost:3333] ");
        System.out.print("[-n source_name *FakeVideoSource] ");
        System.out.print("[-c channel_name *Duke] ");
        System.out.print("[-p pathname_for_pictures *./duke/Duke]");
        System.out.print("[-k picture_count *10]");
        System.out.print("[-t timer_interval *1000]");
        System.out.println();
    }
    
    public PictureSource(String[] args) {
        //parse args
        try {
            ArgHandler ah=new ArgHandler(args);
            if (ah.checkFlag('h')) {
                printUsage();
                RBNBProcess.exit(0);                
            }
            if (ah.checkFlag('s')) {
                String a=ah.getOption('s');
                if (a!=null) server=a;
            }
            if (ah.checkFlag('n')) {
                String a=ah.getOption('n');
                if (a!=null) sourceName=a;
            }
            if (ah.checkFlag('c')) {
                String a=ah.getOption('c');
                if (a!=null) channelName=a;
            }
            if (ah.checkFlag('p')) {
                String a=ah.getOption('p');
                if (a!=null) picturePath=a;
            }
            if (ah.checkFlag('k')) {
                String a=ah.getOption('k');
                try {
                    if (a!=null) pictureCount=Integer.parseInt(a);
                } catch (Exception ignore) {}
            }
            if (ah.checkFlag('t')) {
                String a=ah.getOption('t');
                try {
                    if (a!=null) timerInterval=Long.parseLong(a);
                } catch (Exception ignore) {}
            }
        } catch (Exception e) {
            System.err.println("PictureSource argument exception "+e.getMessage());
            e.printStackTrace();
            RBNBProcess.exit(0);
        }
        
        System.out.println("Starting PictureSource on " + server + " as " + sourceName);
        System.out.println("  Channel name = " + channelName + "; timer interval = " + timerInterval);
        System.out.println("  Using images " + picturePath + "01.jpg"
                + " through " + picturePath 
                + (pictureCount<10?("0" + pictureCount):("" + pictureCount)) + ".jpg");
        System.out.println("  Use PictureSource -h to see optional parameters");
    }
    
    public boolean loadImageFiles() {
        fileBuffer = new byte[10][];
        text = new String[10];

        current = 0;
        
        URL fig = null;
        try {
            for (int i = 1; i < (pictureCount + 1); i++ )
            {
                text[i-1] = picturePath + ((i<10)?("0" + i):(""+i)) + ".jpg";
            }
            
            for (int i = 0; i < text.length; i++)
            {
                File f = new File(text[i]);
                FileInputStream in = new FileInputStream(f);
                int fileLength = (int)f.length();
                byte[] buffer = new byte[fileLength];
                in.read(buffer);
                fileBuffer[i] = buffer;
                System.out.println("Read " + text[i] + " for " + fileLength + " bytes");
            }
    
            return true;
        }
        catch (Exception e)
        {
            System.out.println("Loading Image files failed at " + current + "; " + e);
            e.printStackTrace();
            return false;
        }
    }

    private byte[] next()
    {
        byte[] ret = null;
        int l = (int)fileBuffer.length;
        current = ( current + 1 ) % l;
        ret = fileBuffer[current];
        return ret;
    }
    
    private void exec()
    {
        readySource();
        if (source != null)
            startThread();
    }
    
    private void readySource() {
        source = new Source(30, "none", 0);
        try {
            source.OpenRBNBConnection(server, sourceName);
        } catch (SAPIException e) {
            System.err.println("Failed to connect to RBNB server.");
            source = null;
            return;
        }

        cmap = new ChannelMap();
        cmap.PutTimeAuto("timeofday");
        channelId = -1;
        try {
            channelId = cmap.Add(channelName);
        } catch (SAPIException e) {
            System.err.println("Failed to add video channel to channel map.");
            source.CloseRBNBConnection();
            source = null;
            cmap = null;
            return;
        }
        cmap.PutMime(channelId, "image/jpeg");
        System.out.println("ChannelId = " + channelId);
    } // readySource

    private void startThread() {
        
      // Use this inner class to hide the public run method
      Runnable r = new Runnable() {
        public void run() {
          runWork();
        }
      };
      timerThread = new Thread(r, "Timer");
      timerThread.start();
   }

    private void runWork ()
    {
        while(true)
        {
            if (!oneStep()) return;
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                return;
            }
        }
    }
            
    private boolean oneStep()
    {
        try{
            byte[] imageData = next();
            cmap.PutDataAsByteArray(channelId, imageData);
            source.Flush(cmap);
            System.out.println("On channel " + channelId + ": sent image file " + text[current] + " for "
                + imageData.length + " bytes");
        } catch (Exception e){
            System.err.println("Failed to send image " + current);
            e.printStackTrace();
            source.CloseRBNBConnection();
            source = null;
            cmap = null;            
            return false;
        }
        return true;
    }
    
    public static void main(String[] args) {
        PictureSource p = new PictureSource(args);
        if (p.loadImageFiles())
        {
            p.exec();
        }
    }
}

---