Flow-IPC · ygoldfeld · Dec 16, 2023 · Dec 13, 2023 · Dec 13, 2023 · Dec 13, 2023
diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml
diff --git a/conanfile.py b/conanfile.py
@@ -7,35 +7,39 @@ class IpcRecipe(ConanFile):
     settings = "os", "compiler", "build_type", "arch"
 
     options = {
-        "build": [True, False], 
+        "build": [True, False],
+        "build_no_lto": [True, False],
         "doc": [True, False],
     }
-    
+
     default_options = {
-        "build": True, 
+        "build": True,
+        "build_no_lto": False,
         "doc": False,
     }
 
     def configure(self):
         if self.options.build:
-            self.options["jemalloc"].enable_cxx = False 
+            self.options["jemalloc"].enable_cxx = False
             self.options["jemalloc"].prefix = "je_"
-    
+
     def generate(self):
         deps = CMakeDeps(self)
         if self.options.doc:
             deps.build_context_activated = ["doxygen/1.9.4"]
         deps.generate()
-       
+
         toolchain = CMakeToolchain(self)
         if self.options.build:
             toolchain.variables["CFG_ENABLE_TEST_SUITE"] = "ON"
             toolchain.variables["JEMALLOC_PREFIX"] = self.options["jemalloc"].prefix
+            if self.options.build_no_lto:
+                toolchain.variables["CFG_NO_LTO"] = "ON"
         if self.options.doc:
             toolchain.variables["CFG_ENABLE_DOC_GEN"] = "ON"
             toolchain.variables["CFG_SKIP_CODE_GEN"] = "ON"
         toolchain.generate()
-    
+
     def build(self):
         cmake = CMake(self)
         cmake.configure()
@@ -44,15 +48,17 @@ def build(self):
         if self.options.build:
             self.run("cmake --build . -- --keep-going VERBOSE=1")
         if self.options.doc:
+            # Note: `flow_doc_public flow_doc_full` could also be added here and work; however
+            # we leave that to `flow` and its own Conan setup.
             self.run("cmake --build . -- ipc_doc_public ipc_doc_full --keep-going VERBOSE=1")
-    
+
     def requirements(self):
         if self.options.build:
             self.requires("capnproto/1.0.1")
             self.requires("flow/1.0")
             self.requires("gtest/1.14.0")
             self.requires("jemalloc/5.2.1")
-    
+
     def build_requirements(self):
         self.tool_requires("cmake/3.26.3")
         if self.options.doc:
@@ -61,6 +67,6 @@ def build_requirements(self):
     def package(self):
         cmake = CMake(self)
         cmake.install()
-            
+
     def layout(self):
         cmake_layout(self)
diff --git a/ipc_core b/ipc_core
diff --git a/ipc_shm_arena_lend b/ipc_shm_arena_lend
diff --git a/msan_ignore_list_clang.cfg b/msan_ignore_list_clang.cfg
@@ -0,0 +1,5 @@
+# boost.chrono duration global initializer => std::string uninit value (TODO: too general but...).
+# There is a number of these, including things like operator+() which are tough to specify in
+# this format; for now going in for a pound, as they say: the entire file.
+[memory]
+src:*/bits/basic_string.h
diff --git a/test/suite/transport_test/cli-script.txt b/test/suite/transport_test/cli-script.txt
@@ -15,6 +15,8 @@
 # See the License for the specific language governing
 # permissions and limitations under the License.
 
+# Please see "Timeout notes" in srv-script.txt.  Then come back here.
+
 # <cmd> <sh-name> <timeout> <timeout-units>
 SOCK_STREAM_CONNECT _socks_1 50 ms
 # -> stm 0
@@ -115,35 +117,35 @@ CHAN_BUNDLE_POSIX_CREATE _mqd_4 0 2
 # Other side of 3-way handshake.
 # <cmd> <stm-slot> <blob-sz> <expected-ipc-err-or-success> <expected-blob-sz>
 #       <timeout> <timeout-units>
-CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 0 1 3 ms
+CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 0 1 15 ms
 # <cmd> <stm-slot> <blob-sz> <expected-ipc-err-or-success>
 CHAN_BUNDLE_POSIX_SEND_BLOB 0 1 0
-CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 0 1 3 ms
+CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 0 1 15 ms
 # <cmd> <stm-slot> <blob-sz-or-0> <expected-ipc-err-or-success> <expected-sock?> <expected-blob-sz>
 #       <timeout> <timeout-units>
-CHAN_BUNDLE_POSIX_RECV 0 10101 0 1 10101 3 ms
+CHAN_BUNDLE_POSIX_RECV 0 10101 0 1 10101 15 ms
 # -> sock 2
 # Similar to other side.
 # <cmd> <stm-slot> <sock-slot-or-none> <blob-sz-or-0> <expected-ipc-err-or-success>
 CHAN_BUNDLE_POSIX_SEND 0 1 20202 0
 CHAN_BUNDLE_POSIX_SEND 0 -1 30303 0
-CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 3 ms
-CHAN_BUNDLE_POSIX_RECV 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 0 3 ms
+CHAN_BUNDLE_POSIX_RECV_BLOB 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 15 ms
+CHAN_BUNDLE_POSIX_RECV 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 0 15 ms
 
 # Now bipc instead of POSIX.
 
 SOCK_STREAM_CONNECT _socks_1 1 s
 # -> stm 3
 SLEEP 100 ms
 CHAN_BUNDLE_BIPC_CREATE _mqd_4 0 3
-CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 0 1 3 ms
+CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 0 1 15 ms
 CHAN_BUNDLE_BIPC_SEND_BLOB 0 1 0
-CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 0 1 3 ms
-CHAN_BUNDLE_BIPC_RECV 0 10101 0 1 10101 3 ms
+CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 0 1 15 ms
+CHAN_BUNDLE_BIPC_RECV 0 10101 0 1 10101 15 ms
 CHAN_BUNDLE_BIPC_SEND 0 1 20202 0
 CHAN_BUNDLE_BIPC_SEND 0 -1 30303 0
-CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 3 ms
-CHAN_BUNDLE_BIPC_RECV 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 0 3 ms
+CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 15 ms
+CHAN_BUNDLE_BIPC_RECV 0 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 0 15 ms
 
 # TODO: Moar....
 

diff --git a/test/suite/transport_test/srv-script.txt b/test/suite/transport_test/srv-script.txt
@@ -15,6 +15,22 @@
 # See the License for the specific language governing
 # permissions and limitations under the License.
 
+# Timeout notes:
+#
+# - There are very tight timeouts below -- in "microseconds" -- and the idea is to ensure
+#   it doesn't block at all in situations, e.g., where we know there are N messages queued-up
+#   locally at that point.  However the actual time depends on computer speed, and on slower machines
+#   like default GitHub runners it can take longer than one experiences in a powerful lab machine.
+#   We are not benchmarking here or perf-testing, so to avoid false failures we use a less tight
+#   timeout that's still in the microseconds.  So 50usec is realistic usually, but we use 250usec.
+# - Moreover... particularly in open-source automated CI/CD pipeline... we sometimes run these
+#   tests (1) on slow machines *and* (2) while compiled with run-time sanitizers (ASAN, MSAN, etc.),
+#   some of which slow-down the code by up to, like, 5x.
+#   So bottom line is some of the below (e.g., 15ms) will look pretty generous even for slower machines;
+#   but the *SANs are the reason it is like that.  TODO: Consider varying this depending on build type (via CMake
+#   build).  That said, again, we are not benchmarking or perf-testing here; timeouts here are to ensure stuff
+#   does not hang for seconds mainly.
+
 # <cmd> <sh-name>
 SOCK_STREAM_ACC_LISTEN _socks_1
 # -> acc 0
@@ -107,13 +123,6 @@ BLOB_STREAM_MQ_BIPC_SND_CREATE _mqd_0 0 0 0 0 0
 
 # Let's actually do some IPC (between processes).
 
-# Note: There are very tight timeouts below -- in "microseconds" -- and the idea is to ensure
-# it doesn't block at all in situations, e.g., where we know there are N messages queued-up
-# locally at that point.  However the actual time depends on computer speed, and on slower machines
-# like default GitHub runners it can take longer than one experiences in a powerful lab machine.
-# We are not benchmarking here or perf-testing, so to avoid false failures we use a less tight
-# timeout that's still in the microseconds.  So 50usec is realistic usually, but we use 250usec.
-
 BLOB_STREAM_MQ_POSIX_RCV_CREATE _mqd_1 1 3 10 0 0
 # -> Posix: rcv 2
 # <cmd> <stm-slot> <blob-sz> <expected-ipc-err-or-success> <expected-blob-sz>
@@ -149,20 +158,20 @@ BLOB_STREAM_MQ_BIPC_RCV_CREATE _mqd_2 0 0 0 0 0
 BLOB_STREAM_MQ_BIPC_SND_CREATE _mqd_3 0 0 0 0 0
 # -> Bipc:snd 2
 # Do other side of 3-way handshake (see other side which does the opposite).
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 1 3 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 1 15 ms
 BLOB_STREAM_MQ_BIPC_SEND_BLOB 2 1 0
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 1 3 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 1 15 ms
 # Now just receive some stuff -- first 2 sans send-would-block -- last 5 after partial would-block.
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
 SLEEP 2 s
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 3 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 10 0 8 15 ms
 # Then graceful-close.
-BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 3 ms
+BLOB_STREAM_MQ_BIPC_RECV_BLOB 2 8192 RECEIVES_FINISHED_CANNOT_RECEIVE 0 15 ms
 
 # Mess with channels now.
 
