update and remove jvm deps

Author: TwoClocks

.gitignore

@@ -23,6 +23,9 @@ Cargo.lock
 .gradle
 build/
 
+# VsCode stuff
+.vscode
+
 # Ignore Gradle GUI config
 gradle-app.setting
 
@@ -52,3 +55,4 @@ compile_commands.json
 CTestTestfile.cmake
 _depsv
 
+cpp/out

Cargo.toml

@@ -1,19 +1,20 @@
 [package]
 name = "async_bench"
-version = "0.1.0"
-edition = "2018"
+version = "0.2.0"
+edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-criterion = { version = "0.3", features = ["async_tokio"] }
+criterion = "0.4"
 rand = "0.8"
-core_affinity = "0.5"
+core_affinity = "0.8"
 byteorder = "1.4"
 libc = "0.2"
 lazy_static = "1.4"
-page_size = "0.4"
-thread-priority = "0.2"
+page_size = "0.5"
+thread-priority = "0.13"
+json = "0.12"
 
 [profile.release]
 lto = true

README.md

@@ -98,13 +98,37 @@ For the coroutine server code, this is the kotlin version which is probably the
 All the coroutine version were written the same. The coroutine code suspends while the event loop spins on memory. When the coroutine code resumes w/ the new value, it writes it.
 
 
-### Suspend vs Resume
+## Suspend vs Resume
+
+The code flow for the coroutine code looks like this :
+```mermaid
+stateDiagram
+    state "Client Measures This" as time
+    state  time {
+        SpinLoop --> Resume
+        Resume --> WriteValue
+    }
+    WriteValue --> Suspend
+    Suspend --> SpinLoop
+```
 
-The code flow for the coroutine code looks like this `SpinLoop->Resume->WriteValue->Suspend::Loop` Since the client is measuring the time it takes from `SpinLoop` to `WriteValue`, it most likely isn't measuring the time `Suspend` takes. There is no reason to think the time to `Resume` is the same as to `Suspend`.
+Since the client is measuring the time it takes from `SpinLoop` to `WriteValue`, it most likely isn't measuring the time `Suspend` takes. There is no reason to think the time to `Resume` is the same as to `Suspend`.
 
 If the event loop is dispatching the same event to multiple listeners, or had multiple events to dispatch, you bear the cost of both the suspend and resume for each event.
 
-So I wrote two version of each coroutine. The version above is called the `Resume` version. The `Suspend` version code flow look like `SpinLoop->Suspend->WriteValue->Resume::Loop`. In the `Suspend` version the `SpinLoop` is in the coroutine code block, and the writing of the value is in the `eventLoop`.
+So I wrote two version of each coroutine. The version above is called the `Resume` version. The `Suspend` version code flow looks like :
+```mermaid
+stateDiagram
+    state "Client Measures This" as time
+    state  time {
+        SpinLoop --> Suspend
+        Suspend --> WriteValue
+    }
+    WriteValue --> Resume
+    Resume --> SpinLoop
+```
+
+ In the `Suspend` version the `SpinLoop` is in the coroutine code block, and the writing of the value is in the `eventLoop`.
 
 ### Callbacks
 The spin loop isn't a fair comparison to the coroutine code, so I added a callback version. I didn't write the reciprocal version of callback, like I did with the coroutine code. I'm just going to assume returning from a callback is cheap.

benches/bench_atomic.rs

