import (
"fmt"
- "github.com/davecgh/go-spew/spew"
"log"
"net/http"
"os"
+ "github.com/davecgh/go-spew/spew"
+
"github.com/anacrolix/torrent"
"github.com/anacrolix/torrent/bencode"
"github.com/anacrolix/torrent/metainfo"
"bufio"
"encoding/binary"
"fmt"
- g "github.com/anacrolix/generics"
"io"
"sync"
+ g "github.com/anacrolix/generics"
"github.com/pkg/errors"
)
package segments
import (
- g "github.com/anacrolix/generics"
"sort"
+
+ g "github.com/anacrolix/generics"
)
func NewIndex(segments LengthIter) (ret Index) {
package segments
import (
- qt "github.com/frankban/quicktest"
"testing"
+
+ qt "github.com/frankban/quicktest"
)
func LengthIterFromSlice(ls []Length) LengthIter {
package storage
import (
- "github.com/anacrolix/torrent/common"
- "github.com/anacrolix/torrent/segments"
- qt "github.com/frankban/quicktest"
"testing"
+ qt "github.com/frankban/quicktest"
"github.com/stretchr/testify/assert"
+ "github.com/anacrolix/torrent/common"
"github.com/anacrolix/torrent/metainfo"
+ "github.com/anacrolix/torrent/segments"
)
type requiredLength struct {
package storage
import (
- "github.com/anacrolix/torrent/segments"
"io"
"log"
"os"
"github.com/anacrolix/torrent/metainfo"
+ "github.com/anacrolix/torrent/segments"
)
type filePieceImpl struct {
})
})
for index := range t.pieces {
- rle.Append(t.pieceState(pieceIndex(index)), 1)
+ rle.Append(t.pieceState(index), 1)
}
rle.Flush()
return