diff options
Diffstat (limited to 'cpp/src/qpid')
| -rw-r--r-- | cpp/src/qpid/broker/DtxHandlerImpl.cpp | 10 | ||||
| -rw-r--r-- | cpp/src/qpid/sys/apr/LFProcessor.cpp | 2 |
2 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/DtxHandlerImpl.cpp b/cpp/src/qpid/broker/DtxHandlerImpl.cpp index c7ed95e5d3..aeb1c3014c 100644 --- a/cpp/src/qpid/broker/DtxHandlerImpl.cpp +++ b/cpp/src/qpid/broker/DtxHandlerImpl.cpp @@ -77,7 +77,7 @@ void DtxHandlerImpl::end(const MethodContext& context, } dClient.endOk(XA_OK, context.getRequestId()); } - } catch (DtxTimeoutException e) { + } catch (const DtxTimeoutException& e) { dClient.endOk(XA_RBTIMEOUT, context.getRequestId()); } } @@ -98,7 +98,7 @@ void DtxHandlerImpl::start(const MethodContext& context, channel.startDtx(xid, broker.getDtxManager(), join); } dClient.startOk(XA_OK, context.getRequestId()); - } catch (DtxTimeoutException e) { + } catch (const DtxTimeoutException& e) { dClient.startOk(XA_RBTIMEOUT, context.getRequestId()); } } @@ -112,7 +112,7 @@ void DtxHandlerImpl::prepare(const MethodContext& context, try { bool ok = broker.getDtxManager().prepare(xid); cClient.prepareOk(ok ? XA_OK : XA_RBROLLBACK, context.getRequestId()); - } catch (DtxTimeoutException e) { + } catch (const DtxTimeoutException& e) { cClient.prepareOk(XA_RBTIMEOUT, context.getRequestId()); } } @@ -125,7 +125,7 @@ void DtxHandlerImpl::commit(const MethodContext& context, try { bool ok = broker.getDtxManager().commit(xid, onePhase); cClient.commitOk(ok ? XA_OK : XA_RBROLLBACK, context.getRequestId()); - } catch (DtxTimeoutException e) { + } catch (const DtxTimeoutException& e) { cClient.commitOk(XA_RBTIMEOUT, context.getRequestId()); } } @@ -138,7 +138,7 @@ void DtxHandlerImpl::rollback(const MethodContext& context, try { broker.getDtxManager().rollback(xid); cClient.rollbackOk(XA_OK, context.getRequestId()); - } catch (DtxTimeoutException e) { + } catch (const DtxTimeoutException& e) { cClient.rollbackOk(XA_RBTIMEOUT, context.getRequestId()); } } diff --git a/cpp/src/qpid/sys/apr/LFProcessor.cpp b/cpp/src/qpid/sys/apr/LFProcessor.cpp index bb53e45a83..69c92cc2c4 100644 --- a/cpp/src/qpid/sys/apr/LFProcessor.cpp +++ b/cpp/src/qpid/sys/apr/LFProcessor.cpp @@ -136,7 +136,7 @@ void LFProcessor::run(){ session->stopProcessing(); } } - }catch(std::exception e){ + }catch(const std::exception& e){ QPID_LOG(error, e.what()); } } |