Catching the context

License: MIT Signed-off-by: rht <[email protected]>
rht · Nov 22, 2015 · 8d1ea86 · 8d1ea86
1 parent fe40df8
commit 8d1ea86
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 0 deletions.
diff --git a/cmd/ipfs/main.go b/cmd/ipfs/main.go
@@ -321,6 +321,13 @@ func callCommand(ctx context.Context, req cmds.Request, root *cmds.Command, cmd
 		}
 	}
 
+	go func() {
+		select {
+		case <-ctx.Done():
+			fmt.Fprintf(os.Stderr, "ffff")
+		}
+	}()
+
 	if client != nil {
 		log.Debug("Executing command via API")
 		res, err = client.Send(req)

diff --git a/core/commands/get.go b/core/commands/get.go
@@ -50,6 +50,8 @@ may also specify the level of compression by specifying '-l=<1-9>'.
 		return err
 	},
 	Run: func(req cmds.Request, res cmds.Response) {
+		fmt.Fprintf(res.Stderr(), "!!!")
+
 		cmplvl, err := getCompressOptions(req)
 		if err != nil {
 			res.SetError(err, cmds.ErrClient)
@@ -63,6 +65,14 @@ may also specify the level of compression by specifying '-l=<1-9>'.
 		}
 		p := path.Path(req.Arguments()[0])
 		ctx := req.Context()
+
+		go func() {
+			select {
+			case <-ctx.Done():
+				fmt.Fprintf(res.Stderr(), "here!%s", ctx.Err())
+			}
+		}()
+
 		dn, err := core.Resolve(ctx, node, p)
 		if err != nil {
 			res.SetError(err, cmds.ErrNormal)