Mirror - Code Search

tests/test_tutorial/test_using_request_directly/test_tutorial001.py

                                    },
                                },
                            },
                            "description": "Validation Error",
                        },
                    },
                    "summary": "Read Root",
                },
            },
        },
        "components": {
            "schemas": {

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 3.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-utils.go

	}

	// Success.
	return totalWritten, nil
}

// returns deploymentID from uploadID
func getDeplIDFromUpload(uploadID string) (string, error) {
	uploadBytes, err := base64.RawURLEncoding.DecodeString(uploadID)
	if err != nil {
		return "", fmt.Errorf("error parsing uploadID %s (%w)", uploadID, err)
	}
	slc := strings.SplitN(string(uploadBytes), ".", 2)
	if len(slc) != 2 {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Wed Jan 31 02:11:45 GMT 2024

- 3.1K bytes

- Click Count (0)

github.com/minio/minio

internal/store/batch.go

type BatchConfig[I any] struct {
	Limit         uint32
	Store         Store[I]
	CommitTimeout time.Duration
	Log           logger
}

// Add adds the item to the batch
func (b *Batch[I]) Add(item I) error {
	b.Lock()
	defer b.Unlock()

	if b.isFull() {
		if b.store == nil {
			return ErrBatchFull
		}
		// commit batch to store
		if err := b.commit(); err != nil {
			return err
		}
	}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Sep 06 23:06:30 GMT 2024

- 2.9K bytes

- Click Count (0)

github.com/golang/go

misc/ios/detect.go

	out, err := cmd.Output()
	if err != nil {
		fmt.Println(strings.Join(cmd.Args, "\n"))
		fmt.Fprintln(os.Stderr, err)
		os.Exit(1)
	}
	return out
}

func check(err error) {
	if err != nil {
		fail(err.Error())
	}
}

func fail(msg string, v ...interface{}) {
	fmt.Fprintf(os.Stderr, msg, v...)
	fmt.Fprintln(os.Stderr)
	os.Exit(1)

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Thu Oct 19 23:33:30 GMT 2023

- 3.2K bytes

- Click Count (0)

github.com/minio/minio

internal/lock/lock_nix.go

// flags and shouldn't be considered as replacement
// for os.OpenFile().
func LockedOpenFile(path string, flag int, perm os.FileMode) (*LockedFile, error) {
	return lockedOpenFile(path, flag, perm, 0)
}

// Open - Call os.OpenFile
func Open(path string, flag int, perm os.FileMode) (*os.File, error) {
	return os.OpenFile(path, flag, perm)

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Thu Aug 19 01:35:22 GMT 2021

- 2.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

docs/smb3-features/05-rdma-smb-direct-design.md

    // Getters for all statistics...
}
```

## 9. Error Handling and Fallback

### 9.1 RDMA Error Recovery
```java
public class RdmaErrorHandler {
    public void handleRdmaError(RdmaConnection connection, Exception error) {
        log.warn("RDMA error occurred: {}", error.getMessage());
        
        if (isRecoverableError(error)) {
            // Attempt to recover connection
            try {

Created: Sat Dec 20 13:44:44 GMT 2025

- Last Modified: Sat Aug 16 02:53:50 GMT 2025

- 35.9K bytes

- Click Count (0)

github.com/minio/minio

cmd/erasure-server-pool-decom_gen_test.go

	}

	vn := PoolDecommissionInfo{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

func BenchmarkEncodePoolDecommissionInfo(b *testing.B) {
	v := PoolDecommissionInfo{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 11K bytes

- Click Count (0)

github.com/minio/minio

cmd/batch-job-common-types_gen_test.go

		t.Log("WARNING: TestEncodeDecodeBatchJobKV Msgsize() is inaccurate")
	}

	vn := BatchJobKV{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

func BenchmarkEncodeBatchJobKV(b *testing.B) {
	v := BatchJobKV{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 11.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/batch-rotate_gen_test.go

	}

	vn := BatchJobKeyRotateEncryption{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

func BenchmarkEncodeBatchJobKeyRotateEncryption(b *testing.B) {
	v := BatchJobKeyRotateEncryption{}
	var buf bytes.Buffer

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 11.8K bytes

- Click Count (0)

github.com/minio/minio

cmd/xl-storage-format-v2_gen_test.go

	}

	vn := xlMetaDataDirDecoder{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

func BenchmarkEncodexlMetaDataDirDecoder(b *testing.B) {
	v := xlMetaDataDirDecoder{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 11.5K bytes

- Click Count (0)

Search Options