From b2d5fcd48aa03ca0f11ac9cab09a9d2c3cea3b59 Mon Sep 17 00:00:00 2001 From: Megan Marsh Date: Wed, 5 Jul 2017 12:27:59 -0700 Subject: [PATCH] move wait earlier --- packer/rpc/communicator.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packer/rpc/communicator.go b/packer/rpc/communicator.go index d4823a49a..816e2c7d8 100644 --- a/packer/rpc/communicator.go +++ b/packer/rpc/communicator.go @@ -102,6 +102,7 @@ func (c *communicator) Start(cmd *packer.RemoteCmd) (err error) { go func() { conn, err := c.mux.Accept(responseStreamId) + wg.Wait() if err != nil { log.Printf("[ERR] Error accepting response stream %d: %s", responseStreamId, err) @@ -113,7 +114,6 @@ func (c *communicator) Start(cmd *packer.RemoteCmd) (err error) { var finished CommandFinished decoder := gob.NewDecoder(conn) err = decoder.Decode(&finished) - wg.Wait() if err != nil { log.Printf("[ERR] Error decoding response stream %d: %s", responseStreamId, err)