dove

Author: hwholiday

dove/dove.go

@@ -1,11 +1,10 @@
 package dove
 
 import (
+	"github.com/hwholiday/ghost/dove/network"
 	"log"
 	"net"
 	"sync"
-
-	"github.com/hwholiday/learning_tools/dove/network"
 )
 
 const (

dove/manager.go

@@ -2,10 +2,9 @@ package dove
 
 import (
 	"errors"
+	"github.com/hwholiday/ghost/dove/network"
 	"sync"
 	"sync/atomic"
-
-	"github.com/hwholiday/learning_tools/dove/network"
 )
 
 var ErrExceedsLengthLimit = errors.New("exceeds length limit")

dove/network/client.go

@@ -144,7 +144,7 @@ func (c *conn) read() ([]byte, error) {
 
 func (c *conn) witer(byt []byte) error {
 	var (
-		length = len(byt)
+		length = int64(len(byt))
 	)
 	if err := binary.Write(c.readWriter.Writer, c.opts.endian, length); err != nil {
 		return err

dove/network/option.go

@@ -78,6 +78,7 @@ func newOptions(opts ...Option) (*options, error) {
 		readBufferSize:    4096,
 		witerChanLen:      1,
 		readChanLen:       1,
+		length:            8,
 		heartbeatInterval: time.Second * 30,
 		useBigEndian:      true,
 	}
@@ -87,9 +88,6 @@ func newOptions(opts ...Option) (*options, error) {
 	if o.conn == nil {
 		return nil, errors.New("conn is nil")
 	}
-	if o.length == 0 {
-		return nil, errors.New("length is 0")
-	}
 	if o.useBigEndian {
 		o.endian = binary.BigEndian
 	} else {