From 41f3776cf8058ab4170679adcf4da80da5ff5369 Mon Sep 17 00:00:00 2001 From: Ben Firshman Date: Fri, 6 Jun 2014 18:28:34 -0700 Subject: [PATCH] Support attaching to containers in forward backend Signed-off-by: Ben Firshman --- backends/forward.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/backends/forward.go b/backends/forward.go index 4ec2c54ca0..e808228b27 100644 --- a/backends/forward.go +++ b/backends/forward.go @@ -46,10 +46,15 @@ type forwarder struct { } func (f *forwarder) attach(ctx *beam.Message) error { - ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: f.Server}) - for { - time.Sleep(1 * time.Second) - (&beam.Object{ctx.Ret}).Log("forward: heartbeat") + if ctx.Args[0] == "" { + ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: f.Server}) + for { + time.Sleep(1 * time.Second) + (&beam.Object{ctx.Ret}).Log("forward: heartbeat") + } + } else { + c := f.newContainer(ctx.Args[0]) + ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: c}) } return nil }