diff options
author | Kim van der Riet <kpvdr@apache.org> | 2012-07-20 13:50:48 +0000 |
---|---|---|
committer | Kim van der Riet <kpvdr@apache.org> | 2012-07-20 13:50:48 +0000 |
commit | dd79efca55e3ff0a0e0c25e395967ce9b3f80482 (patch) | |
tree | e10963e1718a58e3ee4cfaf41cd08bc6856d3b63 /cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp | |
parent | 2e437e1569009d8e8ed3ed896d751994e2e85d74 (diff) | |
download | qpid-python-dd79efca55e3ff0a0e0c25e395967ce9b3f80482.tar.gz |
QPID-3858: WIP: Moved QueueAsycnContext from namespace tests::storePerftools::asyncPerf to qpid::broker
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1363776 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp')
-rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp | 108 |
1 files changed, 0 insertions, 108 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp b/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp deleted file mode 100644 index 0312f61d3c..0000000000 --- a/cpp/src/tests/storePerftools/asyncPerf/QueueAsyncContext.cpp +++ /dev/null @@ -1,108 +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. - */ - -/** - * \file QueueContext.cpp - */ - -#include "QueueAsyncContext.h" - -#include "SimpleMessage.h" - -#include <cassert> - -namespace tests { -namespace storePerftools { -namespace asyncPerf { - -QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<SimpleQueue> q, - qpid::broker::TxnHandle& th, - qpid::broker::AsyncResultCallback rcb, - qpid::broker::AsyncResultQueue* const arq) : - m_q(q), - m_th(th), - m_rcb(rcb), - m_arq(arq) -{ - assert(m_q.get() != 0); -} - -QueueAsyncContext::QueueAsyncContext(boost::shared_ptr<SimpleQueue> q, - boost::intrusive_ptr<SimpleMessage> msg, - qpid::broker::TxnHandle& th, - qpid::broker::AsyncResultCallback rcb, - qpid::broker::AsyncResultQueue* const arq) : - m_q(q), - m_msg(msg), - m_th(th), - m_rcb(rcb), - m_arq(arq) -{ - assert(m_q.get() != 0); - assert(m_msg.get() != 0); -} - -QueueAsyncContext::~QueueAsyncContext() -{} - -boost::shared_ptr<SimpleQueue> -QueueAsyncContext::getQueue() const -{ - return m_q; -} - -boost::intrusive_ptr<SimpleMessage> -QueueAsyncContext::getMessage() const -{ - return m_msg; -} - -qpid::broker::TxnHandle -QueueAsyncContext::getTxnHandle() const -{ - return m_th; -} - -qpid::broker::AsyncResultQueue* -QueueAsyncContext::getAsyncResultQueue() const -{ - return m_arq; -} - -qpid::broker::AsyncResultCallback -QueueAsyncContext::getAsyncResultCallback() const -{ - return m_rcb; -} - -void -QueueAsyncContext::invokeCallback(const qpid::broker::AsyncResultHandle* const arh) const -{ - if (m_rcb) { - m_rcb(arh); - } -} - -void -QueueAsyncContext::destroy() -{ - delete this; -} - -}}} // namespace tests::storePerftools::asyncPerf |