DO NOT MERGE instrumented build

.env

@@ -1,4 +1,4 @@
-FIBERS_VER=v0.9.1
+FIBERS_VER=v0.9.2
 TRIE_VER=v0.3
-BUS_VER=v0.8.1
+BUS_VER=v0.8.2
 UI_VER=a8c5965

src/devicecode/main.lua

@@ -7,6 +7,7 @@ local op     = require 'fibers.op'
 local sleep  = require 'fibers.sleep'
 local authz  = require 'devicecode.authz'
 local busmod = require 'bus'
+local leak_probe = require 'devicecode.support.leak_probe'
 
 local safe   = require 'coxpcall'
 
@@ -192,6 +193,8 @@ function M.run(scope, params)
         principal = authz.service_principal('main'),
     })
 
+    leak_probe.start(scope, { conn = main_conn, note = 'devicecode main' })
+
     retain_main_state(main_conn, 'starting', {
         env      = env,
         services = service_names,

src/devicecode/support/capability_dependencies.lua

@@ -16,6 +16,7 @@ local bus_cleanup = require 'devicecode.support.bus_cleanup'
 local queue       = require 'devicecode.support.queue'
 local dep_failure = require 'devicecode.support.dependency_failure'
 local tablex      = require 'shared.table'
+local safe        = require 'coxpcall'
 
 local M = {}
 local Dependencies = {}
@@ -139,7 +140,7 @@ local function subscribe_for(conn, dep, opts)
 	-- connection.  A bus connection is needed only for the fallback topic
 	-- subscription path below.
 	if dep.ref ~= nil and type(dep.ref.get_status_sub) == 'function' then
-		local ok, sub, sub_err = pcall(function ()
+		local ok, sub, sub_err = safe.pcall(function ()
 			return dep.ref:get_status_sub({
 				queue_len = dep.queue_len or opts.status_queue_len or opts.queue_len or 8,
 				full = dep.full or opts.status_full or opts.full or 'drop_oldest',