nups
Class InputServer

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--nups.InputServer
All Implemented Interfaces:
java.lang.Runnable

public class InputServer
extends java.lang.Thread

Manage a thread pool for incoming connections

See Also:
InputServerThread

Field Summary
(package private)  java.util.Vector connections
           
(package private)  nupsApp parent
           
(package private)  int port
           
(package private)  java.util.Vector sleepers
           
(package private)  int threads
           
 
Fields inherited from class java.lang.Thread
inheritableThreadLocals, MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY, threadLocals
 
Constructor Summary
InputServer(nupsApp parent, int port, int threads)
           
 
Method Summary
 void addSample(int id, java.sql.Timestamp time, int value)
           
 void end()
           
 void messageAdd(java.lang.String message)
           
 void run()
           
 void start()
           
 
Methods inherited from class java.lang.Thread
, activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

threads

int threads

port

int port

connections

java.util.Vector connections

sleepers

java.util.Vector sleepers

parent

nupsApp parent
Constructor Detail

InputServer

public InputServer(nupsApp parent,
                   int port,
                   int threads)
Method Detail

start

public void start()
Overrides:
start in class java.lang.Thread

end

public void end()

messageAdd

public void messageAdd(java.lang.String message)

addSample

public void addSample(int id,
                      java.sql.Timestamp time,
                      int value)

run

public void run()
Overrides:
run in class java.lang.Thread