From: qydysky <qydysky@foxmail.com>
Date: Fri, 15 Jan 2021 05:51:55 +0000 (+0800)
Subject: 101
X-Git-Tag: v0.3.6~1
X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=7961661607d935827b98484d7f7e85d0900c7e3d;p=part%2F.git

101
---

diff --git a/Reqf.go b/Reqf.go
index d7ebb27..53d4b35 100644
--- a/Reqf.go
+++ b/Reqf.go
@@ -177,11 +177,17 @@ func (this *req) Reqf_1(val Rval) (error) {
             if compress_type := resp.Header[`Content-Encoding`];compress_type!=nil{
                 switch compress_type[0]{
                 case `br`:
-                    if this.Respon,err = compress.UnBr(this.Respon);err != nil {return err}
+                    if tmp,err := compress.UnBr(this.Respon);err != nil {
+                        return err
+                    }else{this.Respon = append([]byte{},tmp...)}
                 case `gzip`:
-                    if this.Respon,err = compress.UnGzip(this.Respon);err != nil {return err}
+                    if tmp,err := compress.UnGzip(this.Respon);err != nil {
+                        return err
+                    }else{this.Respon = append([]byte{},tmp...)}
                 case `deflate`:
-                    if this.Respon,err = compress.UnFlate(this.Respon);err != nil {return err}
+                    if tmp,err := compress.UnFlate(this.Respon);err != nil {
+                        return err
+                    }else{this.Respon = append([]byte{},tmp...)}
                 default:
                 }
             }
diff --git a/msgq/Msgq.go b/msgq/Msgq.go
index 3851286..f940eb6 100644
--- a/msgq/Msgq.go
+++ b/msgq/Msgq.go
@@ -3,6 +3,7 @@ package part
 import (
 	"sync"
 	"time"
+	"runtime"
 	"container/list"
 )
 
@@ -44,6 +45,7 @@ func (m *Msgq) Push(msg interface{}) {
 		m.wait_push <- struct{}{}
 	}
 	if pull_num < 1 {<- m.ticker.C}
+	runtime.Gosched()
 	select {
 	case <- m.wait_push:
 	case <- m.ticker.C: