- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for sendiri (0.04 sec)
-
docs/changelogs/changelog_3x.md
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
errCh := make(chan error, 1) go func() { sentErr := false sendErr := func(err error) { if !sentErr { select { case results <- itemOrErr[ObjectInfo]{Err: err}: sentErr = true case <-parentCtx.Done(): } } } defer func() { select { case <-ctx.Done(): sendErr(ctx.Err()) default: } xioutil.SafeClose(results)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/admin-handlers-users.go
writeErrorResponseJSON(ctx, w, apiErr, r.URL) return } } // Check if we are creating svc account for request sender. isSvcAccForRequestor := targetUser == requestorUser || targetUser == requestorParentUser // If we are creating svc account for request sender, ensure // that targetUser is a real user (i.e. not derived // credentials). if isSvcAccForRequestor { if requestorIsDerivedCredential {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 90.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
try { CommonServerMessageBlockResponse resp = thisReq.getResponse(); if (log.isTraceEnabled()) { log.trace("Sending " + thisReq); } resp = super.sendrecv(curHead, resp, params); if (!checkStatus(curHead, resp)) { if (log.isDebugEnabled()) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0) -
cmd/batch-handlers.go
}, } opts, _, err := batchReplicationOpts(ctx, "", gr.ObjInfo) if err != nil { batchLogIf(ctx, err) continue } // TODO: I am not sure we read it back, but we aren't sending whether checksums are single/multipart. for k, vals := range opts.Header() { for _, v := range vals { snowballObj.Headers.Add(k, v) } } input <- snowballObj } }()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0) -
cmd/bucket-handlers.go
writeSuccessResponseXML(w, encodedSuccessResponse) } // ListBucketsHandler - GET Service. // ----------- // This implementation of the GET operation returns a list of all buckets // owned by the authenticated sender of the request. func (api objectAPIHandlers) ListBucketsHandler(w http.ResponseWriter, r *http.Request) { ctx := newContext(r, w, "ListBuckets") defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
cmd/test-utils_test.go
} // httptest Recorder to capture all the response by the http handler. rec := httptest.NewRecorder() // reading the body to preserve it so that it can be used again for second attempt of sending unsigned HTTP request. // If the body is read in the handler the same request cannot be made use of. buf, err := io.ReadAll(anonReq.Body) if err != nil { t.Fatal(failTestStr(anonTestStr, err.Error())) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
val logs = testLogHandler.takeAll() assertThat(firstFrame(logs, "HEADERS")!!, "header logged") .contains("HEADERS END_HEADERS") // While MockWebServer waits to read the client's HEADERS frame before sending the response, it // doesn't wait to read the client's DATA frame and may send a DATA frame before the client // does. So we can't assume the client's empty DATA will be logged first.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0)