@@ -190,12 +199,12 @@ CHAN_BUNDLE_POSIX_SEND_BLOB 0 1 0
 CHAN_BUNDLE_POSIX_SEND 0 2 10101 0
 # <cmd> <stm-slot> <blob-sz-or-0> <expected-ipc-err-or-success> <expected-sock?> <expected-blob-sz>
 #       <timeout> <timeout-units>
-CHAN_BUNDLE_POSIX_RECV 0 20202 0 1 20202 10 ms
+CHAN_BUNDLE_POSIX_RECV 0 20202 0 1 20202 30 ms
 # -> sock 3
-CHAN_BUNDLE_POSIX_RECV 0 30303 0 0 30303 10 ms
+CHAN_BUNDLE_POSIX_RECV 0 30303 0 0 30303 30 ms
 # <cmd> <stm-slot> <dupe-call?> <expected-ipc-err-or-success> <timeout> <timeout-units>
-CHAN_BUNDLE_POSIX_SEND_END 0 0 0 3 ms
-CHAN_BUNDLE_POSIX_SEND_END 0 1 0 3 ms
+CHAN_BUNDLE_POSIX_SEND_END 0 0 0 15 ms
+CHAN_BUNDLE_POSIX_SEND_END 0 1 0 15 ms
 
 # Now bipc instead of POSIX.
 
@@ -206,10 +215,10 @@ CHAN_BUNDLE_BIPC_SEND_BLOB 0 1 0
 CHAN_BUNDLE_BIPC_RECV_BLOB 0 8192 0 1 500 ms
 CHAN_BUNDLE_BIPC_SEND_BLOB 0 1 0
 CHAN_BUNDLE_BIPC_SEND 0 2 10101 0
-CHAN_BUNDLE_BIPC_RECV 0 20202 0 1 20202 10 ms
-CHAN_BUNDLE_BIPC_RECV 0 30303 0 0 30303 10 ms
-CHAN_BUNDLE_BIPC_SEND_END 0 0 0 3 ms
-CHAN_BUNDLE_BIPC_SEND_END 0 1 0 3 ms
+CHAN_BUNDLE_BIPC_RECV 0 20202 0 1 20202 30 ms
+CHAN_BUNDLE_BIPC_RECV 0 30303 0 0 30303 30 ms
+CHAN_BUNDLE_BIPC_SEND_END 0 0 0 15 ms
+CHAN_BUNDLE_BIPC_SEND_END 0 1 0 15 ms
 
 # TODO: Moar....
 

diff --git a/ubsan_suppressions_clang_13.cfg b/ubsan_suppressions_clang_13.cfg
@@ -0,0 +1,3 @@
+# (See explanation in higher-version suppressions file.)
+shift-base:je_mallocx
+shift-exponent:je_mallocx
diff --git a/ubsan_suppressions_clang_15.cfg b/ubsan_suppressions_clang_15.cfg
@@ -0,0 +1 @@
+ubsan_suppressions_clang_17.cfg
diff --git a/ubsan_suppressions_clang_16.cfg b/ubsan_suppressions_clang_16.cfg
@@ -0,0 +1 @@
+ubsan_suppressions_clang_17.cfg
diff --git a/ubsan_suppressions_clang_17.cfg b/ubsan_suppressions_clang_17.cfg
@@ -0,0 +1,15 @@
+# src/jemalloc.c:3133:16: runtime error: left shift of 4095 by 20 places cannot be represented in type 'int'
+# Looks harmless... a macro is doing essentially `((1 << 12) - 1) << 20`, which is a negative int -- used as an & mask.
+# jemalloc should be more civilized IMO, but it is fine.
+# Lastly: docs say `shift` is a usable suppression type, but it is not; it is a grouping; one must use these
+# in the file.  Possibly just one of the two is enough, but let us not quibble.
+shift-base:je_mallocx
+shift-exponent:je_mallocx
+# tcache.c:144:2: runtime error: variable length array bound evaluates to non-positive value 0
+# Gets invoked from some kind of cleanup hook.  Also look harmless in context, as the actual bound
+# being 0 controls various code touching the "array."  The var-length array is a gcc extension;
+# probably clang too then.
+# jemalloc should really not do this sort of thing though.
+vla-bound:je_tcache_bin_flush_small
+# (Very similar situation; skipping details.)
+vla-bound:je_tcache_bin_flush_large
+26 −4		src/ipc/test/test_logger.hpp
+34 −13		src/ipc/transport/bipc_mq_handle.cpp
+35 −12		src/ipc/transport/posix_mq_handle.cpp
+2 −2		src/ipc/session/standalone/shm/arena_lend/jemalloc/test/shm_session_test.cpp
+1 −2		src/ipc/shm/arena_lend/jemalloc/test/shm_pool_collection_test.cpp