Package org.fisco.bcos.sdk.network

Class NetworkImp

java.lang.Object

org.fisco.bcos.sdk.network.NetworkImp

All Implemented Interfaces:

Network

public class NetworkImp
extends java.lang.Object
implements Network

An implementation of Network

Constructor Summary

Constructors

Constructor	Description
NetworkImp(ConfigOption configOption, MsgHandler handler)

Method Summary

Modifier and Type	Method	Description
void	broadcast(Message out)	Broadcast message
java.util.Map<java.lang.String,io.netty.channel.ChannelHandlerContext>	getAvailableConnections()	Get available connection context
ConfigOption	getConfigOption()
java.util.List<ConnectionInfo>	getConnectionInfo()	Get connection information
int	getSslCryptoType()
void	removeConnection(java.lang.String peerIpPort)	Remove the connection if version negotiation failed
void	sendToPeer(Message out, java.lang.String peerIpPort)	Send to peer
void	setMsgHandleThreadPool(java.util.concurrent.ExecutorService threadPool)	Set thread pool
void	start()	Start connect peers
void	stop()	Exit gracefully

Methods inherited from class java.lang.Object

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

Constructor Details

NetworkImp

public NetworkImp(ConfigOption configOption, MsgHandler handler) throws ConfigException

Throws:

ConfigException

Method Details

getConfigOption

public ConfigOption getConfigOption()

Specified by:

getConfigOption in interface Network

getSslCryptoType

public int getSslCryptoType()

Specified by:

getSslCryptoType in interface Network

broadcast

public void broadcast(Message out)

Description copied from interface: Network

Broadcast message

Specified by:

broadcast in interface Network

Parameters:

out - the message to broadcast

sendToPeer

public void sendToPeer(Message out, java.lang.String peerIpPort) throws NetworkException

Description copied from interface: Network

Send to peer

Specified by:

sendToPeer in interface Network

Parameters:

out - the sent message

peerIpPort - the node to receive the message

Throws:

NetworkException - the network exception

getConnectionInfo

public java.util.List<ConnectionInfo> getConnectionInfo()

Description copied from interface: Network

Get connection information

Specified by:

getConnectionInfo in interface Network

Returns:

list of connection information

start

public void start() throws NetworkException

Description copied from interface: Network

Start connect peers

Specified by:

start in interface Network

Throws:

NetworkException - start the network exceptioned

getAvailableConnections

public java.util.Map<java.lang.String,io.netty.channel.ChannelHandlerContext> getAvailableConnections()

Description copied from interface: Network

Get available connection context

Specified by:

getAvailableConnections in interface Network

Returns:

the map between the peer endpoint and the channelHandlerContext

removeConnection

public void removeConnection(java.lang.String peerIpPort)

Description copied from interface: Network

Remove the connection if version negotiation failed

Specified by:

removeConnection in interface Network

Parameters:

peerIpPort - the peer connection to be removed

setMsgHandleThreadPool

public void setMsgHandleThreadPool(java.util.concurrent.ExecutorService threadPool)

Description copied from interface: Network

Set thread pool

Specified by:

setMsgHandleThreadPool in interface Network

Parameters:

threadPool - the threadpool to handle the network message

stop

public void stop()

Description copied from interface: Network

Exit gracefully

Specified by:

stop in interface Network