You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/11/28 20:02:58 UTC
svn commit: r1414866 -
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h
Author: tabish
Date: Wed Nov 28 19:02:57 2012
New Revision: 1414866
URL: http://svn.apache.org/viewvc?rev=1414866&view=rev
Log:
Minor code fix.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h?rev=1414866&r1=1414865&r2=1414866&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/concurrent/LinkedBlockingQueue.h Wed Nov 28 19:02:57 2012
@@ -66,8 +66,8 @@ namespace concurrent {
private:
- QueueNode( const QueueNode& );
- QueueNode& operator= ( const QueueNode& );
+ QueueNode(const QueueNode&);
+ QueueNode& operator=(const QueueNode&);
public:
@@ -110,8 +110,8 @@ namespace concurrent {
class TotalLock {
private:
- TotalLock( const TotalLock& src );
- TotalLock& operator= ( const TotalLock& src );
+ TotalLock(const TotalLock& src);
+ TotalLock& operator=(const TotalLock& src);
private:
@@ -119,7 +119,7 @@ namespace concurrent {
public:
- TotalLock( const LinkedBlockingQueue<E>* parent ) : parent(parent) {
+ TotalLock(const LinkedBlockingQueue<E>* parent) : parent(parent) {
parent->putLock.lock();
parent->takeLock.lock();
}
@@ -245,7 +245,7 @@ namespace concurrent {
this->notEmpty.reset(this->takeLock.newCondition());
this->notFull.reset(this->putLock.newCondition());
- Pointer< Iterator<E> > iter(queue.iterator);
+ Pointer< Iterator<E> > iter(queue.iterator());
try {