Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 680 for Threads (0.08 sec)

  1. internal/s3select/jstream/decoder.go

    	if r2 < 0 {
    		return "", d.mkError(ErrSyntax, "in unicode escape sequence")
    	}
    
    	// write surrogate pair
    	d.scratch.addRune(utf16.DecodeRune(r, r2))
    	c = d.next()
    	goto scan
    }
    
    // u4 reads four bytes following a \u escape
    func (d *Decoder) u4() rune {
    	// logic taken from:
    	// github.com/buger/jsonparser/blob/master/escape.go#L20
    	var h [4]int
    	for i := 0; i < 4; i++ {
    		c := d.next()
    		switch {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    		ctransport.Proxy = http.ProxyURL(proxyURL)
    		h.config.Transport = ctransport
    	}
    
    	h.client = &http.Client{Transport: h.config.Transport}
    	return h, nil
    }
    
    // SendFromStore - reads the log from store and sends it to webhook.
    func (h *Target) SendFromStore(key store.Key) (err error) {
    	var eventData []byte
    	eventData, err = h.store.GetRaw(key)
    	if err != nil {
    		if os.IsNotExist(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/testing/AbstractPackageSanityTests.java

     *
     * <p>{@link #setDefault} allows subclasses to specify default values for types.
     *
     * <p>This class incurs IO because it scans the classpath and reads classpath resources.
     *
     * @author Ben Yu
     * @since 14.0
     */
    // TODO: Switch to JUnit 4 and use @Parameterized and @BeforeClass
    // Note: @Test annotations are deliberate, as some subclasses specify @RunWith(JUnit4).
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 19:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     * Unlike many other double-ended priority queues, it stores elements in a single array, as compact
     * as the traditional heap data structure used in {@link PriorityQueue}.
     *
     * <p>This class is not thread-safe, and does not accept null elements.
     *
     * <p><i>Performance notes:</i>
     *
     * <ul>
     *   <li>If you only access one end of the queue, and do use a maximum size, this class will perform
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/mylasta/action/FessMessages.java

        /** The key of the message: Unauthorized request. */
        public static final String ERRORS_unauthorized_request = "{errors.unauthorized_request}";
    
        /** The key of the message: Failed to print thread dump. */
        public static final String ERRORS_failed_to_print_thread_dump = "{errors.failed_to_print_thread_dump}";
    
        /** The key of the message: {0} is not supported. */
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		}
    	}
    
    	if len(buf) == 0 {
    		if err != nil {
    			return nil, time.Time{}, err
    		}
    		return nil, time.Time{}, errFileNotFound
    	}
    
    	return buf, dmTime, nil
    }
    
    // ReadXL reads from path/xl.meta, does not interpret the data it read. This
    // is a raw call equivalent of ReadVersion().
    func (s *xlStorage) ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. docs/metrics/prometheus/list.md

    | `minio_node_drive_used_inodes`       | Total inodes used on a drive.                            |
    | `minio_node_drive_reads_per_sec`     | Reads per second on a drive.                             |
    | `minio_node_drive_reads_kb_per_sec`  | Kilobytes read per second on a drive.                    |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  8. istioctl/pkg/workload/workload.go

    	configureCmd.PersistentFlags().StringVar(&externalIP, "externalIP", "", "External IP address of the workload")
    	opts.AttachControlPlaneFlags(configureCmd)
    	return configureCmd
    }
    
    // Reads a WorkloadGroup yaml. Additionally populates default values if unset
    // TODO: add WorkloadGroup validation in pkg/config/validation
    func readWorkloadGroup(filename string, wg *clientnetworking.WorkloadGroup) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 25.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/primitives/Ints.java

        // array slot is read and written exactly once. However, it can have very poor memory locality:
        // benchmarking shows it can take 7 times longer than the other two in some cases. The other two
        // do n swaps, minus a delta (0 or 2 for Reversal, gcd(d, n) for Successive), so that's about
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 31K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/graph/Network.java

     * }</pre>
     *
     * <p>Instances of {@link ImmutableNetwork} do not implement {@link MutableNetwork} (obviously!) and
     * are contractually guaranteed to be unmodifiable and thread-safe.
     *
     * <p>The Guava User Guide has <a
     * href="https://github.com/google/guava/wiki/GraphsExplained#building-graph-instances">more
     * information on (and examples of) building graphs</a>.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 10 15:41:27 UTC 2024
    - 21.1K bytes
    - Viewed (0)
Back to top