1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*
* 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 AsyncOperation.cpp
*/
#include "AsyncOperation.h"
#include "qpid/Exception.h"
#include "qpid/broker/BrokerContext.h" // for delete in d'tor
#include <sstream>
namespace qpid {
namespace asyncStore {
AsyncOperation::AsyncOperation() :
m_op(NONE),
m_targetHandle(),
m_dataSrc(0),
m_txnHandle(0),
m_resCb(0),
m_brokerCtxt(0)
{}
AsyncOperation::AsyncOperation(const opCode op,
const qpid::broker::IdHandle* th,
const qpid::broker::ResultCallback resCb,
qpid::broker::BrokerContext* brokerCtxt) :
m_op(op),
m_targetHandle(th),
m_dataSrc(0),
m_txnHandle(0),
m_resCb(resCb),
m_brokerCtxt(brokerCtxt)
{}
AsyncOperation::AsyncOperation(const opCode op,
const qpid::broker::IdHandle* th,
const qpid::broker::DataSource* dataSrc,
const qpid::broker::ResultCallback resCb,
qpid::broker::BrokerContext* brokerCtxt) :
m_op(op),
m_targetHandle(th),
m_dataSrc(dataSrc),
m_txnHandle(0),
m_resCb(resCb),
m_brokerCtxt(brokerCtxt)
{}
AsyncOperation::AsyncOperation(const opCode op,
const qpid::broker::IdHandle* th,
const qpid::broker::TxnHandle* txnHandle,
const qpid::broker::ResultCallback resCb,
qpid::broker::BrokerContext* brokerCtxt) :
m_op(op),
m_targetHandle(th),
m_dataSrc(0),
m_txnHandle(txnHandle),
m_resCb(resCb),
m_brokerCtxt(brokerCtxt)
{}
AsyncOperation::AsyncOperation(const opCode op,
const qpid::broker::IdHandle* th,
const qpid::broker::DataSource* dataSrc,
const qpid::broker::TxnHandle* txnHandle,
const qpid::broker::ResultCallback resCb,
qpid::broker::BrokerContext* brokerCtxt) :
m_op(op),
m_targetHandle(th),
m_dataSrc(dataSrc),
m_txnHandle(txnHandle),
m_resCb(resCb),
m_brokerCtxt(brokerCtxt)
{}
AsyncOperation::~AsyncOperation()
{}
const char*
AsyncOperation::getOpStr() const
{
return getOpStr(m_op);
}
//static
const char*
AsyncOperation::getOpStr(const opCode op)
{
switch (op) {
case NONE: return "<none>";
case TXN_PREPARE: return "TXN_PREPARE";
case TXN_COMMIT: return "TXN_COMMIT";
case TXN_ABORT: return "TXN_ABORT";
case CONFIG_CREATE: return "CONFIG_CREATE";
case CONFIG_DESTROY: return "CONFIG_DESTROY";
case QUEUE_CREATE: return "QUEUE_CREATE";
case QUEUE_FLUSH: return "QUEUE_FLUSH";
case QUEUE_DESTROY: return "QUEUE_DESTROY";
case EVENT_CREATE: return "EVENT_CREATE";
case EVENT_DESTROY: return "EVENT_DESTROY";
case MSG_ENQUEUE: return "MSG_ENQUEUE";
case MSG_DEQUEUE: return "MSG_DEQUEUE";
}
std::ostringstream oss;
oss << "AsyncStore: AsyncOperation::getOpStr(): Unknown op-code \"" << op << "\"";
throw qpid::Exception(oss.str());
}
}} // namespace qpid::asyncStore
|
