Enable rsocket stream handling in EdenServer

Summary: This diff allows watchman to connect to `EdenServer` over an rsocket stream.

Reviewed By: simpkins, strager

Differential Revision: D15900246

fbshipit-source-id: e4a99fcd7b9c75b6ad2c331c1bbf13d22f78cfd7
This commit is contained in:
Jon Maltiel Swenson 2019-06-19 13:47:56 -07:00 committed by Facebook Github Bot
parent 4f481f4134
commit df6ac2b2a8

View File

@ -21,6 +21,7 @@
#include <signal.h>
#include <thrift/lib/cpp/concurrency/ThreadManager.h>
#include <thrift/lib/cpp2/server/ThriftServer.h>
#include <thrift/lib/cpp2/transport/rsocket/server/RSRoutingHandler.h>
#include "common/stats/ServiceData.h"
#include "eden/fs/config/CheckoutConfig.h"
@ -1078,6 +1079,8 @@ Future<Unit> EdenServer::createThriftServer() {
server_->setNumIOWorkerThreads(FLAGS_thrift_num_workers);
server_->setEnableCodel(FLAGS_thrift_enable_codel);
server_->setMinCompressBytes(FLAGS_thrift_min_compress_bytes);
server_->addRoutingHandler(
std::make_unique<apache::thrift::RSRoutingHandler>());
server_->enableRocketServer(false);
handler_ = make_shared<EdenServiceHandler>(this);