YuanHong
/
YHEchoPackage
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 22 Wiki Activity

优化proto编码

master v0.0.14
mic 2023-02-09 17:47:25 +08:00
parent d4eeef991c
commit e8ba87e806
2 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tcp/gnetserver.go
View File

@ -82,13 +82,12 @@ func (s *GnetServer) OnClose(c gnet.Conn, err error) (action gnet.Action) {
} }
func (s *GnetServer) OnTraffic(c gnet.Conn) (action gnet.Action) { func (s *GnetServer) OnTraffic(c gnet.Conn) (action gnet.Action) {
var (
err error
pkg YHProto.EchoPackage
)
for { for {
var (
err error
pkg YHProto.EchoPackage
)
err = pkg.DecodeGnet(c) err = pkg.DecodeGnet(c)
if err == YHProto.ErrNotEnoughStream { if err == YHProto.ErrNotEnoughStream {
break break

6
ws/gnetserver.go
View File

@ -104,11 +104,11 @@ func (s *GnetServer) OnTraffic(c gnet.Conn) (action gnet.Action) {
if messages == nil { if messages == nil {
return gnet.None return gnet.None
} }
var (
pkg YHProto.EchoPackage
)
for _, message := range messages { for _, message := range messages {
var (
pkg YHProto.EchoPackage
)
switch message.OpCode { switch message.OpCode {
case ws.OpContinuation: case ws.OpContinuation:
case ws.OpText: case ws.OpText: