- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for written (0.05 sec)
-
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) -
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) -
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) -
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) -
.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) -
.github/workflows/publish.yml
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Fri Sep 05 12:48:16 UTC 2025 - 1K bytes - Viewed (0) -
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) -
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) -
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) -
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)