ezmsg-perf: much more comprehensive perf test with analysis

pyproject.toml

@@ -24,6 +24,7 @@ dev = [
   {include-group = "lint"},
   {include-group = "test"},
   "pre-commit>=4.3.0",
+  "viztracer>=1.0.4",
 ]
 lint = [
     "flake8>=7.3.0",
@@ -34,7 +35,8 @@ test = [
     "pytest>=8.4.1",
     "pytest-asyncio>=1.1.0",
     "pytest-cov>=6.2.1",
-    "xarray>=2023.1.0;python_version<'3.13'"
+    "xarray>=2023.1.0;python_version<'3.13'",
+    "psutil>=7.1.0",
 ]
 docs = [
     "ezmsg-sigproc>=2.2.0",
@@ -44,6 +46,7 @@ docs = [
 
 [project.scripts]
 ezmsg = "ezmsg.core.command:cmdline"
+ezmsg-perf = "ezmsg.util.perf.command:command"
 
 [project.optional-dependencies]
 axisarray = [

src/ezmsg/core/subclient.py

@@ -210,7 +210,7 @@ async def _handle_publisher(
 
                 self._incoming.put_nowait((id, msg_id))
 
-        except (ConnectionResetError, BrokenPipeError):
+        except (ConnectionResetError, BrokenPipeError, asyncio.IncompleteReadError):
             logger.debug(f"connection fail: sub:{self.id} -> pub:{id}")
 
         finally: