RepoMirrors
/
go-ceph
mirror of https://github.com/ceph/go-ceph
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rbd: fix error handling for write, seek and flush

This commit is contained in:
Sylvain Baubeau 2015-01-15 15:15:31 +01:00
parent 921a14b17f
commit 75e9c455a6
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
rbd/rbd.go
View File

@ -632,7 +632,11 @@ func (image *Image) Write(data []byte) (n int, err error) {
image.offset += int64(ret) image.offset += int64(ret)
} }
return ret, RBDError(ret) if ret != len(data) {
err = RBDError(-1)
}
return ret, err
} }
func (image *Image) Seek(offset int64, whence int) (int64, error) { func (image *Image) Seek(offset int64, whence int) (int64, error) {
@ -730,12 +734,12 @@ func (image *Image) AioRelease(c Completion) {
// int rbd_flush(rbd_image_t image); // int rbd_flush(rbd_image_t image);
func (image *Image) Flush() error { func (image *Image) Flush() error {
return RBDError(C.rbd_flush(image.image)) return GetError(C.rbd_flush(image.image))
} }
// int rbd_aio_flush(rbd_image_t image, rbd_completion_t c); // int rbd_aio_flush(rbd_image_t image, rbd_completion_t c);
func (image *Image) AioFlush(c Completion) error { func (image *Image) AioFlush(c Completion) error {
return RBDError(C.rbd_aio_flush(image.image, C.rbd_completion_t(c))) return GetError(C.rbd_aio_flush(image.image, C.rbd_completion_t(c)))
} }
// int rbd_snap_list(rbd_image_t image, rbd_snap_info_t *snaps, int *max_snaps); // int rbd_snap_list(rbd_image_t image, rbd_snap_info_t *snaps, int *max_snaps);