| Package | Description |
|---|---|
| org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs
|
| org.apache.reef.wake.remote.impl | |
| org.apache.reef.wake.remote.transport | |
| org.apache.reef.wake.remote.transport.netty |
| Modifier and Type | Method and Description |
|---|---|
Link<byte[]> |
NamingMessage.getLink()
Gets a link
|
| Modifier and Type | Method and Description |
|---|---|
void |
NamingMessage.setLink(Link<byte[]> link)
Sets the link
|
| Modifier and Type | Method and Description |
|---|---|
Link<byte[]> |
TransportEvent.getLink()
Returns the link associated with the event
which can be used to write back to the client
without creating a new link
|
| Constructor and Description |
|---|
TransportEvent(byte[] data,
Link<byte[]> link)
Constructs the transport even object using link to
initialize local and remote address if link not null
|
| Modifier and Type | Method and Description |
|---|---|
<T> Link<T> |
Transport.get(SocketAddress remoteAddr)
Returns a link for the remote address if already cached; otherwise, returns null
|
<T> Link<T> |
Transport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns
When it opens a link for the remote address, only one attempt for the address is made at a given time
|
| Modifier and Type | Class and Description |
|---|---|
class |
NettyLink<T>
Link implementation with Netty
|
| Modifier and Type | Method and Description |
|---|---|
<T> Link<T> |
NettyMessagingTransport.get(SocketAddress remoteAddr)
Returns a link for the remote address if already cached; otherwise, returns null
|
<T> Link<T> |
NettyMessagingTransport.open(SocketAddress remoteAddr,
Encoder<? super T> encoder,
LinkListener<? super T> listener)
Returns a link for the remote address if cached; otherwise opens, caches and returns
When it opens a link for the remote address, only one attempt for the address is made at a given time
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.