Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 213 for sendMsg (0.04 seconds)

  1. src/main/java/jcifs/smb/SmbTreeInternal.java

        @Deprecated
        void connectLogon(CIFSContext tf) throws SmbException;
    
        /**
         * Sends an SMB request and returns the response
         * @param <T> the response type
         * @param request the request to send
         * @param params optional request parameters
         * @return response message
         * @throws CIFSException if an error occurs sending the request
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  2. internal/grid/muxclient.go

    func (m *muxClient) sendLocked(msg message) error {
    	dst := GetByteBufferCap(msg.Msgsize())
    	msg.Seq = m.SendSeq
    	msg.MuxID = m.MuxID
    	msg.Flags |= m.BaseFlags
    	if debugPrint {
    		fmt.Println("Client sending", &msg, "to", m.parent.Remote)
    	}
    	m.SendSeq++
    
    	dst, err := msg.MarshalMsg(dst)
    	if err != nil {
    		return err
    	}
    	if msg.Flags&FlagSubroute != 0 {
    		if m.subroute == nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  3. docs/en/docs/advanced/openapi-callbacks.md

    The process that happens when your API app calls the *external API* is named a "callback". Because the software that the external developer wrote sends a request to your API and then your API *calls back*, sending a request to an *external API* (that was probably created by the same developer).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 7.7K bytes
    - Click Count (0)
  4. docs/en/docs/advanced/advanced-dependencies.md

    {* ../../docs_src/dependencies/tutorial013_an_py310.py ln[19:21] *}
    
    ...would be run after the response finishes sending the slow data:
    
    {* ../../docs_src/dependencies/tutorial013_an_py310.py ln[30:38] hl[31:33] *}
    
    But as `generate_stream()` doesn't use the database session, it is not really necessary to keep the session open while sending the response.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 9K bytes
    - Click Count (0)
  5. internal/s3select/message.go

    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    	// 3. If caller is done, it waits for this go-routine to exit
    	// in Finish()
    
    	quitFlag := false
    	for !quitFlag {
    		select {
    		case data := <-writer.errCh:
    			quitFlag = true
    			// Flush collected records before sending error message
    			if !writer.flushRecords() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  6. internal/config/lambda/event/targetlist.go

    // any for the associated TargetID
    type TargetIDResult struct {
    	// ID where the remove or send were initiated.
    	ID TargetID
    	// Stores any error while removing a target or while sending an event.
    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  7. docs/en/docs/advanced/strict-content-type.md

    * It's running without any authentication, it doesn't have to send any credentials.
    * The browser thinks it's not sending JSON (because of the missing `Content-Type` header).
    
    Then the malicious website could make the local AI agent send angry messages to the user's ex-boss... or worse. 😅
    
    ## Open Internet { #open-internet }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Mon Feb 23 17:45:20 GMT 2026
    - 3.2K bytes
    - Click Count (0)
  8. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan any
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  9. docs/en/docs/tutorial/server-sent-events.md

    ## Raw Data { #raw-data }
    
    If you need to send data **without** JSON encoding, use `raw_data` instead of `data`.
    
    This is useful for sending pre-formatted text, log lines, or special <dfn title="A value used to indicate a special condition or state">"sentinel"</dfn> values like `[DONE]`.
    
    {* ../../docs_src/server_sent_events/tutorial003_py310.py hl[17] *}
    
    /// note
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 4.6K bytes
    - Click Count (0)
  10. internal/logger/target/http/http.go

    	maxWorkers int64
    
    	// workerStartMu sync.Mutex
    	lastStarted time.Time
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan any
    	logChMu sync.RWMutex
    
    	// If this webhook is being re-configured we will
    	// assign the new webhook target to this field.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top