Index: common.scm
==================================================================
--- common.scm
+++ common.scm
@@ -17,11 +17,11 @@
 ;;     along with Megatest.  If not, see <http://www.gnu.org/licenses/>.
 
 ;;======================================================================
 
 (use srfi-1 data-structures posix regex-case (prefix base64 base64:)
-     format dot-locking csv-xml z3 ;; sql-de-lite
+     format dot-locking csv-xml z3 udp ;; sql-de-lite
      hostinfo md5 message-digest typed-records directory-utils stack
      matchable regex posix (srfi 18) extras ;; tcp 
      (prefix nanomsg nmsg:)
      (prefix sqlite3 sqlite3:)
      pkts (prefix dbi dbi:)
@@ -81,10 +81,11 @@
     (length (glob (conc "/proc/" pid "/fd/*")))
     (length  (filter identity (map socket? (glob (conc "/proc/" pid "/fd/*")))))
   )
 )
 
+  
 
 ;; GLOBALS
 
 ;; CONTEXTS
 (defstruct cxt
@@ -3049,5 +3050,30 @@
            exn
            #t ;; just ignore it, it might have died in the meantime so joining it will throw an exception
            (thread-join! thread))
            )))
    (hash-table-keys *common:thread-punchlist*)))
+
+(define (common:telemetry-log event #!key (payload '()))
+  (let* ((serverhost (configf:lookup *configdat* "telemetry" "host"))
+         (serverport (configf:lookup-number *configdat* "telemetry" "port"))
+         (user (or (get-environment-variable "USER") "unknown"))
+         (host (or (get-environment-variable "HOST") "unknown")))
+
+    (handle-exceptions
+     exn
+     (debug:print-info 0 *default-log-port* "common-telemetry-log failure")
+     (if (and serverhost serverport user host event)
+         (let* ((start (conc "[megatest "event"]"))
+                (toppath (or *toppath* "/dev/null"))
+                (payload-serialized
+                 (base64:base64-encode
+                  (z3:encode-buffer
+                   (with-output-to-string (lambda () (pp payload))))))
+                (msg     (conc user":"host":"start":"
+                               toppath":"payload-serialized))
+                (s (udp-open-socket)))
+           (udp-bind! s #f 0)
+           (udp-connect! s serverhost serverport)
+            (print msg)
+            (print (udp-send s msg))
+            (udp-close-socket s))))))

Index: runs.scm
==================================================================
--- runs.scm
+++ runs.scm
@@ -451,10 +451,17 @@
 
     ;; register this run in monitor.db
     (rmt:tasks-add "run-tests" user target runname test-patts task-key) ;; params)
     (rmt:tasks-set-state-given-param-key task-key "running")
 
+    (common:telemetry-log "run-tests"
+                          payload:
+                          `( (target . ,target)
+                             (run-name . ,runname)
+                             (test-patts . ,test-patts) ) )
+
+    
     ;; Now generate all the tests lists
     (set! all-tests-registry (tests:get-all))   ;; hash of testname => path-to-test
     (set! all-test-names     (hash-table-keys all-tests-registry))
     ;; filter first for allowed-tests (from -tagexpr) then for test-patts.
     (set! test-names         (tests:filter-test-names