boost/fiber
2
0
Fork 0
mirror of https://github.com/boostorg/fiber.git synced 2026-02-17 13:42:21 +00:00
Code Issues Projects Releases Wiki Activity

small formating + fixing for channels

Browse Source
This commit is contained in:
Oliver Kowalke
2015-06-28 10:25:05 +02:00
parent cdcbbf09a7
commit afe7714c61
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
include/boost/fiber/bounded_channel.hpp
View File

@@ -108,7 +108,7 @@ private:
}
channel_op_status push_( typename node::ptr const& new_node,
std::unique_lock< boost::fibers::mutex >& lk ) {
std::unique_lock< boost::fibers::mutex > & lk ) {
if ( is_closed_() ) {
return channel_op_status::closed;
}
@@ -134,8 +134,8 @@ private:
template< typename Clock, typename Duration >
channel_op_status push_wait_until_( typename node::ptr const& new_node,
std::chrono::time_point< Clock, Duration > const& timeout_time,
std::unique_lock< boost::fibers::mutex >& lk) {
std::chrono::time_point< Clock, Duration > const& timeout_time,
std::unique_lock< boost::fibers::mutex > & lk) {
if ( is_closed_() ) {
return channel_op_status::closed;
}

6
include/boost/fiber/unbounded_channel.hpp
View File

@@ -95,7 +95,7 @@ private:
}
channel_op_status push_( typename node::ptr const& new_node,
std::unique_lock< boost::fibers::mutex >& lk) {
std::unique_lock< boost::fibers::mutex > & lk) {
if ( is_closed_() ) {
return channel_op_status::closed;
}
@@ -135,10 +135,10 @@ private:
typename node::ptr pop_head_() {
typename node::ptr old_head = head_;
head_ = old_head->nxt;
if ( nullptr == head_) {
if ( ! head_) {
tail_ = & head_;
}
old_head->nxt = nullptr;
old_head->nxt.reset();
return old_head;
}