INNER CODE UNIT · Go

err

sealerio/sealer · cmd/dist-receiver/main.go:234

			err := ipfs.Swarm().Connect(ctx, *peerInfo)
			if err != nil {
				panic(fmt.Errorf("failed to connect to %s: %s", peerInfo.ID, err))
			}
		}(peerInfo)
	}
	wg.Wait()
	return nil
}

func stage(w http.ResponseWriter, req *http.Request) {
	fmt.Fprintf(w, "%d", stageNow)
}

func next(w http.ResponseWriter, req *http.Request) {
	sig <- struct{}{}
}

View source record →