package tracker
import (
- "bytes"
- "encoding"
- "encoding/binary"
"errors"
"net"
"net/url"
Port int
}
-type CompactPeer struct {
- IP [4]byte
- Port uint16
-}
-
-var _ encoding.BinaryUnmarshaler = &CompactPeer{}
-
-func (cp *CompactPeer) UnmarshalBinary(b []byte) (err error) {
- err = binary.Read(bytes.NewReader(b), binary.BigEndian, cp)
- return
-}
-
const (
None AnnounceEvent = iota
Completed // The local peer just completed the torrent.
package util
import (
- "bitbucket.org/anacrolix/go.torrent/tracker"
+ "bytes"
+ "encoding"
+ "encoding/binary"
"github.com/anacrolix/libtorgo/bencode"
)
-type CompactPeers []tracker.CompactPeer
+type CompactPeers []CompactPeer
func (me *CompactPeers) UnmarshalBencode(bb []byte) (err error) {
var b []byte
func (me *CompactPeers) UnmarshalBinary(b []byte) (err error) {
for i := 0; i < len(b); i += 6 {
- var p tracker.CompactPeer
+ var p CompactPeer
err = p.UnmarshalBinary([]byte(b[i : i+6]))
if err != nil {
return
}
return
}
+
+type CompactPeer struct {
+ IP [4]byte
+ Port uint16
+}
+
+var _ encoding.BinaryUnmarshaler = &CompactPeer{}
+
+func (cp *CompactPeer) UnmarshalBinary(b []byte) (err error) {
+ err = binary.Read(bytes.NewReader(b), binary.BigEndian, cp)
+ return
+}