Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for unblocking (0.09 seconds)

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

  1. cmd/peer-rest-server.go

    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()})
    
    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  2. tensorflow/BUILD

    selects.config_setting_group(
        name = "mobile",
        match_any = [
            ":android",
            ":chromiumos",
            # TODO(jakeharmon8): Move all platform configs to TSL with fuchsia (non-blocking)
            ":fuchsia",
            ":emscripten",
            ":ios",
        ],
        visibility = ["//visibility:public"],
    )
    
    config_setting(
        name = "lite_protos_legacy",
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Tue Mar 24 21:00:18 GMT 2026
    - 53.1K bytes
    - Click Count (0)
  3. docs/bucket/notifications/README.md

    mandatory      (on|off)    quietly ignore undelivered messages when set to 'off', default is 'on'
    durable        (on|off)    persist queue across broker restarts when set to 'on', default is 'off'
    no_wait        (on|off)    non-blocking message delivery when set to 'on', default is 'off'
    internal       (on|off)    set to 'on' for exchange to be not used directly by publishers, but only when bound to other exchanges
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/MapMakerInternalMap.java

      /*
       * The basic strategy is to subdivide the table among Segments, each of which itself is a
       * concurrently readable hash table. The map supports non-blocking reads and concurrent writes
       * across different segments.
       *
       * The page replacement algorithm's data structures are kept casually consistent with the map. The
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

      /*
       * The basic strategy is to subdivide the table among Segments, each of which itself is a
       * concurrently readable hash table. The map supports non-blocking reads and concurrent writes
       * across different segments.
       *
       * The page replacement algorithm's data structures are kept casually consistent with the map. The
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  6. cmd/xl-storage.go

    			targetPath2,
    		} {
    			if target == "" {
    				continue
    			}
    			select {
    			case s.immediatePurge <- target:
    			default:
    				// Too much back pressure, we will perform the delete
    				// blocking at this point we need to serialize operations.
    				removeAll(target)
    			}
    		}
    	}
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
Back to Top