Skip to content

Commit a18ba90

Browse files
authored
Merge pull request #590 from skoef/comSetOptionEOF
return EOF response on COM_SET_OPTION commands
2 parents ba73da2 + b560922 commit a18ba90

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

server/command.go

+6
Original file line numberDiff line numberDiff line change
@@ -125,6 +125,12 @@ func (c *Conn) dispatch(data []byte) interface{} {
125125
} else {
126126
return r
127127
}
128+
case COM_SET_OPTION:
129+
if err := c.h.HandleOtherCommand(cmd, data); err != nil {
130+
return err
131+
}
132+
133+
return eofResponse{}
128134
default:
129135
return c.h.HandleOtherCommand(cmd, data)
130136
}

server/resp.go

+3
Original file line numberDiff line numberDiff line change
@@ -170,11 +170,14 @@ func (c *Conn) writeFieldList(fs []*Field) error {
170170
}
171171

172172
type noResponse struct{}
173+
type eofResponse struct{}
173174

174175
func (c *Conn) writeValue(value interface{}) error {
175176
switch v := value.(type) {
176177
case noResponse:
177178
return nil
179+
case eofResponse:
180+
return c.writeEOF()
178181
case error:
179182
return c.writeError(v)
180183
case nil:

0 commit comments

Comments
 (0)