org.apache.spark.rpc.netty

Class SharedMessageLoop

Object

org.apache.spark.rpc.netty.MessageLoop

org.apache.spark.rpc.netty.SharedMessageLoop

All Implemented Interfaces:

Logging

public class SharedMessageLoop
extends MessageLoop

A message loop that serves multiple RPC endpoints, using a shared thread pool.

Constructor Summary

Constructors

Constructor and Description
SharedMessageLoop(SparkConf conf, org.apache.spark.rpc.netty.Dispatcher dispatcher, int numUsableCores)

Method Summary

Modifier and Type	Method and Description
void	post(String endpointName, InboxMessage message)
void	register(String name, RpcEndpoint endpoint)
void	unregister(String name)

Methods inherited from class org.apache.spark.rpc.netty.MessageLoop

PoisonPill, stop

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.internal.Logging

initializeForcefully, initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

SharedMessageLoop

public SharedMessageLoop(SparkConf conf,
                         org.apache.spark.rpc.netty.Dispatcher dispatcher,
                         int numUsableCores)

Method Detail

post

public void post(String endpointName,
                 InboxMessage message)

Specified by:

post in class MessageLoop

register

public void register(String name,
                     RpcEndpoint endpoint)

unregister

public void unregister(String name)

Specified by:

unregister in class MessageLoop