mirror of
https://github.com/valitydev/thrift.git
synced 2024-11-07 10:48:51 +00:00
49ff8b123a
To ensure there are no include path collisions the C and C++ header include paths should include 'thrift' as the root leaf. This will prevent having to place /usr/include/thrift into the compilers include header search path, which might otherwise result in the compiler accidentally picking up headers that it shouldn't. e.g. #include <foo/bar.h> should be #include <thrift/foo/bar.h> Change-Id: I48f2b0f549bda0fc81e85506ac857adc800b98a1 git-svn-id: https://svn.apache.org/repos/asf/thrift/trunk@1325674 13f79535-47bb-0310-9956-ffa450edef68
41 lines
923 B
C++
41 lines
923 B
C++
#include <iostream>
|
|
#include <cstdlib>
|
|
#include <thrift/protocol/TBinaryProtocol.h>
|
|
|
|
#include "zmq.hpp"
|
|
#include "TZmqClient.h"
|
|
#include "Storage.h"
|
|
|
|
using boost::shared_ptr;
|
|
using apache::thrift::transport::TZmqClient;
|
|
using apache::thrift::protocol::TBinaryProtocol;
|
|
|
|
int main(int argc, char** argv) {
|
|
const char* endpoint = "tcp://127.0.0.1:9090";
|
|
int socktype = ZMQ_REQ;
|
|
int incr = 0;
|
|
if (argc > 1) {
|
|
incr = atoi(argv[1]);
|
|
if (incr) {
|
|
socktype = ZMQ_DOWNSTREAM;
|
|
endpoint = "tcp://127.0.0.1:9091";
|
|
}
|
|
}
|
|
|
|
zmq::context_t ctx(1);
|
|
shared_ptr<TZmqClient> transport(new TZmqClient(ctx, endpoint, socktype));
|
|
shared_ptr<TBinaryProtocol> protocol(new TBinaryProtocol(transport));
|
|
StorageClient client(protocol);
|
|
transport->open();
|
|
|
|
if (incr) {
|
|
client.incr(incr);
|
|
usleep(50000);
|
|
} else {
|
|
int value = client.get();
|
|
std::cout << value << std::endl;
|
|
}
|
|
|
|
return 0;
|
|
}
|