forked from ngaut/goTorrent
-
Notifications
You must be signed in to change notification settings - Fork 0
/
until.go
63 lines (53 loc) · 1.35 KB
/
until.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package main
import(
"bytes"
"os"
"net"
"strconv"
"math/rand"
"log"
"errors"
)
func peerId() string {
sid := "-tt" + strconv.Itoa(os.Getpid()) + "_" + strconv.FormatInt(rand.Int63(), 10)
log.Println("peerId() ", sid[0:20])
return sid[0:20]
}
var kBitTorrentHeader = []byte{'\x13', 'B', 'i', 't', 'T', 'o', 'r',
'r', 'e', 'n', 't', ' ', 'p', 'r', 'o', 't', 'o', 'c', 'o', 'l'}
func string2Bytes(s string) []byte { return bytes.NewBufferString(s).Bytes() }
func GetLocalIP() (string, error) {
ifs, err := net.Interfaces()
if err != nil {
return "", err
}
for _, t := range ifs {
addrsList, err := t.Addrs()
if err != nil {
return "", err
}
for _, a := range addrsList {
/*
ipnet, ok := a.(*net.IPNet)
log.Printf("%+v\n", ipnet)
if !ok {
continue
}
v4 := ipnet.IP.To4()
log.Printf("%+v\n", ipnet.IP.To4())
if v4 == nil || v4[0] == 127 { // loopback address
continue
}
return v4, nil
*/
return a.String(), nil
}
}
return "", errors.New("cannot find local IP address")
}
type CacheValue struct{
buf []byte
}
func (self *CacheValue) Size() int{
return len(self.buf)
}