Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for written (0.05 sec)

  1. cmd/erasure-object.go

    		closeBitrotReaders(readers)
    		if err != nil {
    			// If we have successfully written all the content that was asked
    			// by the client, but we still see an error - this would mean
    			// that we have some parts or data blocks missing or corrupted
    			// - attempt a heal to successfully heal them for future calls.
    			if written == partLength {
    				if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	}
    
    	if writeQuorum < 0 {
    		return fi, nil, errErasureWriteQuorum
    	}
    
    	quorum := readQuorum
    	if write {
    		quorum = writeQuorum
    	}
    
    	// List all online disks.
    	_, modTime, etag := listOnlineDisks(storageDisks, partsMetadata, errs, quorum)
    
    	if write {
    		err = reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	} else {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/object-handlers.go

    			// write error response only if no data or headers has been written to client yet
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		return
    	}
    
    	if err = httpWriter.Close(); err != nil {
    		if !httpWriter.HasWritten() && !statusCodeWritten { // write error response only if no data or headers has been written to client yet
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    // tests are adjusted to use GetObjectNInfo this function can be removed.
    func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) {
    	var header http.Header
    	if etag != "" {
    		header.Set("ETag", etag)
    	}
    	Range := &HTTPRangeSpec{Start: startOffset, End: startOffset + length}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. .github/workflows/detect-conflicts.yml

    name: "Conflict detector"
    on:
      push:
      pull_request_target:
        types: [synchronize]
    
    jobs:
      main:
        permissions:
          contents: read
          pull-requests: write
        runs-on: ubuntu-latest
        steps:
          - name: Check if PRs have merge conflicts
            uses: eps1lon/actions-label-merge-conflict@v3
            with:
              dirtyLabel: "conflicts"
              repoToken: "${{ secrets.GITHUB_TOKEN }}"
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 08:33:44 UTC 2025
    - 499 bytes
    - Viewed (0)
  6. .github/workflows/publish.yml

        types:
          - created
    
    jobs:
      publish:
        runs-on: ubuntu-latest
        strategy:
          matrix:
            package:
              - fastapi
              - fastapi-slim
        permissions:
          id-token: write
        steps:
          - name: Dump GitHub context
            env:
              GITHUB_CONTEXT: ${{ toJson(github) }}
            run: echo "$GITHUB_CONTEXT"
          - uses: actions/checkout@v5
          - name: Set up Python
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:16 UTC 2025
    - 1K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

                private static final int MAX_LEN = 1000;
    
                private final ByteArrayOutputStream buf = new ByteArrayOutputStream(MAX_LEN);
    
                @Override
                public void write(final int b) throws IOException {
                    if (b == '\n' || b == '\r' || buf.size() >= MAX_LEN) {
                        try {
                            final String msg = buf.toString(Constants.UTF_8);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
  8. cmd/object-multipart-handlers.go

    		w.Header().Set(xhttp.AmzChecksumAlgo, res.ChecksumAlgo)
    		if res.ChecksumType != "" {
    			w.Header().Set(xhttp.AmzChecksumType, res.ChecksumType)
    		}
    	}
    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    }
    
    // CopyObjectPartHandler - uploads a part by copying data from an existing object as data source.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 39.5K bytes
    - Viewed (0)
  9. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java

            final CountDownLatch statusReadLatch = new CountDownLatch(1);
            final AtomicInteger successCount = new AtomicInteger(0);
    
            crawlerContext.setStatus(CrawlerStatus.INITIALIZING);
    
            Thread writer = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        statusSetLatch.await();
                        crawlerContext.setStatus(CrawlerStatus.DONE);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 25.6K bytes
    - Viewed (0)
  10. docs/en/docs/release-notes.md

    ## 0.100.0
    
    ✨ Support for **Pydantic v2** ✨
    
    Pydantic version 2 has the **core** re-written in **Rust** and includes a lot of improvements and features, for example:
    
    * Improved **correctness** in corner cases.
    * **Safer** types.
    * Better **performance** and **less energy** consumption.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
Back to top