- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 112 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/admin-handlers.go
} else { writeSuccessResponseJSON(w, respBytes) } return } respCh := make(chan healResp, 1) switch { case hip.forceStop: go func() { respBytes, apiErr := globalAllHealState.stopHealSequence(healPath) hr := healResp{respBytes: respBytes, apiErr: apiErr} respCh <- hr }() case hip.clientToken == "":
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 99.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/SmbComTransactionResponseTest.java
byte command = (byte) 0x25; byte subcommand = (byte) 0x01; TestSmbComTransactionResponse resp = new TestSmbComTransactionResponse(mockConfig, command, subcommand); assertNotNull(resp); assertEquals(command, resp.getCommand()); assertEquals(subcommand, resp.getSubCommand()); } @Test @DisplayName("Test dataCount getter and setter") void testDataCountGetterSetter() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.4K 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/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java
Trans2FindFirst2Response resp = inv.getArgument(1); setField(resp, jcifs.internal.smb1.trans.SmbComTransactionResponse.class, "results", new FileEntry[] { new FE("x") }); setField(resp, Trans2FindFirst2Response.class, "sid", 7); setField(resp, jcifs.internal.smb1.trans.SmbComTransactionResponse.class, "status", 0); resp.received(); return resp; });
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.7K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/Trans2QueryPathInformationResponseTest.java
Trans2QueryPathInformationResponse resp = new Trans2QueryPathInformationResponse(Trans2QueryPathInformationResponse.SMB_QUERY_FILE_STANDARD_INFO); // Create a buffer with sample data byte[] buffer = new byte[100]; int result = resp.readDataWireFormat(buffer, 0, 24); assertNotNull(resp.info);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.5K bytes - Viewed (0)