1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
package hdfs
import (
"os"
"path"
hdfs "github.com/colinmarc/hdfs/v2/internal/protocol/hadoop_hdfs"
"google.golang.org/protobuf/proto"
)
// Mkdir creates a new directory with the specified name and permission bits.
func (c *Client) Mkdir(dirname string, perm os.FileMode) error {
return c.mkdir(dirname, perm, false)
}
// MkdirAll creates a directory for dirname, along with any necessary parents,
// and returns nil, or else returns an error. The permission bits perm are used
// for all directories that MkdirAll creates. If dirname is already a directory,
// MkdirAll does nothing and returns nil.
func (c *Client) MkdirAll(dirname string, perm os.FileMode) error {
return c.mkdir(dirname, perm, true)
}
func (c *Client) mkdir(dirname string, perm os.FileMode, createParent bool) error {
dirname = path.Clean(dirname)
info, err := c.getFileInfo(dirname)
err = interpretException(err)
if err == nil {
if createParent && info.IsDir() {
return nil
}
return &os.PathError{"mkdir", dirname, os.ErrExist}
} else if !os.IsNotExist(err) {
return &os.PathError{"mkdir", dirname, err}
}
req := &hdfs.MkdirsRequestProto{
Src: proto.String(dirname),
Masked: &hdfs.FsPermissionProto{Perm: proto.Uint32(uint32(perm))},
CreateParent: proto.Bool(createParent),
}
resp := &hdfs.MkdirsResponseProto{}
err = c.namenode.Execute("mkdirs", req, resp)
if err != nil {
return &os.PathError{"mkdir", dirname, interpretException(err)}
}
return nil
}
|
