mirror of
https://github.com/cubefs/cubefs.git
synced 2026-08-02 02:00:56 +00:00
7a57837f74
Adjust the format of the license header information of the third-party code used to make the format more compliant. The NOTICE file supplements the third-party code NOTIC information and explains the use of the code. Signed-off-by: Mofei Zhang <mofei2816@gmail.com>
104 lines
2.1 KiB
Go
104 lines
2.1 KiB
Go
// Copyright 2019 The ChubaoFS Authors.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
|
|
// implied. See the License for the specific language governing
|
|
// permissions and limitations under the License.
|
|
|
|
package objectnode
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/chubaofs/chubaofs/proto"
|
|
|
|
"github.com/chubaofs/chubaofs/util/log"
|
|
)
|
|
|
|
const (
|
|
volumeRootInode = uint64(1)
|
|
)
|
|
|
|
type xattrStore struct {
|
|
vm *VolumeManager //vol *Volume
|
|
}
|
|
|
|
func (s *xattrStore) Init(vm *VolumeManager) {
|
|
s.vm = vm
|
|
}
|
|
|
|
func (s *xattrStore) getInode(vol, path string) (*Volume, uint64, error) {
|
|
v, err := s.vm.Volume(vol)
|
|
if err != nil {
|
|
return nil, 0, err
|
|
}
|
|
inode := volumeRootInode
|
|
if path != "" && path != "/" {
|
|
items := strings.Split(path, "/")
|
|
for _, item := range items {
|
|
if item == "" {
|
|
continue
|
|
}
|
|
inode, _, err = v.mw.Lookup_ll(inode, item)
|
|
if err != nil {
|
|
return v, inode, err
|
|
}
|
|
}
|
|
}
|
|
return v, inode, nil
|
|
}
|
|
|
|
func (s *xattrStore) Put(vol, path, key string, data []byte) (err error) {
|
|
v, err1 := s.vm.Volume(vol)
|
|
if err1 != nil {
|
|
err = err1
|
|
return
|
|
}
|
|
err = v.SetXAttr(path, key, data)
|
|
if err != nil {
|
|
log.LogErrorf("policy: %v, %v", key, data)
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *xattrStore) Get(vol, path, key string) (val []byte, err error) {
|
|
var v *Volume
|
|
v, err = s.vm.Volume(vol)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
var xattrInfo *proto.XAttrInfo
|
|
if xattrInfo, err = v.GetXAttr(path, key); err != nil {
|
|
return
|
|
}
|
|
if xattrInfo == nil {
|
|
return
|
|
}
|
|
|
|
var strVal string
|
|
strVal = xattrInfo.XAttrs[key]
|
|
if len(strVal) > 0 {
|
|
val = []byte(strVal)
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *xattrStore) Delete(vol, obj, key string) (err error) {
|
|
|
|
return
|
|
}
|
|
|
|
func (s *xattrStore) List(vol, obj string) (data [][]byte, err error) {
|
|
|
|
return
|
|
}
|
