@@ -18,17 +18,17 @@ using namespace std;
18
18
using namespace pqxx ;
19
19
20
20
template <class T >
21
- class unique_ptr
21
+ class my_unique_ptr
22
22
{
23
23
T* ptr;
24
24
25
25
public:
26
- unique_ptr (T* p = NULL ) : ptr(p) {}
27
- ~unique_ptr () { delete ptr; }
26
+ my_unique_ptr (T* p = NULL ) : ptr(p) {}
27
+ ~my_unique_ptr () { delete ptr; }
28
28
T& operator *() { return *ptr; }
29
29
T* operator ->() { return ptr; }
30
30
void operator =(T* p) { ptr = p; }
31
- void operator =(unique_ptr & other) {
31
+ void operator =(my_unique_ptr & other) {
32
32
ptr = other.ptr ;
33
33
other.ptr = NULL ;
34
34
}
@@ -115,7 +115,7 @@ xid_t execQuery( transaction_base& txn, char const* sql, ...)
115
115
void * reader (void * arg)
116
116
{
117
117
thread& t = *(thread*)arg;
118
- vector< unique_ptr <connection> > conns (cfg.connections .size ());
118
+ vector< my_unique_ptr <connection> > conns (cfg.connections .size ());
119
119
for (size_t i = 0 ; i < conns.size (); i++) {
120
120
conns[i] = new connection (cfg.connections [i]);
121
121
}
@@ -132,8 +132,8 @@ void* reader(void* arg)
132
132
}
133
133
txn.commit ();
134
134
}
135
- vector< unique_ptr <nontransaction> > txns (conns.size ());
136
- vector< unique_ptr <pipeline> > pipes (conns.size ());
135
+ vector< my_unique_ptr <nontransaction> > txns (conns.size ());
136
+ vector< my_unique_ptr <pipeline> > pipes (conns.size ());
137
137
vector<pipeline::query_id> results (conns.size ());
138
138
for (size_t i = 0 ; i < conns.size (); i++) {
139
139
txns[i] = new nontransaction (*conns[i]);
@@ -196,8 +196,10 @@ void* writer(void* arg)
196
196
197
197
pipeline srcPipe (srcTx);
198
198
pipeline dstPipe (dstTx);
199
+
199
200
srcPipe.insert (" commit transaction" );
200
201
dstPipe.insert (" commit transaction" );
202
+
201
203
srcPipe.complete ();
202
204
dstPipe.complete ();
203
205
0 commit comments