cephfs: add mkdir

Signed-off-by: Noah Watkins <noahwatkins@gmail.com>
dotnwat · May 1, 2015 · 0f4cf26 · 0f4cf26
1 parent de82ee5
commit 0f4cf26
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 11 deletions.
diff --git a/cephfs/cephfs.go b/cephfs/cephfs.go
@@ -75,3 +75,15 @@ func (mount *MountInfo) ChangeDir(path string) error {
         return CephError(ret)
     }
 }
+
+func (mount *MountInfo) MakeDir(path string, mode uint32) error {
+    c_path := C.CString(path)
+    defer C.free(unsafe.Pointer(c_path))
+
+    ret := C.ceph_mkdir(mount.mount, c_path, C.mode_t(mode))
+    if ret == 0 {
+        return nil
+    } else {
+        return CephError(ret)
+    }
+}
diff --git a/cephfs/cephfs_test.go b/cephfs/cephfs_test.go
@@ -48,21 +48,19 @@ func TestChangeDir(t *testing.T) {
     err = mount.Mount()
     assert.NoError(t, err)
 
-    err = mount.ChangeDir("/")
-    assert.NoError(t, err)
-}
+    dir1 := mount.CurrentDir()
+    assert.NotNil(t, dir1)
 
-func TestCurrentDir(t *testing.T) {
-    mount, err := cephfs.CreateMount()
+    err = mount.MakeDir("/asdf", 0755)
     assert.NoError(t, err)
-    assert.NotNil(t, mount)
 
-    err = mount.ReadDefaultConfigFile()
+    err = mount.ChangeDir("/asdf")
     assert.NoError(t, err)
 
-    err = mount.Mount()
-    assert.NoError(t, err)
+    dir2 := mount.CurrentDir()
+    assert.NotNil(t, dir2)
 
-    dir := mount.CurrentDir()
-    assert.NotNil(t, dir)
+    assert.NotEqual(t, dir1, dir2)
+    assert.Equal(t, dir1, "/")
+    assert.Equal(t, dir2, "/asdf")
 }