From 9b9a86cf80f24208e04cebf451596cd7f4776661 Mon Sep 17 00:00:00 2001 From: Aaron Jacobs Date: Mon, 27 Jul 2015 15:33:33 +1000 Subject: [PATCH] Fixed Connection.Reply. --- connection.go | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/connection.go b/connection.go index ba6056d..e888516 100644 --- a/connection.go +++ b/connection.go @@ -478,13 +478,11 @@ func (c *Connection) Reply(ctx context.Context, opErr error) { } // Send the reply to the kernel. - err = c.writeMessage(replyMsg) - if err != nil { - err = fmt.Errorf("writeMessage: %v", err) + replyMsg := kernelResponse(m.Header().Unique, op, opErr, c.protocol) + if err := c.writeMessage(replyMsg); err != nil { + log.Fatalf("writeMessage: %v", err) return } - - return } // Close the connection. Must not be called until operations that were read