aboutsummaryrefslogtreecommitdiff
path: root/lib/std/event/loop.zig
diff options
context:
space:
mode:
authorVexu <15308111+Vexu@users.noreply.github.com>2019-11-13 00:45:37 +0200
committerVexu <15308111+Vexu@users.noreply.github.com>2019-11-13 00:52:15 +0200
commitf0c94d95dde320ba5e7509dc1499b33e54a1c951 (patch)
tree0a2d9acdfa2a066c0fcee6d893747ee731a5083b /lib/std/event/loop.zig
parent110ef2e52825656fc048cba020f0fc36a1e58d13 (diff)
downloadzig-f0c94d95dde320ba5e7509dc1499b33e54a1c951.tar.gz
zig-f0c94d95dde320ba5e7509dc1499b33e54a1c951.zip
use @atomicStore in std lib
Diffstat (limited to 'lib/std/event/loop.zig')
-rw-r--r--lib/std/event/loop.zig4
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/std/event/loop.zig b/lib/std/event/loop.zig
index 543863c71e..a6284411eb 100644
--- a/lib/std/event/loop.zig
+++ b/lib/std/event/loop.zig
@@ -820,7 +820,7 @@ pub const Loop = struct {
_ = os.kevent(self.os_data.fs_kqfd, fs_kevs, empty_kevs, null) catch unreachable;
},
.linux => {
- _ = @atomicRmw(i32, &self.os_data.fs_queue_item, AtomicRmwOp.Xchg, 1, AtomicOrder.SeqCst);
+ @atomicStore(i32, &self.os_data.fs_queue_item, 1, AtomicOrder.SeqCst);
const rc = os.linux.futex_wake(&self.os_data.fs_queue_item, os.linux.FUTEX_WAKE, 1);
switch (os.linux.getErrno(rc)) {
0 => {},
@@ -843,7 +843,7 @@ pub const Loop = struct {
fn posixFsRun(self: *Loop) void {
while (true) {
if (builtin.os == .linux) {
- _ = @atomicRmw(i32, &self.os_data.fs_queue_item, .Xchg, 0, .SeqCst);
+ @atomicStore(i32, &self.os_data.fs_queue_item, 0, .SeqCst);
}
while (self.os_data.fs_queue.get()) |node| {
switch (node.data.msg) {