Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 112 for respCh (0.06 sec)

  1. 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)
  2. 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)
  3. cmd/admin-heal-ops.go

    			return nil
    		}
    		// Don't wait for result
    		return nil
    	}
    
    	// respCh must be set to wait for result.
    	// We make it size 1, so a result can always be written
    	// even if we aren't listening.
    	task.respCh = make(chan healResult, 1)
    	select {
    	case globalBackgroundHealRoutine.tasks <- task:
    		if serverDebugLog {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top