org.corfudb.infrastructure

Class CorfuServer

java.lang.Object

org.corfudb.infrastructure.CorfuServer

public class CorfuServer
extends Object

This is the new Corfu server single-process executable.

The command line options are documented in the USAGE variable.

Created by mwei on 11/30/15.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CorfuServer.BootstrapConfigurer A functional interface for receiving and configuring a ServerBootstrap.

Constructor Summary

Constructors

Constructor and Description
CorfuServer()

Method Summary

Modifier and Type	Method and Description
static void	cleanShutdown(List<AbstractServer> servers) Attempt to cleanly shutdown all the servers.
static void	configureBootstrapOptions(ServerContext context, io.netty.bootstrap.ServerBootstrap bootstrap) Configure server bootstrap per-channel options, such as TCP options, etc.
static void	main(String[] args) Main program entry point.
static void	restartServer(ServerContext serverContext, boolean resetData) Cleanly shuts down the server and restarts.
static io.netty.channel.ChannelFuture	startAndListen(io.netty.channel.EventLoopGroup bossGroup, io.netty.channel.EventLoopGroup workerGroup, CorfuServer.BootstrapConfigurer bootstrapConfigurer, ServerContext context, NettyServerRouter router, String address, int port) Start the Corfu server and bind it to the given port using the provided channelType.
static void	startServer(Map<String,Object> opts, boolean bindToAllInterfaces) Creates all the components of the Corfu Server.

Methods inherited from class java.lang.Object

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

Constructor Detail

CorfuServer

public CorfuServer()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Main program entry point.

Parameters:

args - command line argument strings

Throws:

Exception

startServer

public static void startServer(Map<String,Object> opts,
                               boolean bindToAllInterfaces)

Creates all the components of the Corfu Server. Starts the Server Router.

Parameters:

opts - Options passed by the user.

startAndListen

public static io.netty.channel.ChannelFuture startAndListen(@Nonnull
                                                            io.netty.channel.EventLoopGroup bossGroup,
                                                            @Nonnull
                                                            io.netty.channel.EventLoopGroup workerGroup,
                                                            @Nonnull
                                                            CorfuServer.BootstrapConfigurer bootstrapConfigurer,
                                                            @Nonnull
                                                            ServerContext context,
                                                            @Nonnull
                                                            NettyServerRouter router,
                                                            String address,
                                                            int port)

Start the Corfu server and bind it to the given port using the provided channelType. It is the callers' responsibility to shutdown the EventLoopGroups. For implementations which listen on multiple ports, EventLoopGroups may be reused.

Parameters:

bossGroup - The "boss" EventLoopGroup which services incoming connections.

workerGroup - The "worker" EventLoopGroup which services incoming requests.

bootstrapConfigurer - A CorfuServer.BootstrapConfigurer which will receive the ServerBootstrap to set options.

context - A ServerContext which will be used to configure the server.

router - A NettyServerRouter which will process incoming messages.

port - The port the ServerChannel will be created on.

Returns:

A ChannelFuture which can be used to wait for the server to be shutdown.

configureBootstrapOptions

public static void configureBootstrapOptions(@Nonnull
                                             ServerContext context,
                                             @Nonnull
                                             io.netty.bootstrap.ServerBootstrap bootstrap)

Configure server bootstrap per-channel options, such as TCP options, etc.

Parameters:

context - The ServerContext to use.

bootstrap - The ServerBootstrap to be configured.

restartServer

public static void restartServer(ServerContext serverContext,
                                 boolean resetData)

Cleanly shuts down the server and restarts.

Parameters:

serverContext - Server Context.

resetData - Resets and clears all data if True.

cleanShutdown

public static void cleanShutdown(@Nonnull
                                 List<AbstractServer> servers)

Attempt to cleanly shutdown all the servers.