org.nd4j.parameterserver.distributed.v2.transport.impl

Class DummyTransport.Connector

java.lang.Object

org.nd4j.parameterserver.distributed.v2.transport.impl.DummyTransport.Connector

Enclosing class:

DummyTransport

public static class DummyTransport.Connector
extends Object

This class is written to mimic network connectivity locally

Constructor Summary

Constructors

Constructor and Description
Connector()

Method Summary

Modifier and Type	Method and Description
void	blockUntilFinished()
void	dropConnection(String... ids)
ExecutorService	executorService()
void	register(Transport... transports)
void	transferMessage(@NonNull VoidMessage message, @NonNull String senderId, @NonNull String targetId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Connector

public Connector()

Method Detail

register

public void register(Transport... transports)

blockUntilFinished

public void blockUntilFinished()
                        throws InterruptedException

Throws:

InterruptedException

transferMessage

public void transferMessage(@NonNull
                            @NonNull VoidMessage message,
                            @NonNull
                            @NonNull String senderId,
                            @NonNull
                            @NonNull String targetId)

executorService

public ExecutorService executorService()

dropConnection

public void dropConnection(@NonNull
                           String... ids)