X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=adapter%2Fsocketclient%2Fsocketclient.go;h=f63e8b88f58147490c24ccb9acc2671474b4394b;hb=1548c7e12531e3d055567d761c580a1c7ff0ac40;hp=b2c5d4733120e0a39c3d88d4f931c9f1b1cd820a;hpb=f4f4a8613711d724cd4dc7224e8d7a1de4b8050e;p=govpp.git diff --git a/adapter/socketclient/socketclient.go b/adapter/socketclient/socketclient.go index b2c5d47..f63e8b8 100644 --- a/adapter/socketclient/socketclient.go +++ b/adapter/socketclient/socketclient.go @@ -266,9 +266,8 @@ func (c *socketClient) Disconnect() error { // wait for readerLoop to return c.wg.Wait() - if err := c.close(); err != nil { - log.Debugf("closing failed: %v", err) - } + // Don't bother sending a vl_api_sockclnt_delete_t message, + // just close the socket. if err := c.disconnect(); err != nil { return err @@ -375,48 +374,6 @@ func (c *socketClient) open() error { return nil } -func (c *socketClient) close() error { - var msgCodec = codec.DefaultCodec - - req := &memclnt.SockclntDelete{ - Index: c.clientIndex, - } - msg, err := msgCodec.EncodeMsg(req, c.sockDelMsgId) - if err != nil { - log.Debugln("Encode error:", err) - return err - } - // set non-0 context - msg[5] = deleteMsgContext - - log.Debugf("sending socklntDel (%d bytes): % 0X", len(msg), msg) - - if err := c.writeMsg(msg); err != nil { - log.Debugln("Write error: ", err) - return err - } - - msgReply, err := c.readMsgTimeout(nil, c.disconnectTimeout) - if err != nil { - if nerr, ok := err.(net.Error); ok && nerr.Timeout() { - // we accept timeout for reply - return nil - } - log.Debugln("Read error:", err) - return err - } - - reply := new(memclnt.SockclntDeleteReply) - if err := msgCodec.DecodeMsg(msgReply, reply); err != nil { - log.Debugln("Decoding sockclnt_delete_reply failed:", err) - return err - } else if reply.Response != 0 { - return fmt.Errorf("sockclnt_delete_reply: response error (%d)", reply.Response) - } - - return nil -} - func (c *socketClient) GetMsgID(msgName string, msgCrc string) (uint16, error) { if msgID, ok := c.msgTable[msgName+"_"+msgCrc]; ok { return msgID, nil