17 #include <gflags/gflags.h> 25 using namespace folly;
37 std::cout <<
"handling " << msg << std::endl;
38 write(ctx, msg +
"\r\n");
46 std::shared_ptr<AsyncTransportWrapper> sock)
override {
51 pipeline->addBack(EchoHandler());
61 server.
childPipeline(std::make_shared<EchoPipelineFactory>());
62 server.
bind(FLAGS_port);
Pipeline< IOBufQueue &, std::string > EchoPipeline
void write(const T &in, folly::io::Appender &appender)
void bind(folly::AsyncServerSocket::UniquePtr s)
—— Concurrent Priority Queue Implementation ——
DEFINE_int32(http_port, 11000,"Port to listen on with HTTP protocol")
void read(Context *ctx, std::string msg) override
ServerBootstrap * childPipeline(std::shared_ptr< PipelineFactory< Pipeline >> factory)
EchoPipeline::Ptr newPipeline(std::shared_ptr< AsyncTransportWrapper > sock) override
void init(int *argc, char ***argv, bool removeFlags)
std::shared_ptr< Pipeline > Ptr
int main(int argc, char *argv[])