Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 481 for Mlock (0.02 seconds)

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

  1. docs/en/data/topic_repos.yml

    - name: NoteDiscovery
      html_url: https://github.com/gamosoft/NoteDiscovery
      stars: 1107
      owner_login: gamosoft
      owner_html_url: https://github.com/gamosoft
    - name: flock
      html_url: https://github.com/Onelevenvy/flock
      stars: 1055
      owner_login: Onelevenvy
      owner_html_url: https://github.com/Onelevenvy
    - name: fastapi-observability
      html_url: https://github.com/blueswen/fastapi-observability
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Dec 01 13:17:29 GMT 2025
    - 16K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

        }
    
        @Override
        public E element() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.element();
        }
    
        @Override
        public Iterator<E> iterator() {
          // We explicitly don't lock for iterator()
          assertFalse(Thread.holdsLock(mutex));
          return delegate.iterator();
        }
    
        @Override
        public int size() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.size();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. docs/site-replication/README.md

    - Creation of STS credentials
    - Creation and deletion of service accounts (except those owned by the root user)
    - Changes to Bucket features such as:
      - Bucket Policies
      - Bucket Tags
      - Bucket Object-Lock configurations (including retention and legal hold configuration)
      - Bucket Encryption configuration
    
    > NOTE: Bucket versioning is automatically enabled for all new and existing buckets on all replicated sites.
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  4. cmd/dynamic-timeouts.go

    func (dt *dynamicTimeout) logEntry(duration time.Duration) {
    	if duration < 0 {
    		return
    	}
    	entries := int(atomic.AddInt64(&dt.entries, 1))
    	index := entries - 1
    	if index < dynamicTimeoutLogSize {
    		dt.mutex.Lock()
    		dt.log[index] = duration
    
    		// We leak entries while we copy
    		if entries == dynamicTimeoutLogSize {
    			// Make copy on stack in order to call adjust()
    			logCopy := [dynamicTimeoutLogSize]time.Duration{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultLifecyclePluginAnalyzer.java

            this.defaultLifeCycles = requireNonNull(defaultLifeCycles);
        }
    
        // These methods deal with construction intact Plugin object that look like they come from a standard
        // <plugin/> block in a Maven POM. We have to do some wiggling to pull the sources of information
        // together and this really shows the problem of constructing a sensible default configuration, but
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 9K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

              headers.value(i) == "trailers"
            ) {
              result.add(Header(name, headers.value(i)))
            }
          }
          return result
        }
    
        /** Returns headers for a name value block containing an HTTP/2 response. */
        fun readHttp2HeadersList(
          headerBlock: Headers,
          protocol: Protocol,
        ): Response.Builder {
          var statusLine: StatusLine? = null
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

            };
        Thread runner = new Thread(task, "runner");
        runner.start();
        isInterruptibleRegistered.await();
        // trigger the interrupt on another thread since it will block
        Thread interrupter =
            new Thread("Interrupter") {
              @Override
              public void run() {
                task.interruptTask();
              }
            };
        interrupter.start();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  8. internal/bucket/lifecycle/transition.go

    	trnDate, err := time.Parse(time.RFC3339, dateStr)
    	if err != nil {
    		return errTransitionInvalidDate
    	}
    	// Allow only date timestamp specifying midnight GMT
    	hr, m, sec := trnDate.Clock()
    	nsec := trnDate.Nanosecond()
    	loc := trnDate.Location()
    	if hr != 0 || m != 0 || sec != 0 || nsec != 0 || loc.String() != time.UTC.String() {
    		return errTransitionDateNotMidnight
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                            if (file.exists()) {
                                if (!file.delete()) {
                                    // sleep for 10ms just in case this is windows holding a file lock
                                    try {
                                        Thread.sleep(10);
                                    } catch (InterruptedException ie) {
                                        // ignore
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  10. cmd/metacache.go

    	// Max time between client calls before dropping an async cache listing.
    	metacacheMaxClientWait = 3 * time.Minute
    
    	// metacacheBlockSize is the number of file/directory entries to have in each block.
    	metacacheBlockSize = 5000
    
    	// metacacheSharePrefix controls whether prefixes on dirty paths are always shared.
    	// This will make `test/a` and `test/b` share listings if they are concurrent.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jul 12 16:23:16 GMT 2024
    - 6K bytes
    - Click Count (0)
Back to Top