- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 235 for path1b (0.19 sec)
-
cmd/iam-etcd-store.go
func (ies *IAMEtcdStore) loadIAMConfig(ctx context.Context, item interface{}, path string) error { data, err := readKeyEtcd(ctx, ies.client, path) if err != nil { return err } return getIAMConfig(item, data, path) } func (ies *IAMEtcdStore) loadIAMConfigBytes(ctx context.Context, path string) ([]byte, error) { data, err := readKeyEtcd(ctx, ies.client, path) if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
cmd/namespace-lock_test.go
for i := 0; i < 10000; i++ { nsLk := newNSLock(false) // lk1; ref=1 if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) { t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch) nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond) }()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
docs/debugging/pprofgoparser/main.go
flag.DurationVar(&margin, "margin", 0, "margin time") flag.StringVar(&searchText, "search", "", "Regex to search for a text in one goroutine stacktrace") } func parseGoroutineType2(path string) (map[time.Duration][]string, error) { f, err := os.Open(path) if err != nil { return nil, err } bf := bytes.Buffer{} save := func(s string) { bf.WriteString(s + "\n") } reset := func() { bf.Reset() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 06 11:43:16 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/config.go
minioMetaBucket: path.Join(minioMetaBucket, historyFile), }) if err != nil { return err } } return saveConfig(ctx, objAPI, historyFile, kv) } func saveServerConfig(ctx context.Context, objAPI ObjectLayer, cfg interface{}) error { data, err := json.Marshal(cfg) if err != nil { return err } configFile := path.Join(minioConfigPrefix, minioConfigFile)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
internal/crypto/key.go
var ( sealingKey [32]byte encryptedKey bytes.Buffer ) mac := hmac.New(sha256.New, extKey) mac.Write(iv[:]) mac.Write([]byte(domain)) mac.Write([]byte(SealAlgorithm)) mac.Write([]byte(path.Join(bucket, object))) // use path.Join for canonical 'bucket/object' mac.Sum(sealingKey[:0]) if n, err := sio.Encrypt(&encryptedKey, bytes.NewReader(key[:]), sio.Config{Key: sealingKey[:], CipherSuites: fips.DARECiphers()}); n != 64 || err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/os-reliable.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "fmt" "os" "path" ) // Wrapper functions to os.RemoveAll, which calls reliableRemoveAll // this is to ensure that if there is a racy parent directory // create in between we can simply retry the operation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} // getHealSequence - Retrieve a heal sequence by path. The second // argument returns if a heal sequence actually exists. func (ahs *allHealState) getHealSequence(path string) (h *healSequence, exists bool) { ahs.RLock() defer ahs.RUnlock() h, exists = ahs.healSeqMap[path] return h, exists } func (ahs *allHealState) stopHealSequence(path string) ([]byte, APIError) { var hsp madmin.HealStopSuccess
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
internal/disk/stat_bsd.go
package disk import ( "errors" "fmt" "syscall" ) // GetInfo returns total and free bytes available in a directory, e.g. `/`. func GetInfo(path string, _ bool) (info Info, err error) { s := syscall.Statfs_t{} err = syscall.Statfs(path, &s) if err != nil { return Info{}, err } reservedBlocks := s.Bfree - s.Bavail info = Info{ Total: uint64(s.Bsize) * (s.Blocks - reservedBlocks),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/disk/type_windows.go
package disk import ( "path/filepath" "syscall" "unsafe" ) // GetVolumeInformation provides windows drive volume information. var GetVolumeInformation = kernel32.NewProc("GetVolumeInformationW") // getFSType returns the filesystem type of the underlying mounted filesystem func getFSType(path string) string { volumeNameSize, nFileSystemNameSize := uint32(260), uint32(260)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.2K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops_gen.go
return } case "DiskIndex": z.DiskIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "DiskIndex") return } case "Path": z.Path, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Path") return } case "Endpoint": z.Endpoint, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Endpoint") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0)