提交 74ec1a9a 作者: keks 提交者: Steven Allen

address stebalien's comments

License: MIT
Signed-off-by: 's avatarkeks <keks@cryptoscope.co>
上级 08cc8552
...@@ -188,7 +188,7 @@ func daemonFunc(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment ...@@ -188,7 +188,7 @@ func daemonFunc(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment
// Inject metrics before we do anything // Inject metrics before we do anything
err := mprome.Inject() err := mprome.Inject()
if err != nil { if err != nil {
return fmt.Errorf("Injecting prometheus handler for metrics failed with message %s", err.Error()) log.Errorf("Injecting prometheus handler for metrics failed with message: %s\n", err.Error())
} }
// let the user know we're going. // let the user know we're going.
......
...@@ -112,7 +112,6 @@ var filesStatCmd = &cmds.Command{ ...@@ -112,7 +112,6 @@ var filesStatCmd = &cmds.Command{
_, err := statGetFormatOptions(req) _, err := statGetFormatOptions(req)
if err != nil { if err != nil {
// REVIEW NOTE: We didn't return here before, was that correct?
return cmdkit.Errorf(cmdkit.ErrClient, err.Error()) return cmdkit.Errorf(cmdkit.ErrClient, err.Error())
} }
...@@ -725,7 +724,7 @@ stat' on the file or any of its ancestors. ...@@ -725,7 +724,7 @@ stat' on the file or any of its ancestors.
cidVersionOption, cidVersionOption,
hashOption, hashOption,
}, },
Run: func(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment) error { Run: func(req *cmds.Request, re cmds.ResponseEmitter, env cmds.Environment) (retErr error) {
path, err := checkPath(req.Arguments[0]) path, err := checkPath(req.Arguments[0])
if err != nil { if err != nil {
return err return err
...@@ -775,7 +774,11 @@ stat' on the file or any of its ancestors. ...@@ -775,7 +774,11 @@ stat' on the file or any of its ancestors.
defer func() { defer func() {
err := wfd.Close() err := wfd.Close()
if err != nil { if err != nil {
re.CloseWithError(cmdkit.Errorf(cmdkit.ErrNormal, err.Error())) if retErr == nil {
retErr = err
} else {
log.Error("files: error closing file mfs file descriptor", err)
}
} }
}() }()
......
...@@ -103,9 +103,7 @@ may also specify the level of compression by specifying '-l=<1-9>'. ...@@ -103,9 +103,7 @@ may also specify the level of compression by specifying '-l=<1-9>'.
outReader, ok := v.(io.Reader) outReader, ok := v.(io.Reader)
if !ok { if !ok {
// TODO or just return the error here? return e.New(e.TypeErr(outReader, v))
log.Error(e.New(e.TypeErr(outReader, v)))
return nil
} }
outPath := getOutPath(req) outPath := getOutPath(req)
......
...@@ -107,11 +107,10 @@ time. ...@@ -107,11 +107,10 @@ time.
return err return err
} }
err = cmds.EmitOnce(res, &BlockStat{ return cmds.EmitOnce(res, &BlockStat{
Key: root.Cid().String(), Key: root.Cid().String(),
Size: int(hres.ContentLength), Size: int(hres.ContentLength),
}) })
return err
}, },
Encoders: cmds.EncoderMap{ Encoders: cmds.EncoderMap{
cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, bs *BlockStat) error { cmds.Text: cmds.MakeTypedEncoder(func(req *cmds.Request, w io.Writer, bs *BlockStat) error {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论