/* * 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_THRIFT_H_ #define _THRIFT_THRIFT_H_ 1 #ifdef HAVE_CONFIG_H #include "config.h" #endif #include #include #include #ifdef HAVE_INTTYPES_H #include #endif #include #include #include #include #include #include #include "TLogging.h" namespace apache { namespace thrift { class TOutput { public: TOutput() : f_(&errorTimeWrapper) {} inline void setOutputFunction(void (*function)(const char *)){ f_ = function; } inline void operator()(const char *message){ f_(message); } // It is important to have a const char* overload here instead of // just the string version, otherwise errno could be corrupted // if there is some problem allocating memory when constructing // the string. void perror(const char *message, int errno_copy); inline void perror(const std::string &message, int errno_copy) { perror(message.c_str(), errno_copy); } void printf(const char *message, ...); inline static void errorTimeWrapper(const char* msg) { time_t now; char dbgtime[26]; time(&now); ctime_r(&now, dbgtime); dbgtime[24] = 0; fprintf(stderr, "Thrift: %s %s\n", dbgtime, msg); } /** Just like strerror_r but returns a C++ string object. */ static std::string strerror_s(int errno_copy); private: void (*f_)(const char *); }; extern TOutput GlobalOutput; namespace protocol { class TProtocol; } class TException : public std::exception { public: TException() {} TException(const std::string& message) : message_(message) {} virtual ~TException() throw() {} virtual const char* what() const throw() { if (message_.empty()) { return "Default TException."; } else { return message_.c_str(); } } protected: std::string message_; }; class TApplicationException : public TException { public: /** * Error codes for the various types of exceptions. */ enum TApplicationExceptionType { UNKNOWN = 0 , UNKNOWN_METHOD = 1 , INVALID_MESSAGE_TYPE = 2 , WRONG_METHOD_NAME = 3 , BAD_SEQUENCE_ID = 4 , MISSING_RESULT = 5 }; TApplicationException() : TException(), type_(UNKNOWN) {} TApplicationException(TApplicationExceptionType type) : TException(), type_(type) {} TApplicationException(const std::string& message) : TException(message), type_(UNKNOWN) {} TApplicationException(TApplicationExceptionType type, const std::string& message) : TException(message), type_(type) {} virtual ~TApplicationException() throw() {} /** * Returns an error code that provides information about the type of error * that has occurred. * * @return Error code */ TApplicationExceptionType getType() { return type_; } virtual const char* what() const throw() { if (message_.empty()) { switch (type_) { case UNKNOWN : return "TApplicationException: Unknown application exception"; case UNKNOWN_METHOD : return "TApplicationException: Unknown method"; case INVALID_MESSAGE_TYPE : return "TApplicationException: Invalid message type"; case WRONG_METHOD_NAME : return "TApplicationException: Wrong method name"; case BAD_SEQUENCE_ID : return "TApplicationException: Bad sequence identifier"; case MISSING_RESULT : return "TApplicationException: Missing result"; default : return "TApplicationException: (Invalid exception type)"; }; } else { return message_.c_str(); } } uint32_t read(protocol::TProtocol* iprot); uint32_t write(protocol::TProtocol* oprot) const; protected: /** * Error code */ TApplicationExceptionType type_; }; // Forward declare this structure used by TDenseProtocol namespace reflection { namespace local { struct TypeSpec; }} }} // apache::thrift #endif // #ifndef _THRIFT_THRIFT_H_