Package org.apache.hadoop.ozone.container.replication

Class ReplicationServer

java.lang.Object

org.apache.hadoop.ozone.container.replication.ReplicationServer

public class ReplicationServer
extends Object

Separated network server for server2server container replication.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ReplicationServer.ReplicationConfig	Replication-related configuration.

Constructor Summary

Constructors

Constructor	Description
ReplicationServer(ContainerController controller, ReplicationServer.ReplicationConfig replicationConfig, org.apache.hadoop.hdds.security.SecurityConfig secConf, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient caClient, ContainerImporter importer, String threadNamePrefix)

Method Summary

Modifier and Type	Method	Description
ThreadPoolExecutor	getExecutor()
int	getPort()
void	init()
void	setPoolSize(int size)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationServer

public ReplicationServer(ContainerController controller,
 ReplicationServer.ReplicationConfig replicationConfig,
 org.apache.hadoop.hdds.security.SecurityConfig secConf,
 org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient caClient,
 ContainerImporter importer,
 String threadNamePrefix)

Method Details

init

public void init()

start

public void start()
           throws IOException

Throws:

IOException

stop

public void stop()

getPort

public int getPort()

setPoolSize

public void setPoolSize(int size)

getExecutor

public ThreadPoolExecutor getExecutor()