RpcServer.cpp File Reference

#include <gflags/gflags.h>
#include <folly/init/Init.h>
#include <wangle/service/Service.h>
#include <wangle/service/ExecutorFilter.h>
#include <wangle/service/ServerDispatcher.h>
#include <wangle/bootstrap/ServerBootstrap.h>
#include <wangle/channel/AsyncSocketHandler.h>
#include <wangle/codec/LengthFieldBasedFrameDecoder.h>
#include <wangle/codec/LengthFieldPrepender.h>
#include <wangle/channel/EventBaseHandler.h>
#include <folly/executors/CPUThreadPoolExecutor.h>
#include <wangle/example/rpc/ServerSerializeHandler.h>

Go to the source code of this file.

Classes
class	RpcService
class	RpcPipelineFactory

Typedefs
using	SerializePipeline = wangle::Pipeline< IOBufQueue &, Xtruct >

Functions
	DEFINE_int32 (port, 8080,"test server port")
int	main (int argc, char **argv)

Typedef Documentation

using SerializePipeline = wangle::Pipeline<IOBufQueue&, Xtruct>

Definition at line 38 of file RpcServer.cpp.

Function Documentation

DEFINE_int32	(	port	,
		8080	,
		"test server port"
	)

int main	(	int	argc,
		char **	argv
	)

Definition at line 89 of file RpcServer.cpp.

References wangle::ServerBootstrap< Pipeline >::bind(), wangle::ServerBootstrap< Pipeline >::childPipeline(), folly::init(), and wangle::ServerBootstrap< Pipeline >::waitForStop().

                                {
  folly::Init init(&argc, &argv);

  ServerBootstrap<SerializePipeline> server;
  server.childPipeline(std::make_shared<RpcPipelineFactory>());
  server.bind(FLAGS_port);
  server.waitForStop();

  return 0;
}