Move queue back into main, was breaking go get
This commit is contained in:
parent
10a5421bc3
commit
454f1b1f2d
|
@ -4,15 +4,13 @@ import (
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"./queue"
|
|
||||||
|
|
||||||
"github.com/conformal/btcwire"
|
"github.com/conformal/btcwire"
|
||||||
)
|
)
|
||||||
|
|
||||||
// TODO: Break Client/Peer/Crawler into separate modules.
|
// TODO: Break Client/Peer/Crawler into separate modules.
|
||||||
type Crawler struct {
|
type Crawler struct {
|
||||||
client *Client
|
client *Client
|
||||||
queue *queue.Queue
|
queue *Queue
|
||||||
numSeen int
|
numSeen int
|
||||||
numUnique int
|
numUnique int
|
||||||
numConnected int
|
numConnected int
|
||||||
|
@ -41,7 +39,7 @@ func NewCrawler(client *Client, seeds []string) *Crawler {
|
||||||
}
|
}
|
||||||
|
|
||||||
done := make(chan struct{})
|
done := make(chan struct{})
|
||||||
c.queue = queue.NewQueue(filter, done)
|
c.queue = NewQueue(filter, done)
|
||||||
|
|
||||||
// Prefill the queue
|
// Prefill the queue
|
||||||
for _, address := range seeds {
|
for _, address := range seeds {
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
package queue
|
package main
|
||||||
|
|
||||||
import "sync"
|
import "sync"
|
||||||
|
|
Loading…
Reference in New Issue