Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 213 for sendMsg (0.05 seconds)

  1. cmd/peer-rest-client.go

    	return nil
    }
    
    // CommitBinary - sends commit binary message to remote peers.
    func (client *peerRESTClient) CommitBinary(ctx context.Context) error {
    	respBody, err := client.callWithContext(ctx, peerRESTMethodCommitBinary, nil, nil, -1)
    	if err != nil {
    		return err
    	}
    	defer xhttp.DrainBody(respBody)
    	return nil
    }
    
    // SignalService - sends signal to peer nodes.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb/SmbCopyUtilTest.java

                w.write(payload, 3, out);
            }
    
            // Assert: verify the underlying stream was called
            verify(out, timeout(1000)).write(payload, 0, 3);
    
            // Stop the thread by sending n = -1
            synchronized (w) {
                w.write(new byte[0], -1, out);
            }
    
            w.join(2000);
            assertFalse(w.isAlive(), "WriterThread should stop after -1 sentinel");
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  3. CONTRIBUTING.md

    # Contributing guidelines
    
    ## Pull Request Checklist
    
    Before sending your pull requests, make sure you do the following:
    
    -   Read the [contributing guidelines](CONTRIBUTING.md).
    -   Read the [Code of Conduct](CODE_OF_CONDUCT.md).
    -   Ensure you have signed the
        [Contributor License Agreement (CLA)](https://cla.developers.google.com/).
    -   Check if your changes are consistent with the
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Sat Jan 11 04:47:59 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  4. internal/event/target/nats.go

    	}
    
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the Nats.
    func (target *NATSTarget) send(eventData event.Event) error {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  5. docs/iam/access-management-plugin.md

    MinIO now includes support for using an Access Management Plugin. This is to allow object storage access control to be managed externally via a webhook.
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Dec 13 22:28:48 GMT 2022
    - 4.4K bytes
    - Click Count (1)
  6. src/main/java/jcifs/dcerpc/DcerpcHandle.java

         */
        public abstract byte[] getSessionKey() throws CIFSException;
    
        @Override
        public String toString() {
            return this.binding.toString();
        }
    
        /**
         * Sends a DCERPC fragment to the remote endpoint
         * @param buf the buffer containing the fragment data
         * @param off the offset into the buffer
         * @param length the length of data to send
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  7. src/main/java/jcifs/Configuration.java

         *
         * @return whether DFS lookup is disabled
         */
        boolean isDfsDisabled();
    
        /**
         * Enable hack to make kerberos auth work with DFS sending short names
         *
         * This works by appending the domain name to the netbios short name and will fail horribly if this mapping is not
         * correct for your domain.
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  8. fastapi/sse.py

            ),
        ] = None
        id: Annotated[
            str | None,
            AfterValidator(_check_id_no_null),
            Doc(
                """
                Optional event ID.
    
                The browser sends this value back as the `Last-Event-ID` header on
                automatic reconnection. **Must not contain null (`\\0`) characters.**
                """
            ),
        ] = None
        retry: Annotated[
            int | None,
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 01 09:21:52 GMT 2026
    - 6.2K bytes
    - Click Count (0)
  9. internal/event/target/elasticsearch.go

    	if err != nil {
    		return err
    	}
    
    	err = target.send(eventData)
    	if xnet.IsNetworkOrHostDown(err, false) {
    		return store.ErrNotConnected
    	}
    	return err
    }
    
    // send - sends the event to the target.
    func (target *ElasticsearchTarget) send(eventData event.Event) error {
    	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    	defer cancel()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

                final SearchRequestParams params, final OptionalThing<FessUserBean> userBean) {
            if (logger.isDebugEnabled()) {
                logger.debug("Sending query to searchers: query={}", query);
            }
            final int pageSize = params.getPageSize();
            final int startPosition = params.getStartPosition();
            if (startPosition * 2 >= windowSize) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Dec 25 02:13:14 GMT 2025
    - 28K bytes
    - Click Count (0)
Back to Top