Skip to content
GitLab
Explore
Sign in
Primary navigation
Search or go to…
Project
H
Hercules
Manage
Activity
Members
Labels
Plan
Issues
Issue boards
Milestones
Wiki
Code
Merge requests
Repository
Branches
Commits
Tags
Repository graph
Compare revisions
Snippets
Build
Pipelines
Jobs
Pipeline schedules
Artifacts
Deploy
Releases
Package registry
Model registry
Operate
Environments
Terraform modules
Monitor
Incidents
Analyze
Value stream analytics
Contributor analytics
CI/CD analytics
Repository analytics
Model experiments
Help
Help
Support
GitLab documentation
Compare GitLab plans
Community forum
Contribute to GitLab
Provide feedback
Keyboard shortcuts
?
Snippets
Groups
Projects
Show more breadcrumbs
llvm
Hercules
Merge requests
!217
Misc.
Code
Review changes
Check out branch
Download
Patches
Plain diff
Merged
Misc.
rt_fork_tweak
into
main
Overview
0
Commits
2
Pipelines
1
Changes
1
Merged
rarbore2
requested to merge
rt_fork_tweak
into
main
2 weeks ago
Overview
0
Commits
2
Pipelines
1
Changes
1
Expand
Add region nodes after fork-joins to get better block placements.
0
0
Merge request reports
Viewing commit
3530e5ab
Prev
Next
Show latest version
1 file
+
28
−
0
Inline
Compare changes
Side-by-side
Inline
Show whitespace changes
Show one file at a time
3530e5ab
Spin barrier that might be useful later
· 3530e5ab
Russel Arbore
authored
2 weeks ago
hercules_rt/src/lib.rs
+
28
−
0
Options
@@ -5,6 +5,7 @@ use std::future::Future;
use
std
::
marker
::
PhantomData
;
use
std
::
ptr
::{
copy_nonoverlapping
,
write_bytes
,
NonNull
};
use
std
::
slice
::{
from_raw_parts
,
from_raw_parts_mut
};
use
std
::
sync
::
atomic
::{
AtomicUsize
,
Ordering
};
use
std
::
sync
::
OnceLock
;
/*
@@ -928,3 +929,30 @@ unsafe impl GlobalAlloc for AlignedAlloc {
#[global_allocator]
static
A
:
AlignedAlloc
=
AlignedAlloc
;
pub
struct
SpinBarrier
{
num
:
usize
,
waiting
:
AtomicUsize
,
gen
:
AtomicUsize
,
}
impl
SpinBarrier
{
pub
const
fn
new
(
num
:
usize
)
->
Self
{
SpinBarrier
{
num
,
waiting
:
AtomicUsize
::
new
(
0
),
gen
:
AtomicUsize
::
new
(
0
),
}
}
pub
fn
wait
(
&
self
)
{
let
old_gen
=
self
.gen
.load
(
Ordering
::
Acquire
);
let
old_waiting
=
self
.waiting
.fetch_add
(
1
,
Ordering
::
Relaxed
);
if
old_waiting
+
1
==
self
.num
{
self
.waiting
.store
(
0
,
Ordering
::
Relaxed
);
self
.gen
.fetch_add
(
1
,
Ordering
::
Release
);
}
else
{
while
old_gen
==
self
.gen
.load
(
Ordering
::
Acquire
)
{}
}
}
}
Loading