- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 76 for link (0.16 sec)
-
internal/lock/lock_windows.go
var lockType uint32 = lockFileFailImmediately | lockFileExclusiveLock if flag == syscall.O_RDONLY { // https://docs.microsoft.com/en-us/windows/desktop/api/fileapi/nf-fileapi-lockfileex //lint:ignore SA4016 Reasons lockType = lockFileFailImmediately // Set this to enable shared lock and fail immediately. } return lockedOpenFile(path, flag, perm, lockType) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
` var err error dir := t.TempDir() mountsPath := filepath.Join(dir, "mounts") if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil { t.Fatal(err) } // Verifies if reading each line worked properly. { var mounts mountInfos mounts, err = readProcMounts(mountsPath) if err != nil { t.Fatal(err) } if len(mounts) != 3 { t.Fatalf("expected 3 mounts, got %d", len(mounts))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
internal/event/target/amqp.go
AutoDeleted bool `json:"autoDeleted"` PublisherConfirms bool `json:"publisherConfirms"` QueueDir string `json:"queueDir"` QueueLimit uint64 `json:"queueLimit"` } //lint:file-ignore ST1003 We cannot change these exported names. // AMQP input constants. const ( AmqpQueueDir = "queue_dir" AmqpQueueLimit = "queue_limit" AmqpURL = "url"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
docs/bucket/replication/setup_3site_replication.sh
#!/usr/bin/env bash echo "Running $0" if [ -n "$TEST_DEBUG" ]; then set -x fi trap 'catch $LINENO' ERR # shellcheck disable=SC2120 catch() { if [ $# -ne 0 ]; then echo "error on line $1" for site in sitea siteb sitec; do echo "$site server logs =========" cat "/tmp/${site}_1.log" echo "===========================" cat "/tmp/${site}_2.log" done fi echo "Cleaning up instances of MinIO"
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 10.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} } var ( errDecommissionAlreadyRunning = errors.New("decommission is already in progress") errDecommissionComplete = errors.New("decommission is complete, please remove the servers from command-line") errDecommissionNotStarted = errors.New("decommission is not in progress") ) func (p *poolMeta) Decommission(idx int, pi poolSpaceInfo) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/site-replication.go
break } joinReq.SvcAcctParent = v.AccessKey err = admClient.SRPeerJoin(ctx, joinReq) if err != nil { peerAddErr = errSRPeerResp(fmt.Errorf("unable to link with peer %s: %w", v.Name, err)) break } addedCount++ } if peerAddErr != nil { if addedCount == 0 { return madmin.ReplicateAddStatus{}, peerAddErr }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
helm-releases/minio-5.0.14.tgz
.Values.svcaccts }} echo {{ tpl .accessKey $global }} > $MINIO_ACCESSKEY_SECRETKEY_TMP {{- if .existingSecret }} cat /config/secrets-svc/{{ tpl .existingSecret $global }}/{{ tpl .existingSecretKey $global }} >> $MINIO_ACCESSKEY_SECRETKEY_TMP # Add a new line if it doesn't exist sed -i '$a\' $MINIO_ACCESSKEY_SECRETKEY_TMP {{ else }} echo {{ .secretKey }} >> $MINIO_ACCESSKEY_SECRETKEY_TMP {{- end }} {{- if $svc.policy}} createSvcacct {{ .user }} svc_policy_{{ $idx }} {{ else }} createSvcacct {{ .user }}...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Sep 30 20:46:10 GMT 2023 - 20.6K bytes - Viewed (0) -
cmd/xl-storage.go
// upload an object such as `prefix/object/xl.meta` // where `prefix/object` is already an object if isSysErrNotDir(err) && runtime.GOOS != globalWindowsOSName { // NOTE: On windows the error happens at // next line and returns appropriate error. return res, errFileAccessDenied } if !osIsNotExist(err) { return res, osErrToFileErr(err) } if formatLegacy { // errFileNotFound comes here.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
docs/debugging/pprofgoparser/main.go
skip, record bool ) for s.Scan() { line := s.Text() switch { case skip && line != "": case skip && line == "": skip = false case record && line == "": stackTrace := bf.String() reset() record = false if searchRE == nil || searchRE.MatchString(stackTrace) { ret[t] = append(ret[t], stackTrace) } case record: save(line) default:
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/batch-expire.go
err := val.Decode(&tmp) if err != nil { return err } *p = BatchJobExpirePurge(tmp) p.line, p.col = val.Line, val.Column return nil } // Validate returns nil if value is valid, ie > 0. func (p BatchJobExpirePurge) Validate() error { if p.RetainVersions < 0 { return BatchJobYamlErr{ line: p.line, col: p.col, msg: "retainVersions must be >= 0", } } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1)