Bug fix

alexleemanfui · alexleemanfui · commit 71b854041a27 · 2015-09-01T21:22:37.000+08:00
diff --git a/test/utils/count_down_latch.h b/test/utils/count_down_latch.h
@@ -43,7 +43,7 @@ namespace disruptor4cpp
 		class count_down_latch
 		{
 		public:
-			explicit count_down_latch(std::size_t count)
+			explicit count_down_latch(int count)
 				: count_(count)
 			{
 			}
@@ -62,13 +62,13 @@ namespace disruptor4cpp
 			bool wait(const std::chrono::duration<Rep, Period>& timeout)
 			{
 				std::unique_lock<std::mutex> lock(mutex_);
-				return condition_.wait_for(lock, timeout, [this] { return count_ == 0; });
+				return condition_.wait_for(lock, timeout, [this] { return count_ <= 0; });
 			}
 
 			void count_down()
 			{
 				std::lock_guard<std::mutex> lock(mutex_);
-				if (--count_ == 0)
+				if (--count_ <= 0)
 					condition_.notify_all();
 			}
 
@@ -80,7 +80,7 @@ namespace disruptor4cpp
 
 			std::mutex mutex_;
 			std::condition_variable condition_;
-			std::size_t count_;
+			int count_;
 		};
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -43,7 +43,7 @@ namespace disruptor4cpp`
`43`	`43`	`class count_down_latch`
`44`	`44`	`{`
`45`	`45`	`public:`
`46`		`- explicit count_down_latch(std::size_t count)`
	`46`	`+ explicit count_down_latch(int count)`
`47`	`47`	`: count_(count)`
`48`	`48`	`{`
`49`	`49`	`}`
`@@ -62,13 +62,13 @@ namespace disruptor4cpp`
`62`	`62`	`bool wait(const std::chrono::duration<Rep, Period>& timeout)`
`63`	`63`	`{`
`64`	`64`	`std::unique_lock<std::mutex> lock(mutex_);`
`65`		`- return condition_.wait_for(lock, timeout, [this] { return count_ == 0; });`
	`65`	`+ return condition_.wait_for(lock, timeout, [this] { return count_ <= 0; });`
`66`	`66`	`}`
`67`	`67`
`68`	`68`	`void count_down()`
`69`	`69`	`{`
`70`	`70`	`std::lock_guard<std::mutex> lock(mutex_);`
`71`		`- if (--count_ == 0)`
	`71`	`+ if (--count_ <= 0)`
`72`	`72`	`condition_.notify_all();`
`73`	`73`	`}`
`74`	`74`
`@@ -80,7 +80,7 @@ namespace disruptor4cpp`
`80`	`80`
`81`	`81`	`std::mutex mutex_;`
`82`	`82`	`std::condition_variable condition_;`
`83`		`- std::size_t count_;`
	`83`	`+ int count_;`
`84`	`84`	`};`
`85`	`85`	`}`
`86`	`86`	`}`