Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 507 for mock (0.02 seconds)

  1. CHANGELOG/CHANGELOG-1.18.md

    ## Changelog since v1.18.0-alpha.1
    
    ### Other notable changes
    
    * Bump golang/mock version to v1.3.1 ([#87326](https://github.com/kubernetes/kubernetes/pull/87326), [@wawa0210](https://github.com/wawa0210))
    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)
  2. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * </ul>
     *
     * The last point is subtle. Often the observable object will be managing its own internal state
     * using a lock, however it is dangerous to dispatch listeners while holding a lock because they
     * might run on the {@code directExecutor()} or be otherwise re-entrant (call back into your
     * object). So it is important to not call {@link #dispatch} while holding any locks. This is why
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  3. docs/bucket/replication/sio-error.sh

    ./mc alias set myminio2 http://localhost:9101 minioadmin minioadmin
    
    ./mc ready myminio1
    ./mc ready myminio2
    sleep 1
    
    ./mc mb myminio1/testbucket/ --with-lock
    ./mc mb myminio2/testbucket/ --with-lock
    
    ./mc encrypt set sse-s3 my-minio-key myminio1/testbucket/
    ./mc encrypt set sse-s3 my-minio-key myminio2/testbucket/
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat May 18 18:19:01 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  4. internal/once/init.go

    // if it is not successful yet.
    func (l *Init) Do(f func() error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.do(f)
    	}
    	return nil
    }
    
    func (l *Init) do(f func() error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(); err != nil {
    			return err
    		}
    		// Mark as done only when f() is successful
    		atomic.StoreUint32(&l.done, 1)
    	}
    	return nil
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 09 04:20:31 GMT 2023
    - 2.1K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top