Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 487 for Mock (0.05 seconds)

  1. internal/s3select/simdj/testdata/parking-citations-10.json.zst

    RADO","Route":"00217","Agency":1,"ViolationCode":"8070","ViolationDescr":"PARK IN GRID LOCK ZN","Fine":163,"Latitude":99999,"Longitude":99999} {"Ticket":1106500463,"IssueData":"2015-12-17T00:00:00","IssueTime":"1710","RPState":"CA","PlateExpiry":"201602","Make":"TOYO","BodyStyle":"PA","Color":"BK","Location":"SUNSET/ALVARADO","Route":"00217","Agency":1,"ViolationCode":"8070","ViolationDescr":"PARK IN GRID LOCK ZN","Fine":163,"Latitude":99999,"Longitude":99999} {"Ticket":1106506402,"IssueData":"2...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 693 bytes
    - Click Count (0)
  2. CHANGELOG/CHANGELOG-1.18.md

    - Kubernetes will try to acquire the iptables lock every 100 msec during 5 seconds instead of every second. This is especially useful for environments using kube-proxy in iptables mode with a high churn rate of services. ([#85771](https://github.com/kubernetes/kubernetes/pull/85771), [@aojea](http...
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Jun 16 17:18:28 GMT 2021
    - 373.2K bytes
    - Click Count (0)
  3. cmd/config-current.go

    // found, otherwise use default parameters
    func newSrvConfig(objAPI ObjectLayer) error {
    	// Initialize server config.
    	srvCfg := newServerConfig()
    
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	globalServerConfig = srvCfg
    	globalServerConfigMu.Unlock()
    
    	// Save config into file.
    	return saveServerConfig(GlobalContext, objAPI, srvCfg)
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  4. cmd/api-router.go

    }
    
    func setHTTPServer(h *xhttp.Server) {
    	globalObjLayerMutex.Lock()
    	globalHTTPServer = h
    	globalObjLayerMutex.Unlock()
    }
    
    func newConsoleServerFn() *consoleapi.Server {
    	globalObjLayerMutex.RLock()
    	defer globalObjLayerMutex.RUnlock()
    	return globalConsoleSrv
    }
    
    func setConsoleSrv(srv *consoleapi.Server) {
    	globalObjLayerMutex.Lock()
    	globalConsoleSrv = srv
    	globalObjLayerMutex.Unlock()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:19 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  5. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /**
       * The current state of the service. This should be written with the lock held but can be read
       * without it because it is an immutable object in a volatile field. This is desirable so that
       * methods like {@link #state}, {@link #failureCause} and notably {@link #toString} can be run
       * without grabbing the lock.
       *
       * <p>To update this field correctly the lock must be held to guarantee that the state is
       * consistent.
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  7. tensorflow/c/c_api_internal.h

      }
    
    #if !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
      tensorflow::ApiDefMap api_def_map TF_GUARDED_BY(lock);
    #endif  // !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
      bool update_docs_called TF_GUARDED_BY(lock);
      tensorflow::mutex lock;
    };
    
    #if !defined(IS_MOBILE_PLATFORM) && !defined(IS_SLIM_BUILD)
    struct TF_Server {
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat May 13 00:49:12 GMT 2023
    - 7.6K bytes
    - Click Count (0)
  8. .gitignore

    /tensorflow/lite/**/coreml/**/BUILD
    /tensorflow/lite/**/ios/BUILD
    /tensorflow/lite/**/objc/BUILD
    /tensorflow/lite/**/swift/BUILD
    /tensorflow/lite/examples/ios/simple/data/*.tflite
    /tensorflow/lite/examples/ios/simple/data/*.txt
    Podfile.lock
    Pods
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat Nov 30 21:41:32 GMT 2024
    - 945 bytes
    - Click Count (0)
  9. guava/src/com/google/common/cache/LocalCache.java

       * of reads may not be immediately reflected on the algorithm's data structures. These structures
       * are guarded by a lock and operations are applied in batches to avoid lock contention. The
       * penalty of applying the batches is spread across threads so that the amortized cost is slightly
       * higher than performing just the operation without enforcing the capacity constraint.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Sep 11 19:35:11 GMT 2025
    - 148.9K bytes
    - Click Count (0)
  10. internal/config/lambda/event/targetlist.go

    type TargetList struct {
    	sync.RWMutex
    	targets map[TargetID]Target
    }
    
    // Add - adds unique target to target list.
    func (list *TargetList) Add(targets ...Target) error {
    	list.Lock()
    	defer list.Unlock()
    
    	for _, target := range targets {
    		if _, ok := list.targets[target.ID()]; ok {
    			return fmt.Errorf("target %v already exists", target.ID())
    		}
    		list.targets[target.ID()] = target
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
Back to Top