You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/12/13 22:09:21 UTC
[08/51] [partial] airavata-php-gateway git commit: removing files
from wrong merge
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocol.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocol.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocol.h
deleted file mode 100644
index d6ecc0f..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocol.h
+++ /dev/null
@@ -1,697 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_PROTOCOL_TPROTOCOL_H_
-#define _THRIFT_PROTOCOL_TPROTOCOL_H_ 1
-
-#include <thrift/transport/TTransport.h>
-#include <thrift/protocol/TProtocolException.h>
-
-#include <boost/shared_ptr.hpp>
-#include <boost/static_assert.hpp>
-
-#ifdef HAVE_NETINET_IN_H
-#include <netinet/in.h>
-#endif
-#include <sys/types.h>
-#include <string>
-#include <map>
-#include <vector>
-
-
-// Use this to get around strict aliasing rules.
-// For example, uint64_t i = bitwise_cast<uint64_t>(returns_double());
-// The most obvious implementation is to just cast a pointer,
-// but that doesn't work.
-// For a pretty in-depth explanation of the problem, see
-// http://www.cellperformance.com/mike_acton/2006/06/ (...)
-// understanding_strict_aliasing.html
-template <typename To, typename From>
-static inline To bitwise_cast(From from) {
- BOOST_STATIC_ASSERT(sizeof(From) == sizeof(To));
-
- // BAD!!! These are all broken with -O2.
- //return *reinterpret_cast<To*>(&from); // BAD!!!
- //return *static_cast<To*>(static_cast<void*>(&from)); // BAD!!!
- //return *(To*)(void*)&from; // BAD!!!
-
- // Super clean and paritally blessed by section 3.9 of the standard.
- //unsigned char c[sizeof(from)];
- //memcpy(c, &from, sizeof(from));
- //To to;
- //memcpy(&to, c, sizeof(c));
- //return to;
-
- // Slightly more questionable.
- // Same code emitted by GCC.
- //To to;
- //memcpy(&to, &from, sizeof(from));
- //return to;
-
- // Technically undefined, but almost universally supported,
- // and the most efficient implementation.
- union {
- From f;
- To t;
- } u;
- u.f = from;
- return u.t;
-}
-
-
-namespace apache { namespace thrift { namespace protocol {
-
-using apache::thrift::transport::TTransport;
-
-#ifdef HAVE_SYS_PARAM_H
-#include <sys/param.h>
-#endif
-
-#ifndef __THRIFT_BYTE_ORDER
-# if defined(BYTE_ORDER) && defined(LITTLE_ENDIAN) && defined(BIG_ENDIAN)
-# define __THRIFT_BYTE_ORDER BYTE_ORDER
-# define __THRIFT_LITTLE_ENDIAN LITTLE_ENDIAN
-# define __THRIFT_BIG_ENDIAN BIG_ENDIAN
-# else
-# include <boost/config.hpp>
-# include <boost/detail/endian.hpp>
-# define __THRIFT_BYTE_ORDER BOOST_BYTE_ORDER
-# ifdef BOOST_LITTLE_ENDIAN
-# define __THRIFT_LITTLE_ENDIAN __THRIFT_BYTE_ORDER
-# define __THRIFT_BIG_ENDIAN 0
-# else
-# define __THRIFT_LITTLE_ENDIAN 0
-# define __THRIFT_BIG_ENDIAN __THRIFT_BYTE_ORDER
-# endif
-# endif
-#endif
-
-#if __THRIFT_BYTE_ORDER == __THRIFT_BIG_ENDIAN
-# define ntohll(n) (n)
-# define htonll(n) (n)
-# if defined(__GNUC__) && defined(__GLIBC__)
-# include <byteswap.h>
-# define htolell(n) bswap_64(n)
-# define letohll(n) bswap_64(n)
-# else /* GNUC & GLIBC */
-# define bswap_64(n) \
- ( (((n) & 0xff00000000000000ull) >> 56) \
- | (((n) & 0x00ff000000000000ull) >> 40) \
- | (((n) & 0x0000ff0000000000ull) >> 24) \
- | (((n) & 0x000000ff00000000ull) >> 8) \
- | (((n) & 0x00000000ff000000ull) << 8) \
- | (((n) & 0x0000000000ff0000ull) << 24) \
- | (((n) & 0x000000000000ff00ull) << 40) \
- | (((n) & 0x00000000000000ffull) << 56) )
-# define htolell(n) bswap_64(n)
-# define letohll(n) bswap_64(n)
-# endif /* GNUC & GLIBC */
-#elif __THRIFT_BYTE_ORDER == __THRIFT_LITTLE_ENDIAN
-# define htolell(n) (n)
-# define letohll(n) (n)
-# if defined(__GNUC__) && defined(__GLIBC__)
-# include <byteswap.h>
-# define ntohll(n) bswap_64(n)
-# define htonll(n) bswap_64(n)
-# elif defined(_MSC_VER) /* Microsoft Visual C++ */
-# define ntohll(n) ( _byteswap_uint64((uint64_t)n) )
-# define htonll(n) ( _byteswap_uint64((uint64_t)n) )
-# else /* Not GNUC/GLIBC or MSVC */
-# define ntohll(n) ( (((uint64_t)ntohl((uint32_t)n)) << 32) + ntohl((uint32_t)(n >> 32)) )
-# define htonll(n) ( (((uint64_t)htonl((uint32_t)n)) << 32) + htonl((uint32_t)(n >> 32)) )
-# endif /* GNUC/GLIBC or MSVC or something else */
-#else /* __THRIFT_BYTE_ORDER */
-# error "Can't define htonll or ntohll!"
-#endif
-
-/**
- * Enumerated definition of the types that the Thrift protocol supports.
- * Take special note of the T_END type which is used specifically to mark
- * the end of a sequence of fields.
- */
-enum TType {
- T_STOP = 0,
- T_VOID = 1,
- T_BOOL = 2,
- T_BYTE = 3,
- T_I08 = 3,
- T_I16 = 6,
- T_I32 = 8,
- T_U64 = 9,
- T_I64 = 10,
- T_DOUBLE = 4,
- T_STRING = 11,
- T_UTF7 = 11,
- T_STRUCT = 12,
- T_MAP = 13,
- T_SET = 14,
- T_LIST = 15,
- T_UTF8 = 16,
- T_UTF16 = 17
-};
-
-/**
- * Enumerated definition of the message types that the Thrift protocol
- * supports.
- */
-enum TMessageType {
- T_CALL = 1,
- T_REPLY = 2,
- T_EXCEPTION = 3,
- T_ONEWAY = 4
-};
-
-
-/**
- * Helper template for implementing TProtocol::skip().
- *
- * Templatized to avoid having to make virtual function calls.
- */
-template <class Protocol_>
-uint32_t skip(Protocol_& prot, TType type) {
- switch (type) {
- case T_BOOL:
- {
- bool boolv;
- return prot.readBool(boolv);
- }
- case T_BYTE:
- {
- int8_t bytev;
- return prot.readByte(bytev);
- }
- case T_I16:
- {
- int16_t i16;
- return prot.readI16(i16);
- }
- case T_I32:
- {
- int32_t i32;
- return prot.readI32(i32);
- }
- case T_I64:
- {
- int64_t i64;
- return prot.readI64(i64);
- }
- case T_DOUBLE:
- {
- double dub;
- return prot.readDouble(dub);
- }
- case T_STRING:
- {
- std::string str;
- return prot.readBinary(str);
- }
- case T_STRUCT:
- {
- uint32_t result = 0;
- std::string name;
- int16_t fid;
- TType ftype;
- result += prot.readStructBegin(name);
- while (true) {
- result += prot.readFieldBegin(name, ftype, fid);
- if (ftype == T_STOP) {
- break;
- }
- result += skip(prot, ftype);
- result += prot.readFieldEnd();
- }
- result += prot.readStructEnd();
- return result;
- }
- case T_MAP:
- {
- uint32_t result = 0;
- TType keyType;
- TType valType;
- uint32_t i, size;
- result += prot.readMapBegin(keyType, valType, size);
- for (i = 0; i < size; i++) {
- result += skip(prot, keyType);
- result += skip(prot, valType);
- }
- result += prot.readMapEnd();
- return result;
- }
- case T_SET:
- {
- uint32_t result = 0;
- TType elemType;
- uint32_t i, size;
- result += prot.readSetBegin(elemType, size);
- for (i = 0; i < size; i++) {
- result += skip(prot, elemType);
- }
- result += prot.readSetEnd();
- return result;
- }
- case T_LIST:
- {
- uint32_t result = 0;
- TType elemType;
- uint32_t i, size;
- result += prot.readListBegin(elemType, size);
- for (i = 0; i < size; i++) {
- result += skip(prot, elemType);
- }
- result += prot.readListEnd();
- return result;
- }
- case T_STOP: case T_VOID: case T_U64: case T_UTF8: case T_UTF16:
- break;
- }
- return 0;
-}
-
-/**
- * Abstract class for a thrift protocol driver. These are all the methods that
- * a protocol must implement. Essentially, there must be some way of reading
- * and writing all the base types, plus a mechanism for writing out structs
- * with indexed fields.
- *
- * TProtocol objects should not be shared across multiple encoding contexts,
- * as they may need to maintain internal state in some protocols (i.e. XML).
- * Note that is is acceptable for the TProtocol module to do its own internal
- * buffered reads/writes to the underlying TTransport where appropriate (i.e.
- * when parsing an input XML stream, reading should be batched rather than
- * looking ahead character by character for a close tag).
- *
- */
-class TProtocol {
- public:
- virtual ~TProtocol() {}
-
- /**
- * Writing functions.
- */
-
- virtual uint32_t writeMessageBegin_virt(const std::string& name,
- const TMessageType messageType,
- const int32_t seqid) = 0;
-
- virtual uint32_t writeMessageEnd_virt() = 0;
-
-
- virtual uint32_t writeStructBegin_virt(const char* name) = 0;
-
- virtual uint32_t writeStructEnd_virt() = 0;
-
- virtual uint32_t writeFieldBegin_virt(const char* name,
- const TType fieldType,
- const int16_t fieldId) = 0;
-
- virtual uint32_t writeFieldEnd_virt() = 0;
-
- virtual uint32_t writeFieldStop_virt() = 0;
-
- virtual uint32_t writeMapBegin_virt(const TType keyType,
- const TType valType,
- const uint32_t size) = 0;
-
- virtual uint32_t writeMapEnd_virt() = 0;
-
- virtual uint32_t writeListBegin_virt(const TType elemType,
- const uint32_t size) = 0;
-
- virtual uint32_t writeListEnd_virt() = 0;
-
- virtual uint32_t writeSetBegin_virt(const TType elemType,
- const uint32_t size) = 0;
-
- virtual uint32_t writeSetEnd_virt() = 0;
-
- virtual uint32_t writeBool_virt(const bool value) = 0;
-
- virtual uint32_t writeByte_virt(const int8_t byte) = 0;
-
- virtual uint32_t writeI16_virt(const int16_t i16) = 0;
-
- virtual uint32_t writeI32_virt(const int32_t i32) = 0;
-
- virtual uint32_t writeI64_virt(const int64_t i64) = 0;
-
- virtual uint32_t writeDouble_virt(const double dub) = 0;
-
- virtual uint32_t writeString_virt(const std::string& str) = 0;
-
- virtual uint32_t writeBinary_virt(const std::string& str) = 0;
-
- uint32_t writeMessageBegin(const std::string& name,
- const TMessageType messageType,
- const int32_t seqid) {
- T_VIRTUAL_CALL();
- return writeMessageBegin_virt(name, messageType, seqid);
- }
-
- uint32_t writeMessageEnd() {
- T_VIRTUAL_CALL();
- return writeMessageEnd_virt();
- }
-
-
- uint32_t writeStructBegin(const char* name) {
- T_VIRTUAL_CALL();
- return writeStructBegin_virt(name);
- }
-
- uint32_t writeStructEnd() {
- T_VIRTUAL_CALL();
- return writeStructEnd_virt();
- }
-
- uint32_t writeFieldBegin(const char* name,
- const TType fieldType,
- const int16_t fieldId) {
- T_VIRTUAL_CALL();
- return writeFieldBegin_virt(name, fieldType, fieldId);
- }
-
- uint32_t writeFieldEnd() {
- T_VIRTUAL_CALL();
- return writeFieldEnd_virt();
- }
-
- uint32_t writeFieldStop() {
- T_VIRTUAL_CALL();
- return writeFieldStop_virt();
- }
-
- uint32_t writeMapBegin(const TType keyType,
- const TType valType,
- const uint32_t size) {
- T_VIRTUAL_CALL();
- return writeMapBegin_virt(keyType, valType, size);
- }
-
- uint32_t writeMapEnd() {
- T_VIRTUAL_CALL();
- return writeMapEnd_virt();
- }
-
- uint32_t writeListBegin(const TType elemType, const uint32_t size) {
- T_VIRTUAL_CALL();
- return writeListBegin_virt(elemType, size);
- }
-
- uint32_t writeListEnd() {
- T_VIRTUAL_CALL();
- return writeListEnd_virt();
- }
-
- uint32_t writeSetBegin(const TType elemType, const uint32_t size) {
- T_VIRTUAL_CALL();
- return writeSetBegin_virt(elemType, size);
- }
-
- uint32_t writeSetEnd() {
- T_VIRTUAL_CALL();
- return writeSetEnd_virt();
- }
-
- uint32_t writeBool(const bool value) {
- T_VIRTUAL_CALL();
- return writeBool_virt(value);
- }
-
- uint32_t writeByte(const int8_t byte) {
- T_VIRTUAL_CALL();
- return writeByte_virt(byte);
- }
-
- uint32_t writeI16(const int16_t i16) {
- T_VIRTUAL_CALL();
- return writeI16_virt(i16);
- }
-
- uint32_t writeI32(const int32_t i32) {
- T_VIRTUAL_CALL();
- return writeI32_virt(i32);
- }
-
- uint32_t writeI64(const int64_t i64) {
- T_VIRTUAL_CALL();
- return writeI64_virt(i64);
- }
-
- uint32_t writeDouble(const double dub) {
- T_VIRTUAL_CALL();
- return writeDouble_virt(dub);
- }
-
- uint32_t writeString(const std::string& str) {
- T_VIRTUAL_CALL();
- return writeString_virt(str);
- }
-
- uint32_t writeBinary(const std::string& str) {
- T_VIRTUAL_CALL();
- return writeBinary_virt(str);
- }
-
- /**
- * Reading functions
- */
-
- virtual uint32_t readMessageBegin_virt(std::string& name,
- TMessageType& messageType,
- int32_t& seqid) = 0;
-
- virtual uint32_t readMessageEnd_virt() = 0;
-
- virtual uint32_t readStructBegin_virt(std::string& name) = 0;
-
- virtual uint32_t readStructEnd_virt() = 0;
-
- virtual uint32_t readFieldBegin_virt(std::string& name,
- TType& fieldType,
- int16_t& fieldId) = 0;
-
- virtual uint32_t readFieldEnd_virt() = 0;
-
- virtual uint32_t readMapBegin_virt(TType& keyType,
- TType& valType,
- uint32_t& size) = 0;
-
- virtual uint32_t readMapEnd_virt() = 0;
-
- virtual uint32_t readListBegin_virt(TType& elemType,
- uint32_t& size) = 0;
-
- virtual uint32_t readListEnd_virt() = 0;
-
- virtual uint32_t readSetBegin_virt(TType& elemType,
- uint32_t& size) = 0;
-
- virtual uint32_t readSetEnd_virt() = 0;
-
- virtual uint32_t readBool_virt(bool& value) = 0;
-
- virtual uint32_t readBool_virt(std::vector<bool>::reference value) = 0;
-
- virtual uint32_t readByte_virt(int8_t& byte) = 0;
-
- virtual uint32_t readI16_virt(int16_t& i16) = 0;
-
- virtual uint32_t readI32_virt(int32_t& i32) = 0;
-
- virtual uint32_t readI64_virt(int64_t& i64) = 0;
-
- virtual uint32_t readDouble_virt(double& dub) = 0;
-
- virtual uint32_t readString_virt(std::string& str) = 0;
-
- virtual uint32_t readBinary_virt(std::string& str) = 0;
-
- uint32_t readMessageBegin(std::string& name,
- TMessageType& messageType,
- int32_t& seqid) {
- T_VIRTUAL_CALL();
- return readMessageBegin_virt(name, messageType, seqid);
- }
-
- uint32_t readMessageEnd() {
- T_VIRTUAL_CALL();
- return readMessageEnd_virt();
- }
-
- uint32_t readStructBegin(std::string& name) {
- T_VIRTUAL_CALL();
- return readStructBegin_virt(name);
- }
-
- uint32_t readStructEnd() {
- T_VIRTUAL_CALL();
- return readStructEnd_virt();
- }
-
- uint32_t readFieldBegin(std::string& name,
- TType& fieldType,
- int16_t& fieldId) {
- T_VIRTUAL_CALL();
- return readFieldBegin_virt(name, fieldType, fieldId);
- }
-
- uint32_t readFieldEnd() {
- T_VIRTUAL_CALL();
- return readFieldEnd_virt();
- }
-
- uint32_t readMapBegin(TType& keyType, TType& valType, uint32_t& size) {
- T_VIRTUAL_CALL();
- return readMapBegin_virt(keyType, valType, size);
- }
-
- uint32_t readMapEnd() {
- T_VIRTUAL_CALL();
- return readMapEnd_virt();
- }
-
- uint32_t readListBegin(TType& elemType, uint32_t& size) {
- T_VIRTUAL_CALL();
- return readListBegin_virt(elemType, size);
- }
-
- uint32_t readListEnd() {
- T_VIRTUAL_CALL();
- return readListEnd_virt();
- }
-
- uint32_t readSetBegin(TType& elemType, uint32_t& size) {
- T_VIRTUAL_CALL();
- return readSetBegin_virt(elemType, size);
- }
-
- uint32_t readSetEnd() {
- T_VIRTUAL_CALL();
- return readSetEnd_virt();
- }
-
- uint32_t readBool(bool& value) {
- T_VIRTUAL_CALL();
- return readBool_virt(value);
- }
-
- uint32_t readByte(int8_t& byte) {
- T_VIRTUAL_CALL();
- return readByte_virt(byte);
- }
-
- uint32_t readI16(int16_t& i16) {
- T_VIRTUAL_CALL();
- return readI16_virt(i16);
- }
-
- uint32_t readI32(int32_t& i32) {
- T_VIRTUAL_CALL();
- return readI32_virt(i32);
- }
-
- uint32_t readI64(int64_t& i64) {
- T_VIRTUAL_CALL();
- return readI64_virt(i64);
- }
-
- uint32_t readDouble(double& dub) {
- T_VIRTUAL_CALL();
- return readDouble_virt(dub);
- }
-
- uint32_t readString(std::string& str) {
- T_VIRTUAL_CALL();
- return readString_virt(str);
- }
-
- uint32_t readBinary(std::string& str) {
- T_VIRTUAL_CALL();
- return readBinary_virt(str);
- }
-
- /*
- * std::vector is specialized for bool, and its elements are individual bits
- * rather than bools. We need to define a different version of readBool()
- * to work with std::vector<bool>.
- */
- uint32_t readBool(std::vector<bool>::reference value) {
- T_VIRTUAL_CALL();
- return readBool_virt(value);
- }
-
- /**
- * Method to arbitrarily skip over data.
- */
- uint32_t skip(TType type) {
- T_VIRTUAL_CALL();
- return skip_virt(type);
- }
- virtual uint32_t skip_virt(TType type) {
- return ::apache::thrift::protocol::skip(*this, type);
- }
-
- inline boost::shared_ptr<TTransport> getTransport() {
- return ptrans_;
- }
-
- // TODO: remove these two calls, they are for backwards
- // compatibility
- inline boost::shared_ptr<TTransport> getInputTransport() {
- return ptrans_;
- }
- inline boost::shared_ptr<TTransport> getOutputTransport() {
- return ptrans_;
- }
-
- protected:
- TProtocol(boost::shared_ptr<TTransport> ptrans):
- ptrans_(ptrans) {
- }
-
- boost::shared_ptr<TTransport> ptrans_;
-
- private:
- TProtocol() {}
-};
-
-/**
- * Constructs input and output protocol objects given transports.
- */
-class TProtocolFactory {
- public:
- TProtocolFactory() {}
-
- virtual ~TProtocolFactory() {}
-
- virtual boost::shared_ptr<TProtocol> getProtocol(boost::shared_ptr<TTransport> trans) = 0;
-};
-
-/**
- * Dummy protocol class.
- *
- * This class does nothing, and should never be instantiated.
- * It is used only by the generator code.
- */
-class TDummyProtocol : public TProtocol {
-};
-
-}}} // apache::thrift::protocol
-
-#endif // #define _THRIFT_PROTOCOL_TPROTOCOL_H_ 1
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolDecorator.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolDecorator.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolDecorator.h
deleted file mode 100644
index 7850bc5..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolDecorator.h
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef THRIFT_TPROTOCOLDECORATOR_H_
-#define THRIFT_TPROTOCOLDECORATOR_H_ 1
-
-#include <thrift/protocol/TProtocol.h>
-#include <boost/shared_ptr.hpp>
-
-namespace apache
-{
- namespace thrift
- {
- namespace protocol
- {
- using boost::shared_ptr;
-
- /**
- * <code>TProtocolDecorator</code> forwards all requests to an enclosed
- * <code>TProtocol</code> instance, providing a way to author concise
- * concrete decorator subclasses.
- *
- * <p>See p.175 of Design Patterns (by Gamma et al.)</p>
- *
- * @see apache::thrift::protocol::TMultiplexedProtocol
- */
- class TProtocolDecorator : public TProtocol
- {
- public:
- virtual ~TProtocolDecorator() {}
-
- // Desc: Initializes the protocol decorator object.
- TProtocolDecorator( shared_ptr<TProtocol> proto )
- : TProtocol(proto->getTransport()), protocol(proto)
- {
- }
-
- virtual uint32_t writeMessageBegin_virt(
- const std::string& name,
- const TMessageType messageType,
- const int32_t seqid)
- {
- return protocol->writeMessageBegin(name, messageType, seqid);
- }
- virtual uint32_t writeMessageEnd_virt() { return protocol->writeMessageEnd(); }
- virtual uint32_t writeStructBegin_virt(const char* name) { return protocol->writeStructBegin(name); }
- virtual uint32_t writeStructEnd_virt() { return protocol->writeStructEnd(); }
-
- virtual uint32_t writeFieldBegin_virt(const char* name,
- const TType fieldType,
- const int16_t fieldId) { return protocol->writeFieldBegin(name,fieldType,fieldId); }
-
- virtual uint32_t writeFieldEnd_virt() { return protocol->writeFieldEnd(); }
- virtual uint32_t writeFieldStop_virt() { return protocol->writeFieldStop(); }
-
- virtual uint32_t writeMapBegin_virt(const TType keyType,
- const TType valType,
- const uint32_t size) { return protocol->writeMapBegin(keyType,valType,size); }
-
- virtual uint32_t writeMapEnd_virt() { return protocol->writeMapEnd(); }
-
- virtual uint32_t writeListBegin_virt(const TType elemType, const uint32_t size) { return protocol->writeListBegin(elemType,size); }
- virtual uint32_t writeListEnd_virt() { return protocol->writeListEnd(); }
-
- virtual uint32_t writeSetBegin_virt(const TType elemType, const uint32_t size) { return protocol->writeSetBegin(elemType,size); }
- virtual uint32_t writeSetEnd_virt() { return protocol->writeSetEnd(); }
-
- virtual uint32_t writeBool_virt(const bool value) { return protocol->writeBool(value); }
- virtual uint32_t writeByte_virt(const int8_t byte) { return protocol->writeByte(byte); }
- virtual uint32_t writeI16_virt(const int16_t i16) { return protocol->writeI16(i16); }
- virtual uint32_t writeI32_virt(const int32_t i32) { return protocol->writeI32(i32); }
- virtual uint32_t writeI64_virt(const int64_t i64) { return protocol->writeI64(i64); }
-
- virtual uint32_t writeDouble_virt(const double dub) { return protocol->writeDouble(dub); }
- virtual uint32_t writeString_virt(const std::string& str) { return protocol->writeString(str); }
- virtual uint32_t writeBinary_virt(const std::string& str) { return protocol->writeBinary(str); }
-
- virtual uint32_t readMessageBegin_virt(std::string& name, TMessageType& messageType, int32_t& seqid) { return protocol->readMessageBegin(name,messageType,seqid); }
- virtual uint32_t readMessageEnd_virt() { return protocol->readMessageEnd(); }
-
- virtual uint32_t readStructBegin_virt(std::string& name) { return protocol->readStructBegin(name); }
- virtual uint32_t readStructEnd_virt() { return protocol->readStructEnd(); }
-
- virtual uint32_t readFieldBegin_virt(std::string& name, TType& fieldType, int16_t& fieldId) { return protocol->readFieldBegin(name, fieldType, fieldId); }
- virtual uint32_t readFieldEnd_virt() { return protocol->readFieldEnd(); }
-
- virtual uint32_t readMapBegin_virt(TType& keyType, TType& valType, uint32_t& size) { return protocol->readMapBegin(keyType,valType,size); }
- virtual uint32_t readMapEnd_virt() { return protocol->readMapEnd(); }
-
- virtual uint32_t readListBegin_virt(TType& elemType, uint32_t& size) { return protocol->readListBegin(elemType,size); }
- virtual uint32_t readListEnd_virt() { return protocol->readListEnd(); }
-
- virtual uint32_t readSetBegin_virt(TType& elemType, uint32_t& size) { return protocol->readSetBegin(elemType,size); }
- virtual uint32_t readSetEnd_virt() { return protocol->readSetEnd(); }
-
- virtual uint32_t readBool_virt(bool& value) { return protocol->readBool(value); }
- virtual uint32_t readBool_virt(std::vector<bool>::reference value) { return protocol->readBool(value); }
-
- virtual uint32_t readByte_virt(int8_t& byte) { return protocol->readByte(byte); }
-
- virtual uint32_t readI16_virt(int16_t& i16) { return protocol->readI16(i16); }
- virtual uint32_t readI32_virt(int32_t& i32) { return protocol->readI32(i32); }
- virtual uint32_t readI64_virt(int64_t& i64) { return protocol->readI64(i64); }
-
- virtual uint32_t readDouble_virt(double& dub) { return protocol->readDouble(dub); }
-
- virtual uint32_t readString_virt(std::string& str) { return protocol->readString(str); }
- virtual uint32_t readBinary_virt(std::string& str) { return protocol->readBinary(str); }
-
- private:
- shared_ptr<TProtocol> protocol;
- };
- }
- }
-}
-
-#endif // THRIFT_TPROTOCOLDECORATOR_H_
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolException.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolException.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolException.h
deleted file mode 100644
index a03d3c8..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolException.h
+++ /dev/null
@@ -1,104 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_PROTOCOL_TPROTOCOLEXCEPTION_H_
-#define _THRIFT_PROTOCOL_TPROTOCOLEXCEPTION_H_ 1
-
-#include <string>
-
-namespace apache { namespace thrift { namespace protocol {
-
-/**
- * Class to encapsulate all the possible types of protocol errors that may
- * occur in various protocol systems. This provides a sort of generic
- * wrapper around the vague UNIX E_ error codes that lets a common code
- * base of error handling to be used for various types of protocols, i.e.
- * pipes etc.
- *
- */
-class TProtocolException : public apache::thrift::TException {
- public:
-
- /**
- * Error codes for the various types of exceptions.
- */
- enum TProtocolExceptionType
- { UNKNOWN = 0
- , INVALID_DATA = 1
- , NEGATIVE_SIZE = 2
- , SIZE_LIMIT = 3
- , BAD_VERSION = 4
- , NOT_IMPLEMENTED = 5
- };
-
- TProtocolException() :
- apache::thrift::TException(),
- type_(UNKNOWN) {}
-
- TProtocolException(TProtocolExceptionType type) :
- apache::thrift::TException(),
- type_(type) {}
-
- TProtocolException(const std::string& message) :
- apache::thrift::TException(message),
- type_(UNKNOWN) {}
-
- TProtocolException(TProtocolExceptionType type, const std::string& message) :
- apache::thrift::TException(message),
- type_(type) {}
-
- virtual ~TProtocolException() throw() {}
-
- /**
- * Returns an error code that provides information about the type of error
- * that has occurred.
- *
- * @return Error code
- */
- TProtocolExceptionType getType() {
- return type_;
- }
-
- virtual const char* what() const throw() {
- if (message_.empty()) {
- switch (type_) {
- case UNKNOWN : return "TProtocolException: Unknown protocol exception";
- case INVALID_DATA : return "TProtocolException: Invalid data";
- case NEGATIVE_SIZE : return "TProtocolException: Negative size";
- case SIZE_LIMIT : return "TProtocolException: Exceeded size limit";
- case BAD_VERSION : return "TProtocolException: Invalid version";
- case NOT_IMPLEMENTED : return "TProtocolException: Not implemented";
- default : return "TProtocolException: (Invalid exception type)";
- }
- } else {
- return message_.c_str();
- }
- }
-
- protected:
- /**
- * Error code
- */
- TProtocolExceptionType type_;
-
-};
-
-}}} // apache::thrift::protocol
-
-#endif // #ifndef _THRIFT_PROTOCOL_TPROTOCOLEXCEPTION_H_
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolTap.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolTap.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolTap.h
deleted file mode 100644
index f493f88..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TProtocolTap.h
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_PROTOCOL_TPROTOCOLTAP_H_
-#define _THRIFT_PROTOCOL_TPROTOCOLTAP_H_ 1
-
-#include <thrift/protocol/TVirtualProtocol.h>
-
-namespace apache { namespace thrift { namespace protocol {
-
-using apache::thrift::transport::TTransport;
-
-/**
- * Puts a wiretap on a protocol object. Any reads to this class are passed
- * through to an enclosed protocol object, but also mirrored as write to a
- * second protocol object.
- *
- */
-class TProtocolTap : public TVirtualProtocol<TProtocolTap> {
- public:
- TProtocolTap(boost::shared_ptr<TProtocol> source,
- boost::shared_ptr<TProtocol> sink)
- : TVirtualProtocol<TProtocolTap>(source->getTransport())
- , source_(source)
- , sink_(sink)
- {}
-
- uint32_t readMessageBegin(std::string& name,
- TMessageType& messageType,
- int32_t& seqid) {
- uint32_t rv = source_->readMessageBegin(name, messageType, seqid);
- sink_->writeMessageBegin(name, messageType, seqid);
- return rv;
- }
-
- uint32_t readMessageEnd() {
- uint32_t rv = source_->readMessageEnd();
- sink_->writeMessageEnd();
- return rv;
- }
-
- uint32_t readStructBegin(std::string& name) {
- uint32_t rv = source_->readStructBegin(name);
- sink_->writeStructBegin(name.c_str());
- return rv;
- }
-
- uint32_t readStructEnd() {
- uint32_t rv = source_->readStructEnd();
- sink_->writeStructEnd();
- return rv;
- }
-
- uint32_t readFieldBegin(std::string& name,
- TType& fieldType,
- int16_t& fieldId) {
- uint32_t rv = source_->readFieldBegin(name, fieldType, fieldId);
- if (fieldType == T_STOP) {
- sink_->writeFieldStop();
- } else {
- sink_->writeFieldBegin(name.c_str(), fieldType, fieldId);
- }
- return rv;
- }
-
-
- uint32_t readFieldEnd() {
- uint32_t rv = source_->readFieldEnd();
- sink_->writeFieldEnd();
- return rv;
- }
-
- uint32_t readMapBegin(TType& keyType,
- TType& valType,
- uint32_t& size) {
- uint32_t rv = source_->readMapBegin(keyType, valType, size);
- sink_->writeMapBegin(keyType, valType, size);
- return rv;
- }
-
-
- uint32_t readMapEnd() {
- uint32_t rv = source_->readMapEnd();
- sink_->writeMapEnd();
- return rv;
- }
-
- uint32_t readListBegin(TType& elemType, uint32_t& size) {
- uint32_t rv = source_->readListBegin(elemType, size);
- sink_->writeListBegin(elemType, size);
- return rv;
- }
-
-
- uint32_t readListEnd() {
- uint32_t rv = source_->readListEnd();
- sink_->writeListEnd();
- return rv;
- }
-
- uint32_t readSetBegin(TType& elemType, uint32_t& size) {
- uint32_t rv = source_->readSetBegin(elemType, size);
- sink_->writeSetBegin(elemType, size);
- return rv;
- }
-
-
- uint32_t readSetEnd() {
- uint32_t rv = source_->readSetEnd();
- sink_->writeSetEnd();
- return rv;
- }
-
- uint32_t readBool(bool& value) {
- uint32_t rv = source_->readBool(value);
- sink_->writeBool(value);
- return rv;
- }
-
- // Provide the default readBool() implementation for std::vector<bool>
- using TVirtualProtocol<TProtocolTap>::readBool;
-
- uint32_t readByte(int8_t& byte) {
- uint32_t rv = source_->readByte(byte);
- sink_->writeByte(byte);
- return rv;
- }
-
- uint32_t readI16(int16_t& i16) {
- uint32_t rv = source_->readI16(i16);
- sink_->writeI16(i16);
- return rv;
- }
-
- uint32_t readI32(int32_t& i32) {
- uint32_t rv = source_->readI32(i32);
- sink_->writeI32(i32);
- return rv;
- }
-
- uint32_t readI64(int64_t& i64) {
- uint32_t rv = source_->readI64(i64);
- sink_->writeI64(i64);
- return rv;
- }
-
- uint32_t readDouble(double& dub) {
- uint32_t rv = source_->readDouble(dub);
- sink_->writeDouble(dub);
- return rv;
- }
-
- uint32_t readString(std::string& str) {
- uint32_t rv = source_->readString(str);
- sink_->writeString(str);
- return rv;
- }
-
- uint32_t readBinary(std::string& str) {
- uint32_t rv = source_->readBinary(str);
- sink_->writeBinary(str);
- return rv;
- }
-
- private:
- boost::shared_ptr<TProtocol> source_;
- boost::shared_ptr<TProtocol> sink_;
-};
-
-}}} // apache::thrift::protocol
-
-#endif // #define _THRIFT_PROTOCOL_TPROTOCOLTAP_H_ 1
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TVirtualProtocol.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TVirtualProtocol.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TVirtualProtocol.h
deleted file mode 100644
index e068725..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/protocol/TVirtualProtocol.h
+++ /dev/null
@@ -1,564 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_PROTOCOL_TVIRTUALPROTOCOL_H_
-#define _THRIFT_PROTOCOL_TVIRTUALPROTOCOL_H_ 1
-
-#include <thrift/protocol/TProtocol.h>
-
-namespace apache { namespace thrift { namespace protocol {
-
-using apache::thrift::transport::TTransport;
-
-/**
- * Helper class that provides default implementations of TProtocol methods.
- *
- * This class provides default implementations of the non-virtual TProtocol
- * methods. It exists primarily so TVirtualProtocol can derive from it. It
- * prevents TVirtualProtocol methods from causing infinite recursion if the
- * non-virtual methods are not overridden by the TVirtualProtocol subclass.
- *
- * You probably don't want to use this class directly. Use TVirtualProtocol
- * instead.
- */
-class TProtocolDefaults : public TProtocol {
- public:
- uint32_t readMessageBegin(std::string& name,
- TMessageType& messageType,
- int32_t& seqid) {
- (void) name;
- (void) messageType;
- (void) seqid;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readMessageEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readStructBegin(std::string& name) {
- (void) name;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readStructEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readFieldBegin(std::string& name,
- TType& fieldType,
- int16_t& fieldId) {
- (void) name;
- (void) fieldType;
- (void) fieldId;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readFieldEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readMapBegin(TType& keyType, TType& valType, uint32_t& size) {
- (void) keyType;
- (void) valType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readMapEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readListBegin(TType& elemType, uint32_t& size) {
- (void) elemType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readListEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readSetBegin(TType& elemType, uint32_t& size) {
- (void) elemType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readSetEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readBool(bool& value) {
- (void) value;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readBool(std::vector<bool>::reference value) {
- (void) value;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readByte(int8_t& byte) {
- (void) byte;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readI16(int16_t& i16) {
- (void) i16;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readI32(int32_t& i32) {
- (void) i32;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readI64(int64_t& i64) {
- (void) i64;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readDouble(double& dub) {
- (void) dub;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readString(std::string& str) {
- (void) str;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t readBinary(std::string& str) {
- (void) str;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support reading (yet).");
- }
-
- uint32_t writeMessageBegin(const std::string& name,
- const TMessageType messageType,
- const int32_t seqid) {
- (void) name;
- (void) messageType;
- (void) seqid;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeMessageEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
-
- uint32_t writeStructBegin(const char* name) {
- (void) name;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeStructEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeFieldBegin(const char* name,
- const TType fieldType,
- const int16_t fieldId) {
- (void) name;
- (void) fieldType;
- (void) fieldId;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeFieldEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeFieldStop() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeMapBegin(const TType keyType,
- const TType valType,
- const uint32_t size) {
- (void) keyType;
- (void) valType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeMapEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeListBegin(const TType elemType, const uint32_t size) {
- (void) elemType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeListEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeSetBegin(const TType elemType, const uint32_t size) {
- (void) elemType;
- (void) size;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeSetEnd() {
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeBool(const bool value) {
- (void) value;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeByte(const int8_t byte) {
- (void) byte;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeI16(const int16_t i16) {
- (void) i16;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeI32(const int32_t i32) {
- (void) i32;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeI64(const int64_t i64) {
- (void) i64;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeDouble(const double dub) {
- (void) dub;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeString(const std::string& str) {
- (void) str;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t writeBinary(const std::string& str) {
- (void) str;
- throw TProtocolException(TProtocolException::NOT_IMPLEMENTED,
- "this protocol does not support writing (yet).");
- }
-
- uint32_t skip(TType type) {
- return ::apache::thrift::protocol::skip(*this, type);
- }
-
- protected:
- TProtocolDefaults(boost::shared_ptr<TTransport> ptrans)
- : TProtocol(ptrans)
- {}
-};
-
-/**
- * Concrete TProtocol classes should inherit from TVirtualProtocol
- * so they don't have to manually override virtual methods.
- */
-template <class Protocol_, class Super_=TProtocolDefaults>
-class TVirtualProtocol : public Super_ {
- public:
- /**
- * Writing functions.
- */
-
- virtual uint32_t writeMessageBegin_virt(const std::string& name,
- const TMessageType messageType,
- const int32_t seqid) {
- return static_cast<Protocol_*>(this)->writeMessageBegin(name, messageType,
- seqid);
- }
-
- virtual uint32_t writeMessageEnd_virt() {
- return static_cast<Protocol_*>(this)->writeMessageEnd();
- }
-
-
- virtual uint32_t writeStructBegin_virt(const char* name) {
- return static_cast<Protocol_*>(this)->writeStructBegin(name);
- }
-
- virtual uint32_t writeStructEnd_virt() {
- return static_cast<Protocol_*>(this)->writeStructEnd();
- }
-
- virtual uint32_t writeFieldBegin_virt(const char* name,
- const TType fieldType,
- const int16_t fieldId) {
- return static_cast<Protocol_*>(this)->writeFieldBegin(name, fieldType,
- fieldId);
- }
-
- virtual uint32_t writeFieldEnd_virt() {
- return static_cast<Protocol_*>(this)->writeFieldEnd();
- }
-
- virtual uint32_t writeFieldStop_virt() {
- return static_cast<Protocol_*>(this)->writeFieldStop();
- }
-
- virtual uint32_t writeMapBegin_virt(const TType keyType,
- const TType valType,
- const uint32_t size) {
- return static_cast<Protocol_*>(this)->writeMapBegin(keyType, valType, size);
- }
-
- virtual uint32_t writeMapEnd_virt() {
- return static_cast<Protocol_*>(this)->writeMapEnd();
- }
-
- virtual uint32_t writeListBegin_virt(const TType elemType,
- const uint32_t size) {
- return static_cast<Protocol_*>(this)->writeListBegin(elemType, size);
- }
-
- virtual uint32_t writeListEnd_virt() {
- return static_cast<Protocol_*>(this)->writeListEnd();
- }
-
- virtual uint32_t writeSetBegin_virt(const TType elemType,
- const uint32_t size) {
- return static_cast<Protocol_*>(this)->writeSetBegin(elemType, size);
- }
-
- virtual uint32_t writeSetEnd_virt() {
- return static_cast<Protocol_*>(this)->writeSetEnd();
- }
-
- virtual uint32_t writeBool_virt(const bool value) {
- return static_cast<Protocol_*>(this)->writeBool(value);
- }
-
- virtual uint32_t writeByte_virt(const int8_t byte) {
- return static_cast<Protocol_*>(this)->writeByte(byte);
- }
-
- virtual uint32_t writeI16_virt(const int16_t i16) {
- return static_cast<Protocol_*>(this)->writeI16(i16);
- }
-
- virtual uint32_t writeI32_virt(const int32_t i32) {
- return static_cast<Protocol_*>(this)->writeI32(i32);
- }
-
- virtual uint32_t writeI64_virt(const int64_t i64) {
- return static_cast<Protocol_*>(this)->writeI64(i64);
- }
-
- virtual uint32_t writeDouble_virt(const double dub) {
- return static_cast<Protocol_*>(this)->writeDouble(dub);
- }
-
- virtual uint32_t writeString_virt(const std::string& str) {
- return static_cast<Protocol_*>(this)->writeString(str);
- }
-
- virtual uint32_t writeBinary_virt(const std::string& str) {
- return static_cast<Protocol_*>(this)->writeBinary(str);
- }
-
- /**
- * Reading functions
- */
-
- virtual uint32_t readMessageBegin_virt(std::string& name,
- TMessageType& messageType,
- int32_t& seqid) {
- return static_cast<Protocol_*>(this)->readMessageBegin(name, messageType,
- seqid);
- }
-
- virtual uint32_t readMessageEnd_virt() {
- return static_cast<Protocol_*>(this)->readMessageEnd();
- }
-
- virtual uint32_t readStructBegin_virt(std::string& name) {
- return static_cast<Protocol_*>(this)->readStructBegin(name);
- }
-
- virtual uint32_t readStructEnd_virt() {
- return static_cast<Protocol_*>(this)->readStructEnd();
- }
-
- virtual uint32_t readFieldBegin_virt(std::string& name,
- TType& fieldType,
- int16_t& fieldId) {
- return static_cast<Protocol_*>(this)->readFieldBegin(name, fieldType,
- fieldId);
- }
-
- virtual uint32_t readFieldEnd_virt() {
- return static_cast<Protocol_*>(this)->readFieldEnd();
- }
-
- virtual uint32_t readMapBegin_virt(TType& keyType,
- TType& valType,
- uint32_t& size) {
- return static_cast<Protocol_*>(this)->readMapBegin(keyType, valType, size);
- }
-
- virtual uint32_t readMapEnd_virt() {
- return static_cast<Protocol_*>(this)->readMapEnd();
- }
-
- virtual uint32_t readListBegin_virt(TType& elemType,
- uint32_t& size) {
- return static_cast<Protocol_*>(this)->readListBegin(elemType, size);
- }
-
- virtual uint32_t readListEnd_virt() {
- return static_cast<Protocol_*>(this)->readListEnd();
- }
-
- virtual uint32_t readSetBegin_virt(TType& elemType,
- uint32_t& size) {
- return static_cast<Protocol_*>(this)->readSetBegin(elemType, size);
- }
-
- virtual uint32_t readSetEnd_virt() {
- return static_cast<Protocol_*>(this)->readSetEnd();
- }
-
- virtual uint32_t readBool_virt(bool& value) {
- return static_cast<Protocol_*>(this)->readBool(value);
- }
-
- virtual uint32_t readBool_virt(std::vector<bool>::reference value) {
- return static_cast<Protocol_*>(this)->readBool(value);
- }
-
- virtual uint32_t readByte_virt(int8_t& byte) {
- return static_cast<Protocol_*>(this)->readByte(byte);
- }
-
- virtual uint32_t readI16_virt(int16_t& i16) {
- return static_cast<Protocol_*>(this)->readI16(i16);
- }
-
- virtual uint32_t readI32_virt(int32_t& i32) {
- return static_cast<Protocol_*>(this)->readI32(i32);
- }
-
- virtual uint32_t readI64_virt(int64_t& i64) {
- return static_cast<Protocol_*>(this)->readI64(i64);
- }
-
- virtual uint32_t readDouble_virt(double& dub) {
- return static_cast<Protocol_*>(this)->readDouble(dub);
- }
-
- virtual uint32_t readString_virt(std::string& str) {
- return static_cast<Protocol_*>(this)->readString(str);
- }
-
- virtual uint32_t readBinary_virt(std::string& str) {
- return static_cast<Protocol_*>(this)->readBinary(str);
- }
-
- virtual uint32_t skip_virt(TType type) {
- return static_cast<Protocol_*>(this)->skip(type);
- }
-
- /*
- * Provide a default skip() implementation that uses non-virtual read
- * methods.
- *
- * Note: subclasses that use TVirtualProtocol to derive from another protocol
- * implementation (i.e., not TProtocolDefaults) should beware that this may
- * override any non-default skip() implementation provided by the parent
- * transport class. They may need to explicitly redefine skip() to call the
- * correct parent implementation, if desired.
- */
- uint32_t skip(TType type) {
- Protocol_* const prot = static_cast<Protocol_*>(this);
- return ::apache::thrift::protocol::skip(*prot, type);
- }
-
- /*
- * Provide a default readBool() implementation for use with
- * std::vector<bool>, that behaves the same as reading into a normal bool.
- *
- * Subclasses can override this if desired, but there normally shouldn't
- * be a need to.
- */
- uint32_t readBool(std::vector<bool>::reference value) {
- bool b = false;
- uint32_t ret = static_cast<Protocol_*>(this)->readBool(b);
- value = b;
- return ret;
- }
- using Super_::readBool; // so we don't hide readBool(bool&)
-
- protected:
- TVirtualProtocol(boost::shared_ptr<TTransport> ptrans)
- : Super_(ptrans)
- {}
-};
-
-}}} // apache::thrift::protocol
-
-#endif // #define _THRIFT_PROTOCOL_TVIRTUALPROTOCOL_H_ 1
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.cpp
deleted file mode 100644
index 3a3e222..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.cpp
+++ /dev/null
@@ -1,179 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#include <thrift/qt/TQIODeviceTransport.h>
-
-#include <QAbstractSocket>
-#include <QIODevice>
-
-#include <thrift/transport/TBufferTransports.h>
-
-using boost::shared_ptr;
-
-namespace apache { namespace thrift { namespace transport {
-
-TQIODeviceTransport::TQIODeviceTransport(shared_ptr<QIODevice> dev)
- : dev_(dev)
-{
-}
-
-TQIODeviceTransport::~TQIODeviceTransport()
-{
- dev_->close();
-}
-
-void TQIODeviceTransport::open()
-{
- if (!isOpen()) {
- throw TTransportException(TTransportException::NOT_OPEN,
- "open(): underlying QIODevice isn't open");
- }
-}
-
-bool TQIODeviceTransport::isOpen()
-{
- return dev_->isOpen();
-}
-
-bool TQIODeviceTransport::peek()
-{
- return dev_->bytesAvailable() > 0;
-}
-
-void TQIODeviceTransport::close()
-{
- dev_->close();
-}
-
-uint32_t TQIODeviceTransport::readAll(uint8_t* buf, uint32_t len)
-{
- uint32_t requestLen = len;
- while (len) {
- uint32_t readSize;
- try {
- readSize = read(buf, len);
- } catch (...) {
- if (len != requestLen) {
- // something read already
- return requestLen - len;
- }
- // error but nothing read yet
- throw;
- }
- if (readSize == 0) {
- dev_->waitForReadyRead(50);
- } else {
- buf += readSize;
- len -= readSize;
- }
- }
- return requestLen;
-}
-
-uint32_t TQIODeviceTransport::read(uint8_t* buf, uint32_t len)
-{
- uint32_t actualSize;
- qint64 readSize;
-
- if (!dev_->isOpen()) {
- throw TTransportException(TTransportException::NOT_OPEN,
- "read(): underlying QIODevice is not open");
- }
-
- actualSize = (uint32_t)std::min((qint64)len, dev_->bytesAvailable());
- readSize = dev_->read(reinterpret_cast<char *>(buf), actualSize);
-
- if (readSize < 0) {
- QAbstractSocket* socket;
- if ((socket = qobject_cast<QAbstractSocket* >(dev_.get()))) {
- throw TTransportException(TTransportException::UNKNOWN,
- "Failed to read() from QAbstractSocket",
- socket->error());
- }
- throw TTransportException(TTransportException::UNKNOWN,
- "Failed to read from from QIODevice");
- }
-
- return (uint32_t)readSize;
-}
-
-void TQIODeviceTransport::write(const uint8_t* buf, uint32_t len)
-{
- while (len) {
- uint32_t written = write_partial(buf, len);
- len -= written;
- dev_->waitForBytesWritten(50);
- }
-}
-
-uint32_t TQIODeviceTransport::write_partial(const uint8_t* buf, uint32_t len)
-{
- qint64 written;
-
- if (!dev_->isOpen()) {
- throw TTransportException(TTransportException::NOT_OPEN,
- "write_partial(): underlying QIODevice is not open");
- }
-
- written = dev_->write(reinterpret_cast<const char*>(buf), len);
- if (written < 0) {
- QAbstractSocket* socket;
- if ((socket = qobject_cast<QAbstractSocket*>(dev_.get()))) {
- throw TTransportException(TTransportException::UNKNOWN,
- "write_partial(): failed to write to QAbstractSocket", socket->error());
- }
-
- throw TTransportException(TTransportException::UNKNOWN,
- "write_partial(): failed to write to underlying QIODevice");
- }
-
- return (uint32_t)written;
-}
-
-void TQIODeviceTransport::flush()
-{
- if (!dev_->isOpen()) {
- throw TTransportException(TTransportException::NOT_OPEN,
- "flush(): underlying QIODevice is not open");
- }
-
- QAbstractSocket* socket;
-
- if ((socket = qobject_cast<QAbstractSocket*>(dev_.get()))) {
- socket->flush();
- } else {
- dev_->waitForBytesWritten(1);
- }
-}
-
-uint8_t* TQIODeviceTransport::borrow(uint8_t* buf, uint32_t* len)
-{
- (void) buf;
- (void) len;
- return NULL;
-}
-
-void TQIODeviceTransport::consume(uint32_t len)
-{
- (void) len;
- throw TTransportException(TTransportException::UNKNOWN);
-}
-
-}}} // apache::thrift::transport
-
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.h
deleted file mode 100644
index 64faa12..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQIODeviceTransport.h
+++ /dev/null
@@ -1,64 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_ASYNC_TQIODEVICE_TRANSPORT_H_
-#define _THRIFT_ASYNC_TQIODEVICE_TRANSPORT_H_ 1
-
-#include <boost/shared_ptr.hpp>
-
-#include <thrift/transport/TVirtualTransport.h>
-
-class QIODevice;
-
-namespace apache { namespace thrift { namespace transport {
-
-/**
- * Transport that operates on a QIODevice (socket, file, etc).
- */
-class TQIODeviceTransport : public apache::thrift::transport::TVirtualTransport<TQIODeviceTransport> {
- public:
- explicit TQIODeviceTransport(boost::shared_ptr<QIODevice> dev);
- virtual ~TQIODeviceTransport();
-
- void open();
- bool isOpen();
- bool peek();
- void close();
-
- uint32_t readAll(uint8_t *buf, uint32_t len);
- uint32_t read(uint8_t* buf, uint32_t len);
-
- void write(const uint8_t* buf, uint32_t len);
- uint32_t write_partial(const uint8_t* buf, uint32_t len);
-
- void flush();
-
- uint8_t* borrow(uint8_t* buf, uint32_t* len);
- void consume(uint32_t len);
-
- private:
- TQIODeviceTransport(const TQIODeviceTransport&);
- TQIODeviceTransport& operator=(const TQIODeviceTransport&);
-
- boost::shared_ptr<QIODevice> dev_;
-};
-}}} // apache::thrift::transport
-
-#endif // #ifndef _THRIFT_ASYNC_TQIODEVICE_TRANSPORT_H_
-
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.cpp
deleted file mode 100644
index 79a8c59..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.cpp
+++ /dev/null
@@ -1,157 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#include <thrift/qt/TQTcpServer.h>
-#include <thrift/qt/TQIODeviceTransport.h>
-
-#include <QTcpSocket>
-
-#include <thrift/cxxfunctional.h>
-
-#include <thrift/protocol/TProtocol.h>
-#include <thrift/async/TAsyncProcessor.h>
-
-using boost::shared_ptr;
-using apache::thrift::protocol::TProtocol;
-using apache::thrift::protocol::TProtocolFactory;
-using apache::thrift::transport::TTransport;
-using apache::thrift::transport::TTransportException;
-using apache::thrift::transport::TQIODeviceTransport;
-using apache::thrift::stdcxx::function;
-using apache::thrift::stdcxx::bind;
-
-QT_USE_NAMESPACE
-
-namespace apache { namespace thrift { namespace async {
-
-struct TQTcpServer::ConnectionContext {
- shared_ptr<QTcpSocket> connection_;
- shared_ptr<TTransport> transport_;
- shared_ptr<TProtocol> iprot_;
- shared_ptr<TProtocol> oprot_;
-
- explicit ConnectionContext(shared_ptr<QTcpSocket> connection,
- shared_ptr<TTransport> transport,
- shared_ptr<TProtocol> iprot,
- shared_ptr<TProtocol> oprot)
- : connection_(connection)
- , transport_(transport)
- , iprot_(iprot)
- , oprot_(oprot)
- {}
-};
-
-TQTcpServer::TQTcpServer(shared_ptr<QTcpServer> server,
- shared_ptr<TAsyncProcessor> processor,
- shared_ptr<TProtocolFactory> pfact,
- QObject* parent)
- : QObject(parent)
- , server_(server)
- , processor_(processor)
- , pfact_(pfact)
-{
- connect(server.get(), SIGNAL(newConnection()), SLOT(processIncoming()));
-}
-
-TQTcpServer::~TQTcpServer()
-{
-}
-
-void TQTcpServer::processIncoming()
-{
- while (server_->hasPendingConnections()) {
- // take ownership of the QTcpSocket; technically it could be deleted
- // when the QTcpServer is destroyed, but any real app should delete this
- // class before deleting the QTcpServer that we are using
- shared_ptr<QTcpSocket> connection(server_->nextPendingConnection());
-
- shared_ptr<TTransport> transport;
- shared_ptr<TProtocol> iprot;
- shared_ptr<TProtocol> oprot;
-
- try {
- transport = shared_ptr<TTransport>(new TQIODeviceTransport(connection));
- iprot = shared_ptr<TProtocol>(pfact_->getProtocol(transport));
- oprot = shared_ptr<TProtocol>(pfact_->getProtocol(transport));
- } catch(...) {
- qWarning("[TQTcpServer] Failed to initialize transports/protocols");
- continue;
- }
-
- ctxMap_[connection.get()] =
- shared_ptr<ConnectionContext>(
- new ConnectionContext(connection, transport, iprot, oprot));
-
- connect(connection.get(), SIGNAL(readyRead()), SLOT(beginDecode()));
-
- // need to use QueuedConnection since we will be deleting the socket in the slot
- connect(connection.get(), SIGNAL(disconnected()), SLOT(socketClosed()),
- Qt::QueuedConnection);
- }
-}
-
-void TQTcpServer::beginDecode()
-{
- QTcpSocket* connection(qobject_cast<QTcpSocket*>(sender()));
- Q_ASSERT(connection);
-
- if (ctxMap_.find(connection) == ctxMap_.end()) {
- qWarning("[TQTcpServer] Got data on an unknown QTcpSocket");
- return;
- }
-
- shared_ptr<ConnectionContext> ctx = ctxMap_[connection];
-
- try {
- processor_->process(
- bind(&TQTcpServer::finish, this,
- ctx, apache::thrift::stdcxx::placeholders::_1),
- ctx->iprot_, ctx->oprot_);
- } catch(const TTransportException& ex) {
- qWarning("[TQTcpServer] TTransportException during processing: '%s'",
- ex.what());
- ctxMap_.erase(connection);
- } catch(...) {
- qWarning("[TQTcpServer] Unknown processor exception");
- ctxMap_.erase(connection);
- }
-}
-
-void TQTcpServer::socketClosed()
-{
- QTcpSocket* connection(qobject_cast<QTcpSocket*>(sender()));
- Q_ASSERT(connection);
-
- if (ctxMap_.find(connection) == ctxMap_.end()) {
- qWarning("[TQTcpServer] Unknown QTcpSocket closed");
- return;
- }
-
- ctxMap_.erase(connection);
-}
-
-void TQTcpServer::finish(shared_ptr<ConnectionContext> ctx, bool healthy)
-{
- if (!healthy) {
- qWarning("[TQTcpServer] Processor failed to process data successfully");
- ctxMap_.erase(ctx->connection_.get());
- }
-}
-
-}}} // apache::thrift::async
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.h
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.h
deleted file mode 100644
index 12a450f..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/TQTcpServer.h
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-#ifndef _THRIFT_TASYNC_QTCP_SERVER_H_
-#define _THRIFT_TASYNC_QTCP_SERVER_H_
-
-#include <QObject>
-#include <QTcpServer>
-
-#include <boost/shared_ptr.hpp>
-
-namespace apache { namespace thrift { namespace protocol {
-class TProtocolFactory;
-}}} // apache::thrift::protocol
-
-namespace apache { namespace thrift { namespace async {
-
-class TAsyncProcessor;
-
-/**
- * Server that uses Qt to listen for connections.
- * Simply give it a QTcpServer that is listening, along with an async
- * processor and a protocol factory, and then run the Qt event loop.
- */
-class TQTcpServer : public QObject {
- Q_OBJECT
- public:
- TQTcpServer(boost::shared_ptr<QTcpServer> server,
- boost::shared_ptr<TAsyncProcessor> processor,
- boost::shared_ptr<apache::thrift::protocol::TProtocolFactory> protocolFactory,
- QT_PREPEND_NAMESPACE(QObject)* parent = NULL);
- virtual ~TQTcpServer();
-
- private Q_SLOTS:
- void processIncoming();
- void beginDecode();
- void socketClosed();
-
- private:
- TQTcpServer(const TQTcpServer&);
- TQTcpServer& operator=(const TQTcpServer&);
-
- class ConnectionContext;
-
- void finish(boost::shared_ptr<ConnectionContext> ctx, bool healthy);
-
- boost::shared_ptr<QTcpServer> server_;
- boost::shared_ptr<TAsyncProcessor> processor_;
- boost::shared_ptr<apache::thrift::protocol::TProtocolFactory> pfact_;
-
- std::map<QT_PREPEND_NAMESPACE(QTcpSocket)*, boost::shared_ptr<ConnectionContext> > ctxMap_;
-};
-
-}}} // apache::thrift::async
-
-#endif // #ifndef _THRIFT_TASYNC_QTCP_SERVER_H_
http://git-wip-us.apache.org/repos/asf/airavata-php-gateway/blob/d55608f1/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/moc_TQTcpServer.cpp
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/moc_TQTcpServer.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/moc_TQTcpServer.cpp
deleted file mode 100644
index 4ac3248..0000000
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/thrift/qt/moc_TQTcpServer.cpp
+++ /dev/null
@@ -1,100 +0,0 @@
-/****************************************************************************
-** Meta object code from reading C++ file 'TQTcpServer.h'
-**
-** Created: Sun Aug 18 16:04:26 2013
-** by: The Qt Meta Object Compiler version 63 (Qt 4.8.1)
-**
-** WARNING! All changes made in this file will be lost!
-*****************************************************************************/
-
-#include "TQTcpServer.h"
-#if !defined(Q_MOC_OUTPUT_REVISION)
-#error "The header file 'TQTcpServer.h' doesn't include <QObject>."
-#elif Q_MOC_OUTPUT_REVISION != 63
-#error "This file was generated using the moc from 4.8.1. It"
-#error "cannot be used with the include files from this version of Qt."
-#error "(The moc has changed too much.)"
-#endif
-
-QT_BEGIN_MOC_NAMESPACE
-static const uint qt_meta_data_apache__thrift__async__TQTcpServer[] = {
-
- // content:
- 6, // revision
- 0, // classname
- 0, 0, // classinfo
- 3, 14, // methods
- 0, 0, // properties
- 0, 0, // enums/sets
- 0, 0, // constructors
- 0, // flags
- 0, // signalCount
-
- // slots: signature, parameters, type, tag, flags
- 36, 35, 35, 35, 0x08,
- 54, 35, 35, 35, 0x08,
- 68, 35, 35, 35, 0x08,
-
- 0 // eod
-};
-
-static const char qt_meta_stringdata_apache__thrift__async__TQTcpServer[] = {
- "apache::thrift::async::TQTcpServer\0\0"
- "processIncoming()\0beginDecode()\0"
- "socketClosed()\0"
-};
-
-void apache::thrift::async::TQTcpServer::qt_static_metacall(QObject *_o, QMetaObject::Call _c, int _id, void **_a)
-{
- if (_c == QMetaObject::InvokeMetaMethod) {
- Q_ASSERT(staticMetaObject.cast(_o));
- TQTcpServer *_t = static_cast<TQTcpServer *>(_o);
- switch (_id) {
- case 0: _t->processIncoming(); break;
- case 1: _t->beginDecode(); break;
- case 2: _t->socketClosed(); break;
- default: ;
- }
- }
- Q_UNUSED(_a);
-}
-
-const QMetaObjectExtraData apache::thrift::async::TQTcpServer::staticMetaObjectExtraData = {
- 0, qt_static_metacall
-};
-
-const QMetaObject apache::thrift::async::TQTcpServer::staticMetaObject = {
- { &QObject::staticMetaObject, qt_meta_stringdata_apache__thrift__async__TQTcpServer,
- qt_meta_data_apache__thrift__async__TQTcpServer, &staticMetaObjectExtraData }
-};
-
-#ifdef Q_NO_DATA_RELOCATION
-const QMetaObject &apache::thrift::async::TQTcpServer::getStaticMetaObject() { return staticMetaObject; }
-#endif //Q_NO_DATA_RELOCATION
-
-const QMetaObject *apache::thrift::async::TQTcpServer::metaObject() const
-{
- return QObject::d_ptr->metaObject ? QObject::d_ptr->metaObject : &staticMetaObject;
-}
-
-void *apache::thrift::async::TQTcpServer::qt_metacast(const char *_clname)
-{
- if (!_clname) return 0;
- if (!strcmp(_clname, qt_meta_stringdata_apache__thrift__async__TQTcpServer))
- return static_cast<void*>(const_cast< TQTcpServer*>(this));
- return QObject::qt_metacast(_clname);
-}
-
-int apache::thrift::async::TQTcpServer::qt_metacall(QMetaObject::Call _c, int _id, void **_a)
-{
- _id = QObject::qt_metacall(_c, _id, _a);
- if (_id < 0)
- return _id;
- if (_c == QMetaObject::InvokeMetaMethod) {
- if (_id < 3)
- qt_static_metacall(this, _c, _id, _a);
- _id -= 3;
- }
- return _id;
-}
-QT_END_MOC_NAMESPACE