Session resume support in client & broker: Client can resume a session

after voluntary suspend() or network failure. Frames lost in network
failure are automatically re-transmitted for transparent re-connection.

client::Session improvements:
 - Locking to avoid races between network & user threads.
 - Replaced client::StateManager with sys::StateMonitor - avoid heap allocation.

qpid::Exception clean up:
 - use QPID_MSG consistently to format exception messages.
 - throw typed exceptions (in reply_exceptions.h) for AMQP exceptions.
 - re-throw correct typed exception on client for exceptions from broker.
 - Removed QpidError.h

rubygen/templates/constants.rb: 
 - constants.h: Added FOO_CLASS_ID and FOO_BAR_METHOD_ID constants.
 - reply_constants.h: Added throwReplyException(code, text)
 
log::Logger:
 - Fixed shutdown race in Statement::~Initializer()


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@588761 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 10 insertions, 32 deletions

diff --git a/cpp/src/qpid/Exception.cpp b/cpp/src/qpid/Exception.cpp
index 11051d1a2e..e0747df49e 100644
--- a/cpp/src/qpid/Exception.cpp
+++ b/cpp/src/qpid/Exception.cpp
@@ -23,6 +23,7 @@
 #include "Exception.h"
 #include <typeinfo>
 #include <errno.h>
+#include <assert.h>
 
 namespace qpid {
 
@@ -31,45 +32,22 @@ std::string strError(int err) {
     return std::string(strerror_r(err, buf, sizeof(buf)));
 }
 
-static void ctorLog(const std::exception* e) {
-    QPID_LOG(trace, "Exception: " << e->what());
+Exception::Exception(const std::string& s) throw() : msg(s) {
+    QPID_LOG(warning, "Exception: " << msg);
 }
-    
-Exception::Exception() throw() { ctorLog(this); }
-
-Exception::Exception(const std::string& str) throw()
-    : whatStr(str) { ctorLog(this); }
-
-Exception::Exception(const char* str) throw() : whatStr(str) { ctorLog(this); }
-
-Exception::Exception(const std::exception& e) throw() : whatStr(e.what()) {}
 
 Exception::~Exception() throw() {}
 
-const char* Exception::what() const throw() { return whatStr.c_str(); }
-
-std::string Exception::toString() const throw() { return whatStr; }
-
-Exception::auto_ptr Exception::clone() const throw() { return Exception::auto_ptr(new Exception(*this)); }
-
-void Exception::throwSelf() const  { throw *this; }
-
-ShutdownException::ShutdownException() : Exception("Shut down.") {}
-
-EmptyException::EmptyException() : Exception("Empty.") {}
-
-const char* Exception::defaultMessage = "Unexpected exception";
-
-void Exception::log(const char* what, const char* message) {
-    QPID_LOG(error, message << ": " << what);
+std::string Exception::str() const throw() {
+    if (msg.empty())
+        const_cast<std::string&>(msg).assign(typeid(*this).name());
+    return msg;
 }
 
-void Exception::log(const std::exception& e, const char* message) {
-    log(e.what(), message);
-}
+const char* Exception::what() const throw() { return str().c_str(); }
 
-void Exception::logUnknown(const char* message) {
-    log("unknown exception.", message);
+std::auto_ptr<Exception> Exception::clone() const throw() {
+    return std::auto_ptr<Exception>(new Exception(*this));
 }
 
 } // namespace qpid