forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 02:42:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

cmd/swarm: cleanup

Browse source
This commit is contained in:
Fabio Barone 2019-02-03 20:45:00 -05:00
parent 5ed219efe2
commit ba3849af4a
2 changed files with 16 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/swarm/explore.go
View file

@ -48,7 +48,7 @@ func explore(ctx *cli.Context) {
defer f.Close()
fileStore := storage.NewFileStore(&storage.FakeChunkStore{}, storage.NewFileStoreParams())
_, err = fileStore.StoreToExplore(context.TODO(), f)
_, err = fileStore.GetAllReferences(context.TODO(), f, false)
if err != nil {
utils.Fatalf("%v\n", err)
} else {

23
cmd/swarm/swarm-smoke/chunkExplorer.go
View file

@ -29,28 +29,25 @@ var (
)
func chunkExplorer(c *cli.Context) error {
fmt.Println("generate endpoints...")
//generateEndpoints(scheme, cluster, appName, from, to)
fmt.Println("done.")
log.Debug("generate endpoints...")
generateEndpoints(scheme, cluster, appName, from, to)
log.Debug("done.")
var has bool
//for _, e := range endpoints {
e := "ws://localhost"
fmt.Println("dialing...." + e + ":8546")
client, _ := rpc.Dial(e + ":8546")
fmt.Println("Trying...." + e)
for _, e := range endpoints {
e = e + ":8546"
log.Debug("dialing...." + e)
client, _ := rpc.Dial(e)
log.Debug("Trying...." + e)
if err := client.Call(&has, "debugapi_hasChunk", addr); err != nil {
fmt.Println("err")
log.Error("Error requesting hasChunk from endpoint", "endpoint", e, "chunkAddress", addr, "err", err)
} else {
if has {
fmt.Println("has")
log.Info("Endpoint "+e+" reports to HAVE chunk", "chunk", addr)
} else {
fmt.Println("not")
log.Debug("Endpoint "+e+" reports to NOT have chunk", "chunk", addr)
log.Info("Endpoint "+e+" reports to NOT have chunk", "chunk", addr)
}
}
}
//}
return nil
}