NettyNetwork

public class NettyNetwork extends ComponentDefinition
Author:Lars Kroll <lkroll@kth.se>

Fields

DATAGRAM_MAX

public static final int DATAGRAM_MAX

INITIAL_BUFFER_SIZE

static final int INITIAL_BUFFER_SIZE

MDC_KEY_ALT_IF

public static final String MDC_KEY_ALT_IF

MDC_KEY_IF

public static final String MDC_KEY_IF

MDC_KEY_PORT

public static final String MDC_KEY_PORT

RECV_BUFFER_SIZE

static final int RECV_BUFFER_SIZE

SEND_BUFFER_SIZE

static final int SEND_BUFFER_SIZE

STREAM_MAX

public static final int STREAM_MAX

bootstrapTCPClient

final Bootstrap bootstrapTCPClient

bootstrapUDTClient

final Bootstrap bootstrapUDTClient

boundUDTPort

volatile int boundUDTPort

channels

final ChannelManager channels

delayedHandler

Handler<SendDelayed> delayedHandler

dropHandler

Handler<DropDelayed> dropHandler

extLog

final Logger extLog

messages

final MessageQueueManager messages

msgHandler

Handler<Msg<?, ?>> msgHandler

notifyHandler

Handler<MessageNotify.Req> notifyHandler

self

final NettyAddress self

startHandler

Handler<Start> startHandler

statusHandler

Handler<ListeningStatus.Request> statusHandler

stopHandler

Handler<Stop> stopHandler

udtBufferSizes

final int udtBufferSizes

udtMSS

final int udtMSS

Constructors

NettyNetwork

public NettyNetwork(NettyInit init)

Methods

deliverMessage

protected void deliverMessage(Msg<?, ?> message, Channel c)

networkException

protected void networkException(NetworkException networkException)

networkStatus

protected void networkStatus(ConnectionStatus status)

notify

void notify(MessageNotify.Req notify)

notify

void notify(MessageNotify.Req notify, MessageNotify.Resp response)

sendUdpMessage

ChannelFuture sendUdpMessage(MessageWrapper msgw)

setCustomMDC

void setCustomMDC()

tearDown

public void tearDown()

trigger

void trigger(KompicsEvent event)