DaqToRbnb.java

package org.nees.daq;

import java.io.IOException;
import java.net.UnknownHostException;
import java.net.Socket;
import java.util.Hashtable;
import java.util.Calendar;
import java.util.GregorianCalendar;
import com.rbnb.sapi.*;

import com.rbnb.utility.ArgHandler; //for argument parsing
import com.rbnb.utility.RBNBProcess; //alternative to System.exit, so
                                       //don't bring down servlet engine
//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 DaqToRbnb {

    private ControlPort controlPort = null;
    private DataThread dataThread = null;
    private ChannelEntry[] channels = new ChannelEntry[0];
    
    private static final String DEFAULT_DAQ_SERVER = "localhost";
    private static final int DEFAULT_DAQ_CONTROL_PORT = 55055;
    private static final int DEFAULT_DAQ_DATA_PORT = 55056;
    
    private String daqServerName = DEFAULT_DAQ_SERVER;
    private int daqControlPort = DEFAULT_DAQ_CONTROL_PORT;
    private int daqDataPort = DEFAULT_DAQ_DATA_PORT;
    
    private static final String DEFAULT_RBNB_SERVER = "localhost";
    private static final int DEFAULT_RBNB_PORT = 3333;
    private static final String DEFAULT_RBNB_SOURCE_NAME = "FromDAQ";

    private String rbnbServerName = DEFAULT_RBNB_SERVER;
    private int rbnbServerPort = DEFAULT_RBNB_PORT;
    private String rbnbSourceName = DEFAULT_RBNB_SOURCE_NAME;
    
    private static final int DEFAULT_CACHE_SIZE=100;
    private int cacheSize = DEFAULT_CACHE_SIZE;

    private Socket controlSocket = null;
    private Socket dataSocket = null;
    
    private Source source;
    
    private double timeOffset = 0.0; // in seconds

    public static final void main(String[] args)
    {
        
        System.out.println("*************************************************");
        System.out.println("* This version of the code is obsoleate, please *");
        System.out.println("* use org.nees.rbnb.DaqToRbnb instead. Also, be *");
        System.out.println("* aware that the parameters may have changed.   *");
        System.out.println("*************************************************");
        
        return;
/*  
        try
        {
            DaqToRbnb control = new DaqToRbnb(args);
            control.startDaqConnections(); // note both connects must be made first
            control.connectToDaqControl();
            control.buildChannels();
            control.start();    
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
*/
    }

    public DaqToRbnb(String[] args)
    {
        computeDefaultTimeOffset();
        parseArgs(args);
    }
    
    private void computeDefaultTimeOffset() {
        Calendar calendar = new GregorianCalendar();
        long tz = calendar.get(Calendar.ZONE_OFFSET);
        long dt = calendar.get(Calendar.DST_OFFSET);
        System.out.println("Default time: Time Zone offset: "
               + (-((double)(tz/1000))/(60.0*60.0))); // in hours
        System.out.println("Defalut time: Daylight Savings Time offest (in hours): "
               + (-((double)(dt/1000))/(60.0*60.0))); // in hours
        // Time zone offset
        timeOffset = - (double)((tz + dt)/1000); // in seconds 
    }

    private void printUsage() {
        System.out.println("DaqToRbnb: usage is...");       
        System.out.println("DaqToRbnb ");
        System.out.println("[-q DAQ Server *" + DEFAULT_DAQ_SERVER + "] ");
        System.out.println("[-c DAQ Control Port *" + DEFAULT_DAQ_CONTROL_PORT + "] ");
        System.out.println("[-d DAQ Data Port *" + DEFAULT_DAQ_DATA_PORT + "] ");
        System.out.println("[-s RBNB Server *" + DEFAULT_RBNB_SERVER + "] ");
        System.out.println("[-p RBNB Port *" + DEFAULT_RBNB_PORT + "] ");
        System.out.println("[-n RBNB Source Name *" + DEFAULT_RBNB_SOURCE_NAME + "] ");
        System.out.println("[-z cache size *" + DEFAULT_CACHE_SIZE + "]");
        double hours = timeOffset/(60.0*60.0);
        System.out.println("[-o time offset, floating point, hours to GMT *"+ hours +"]");
        System.out.println();
    }

    private void parseArgs (String[] args)
    {
        String a;
        //parse args
        try {
            ArgHandler ah=new ArgHandler(args);
            if (ah.checkFlag('h')) {
                printUsage();
                RBNBProcess.exit(0);                
            }
            if (ah.checkFlag('q')) {
                a=ah.getOption('q');
                if (a!=null) daqServerName=a;
            }
            if (ah.checkFlag('c')) {
                a=ah.getOption('c');
                if (a!=null) daqControlPort=Integer.parseInt(a);
            }
            if (ah.checkFlag('d')) {
                a=ah.getOption('d');
                if (a!=null) daqDataPort=Integer.parseInt(a);
            }
            if (ah.checkFlag('s')) {
                a=ah.getOption('s');
                if (a!=null) rbnbServerName=a;
            }
            if (ah.checkFlag('p')) {
                a=ah.getOption('p');
                if (a!=null) rbnbServerPort=Integer.parseInt(a);
            }
            if (ah.checkFlag('n')) {
                a=ah.getOption('n');
                if (a!=null) rbnbSourceName=a;
            }
            if (ah.checkFlag('z')) {
                a=ah.getOption('z');
                if (a!=null)
                try
                {
                    Integer i =  new Integer(a);
                    int value = i.intValue();
                    cacheSize = value;
                }
                catch (Exception ignore) {} 
            }
            if (ah.checkFlag('o')) {
                a=ah.getOption('o');
                if (a!=null)
                try
                {
                    double value =  Double.parseDouble(a); // in hours
                    timeOffset = (long)(value*60.0*60.0); // in seconds
                }
                catch (Exception ignore) {} 
            }
        } catch (Exception e) {
            System.err.println("DaqToRbnb argument exception "+e.getMessage());
            e.printStackTrace();
            RBNBProcess.exit(0);                
        }
        System.out.println("Starting DaqToRbnb with");
        System.out.println("  DAQ: server = " + daqServerName + 
            "; control port = "+ daqControlPort + "; data port = " + daqDataPort );
        System.out.println("  RBNB: server = " + rbnbServerName + 
            "; port = "+ rbnbServerPort + "; source name = " + rbnbSourceName );
        System.out.println("  Time offset (in seconds) = " + timeOffset
            + ", which is " + timeOffset/(60.0*60.0) + " hours");
        System.out.println("  Use DaqToRbnb -h to see optional parameters");
    }
    
    
    private void startDaqConnections()
        throws UnknownHostException, IOException
    {
        controlSocket = new Socket(daqServerName,daqControlPort);

        try
        {
            Thread.sleep(1000);
        } catch (Exception ignore) {}
        System.out.println("...Continued");
        
        dataSocket = new Socket(daqServerName,daqDataPort);
    }

    private void connectToDaqControl()
        throws UnknownHostException, IOException
    {
        controlPort = null;
        
        ControlPort port = null;

        // use a local vaiable in case there is an exception
        port = new ControlPort(controlSocket);

        System.out.println("Pause for one sec after ControlPort...");
        try
        {
            Thread.sleep(1000);
        } catch (Exception ignore) {}
        System.out.println("...Continued");

        controlPort = port;
    }

    private void buildChannels()
        throws IOException, SAPIException
    {
        if (controlPort == null) return;

        dataThread = new DataThread(dataSocket);
    
        source=new Source(cacheSize, "none", 0);
        source.OpenRBNBConnection(rbnbServerName + ":" + rbnbServerPort, rbnbSourceName);
    
        String[] channelList = controlPort.getChannels();
        
        channels = new ChannelEntry[channelList.length];

        for (int i = 0; i < channelList.length; i++)
        {
            String name = channelList[i];
            channels[i] = new ChannelEntry(name);
            dataThread.addListener(name, channels[i]);
        }
        
    }

    private void start() throws IOException
    {
        if (controlPort == null) return;

        if (dataThread == null) return;

        for (int i = 0; i < channels.length; i++)
        {
            channels[i].subscribe();
        }

        System.out.println("Startint data Thread");
        dataThread.start();
        
    }
    
    private class ChannelEntry implements DaqListener
    {
            
        String name;
        ChannelMap map;
        boolean subscribed = false;
        int index;

        ChannelEntry(String name) throws SAPIException
        {
            this.name = name;
            map = new ChannelMap();
            index = map.Add(name);
            System.out.println("RBNB: Connection made to sever = "
                + rbnbServerName + ":" + rbnbServerPort + 
                " as source = " + rbnbSourceName + 
                " with channel = " + name + ".");
        }

        void subscribe() throws IOException
        {
            controlPort.subscribe(name);
            subscribed = true;
        }
        
        void unsubscribe() throws IOException
        {
            controlPort.unsubscribe(name);
            subscribed = false;
        }
    
        /*
            @brief Put DAQ data into turbine
            
            Implements the data listener; data arrives from DAQ and is put on RBNB.
            
            @param name Channel name
            @param time timestamp, RBNB format, in seconds
            @param data DAQ datum
            @see DaqListener#postData
            @bug the timeOffset was added when it was discovered that the DAQ controller
            did not know about time zones and was using the system time from the machine
            of origin as THE TIME.
        */
        public void postData(String name, double  time, double data)
            throws SAPIException
        {
            if (!name.equals(this.name)) return;
            
            map.PutTime(time + timeOffset, 0.0); // in seconds
            
            //map.PutTimeAuto("timeofday");
            double dataArray[] = new double[1];
            dataArray[0] = data;
            map.PutDataAsFloat64(index,dataArray);
            // System.out.println("Put Data, " + name + ": " + data);   
            source.Flush(map);
        }
    }
}

---