uka.karmi.stream
Class StreamServer

java.lang.Object
  java.lang.Thread
      uka.karmi.rmi.ExecutionThread
          uka.karmi.stream.StreamServer

All Implemented Interfaces:

Constants, java.lang.Runnable

Direct Known Subclasses:

GMTechnology.GMThread, PSPTechnology.PSPThread, SocketTechnology.SocketThread

public abstract class StreamServer

extends ExecutionThread

implements Constants

Base class for server threads in stream-based technologies. A server thread accepts incoming remote calls in its service() method. After a call is received, it is dispatched to the appropriate server implementation object.

Author:

Bernhard Haumacher

See Also:

service(StreamServerConnection)

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields inherited from interface uka.karmi.rmi.server.Constants

APP_CALL, COLLECTIVE_OPERATION, DGC_ACK, DGC_CALL, DGC_CALL_ASYNC, MID_BARRIER, MID_COLLECTIVE_EXCHANGE, MID_COLLECTIVE_UPDATE, MID_EXCLUSIVE_LOCK, MID_EXCLUSIVE_UPDATE, MID_REQUEST_TICKET, MID_REQUEST_WAIT, MID_RMA, MID_SERVICE_CREATE_REPLICA, MID_SERVICE_GET_STUB, MID_SERVICE_INTERRUPT, MID_SERVICE_MIGRATE, MID_SERVICE_UPDATE_REFERENCES, MID_WAKEUP, SERVICE_CALL, SKELETON_EXTENSION, STUB_EXTENSION

Constructor Summary

StreamServer()

Method Summary

void	service(StreamServerConnection c) Main entry point for incoming calls in stream-based technologies.

Methods inherited from class uka.karmi.rmi.ExecutionThread

getClientHost

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamServer

public StreamServer()

Method Detail

service

public void service(StreamServerConnection c)
             throws java.lang.Throwable

Main entry point for incoming calls in stream-based technologies. Unmarshals the next call header (request type, object ID, method ID, thread ID) from the stream connection and initializes it. The stream connection is then dispatched using the CallHandler class.

Throws:

java.lang.Throwable

See Also:

CallHandler.dispatch(uka.karmi.rmi.CallHandler.CallbackOperation)