@@ -80,7 +80,7 @@ fn cpp_bench(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child =
-        async_bench::bench_utils::launch_local("cpp/target/release/atomicSpin", vec![SERVER_CPU].as_ref());
+        async_bench::bench_utils::launch_local("cpp/out/atomicSpin", vec![SERVER_CPU].as_ref());
 
     async_bench::bench_utils::run_bench(c, "atomic_spin", "cpp_atomic", &client);
 
@@ -95,7 +95,7 @@ fn cpp_resume(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child =
-        async_bench::bench_utils::launch_local("cpp/target/release/asyncResume", vec![SERVER_CPU].as_ref());
+        async_bench::bench_utils::launch_local("cpp/out/asyncResume", vec![SERVER_CPU].as_ref());
 
     async_bench::bench_utils::run_bench(c, "atomic_spin", "cpp_resume", &client);
 
@@ -110,7 +110,7 @@ fn cpp_suspend(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child =
-        async_bench::bench_utils::launch_local("cpp/target/release/asyncSuspend", vec![SERVER_CPU].as_ref());
+        async_bench::bench_utils::launch_local("cpp/out/asyncSuspend", vec![SERVER_CPU].as_ref());
 
     async_bench::bench_utils::run_bench(c, "atomic_spin", "cpp_suspend", &client);
 
@@ -125,7 +125,7 @@ fn cpp_callback(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child =
-        async_bench::bench_utils::launch_local("cpp/target/release/atomicCallback", vec![SERVER_CPU].as_ref());
+        async_bench::bench_utils::launch_local("cpp/out/atomicCallback", vec![SERVER_CPU].as_ref());
 
     async_bench::bench_utils::run_bench(c, "atomic_spin", "cpp_callback", &client);
 
@@ -208,7 +208,7 @@ fn kotlin_bench(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child = async_bench::bench_utils::launch_local_java(
-        "kotlin/app/build/libs/app-all.jar",
+        "kotlin/servers.jar",
         "kotlin_servers.AtomicSpinKt",
         Some(async_bench::bench_utils::JAVA_OPTS.as_ref()),
         vec![SERVER_CPU].as_ref(),
@@ -226,7 +226,7 @@ fn kotlin_resume(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child = async_bench::bench_utils::launch_local_java(
-        "kotlin/app/build/libs/app-all.jar",
+        "kotlin/servers.jar",
         "kotlin_servers.AsyncResumeKt",
         Some(async_bench::bench_utils::JAVA_OPTS.as_ref()),
         vec![SERVER_CPU].as_ref(),
@@ -244,7 +244,7 @@ fn kotlin_suspend(c: &mut Criterion) {
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
 
     let mut child = async_bench::bench_utils::launch_local_java(
-        "kotlin/app/build/libs/app-all.jar",
+        "kotlin/servers.jar",
         "kotlin_servers.AsyncSuspendKt",
         Some(async_bench::bench_utils::JAVA_OPTS.as_ref()),
         vec![SERVER_CPU].as_ref(),
@@ -260,9 +260,9 @@ fn kotlin_callback(c: &mut Criterion) {
     let client = MappedAtomics::new(true);
 
     core_affinity::set_for_current(CoreId { id: CLIENT_CPU });
-
+    
     let mut child = async_bench::bench_utils::launch_local_java(
-        "kotlin/app/build/libs/app-all.jar",
+        "kotlin/servers.jar",
         "kotlin_servers.AtomicCallbackKt",
         Some(async_bench::bench_utils::JAVA_OPTS.as_ref()),
         vec![SERVER_CPU].as_ref(),
@@ -276,10 +276,6 @@ fn kotlin_callback(c: &mut Criterion) {
 
 criterion_group!(
     benches,
-    rust_callback,
-    rust_callback,
-    rust_callback,
-    rust_callback,
     cpp_bench,
     cpp_resume,
     cpp_suspend,

build_all.sh

@@ -0,0 +1,20 @@
+# Things you need in your path:
+#   - Rust tool chain (cargo, rustc, etc.)
+#   - kotlinc version 1.8.20
+#   - java version 19 or better
+#   - zig version 0.10.1
+
+# Tihs assumes your running from the root of the project
+#!/usr/bin/env sh
+
+cargo build --release
+
+cd kotlin/
+echo "$PWD"
+./build.sh
+cd ../cpp
+echo "$PWD"
+./build.sh
+cd ../zig
+echo "$PWD"
+zig build

cpp/CMakeLists.txt

@@ -1,6 +1,3 @@
-//
-// Created by jonross on 10/8/21.
-//
 
 #ifndef CPP_MAPPEDATOMICS_H
 #define CPP_MAPPEDATOMICS_H
@@ -13,6 +10,7 @@
 #include <cstring>
 #include <unistd.h>
 #include <atomic>
+#include <stdlib.h>
 
 struct MappedAtomics {
     std::atomic<long unsigned int> *clientPtr;
@@ -34,13 +32,13 @@ struct MappedAtomics {
                 S_IWUSR | S_IRGRP | S_IWGRP
         );
         if(shmFd <= 0 ) {
-            std::cout << "shm_open failed. exiting : " << std::strerror(errno) << std::endl;
-            throw std::system_error(errno, std::generic_category());
+            std::cout << "shm_open failed. Is the benchmark running? exiting. error : " << std::strerror(errno) << std::endl;
+            exit(-1);
         }
 //        std::cout << "shm fd = " << shmFd << std::endl;
         if( ftruncate( shmFd, getpagesize() ) != 0 )  {
-            std::cout << "ftruncate failed. exiting : " << std::strerror(errno) << std::endl;
-            throw std::system_error(errno, std::generic_category());
+            std::cout << "ftruncate failed. exiting. error : " << std::strerror(errno) << std::endl;
+            exit(-1);
         }
 
 

cpp/MappedAtomics.h

@@ -1,7 +1,6 @@
 //#define  _GNU_SOURCE
 
 #include <iostream>
-#include <sched.h>
 #include <cstring>
 #include "MappedAtomics.h"
 #include <concepts>
@@ -44,21 +43,8 @@ asyncLoop( AsyncContext *context )
 }
 
 
-int main(int argc, char * argv[]) {
-
-    if(argc < 2) {
-        std::cout << "must pass cpu # to run on. exiting." << std::endl;
-        return -1;
-    }
-    auto cpuNum = std::stoul( argv[1]);
-
-    cpu_set_t cpuSet;
-    CPU_ZERO( &cpuSet );
-    CPU_SET(cpuNum, &cpuSet);
-    if( sched_setaffinity(0, sizeof(cpuSet), &cpuSet) != 0 ) {
-        std::cout << "set affinity failed with following error : " << std::strerror(errno) << std::endl;
-        return -1;
-    }
+#define UU __attribute__((unused))
+int main(UU int argc, UU char * argv[]) {
 
     auto *atomic = new(MappedAtomics);
 

cpp/asyncResume.cpp

@@ -1,8 +1,6 @@
 //#define  _GNU_SOURCE
 
 #include <iostream>
-#include <sched.h>
-#include <cstring>
 #include "MappedAtomics.h"
 #include <concepts>
 #include <coroutine>
@@ -46,21 +44,8 @@ asyncLoop( AsyncContext *context )
 }
 
 
-int main(int argc, char * argv[]) {
-
-    if(argc < 2) {
-        std::cout << "must pass cpu # to run on. exiting." << std::endl;
-        return -1;
-    }
-    auto cpuNum = std::stoul( argv[1]);
-
-    cpu_set_t cpuSet;
-    CPU_ZERO( &cpuSet );
-    CPU_SET(cpuNum, &cpuSet);
-    if( sched_setaffinity(0, sizeof(cpuSet), &cpuSet) != 0 ) {
-        std::cout << "set affinity failed with following error : " << std::strerror(errno) << std::endl;
-        return -1;
-    }
+#define UU __attribute__((unused))
+int main(UU int argc, UU char * argv[]) {
 
     auto *atomic = new(MappedAtomics);
 

cpp/asyncSuspend.cpp

@@ -1,9 +1,6 @@
 //#define  _GNU_SOURCE
 
 #include <iostream>
-#include <sched.h>
-#include <cstring>
-#include <c++/9/functional>
 #include <optional>
 #include "MappedAtomics.h"
 
@@ -42,21 +39,8 @@ class EventLoop {
     }
 };
 
-int main(int argc, char * argv[]) {
-
-    if(argc < 2) {
-        std::cout << "must pass cpu # to run on. exiting." << std::endl;
-        return -1;
-    }
-    auto cpuNum = std::stoul( argv[1]);
-
-    cpu_set_t cpuSet;
-    CPU_ZERO( &cpuSet );
-    CPU_SET(cpuNum, &cpuSet);
-    if( sched_setaffinity(0, sizeof(cpuSet), &cpuSet) != 0 ) {
-        std::cout << "set affinity failed with following error : " << std::strerror(errno) << std::endl;
-        return -1;
-    }
+#define UU __attribute__((unused))
+int main(UU int argc, UU char * argv[]) {
 
     auto *atomic = new(MappedAtomics);
 

cpp/atomicCallback.cpp

@@ -1,25 +1,11 @@
 //#define  _GNU_SOURCE
 
 #include <iostream>
-#include <sched.h>
 #include <cstring>
 #include "MappedAtomics.h"
 
-int main(int argc, char * argv[]) {
-
-    if(argc < 2) {
-        std::cout << "must pass cpu # to run on. exiting." << std::endl;
-        return -1;
-    }
-    auto cpuNum = std::stoul( argv[1]);
-
-    cpu_set_t cpuSet;
-    CPU_ZERO( &cpuSet );
-    CPU_SET(cpuNum, &cpuSet);
-    if( sched_setaffinity(0, sizeof(cpuSet), &cpuSet) != 0 ) {
-        std::cout << "set affinity failed with following error : " << std::strerror(errno) << std::endl;
-        return -1;
-    }
+#define UU __attribute__((unused))
+int main(UU int argc, UU char * argv[]) {
 
     auto *atomic = new(MappedAtomics);
 

cpp/atomicSpin.cpp

@@ -0,0 +1,8 @@
+CMD="zig c++ -std=c++20 -lrt -Wall -Wextra -Wconversion -Wsign-conversion -Ofast -finline-functions"
+
+`mkdir -p out`
+
+`$CMD -oout/atomicSpin atomicSpin.cpp MappedAtomics.cpp`
+`$CMD -oout/asyncResume asyncResume.cpp MappedAtomics.cpp`
+`$CMD -oout/asyncSuspend asyncSuspend.cpp MappedAtomics.cpp`
+`$CMD -oout/atomicCallback atomicCallback.cpp MappedAtomics.cpp`