From cfb7f6188b9cb59bad71baececf78436a1006fed Mon Sep 17 00:00:00 2001 From: Aaron Feng Date: Sat, 14 Jun 2014 05:08:59 -0700 Subject: [PATCH] add heartbeat to attach Docker-DCO-1.1-Signed-off-by: Aaron Feng (github: aaronfeng) --- backends/ec2.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/backends/ec2.go b/backends/ec2.go index 5a320fa3d7..d2e5433d50 100644 --- a/backends/ec2.go +++ b/backends/ec2.go @@ -1,6 +1,7 @@ package backends import ( + "time" "fmt" "github.com/docker/libswarm/beam" ) @@ -55,9 +56,15 @@ func (c *ec2Client) stop(ctx *beam.Message) error { func (c *ec2Client) attach(ctx *beam.Message) error { fmt.Println("*** ec2 OnAttach ***") ctx.Ret.Send(&beam.Message{Verb: beam.Ack, Ret: c.Server}) + + for { + time.Sleep(1 * time.Second) + (&beam.Object{ctx.Ret}).Log("ec2: heartbeat") + } return nil } + func Ec2() beam.Sender { backend := beam.NewServer() backend.OnSpawn(beam.Handler(func(ctx *beam.Message) error {