|
@@ -81,20 +81,17 @@ func (s *SocketServer) SendMessage(req rest.IRequestOut) (<-chan *rest.RequestSt
|
|
|
}
|
|
|
|
|
|
func (s *SocketServer) work() {
|
|
|
- defer log.Println("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA")
|
|
|
loop:
|
|
|
for {
|
|
|
select {
|
|
|
case <-s.socket.Context().Done():
|
|
|
return
|
|
|
case req := <-s.socket.MessagesIn():
|
|
|
- log.Println("REQUEST ARRIVED...")
|
|
|
reqIn := &RequestIn{
|
|
|
RequestStream: req,
|
|
|
owner: s,
|
|
|
core: s.appConf.core,
|
|
|
}
|
|
|
- log.Println("reqIN", reqIn)
|
|
|
var reqOut rest.IRequestOut
|
|
|
command, check := s.appConf.app.Executer(reqIn)
|
|
|
if !check {
|
|
@@ -102,7 +99,6 @@ loop:
|
|
|
} else {
|
|
|
|
|
|
if err := rest.Serialize(reqIn.RData(), command); err != nil {
|
|
|
- log.Println("serialize error", err)
|
|
|
s.socket.Close()
|
|
|
return
|
|
|
}
|
|
@@ -119,7 +115,6 @@ loop:
|
|
|
}
|
|
|
reqOut = command.Execute(reqIn)
|
|
|
}
|
|
|
- log.Println("RESPPPPP", reqOut)
|
|
|
s.SendMessage(reqOut)
|
|
|
reqOut.RClose()
|
|
|
|