DataThread.java

Go to the documentation of this file.

package org.nees.daq;

import java.net.*;
import java.io.*;
import java.util.*;
import com.rbnb.sapi.*;

public class DataThread implements Runnable{

    private Socket         socket;
    private BufferedReader rd;
    private Thread theThread;
    private boolean running = false;
    
    private Hashtable channelTable = new Hashtable();
    
    public DataThread(Socket socket)
        throws IOException
    {
        rd = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    }
    
    public void start() 
    {
        if (theThread != null) return;
        theThread = new Thread(this);
        running = true;
        theThread.start();
    }
    
    public void stop()
    {
        running = false;        
    }

    public void run () {

        String fromDAQ;
        StringTokenizer st;
        ISOtoRbnbTime timestamp;
        double time;
        String channelName;
        double data;
        DaqListener channel;

        // System.out.println("Running thread for DAQ data");
        
        try {
            while(((fromDAQ = rd.readLine()) != null) && running) {
                //System.out.println("Line from DAQ: " + fromDAQ);
                
                if(fromDAQ.startsWith("driverid")) {
                    System.out.println("Skipping driverid: " + fromDAQ);
                }else {
                    // Want to split out the timestamp, all up to tab char
                    st = new StringTokenizer(fromDAQ, "\t\n");
                    
                    String tsString = st.nextToken();
                    timestamp = new ISOtoRbnbTime(tsString);
                    if (!timestamp.is_valid)
                    {
                        System.out.println("Warning: timestamp not valid: " + tsString);
                    }
                    time = timestamp.getValue();
                    
                    while (st.hasMoreTokens())
                    {
                        channelName = st.nextToken();
                        data = Double.parseDouble(st.nextToken());
                        channel = (DaqListener)channelTable.get(channelName);
                        if (channel != null)
                        {
                            channel.postData(channelName,time,data);
                        }
                    }
                }
            }
        }
        catch (Exception e) {
            System.out.println("Socket IO Error: " + e);
        }
        finally
        {
            theThread = null;
            running = false;
        }
    }
    
    public void addListener(String name, DaqListener l)
    {
        channelTable.put(name,l);
    }
    
    public void removeListener(String name)
    {
        channelTable.remove(name);
    }
    
    public boolean isRunning()
    {
        return running;
    }
}

---