]> Sergey Matveev's repositories - btrtrc.git/blobdiff - mse/cmd/mse/main.go
Remove xerrors dependency (#600)
[btrtrc.git] / mse / cmd / mse / main.go
index 9485fc2a52683e3abf27990f09af933172e5fc0f..756f07e6d58019d0b6d51d467acfeb48f0f20bde 100644 (file)
@@ -1,6 +1,7 @@
 package main
 
 import (
+       "fmt"
        "io"
        "log"
        "net"
@@ -8,8 +9,6 @@ import (
        "sync"
 
        "github.com/alexflint/go-arg"
-       "golang.org/x/xerrors"
-
        "github.com/anacrolix/torrent/mse"
 )
 
@@ -41,25 +40,25 @@ func mainErr() error {
        if args.Dial != nil {
                cn, err := net.Dial(args.Dial.Network, args.Dial.Address)
                if err != nil {
-                       return xerrors.Errorf("dialing: %w", err)
+                       return fmt.Errorf("dialing: %w", err)
                }
                defer cn.Close()
                rw, _, err := mse.InitiateHandshake(cn, []byte(args.Dial.SecretKey), args.Dial.InitialPayload, args.CryptoMethod)
                if err != nil {
-                       return xerrors.Errorf("initiating handshake: %w", err)
+                       return fmt.Errorf("initiating handshake: %w", err)
                }
                doStreaming(rw)
        }
        if args.Listen != nil {
                l, err := net.Listen(args.Listen.Network, args.Listen.Address)
                if err != nil {
-                       return xerrors.Errorf("listening: %w", err)
+                       return fmt.Errorf("listening: %w", err)
                }
                defer l.Close()
                cn, err := l.Accept()
                l.Close()
                if err != nil {
-                       return xerrors.Errorf("accepting: %w", err)
+                       return fmt.Errorf("accepting: %w", err)
                }
                defer cn.Close()
                rw, _, err := mse.ReceiveHandshake(cn, func(f func([]byte) bool) {