Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 458 for handleMsg (0.05 sec)

  1. internal/ringbuffer/ring_buffer.go

    // It may return the (non-nil) error from the same call or return the error (and n == 0) from a subsequent call.
    // Callers should always process the n > 0 bytes returned before considering the error err.
    // Doing so correctly handles I/O errors that happen after reading some bytes and also both of the allowed EOF behaviors.
    func (r *RingBuffer) Read(p []byte) (n int, err error) {
    	if len(p) == 0 {
    		return 0, r.readErr(false)
    	}
    
    	r.mu.Lock()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java

            assertEquals(4, attemptCount.get());
        }
    
        /**
         * Test: Null safety in connect() when targetIndices is null
         * Verifies that connect() handles null targetIndices gracefully
         */
        @Test
        public void testConnectWithNullTargetIndices() {
            final AdminClient mockAdminClient = mock(AdminClient.class);
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:44:44 UTC 2025
    - 17K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/dtyp/SecurityDescriptorTest.java

            assertNotNull(securityDescriptor.getOwnerGroupSid());
            assertNull(securityDescriptor.getAces());
        }
    
        @Test
        @DisplayName("Test decode handles SACL offset correctly")
        void testDecodeHandlesSaclOffset() throws SMBProtocolDecodingException {
            // Prepare buffer with SACL offset (should be ignored)
            testBuffer[0] = 0x01; // revision
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/searchlist/AdminSearchlistAction.java

         */
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public HtmlResponse move(final ListForm form) {
            saveToken();
            return doMove(form, 0);
        }
    
        /**
         * Handles pagination movement logic.
         *
         * @param form the list form containing current state
         * @param move the direction to move (-1 for previous, 0 for specific page, 1 for next)
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 22.7K bytes
    - Viewed (1)
  5. cmd/sftp-server.go

    		}
    	}
    
    	// An SSH server is represented by a ServerConfig, which holds
    	// certificate details and handles authentication of ServerConns.
    	sshConfig := &ssh.ServerConfig{
    		Config: ssh.Config{
    			KeyExchanges: allowKexAlgos,
    			Ciphers:      allowCiphers,
    			MACs:         allowMACs,
    		},
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  6. fastapi/routing.py

                Optional[Sequence[Callable[[], Any]]],
                Doc(
                    """
                    A list of startup event handler functions.
    
                    You should instead use the `lifespan` handlers.
    
                    Read more in the [FastAPI docs for `lifespan`](https://fastapi.tiangolo.com/advanced/events/).
                    """
                ),
            ] = None,
            on_shutdown: Annotated[
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 12:54:56 UTC 2025
    - 174.6K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

            String childUrl2 = ftpInfo.toChildUrl("subdir/file.txt");
            assertEquals("ftp://example.com/parent/subdir/file.txt", childUrl2);
    
            // Test that the method properly handles various child paths
            FtpInfo ftpInfo2 = new FtpClient.FtpInfo("ftp://example.com/test", Constants.UTF_8);
            String childUrl3 = ftpInfo2.toChildUrl("child.txt");
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  8. docs/smb3-features/01-smb3-lease-design.md

    2. **Lease Key Persistence**: Save lease keys for reconnection
    3. **Parent-Child Relationships**: Implement hierarchical leases
    4. **Lease Sharing**: Support lease sharing across handles
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 22K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java

        }
    
        /**
         * Add a durable handle V2 context to this request
         * @param timeoutMs the timeout in milliseconds (0 for persistent handles)
         * @param persistent true if this should be a persistent handle
         * @return the create GUID for this handle
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java

            elevateWordPager.clear();
            return asHtml(path_AdminElevateword_AdminElevatewordJsp).renderWith(data -> {
                searchPaging(data, form);
            });
        }
    
        /**
         * Handles search pagination and data preparation for rendering.
         *
         * @param data render data to populate with search results
         * @param form search form containing current search state
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 13:56:35 UTC 2025
    - 22.2K bytes
    - Viewed (0)
Back to top