Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 381 for Sending (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/en/docs/tutorial/handling-errors.md

    You could use it while developing your app to log the body and debug it, return it to the user, etc.
    
    {* ../../docs_src/handling_errors/tutorial005_py310.py hl[14] *}
    
    Now try sending an invalid item like:
    
    ```JSON
    {
      "title": "towel",
      "size": "XL"
    }
    ```
    
    You will receive a response telling you that the data is invalid containing the received body:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

    import org.opensearch.index.query.QueryBuilder;
    import org.opensearch.index.query.QueryBuilders;
    
    /**
     * Helper class for indexing operations in the Fess search engine.
     * This class provides functionality for sending documents to the search engine,
     * managing document lifecycle operations (create, update, delete), and handling
     * thumbnail processing during indexing.
     *
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  3. cmd/metacache-walk.go

    	if !skipAccessChecks(opts.Bucket) {
    		// Stat a volume entry.
    		if err = Access(volumeDir); err != nil {
    			return convertAccessError(err, errVolumeAccessDenied)
    		}
    	}
    
    	// Use a small block size to start sending quickly
    	w := newMetacacheWriter(wr, 16<<10)
    	w.reuseBlocks = true // We are not sharing results, so reuse buffers.
    	defer w.Close()
    	out, err := w.stream()
    	if err != nil {
    		return err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 26 07:06:43 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  4. internal/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
    - 9.2K bytes
    - Click Count (0)
  5. internal/logger/logger.go

    	if len(systemTgts) == 0 {
    		return
    	}
    
    	// Iterate over all logger targets to send the log entry
    	for _, t := range systemTgts {
    		if err := t.Send(ctx, entry); err != nil {
    			if consoleTgt != nil { // Sending to the console never fails
    				consoleTgt.Send(ctx, errToEntry(ctx, "logging", fmt.Errorf("unable to send log event to Logger target (%s): %v", t.String(), err), entry.Level))
    			}
    		}
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheStrategy.kt

          return receivedAge + responseDuration + residentDuration
        }
    
        /**
         * Returns true if the request contains conditions that save the server from sending a response
         * that the client has locally. When a request is enqueued with its own conditions, the built-in
         * response cache won't be used.
         */
        private fun hasConditions(request: Request): Boolean =
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      /**
       * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request
       * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers.
       * This avoids sending potentially sensitive data like HTTP cookies to the proxy unencrypted.
       *
       * In order to support preemptive authentication we pass a fake "Auth Failed" response to the
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.1K bytes
    - Click Count (0)
  8. internal/s3select/message.go

    	// in Finish()
    
    	quitFlag := false
    	for !quitFlag {
    		select {
    		case data := <-writer.errCh:
    			quitFlag = true
    			// Flush collected records before sending error message
    			if !writer.flushRecords() {
    				break
    			}
    			writer.write(data)
    
    		case payload, ok := <-writer.payloadCh:
    			if !ok {
    				// payloadCh is closed by caller to
    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)
  9. src/main/java/org/codelibs/fess/app/web/admin/general/AdminGeneralAction.java

            });
        }
    
        /**
         * Sends a test mail using the provided notification settings.
         *
         * @param form the mail form containing notification settings
         * @return HTML response after sending test mail
         */
        @Execute
        @Secured({ ROLE })
        public HtmlResponse sendmail(final MailForm form) {
            validate(form, messages -> {}, () -> asHtml(path_AdminGeneral_AdminGeneralJsp));
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 05:54:31 GMT 2026
    - 27.2K bytes
    - Click Count (0)
  10. src/test/java/org/codelibs/fess/job/PingSearchEngineJobTest.java

            // Execute
            String result = pingSearchEngineJob.execute();
    
            // Assert
            assertEquals("Status of test-cluster is changed to RED.", result);
            // Note: Notification sending is tested but we don't verify the mock since it uses complex callback mechanism
        }
    
        // Test state change with empty notification addresses
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18.9K bytes
    - Click Count (0)
Back to Top