rpc/recv.go
@@ -8,7 +8,7 @@ "basic.com/valib/deliver.git" ) const mode = deliver.Shm const mode = deliver.PushPull // Reciever recv from ipc type Reciever struct { @@ -74,7 +74,9 @@ count = 0 r.fnLogger("~~~shm recv image:", len(d)) } r.out <- d if len(d) > 2 { r.out <- d } } } } else { @@ -86,7 +88,9 @@ count = 0 r.fnLogger("~~~mangos recv image:", len(msg)) } r.out <- msg if len(msg) > 2 { r.out <- msg } } } time.Sleep(10 * time.Millisecond)