dlss
/
FedP2P
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

A few tweaks

This commit is contained in:
Matt Joiner 2014-11-28 19:42:18 -06:00
parent 17a8b8aa17
commit 0eb36e76ef
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
client.go
View File

@ -977,7 +977,7 @@ func addrPort(addr net.Addr) int {
// and exit.
func (me *Client) connectionLoop(t *torrent, c *connection) error {
decoder := pp.Decoder{
R: bufio.NewReaderSize(c.Socket, 20*1024),
R: bufio.NewReader(c.Socket),
MaxLength: 256 * 1024,
}
for {
@ -1542,7 +1542,7 @@ func (cl *Client) waitWantPeers(t *torrent) bool {
func (cl *Client) announceTorrentDHT(t *torrent, impliedPort bool) {
for cl.waitWantPeers(t) {
log.Printf("announcing torrent %q to DHT", t)
log.Printf("getting peers for %q from DHT", t)
ps, err := cl.dHT.GetPeers(string(t.InfoHash[:]))
if err != nil {
log.Printf("error getting peers from dht: %s", err)