equal
deleted
inserted
replaced
55 t->set_concurrent_top(current_top + unflushed_size); |
55 t->set_concurrent_top(current_top + unflushed_size); |
56 return result; |
56 return result; |
57 } |
57 } |
58 |
58 |
59 template <typename Operation> |
59 template <typename Operation> |
60 inline bool ConcurrentWriteOpExcludeRetired<Operation>::process(typename Operation::Type* t) { |
|
61 if (t->retired() || t->excluded()) { |
|
62 return true; |
|
63 } |
|
64 return ConcurrentWriteOp<Operation>::process(t); |
|
65 } |
|
66 |
|
67 template <typename Operation> |
|
68 inline bool MutexedWriteOp<Operation>::process(typename Operation::Type* t) { |
60 inline bool MutexedWriteOp<Operation>::process(typename Operation::Type* t) { |
69 assert(t != NULL, "invariant"); |
61 assert(t != NULL, "invariant"); |
70 const u1* const current_top = t->top(); |
62 const u1* const current_top = t->top(); |
71 const size_t unflushed_size = t->pos() - current_top; |
63 const size_t unflushed_size = t->pos() - current_top; |
72 if (unflushed_size == 0) { |
64 if (unflushed_size == 0) { |