- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for respCh (0.06 sec)
-
cmd/background-heal-ops.go
} else { res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts) } } if task.respCh != nil { task.respCh <- healResult{result: res, err: err} continue } // when respCh is not set caller is not waiting but we // update the relevant metrics for them if bgSeq != nil { if err == nil { bgSeq.countHealed(res.Type)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 4.6K bytes - Viewed (0) -
cmd/lock-rest-server.go
ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall) defer cancel() resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(ctx, *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err) } // LockHandler - Acquires a lock.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0) -
cmd/lock-rest-client.go
r, err := h.Call(ctx, c.connection, args) if err != nil { return false, err } defer h.PutResponse(r) ok = r.Code == dsync.RespOK switch r.Code { case dsync.RespLockConflict, dsync.RespLockNotFound, dsync.RespOK: // no error case dsync.RespLockNotInitialized: err = errLockNotInitialized default: err = errors.New(r.Err) } return ok, err }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
docs/id/docs/tutorial/path-params.md
Jika anda menjalankan contoh berikut dan kunjungi <a href="http://127.0.0.1:8000/items/foo" class="external-link" target="_blank">http://127.0.0.1:8000/items/foo</a>, anda akan melihat respon: ```JSON {"item_id":"foo"} ``` ## Parameter path dengan tipe data Tipe data parameter path bisa didefinisikan di dalam fungsi, menggunakan anotasi tipe data standar Python:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:29:01 UTC 2025 - 8.8K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/TransWaitNamedPipeResponseTest.java
// Arrange TransWaitNamedPipeResponse resp = new TransWaitNamedPipeResponse(); // Act & Assert - no exceptions should be thrown assertDoesNotThrow(() -> resp.writeSetupWireFormat(null, 0)); assertDoesNotThrow(() -> resp.writeParametersWireFormat(null, 0)); assertDoesNotThrow(() -> resp.writeDataWireFormat(null, 0)); assertDoesNotThrow(() -> resp.readSetupWireFormat(null, 0, 0));
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 5.4K bytes - Viewed (0) -
src/main/java/jcifs/http/NtlmSsp.java
} } else { resp.setHeader("WWW-Authenticate", "NTLM"); } resp.setStatus(HttpServletResponse.SC_UNAUTHORIZED); resp.setContentLength(0); resp.flushBuffer(); return null; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.9K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/session/Smb2LogoffResponseTest.java
void constructor_happyPath() { // Arrange Configuration cfg = Mockito.mock(Configuration.class); // Act Smb2LogoffResponse resp = new Smb2LogoffResponse(cfg); // Assert assertNotNull(resp, "Response instance should be created"); } @Nested @DisplayName("writeBytesWireFormat") class WriteBytesWireFormat { @ParameterizedTest
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.7K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
} } } func fwdStatusToAPIError(statusCode int, resp *http.Response) *APIError { if statusCode < http.StatusBadRequest { return nil } desc := resp.Header.Get(xhttp.AmzFwdErrorMessage) if strings.TrimSpace(desc) == "" { apiErr := errorCodes.ToAPIErr(ErrInvalidRequest) return &apiErr } code := resp.Header.Get(xhttp.AmzFwdErrorCode) if strings.TrimSpace(code) == "" {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 6.5K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComWriteResponseTest.java
private SmbComWriteResponse resp; private Configuration cfgMock; @BeforeEach public void setUp() { // create a mock configuration that satisfies constructor requirements. cfgMock = mock(Configuration.class); resp = new SmbComWriteResponse(cfgMock); } @Test public void testInitialCountIsZero() { assertEquals(0, resp.getCount(), "Initial count should be zero");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 2.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ServerMessageBlock2Request.java
public T initResponse(final CIFSContext tc) { final T resp = createResponse(tc, this); if (resp == null) { return null; } resp.setDigest(getDigest()); setResponse(resp); final ServerMessageBlock2 n = getNext(); if (n instanceof ServerMessageBlock2Request<?>) { resp.setNext(((ServerMessageBlock2Request<?>) n).initResponse(tc)); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Mon Aug 25 14:34:10 UTC 2025 - 7.2K bytes - Viewed (0)