source: ntrip/trunk/GnssCenter/thrift/test2/server.cpp@ 4942

#include <iostream>
#include <string>

#include <thrift/protocol/TBinaryProtocol.h>
#include <thrift/server/TSimpleServer.h>
#include <thrift/transport/TServerSocket.h>
#include <thrift/transport/TBufferTransports.h>

#include "gen-cpp/myService.h"

using namespace std;
using namespace boost;
using namespace ::apache::thrift;
using namespace ::apache::thrift::protocol;
using namespace ::apache::thrift::transport;
using namespace ::apache::thrift::server;

class myServiceHandler : virtual public myServiceIf {
 public:
  myServiceHandler() {}
  void answer(std::string& /* answ */, const std::string& /* question */) {
    // implemented on the client-side only
  }
};

class myServerEventHandler : virtual public TServerEventHandler {
 public:
  myServerEventHandler() {};
  virtual void* createContext(shared_ptr<TProtocol> input,
                              shared_ptr<TProtocol> output) {
    void* context = TServerEventHandler::createContext(input, output);
    cout << "createContext " << context << endl;

    string* str = static_cast<string*>(context);
    cout << "str = " << str << endl;

    return context;
  }
};

int main(int argc, char **argv) {
  int port = 9090;
  shared_ptr<myServiceHandler>  handler(new myServiceHandler());
  shared_ptr<TProcessor>        processor(new myServiceProcessor(handler));
  shared_ptr<TServerSocket>     serverTransport(new TServerSocket(port));
  shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory());
  shared_ptr<TProtocolFactory>  protocolFactory(new TBinaryProtocolFactory());

  TSimpleServer server(processor, serverTransport, 
                       transportFactory, protocolFactory);

  shared_ptr<TServerEventHandler> eventHandler(new myServerEventHandler());
  server.setServerEventHandler(eventHandler);

  server.serve();
  return 0;
}