Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top