|
|
@@ -99,8 +99,13 @@ loop:
|
|
|
} else {
|
|
|
// serialize
|
|
|
if err := rest.Serialize(reqIn.RData(), command); err != nil {
|
|
|
- s.socket.Close()
|
|
|
- return
|
|
|
+ //s.socket.Close()
|
|
|
+ reqOut = reqIn.OutError(err)
|
|
|
+ if _, err := s.SendMessage(reqOut); err != nil {
|
|
|
+ log.Println("socket send error", err)
|
|
|
+ }
|
|
|
+ reqOut.RClose()
|
|
|
+ continue loop
|
|
|
}
|
|
|
// validate
|
|
|
if validator, check := command.(rest.IValidator); check {
|
