(f *ProxyFrame)
| 88 | } |
| 89 | |
| 90 | func (i *Inputer) processDataFrame(f *ProxyFrame) { |
| 91 | id := f.DataFrame.Id |
| 92 | v, ok := i.sonny.Load(id) |
| 93 | if !ok { |
| 94 | loggo.Debug("Inputer processDataFrame no sonnny %s %d", id, len(f.DataFrame.Data)) |
| 95 | return |
| 96 | } |
| 97 | sonny := v.(*ProxyConn) |
| 98 | if !sonny.sendch.WriteTimeout(f, i.config.MainWriteChannelTimeoutMs) { |
| 99 | sonny.needclose = true |
| 100 | loggo.Error("Inputer processDataFrame timeout sonnny %s %d", f.DataFrame.Id, len(f.DataFrame.Data)) |
| 101 | } |
| 102 | sonny.actived++ |
| 103 | loggo.Debug("Inputer processDataFrame %s %d", f.DataFrame.Id, len(f.DataFrame.Data)) |
| 104 | } |
| 105 | |
| 106 | func (i *Inputer) processCloseFrame(f *ProxyFrame) { |
| 107 | id := f.CloseFrame.Id |
no outgoing calls
no test coverage detected