Filter logs by container on client side of ws connection.

(arvados-ws currently ignores object_uuid filters.)

Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@tomclegg.ca>

diff --git a/arvados.go b/arvados.go
index 9cef74a21c6d399ac9773689446b783d817ed975..6550a643af2b4a9d5b50beedb6aa1f4cc4d637ee 100644 (file)
--- a/arvados.go
+++ b/arvados.go
@@ -289,7 +289,9 @@ func (runner *arvadosContainerRunner) logStream(uuid string) *logStream {
                                log.Printf("error decoding websocket message: %s", err)
                                return
                        }
-                       ch <- msg
+                       if msg.ObjectUUID == uuid {
+                               ch <- msg
+                       }
                        select {
                        case <-done:
                                return