mystore/driver.cpp at master · gwint/mystore · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
#include "replica.hpp"

#include "argparse.hpp"

#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>
#include <thrift/transport/TSocket.h>
#include <thrift/transport/TTransport.h>
#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TThreadedServer.h>

int
main(int argc, const char** argv) {
    #ifndef NDEBUG
    std::cout << "The debug flag is set!" << std::endl;
    #endif

    ArgumentParser parser;

    parser.addArgument("--listeningport", 1, false);
    parser.addArgument("--clustermembership", '+', false);

    parser.parse(argc, argv);

    unsigned int portToUse = atoi(parser.retrieve<std::string>("listeningport").c_str());
    std::vector<std::string> clusterMembers = parser.retrieve<std::vector<std::string>>("clustermembership");

    std::shared_ptr<Replica> handler(new Replica(portToUse, clusterMembers));
    std::shared_ptr<apache::thrift::TProcessor> processor(new ReplicaServiceProcessor(handler));
    std::shared_ptr<apache::thrift::transport::TServerTransport> serverTransport(new apache::thrift::transport::TServerSocket(portToUse));
    std::shared_ptr<apache::thrift::transport::TTransportFactory> transportFactory(new apache::thrift::transport::TBufferedTransportFactory());
    std::shared_ptr<apache::thrift::protocol::TProtocolFactory> protocolFactory(new apache::thrift::protocol::TBinaryProtocolFactory());

    apache::thrift::server::TThreadedServer server(processor, serverTransport, transportFactory, protocolFactory);
    server.serve();

    return 0;
}