File tree 1 file changed +11
-14
lines changed
1 file changed +11
-14
lines changed Original file line number Diff line number Diff line change 1
1
package cli
2
2
3
3
import (
4
+ "context"
4
5
"fmt"
5
6
"io"
6
7
"os"
7
8
"sync"
8
9
"syscall"
9
10
10
- "github.com/ipfs/go-ipfs-cmdkit"
11
11
"github.com/ipfs/go-ipfs-cmds"
12
12
"github.com/ipfs/go-ipfs-cmds/debug"
13
13
)
@@ -63,19 +63,16 @@ func (re *responseEmitter) SetLength(l uint64) {
63
63
}
64
64
65
65
func (re * responseEmitter ) CloseWithError (err error ) error {
66
- if err == nil {
66
+ var msg string
67
+ switch err {
68
+ case nil :
67
69
return re .Close ()
68
- }
69
-
70
- if e , ok := err .(cmdkit.Error ); ok {
71
- err = & e
72
- }
73
-
74
- e , ok := err .(* cmdkit.Error )
75
- if ! ok {
76
- e = & cmdkit.Error {
77
- Message : err .Error (),
78
- }
70
+ case context .Canceled :
71
+ msg = "canceled"
72
+ case context .DeadlineExceeded :
73
+ msg = "timed out"
74
+ default :
75
+ msg = err .Error ()
79
76
}
80
77
81
78
re .l .Lock ()
@@ -87,7 +84,7 @@ func (re *responseEmitter) CloseWithError(err error) error {
87
84
88
85
re .exit = 1 // TODO we could let err carry an exit code
89
86
90
- _ , err = fmt .Fprintln (re .stderr , "Error:" , e . Message )
87
+ _ , err = fmt .Fprintln (re .stderr , "Error:" , msg )
91
88
if err != nil {
92
89
return err
93
90
}
You can’t perform that action at this time.
0 commit comments