scala.actors.remote

class TcpService

[source: scala/actors/remote/TcpService.scala]

class TcpService(port : Int)
extends java.lang.Thread with Service
Value Summary
val serializer : JavaSerializer
Values and Variables inherited from Service
kernel
Method Summary
def connect (n : Node) : TcpServiceWorker
def disconnectNode (n : Node) : Unit
def getConnection (n : Node) : Option[TcpServiceWorker]
def isConnected (n : Node) : Boolean
def isReachable (node : Node) : Boolean
def node : Node
def nodeDown (mnode : Node) : Unit
override def run : Unit
def send (node : Node, data : Array[Byte]) : Unit
Sends a byte array to another node on the network. If the node is not yet up, up to TcpService.BufSize messages are buffered.
def terminate : Unit
Methods inherited from java.lang.Thread
java.lang.Thread.start, java.lang.Thread.stop, java.lang.Thread.stop, java.lang.Thread.interrupt, java.lang.Thread.isInterrupted, java.lang.Thread.destroy, java.lang.Thread.isAlive, java.lang.Thread.suspend, java.lang.Thread.resume, java.lang.Thread.setPriority, java.lang.Thread.getPriority, java.lang.Thread.setName, java.lang.Thread.getName, java.lang.Thread.getThreadGroup, java.lang.Thread.countStackFrames, java.lang.Thread.join, java.lang.Thread.join, java.lang.Thread.join, java.lang.Thread.setDaemon, java.lang.Thread.isDaemon, java.lang.Thread.checkAccess, java.lang.Thread.toString, java.lang.Thread.getContextClassLoader, java.lang.Thread.setContextClassLoader, java.lang.Thread.getStackTrace, java.lang.Thread.getId, java.lang.Thread.getState, java.lang.Thread.getUncaughtExceptionHandler, java.lang.Thread.setUncaughtExceptionHandler
Methods inherited from AnyRef
getClass, hashCode, equals, clone, notify, notifyAll, wait, wait, wait, finalize, ==, !=, eq, ne, synchronized
Methods inherited from Any
==, !=, isInstanceOf, asInstanceOf
Value Details
val serializer : JavaSerializer
Overrides
Service.serializer

Method Details
def node : Node
Overrides
Service.node

def send(node : Node, data : Array[Byte]) : Unit
Sends a byte array to another node on the network. If the node is not yet up, up to TcpService.BufSize messages are buffered.
Overrides
Service.send

def terminate : Unit
Overrides
Service.terminate

override def run : Unit
Overrides
java.lang.Thread.java.lang.Thread.run

def getConnection(n : Node) : Option[TcpServiceWorker]

def isConnected(n : Node) : Boolean

def connect(n : Node) : TcpServiceWorker

def disconnectNode(n : Node) : Unit

def isReachable(node : Node) : Boolean

def nodeDown(mnode : Node) : Unit