package main
import (
+ "fmt"
"io"
"log"
"net"
"sync"
"github.com/alexflint/go-arg"
- "golang.org/x/xerrors"
-
"github.com/anacrolix/torrent/mse"
)
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) {