forked from RaftLib/RaftLib
-
Notifications
You must be signed in to change notification settings - Fork 1
/
blocked.hpp
67 lines (60 loc) · 1.72 KB
/
blocked.hpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
/**
* blocked.hpp -
* @author: Jonathan Beard
* @version: Sun Jun 29 14:06:10 2014
*
* Copyright 2014 Jonathan Beard
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef _BLOCKED_HPP_
#define _BLOCKED_HPP_ 1
#include <cstdint>
#include <cassert>
/**
* FIXME...should probably align these to cache line then
* zero extend pad for producer/consumer.
*/
struct Blocked
{
using value_type = std::uint32_t;
using whole_type = std::uint64_t;
static_assert( sizeof( value_type ) * 2 == sizeof( whole_type ),
"Error, the whole type must be double the size of the half type" );
Blocked() = default;
Blocked( const Blocked &other ) : all( other.all ){}
Blocked& operator += ( const Blocked &rhs )
{
if( ! rhs.bec.blocked )
{
(this)->bec.count += rhs.bec.count;
}
return( *this );
}
struct blocked_and_counter
{
value_type blocked;
value_type count;
};
union
{
blocked_and_counter bec;
whole_type all = 0;
};
char pad[ L1D_CACHE_LINE_SIZE - sizeof( whole_type ) ];
}
#if __APPLE__ || __linux
__attribute__ (( aligned( 64 )))
#endif
;
#endif /* END _BLOCKED_HPP_ */