send discovery off into its own goroutine
License: MIT Signed-off-by: Jeromy <why@ipfs.io>
Jeromy committed
Sep 15, 2016 at 00:39 UTC
360f29fadeb5e2bf703f75dae79f28a3780ff949
1 file changed
+9
-7
core/commands/pubsub.go
+9
-7
@@ -105,14 +105,16 @@ To use, the daemon must be run with '--enable-pubsub-experiment'.
105
106
discover, _, _ := req.Option("discover").Bool()
107
if discover {
108
- blk := blocks.NewBlock([]byte("floodsub:" + topic))
109
- cid, err := n.Blocks.AddObject(blk)
110
- if err != nil {
111
- log.Error("pubsub discovery: ", err)
112
- return
113
- }
108
+ go func() {
109
+ blk := blocks.NewBlock([]byte("floodsub:" + topic))
110
+ cid, err := n.Blocks.AddObject(blk)
111
+ if err != nil {
112
+ log.Error("pubsub discovery: ", err)
113
+ return
114
+ }
115
115
- connectToPubSubPeers(req.Context(), n, cid)
116
+ connectToPubSubPeers(req.Context(), n, cid)
117
+ }()
118
}
119
},
120
Marshalers: cmds.MarshalerMap{