Skip to content
This repository was archived by the owner on Apr 28, 2022. It is now read-only.

Commit

Permalink
Merge branch 'master' of https://github.com/KunTengRom/frp
Browse files Browse the repository at this point in the history
  • Loading branch information
liudf0716 committed Jun 19, 2017
2 parents fcca5cb + cb7610e commit 0340c45
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
5 changes: 3 additions & 2 deletions client/control.go
Original file line number Diff line number Diff line change
Expand Up @@ -293,14 +293,15 @@ func (ctl *Control) reader() {
func (ctl *Control) writer() {
var xfrpWriter io.Writer
if config.ClientCommonCfg.UseEncryption {
xfrpWriter, err := crypto.NewWriter(ctl.conn, []byte(config.ClientCommonCfg.PrivilegeToken))
var err error
xfrpWriter, err = crypto.NewWriter(ctl.conn, []byte(config.ClientCommonCfg.PrivilegeToken))
if err != nil {
ctl.conn.Error("crypto new writer error: %v", err)
ctl.conn.Close()
return
}
} else {
xfrpWriter := ctl.conn;
xfrpWriter = ctl.conn;
}
for {
if m, ok := <-ctl.sendCh; !ok {
Expand Down
5 changes: 3 additions & 2 deletions server/control.go
Original file line number Diff line number Diff line change
Expand Up @@ -199,14 +199,15 @@ func (ctl *Control) writer() {

var xfrpWriter io.Writer
if config.ServerCommonCfg.UseEncryption {
xfrpWriter, err := crypto.NewWriter(ctl.conn, []byte(config.ServerCommonCfg.PrivilegeToken))
var err error
xfrpWriter, err = crypto.NewWriter(ctl.conn, []byte(config.ServerCommonCfg.PrivilegeToken))
if err != nil {
ctl.conn.Error("crypto new writer error: %v", err)
ctl.allShutdown.Start()
return
}
} else {
xfrpWriter := ctl.conn;
xfrpWriter = ctl.conn;
}

for {
Expand Down

0 comments on commit 0340c45

Please sign in to comment.