Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1331 - 1340 of 1,643 for ways (0.02 sec)

  1. internal/dsync/dsync_test.go

    			if i%4 == 0 {
    				m.Lock(id, source)
    				acc0 -= 100
    				acc1 += 100
    				m.Unlock(b.Context())
    			} else {
    				for i := 0; i < len(data); i += 4 {
    					data[i]++
    				}
    				// Elaborate way to say runtime.Gosched
    				// that does not put the goroutine onto global runq.
    				go func() {
    					c <- true
    				}()
    				<-c
    			}
    		}
    	})
    }
    
    func BenchmarkMutexSpin(b *testing.B) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  2. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/AbstractBinaryCompatibilityTest.kt

                if (thing == "Field") desc else "com.example.$desc"
        }
    
        fun BuildResult.assertOutputContains(text: String) =
            assertTrue("Output should contain text:\n'$text',\nbut given text was not matched.\n", output.contains(text))
    
        protected
        fun File.withFile(path: String, text: String = ""): File =
            resolve(path).apply {
                parentFile.mkdirs()
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Tue Dec 30 10:14:25 UTC 2025
    - 18K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/Kerb5Context.java

         * abstracts the access so far, that Oracle JDK, Open JDK and IBM JDK are
         * supported.
         *
         * At the time of the first implementation only a test on Oracle JDK was
         * done.
         */
    
        private static final String OPENJDK_JGSS_INQUIRE_TYPE_CLASS = "com.sun.security.jgss.InquireType";
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 13.5K bytes
    - Viewed (1)
  4. impl/maven-core/src/main/resources/META-INF/maven/extension.xml

        <!--
          | MNG-6240: Plugins might depend on maven-aether-provider <= 3.3.9 before the rename to maven-resolver-provider.
          | Since backwards-compatibility was kept, Maven Core also provides this artifact.
         -->
        <exportedArtifact>org.apache.maven:maven-aether-provider</exportedArtifact>
        <exportedArtifact>org.apache.maven:maven-resolver-provider</exportedArtifact>
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Mar 24 14:07:06 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  5. docs/de/docs/deployment/server-workers.md

    Ich zeige Ihnen, wie Sie **Ihr eigenes Image von Grund auf erstellen**, um einen einzelnen Uvicorn-Prozess auszuführen. Es ist ein einfacher Vorgang und wahrscheinlich das, was Sie tun möchten, wenn Sie ein verteiltes Containerverwaltungssystem wie **Kubernetes** verwenden.
    
    ## Zusammenfassung { #recap }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 02 17:32:56 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/QueuesTest.java

          producerThread.cancel(true);
          producer.doneProducing.await();
          if (drained == 0) {
            q.poll(); // not necessarily there if producer was interrupted
          }
        }
      }
    
      public void testDrainOverflow() throws InterruptedException {
        Queues.drain(new SynchronousQueue<>(), new ArrayList<>(), /* numElements= */ 0, MAX_DURATION);
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * and then. This means that we're silently swallowing an exception -- maybe even an Error. But
         * this is no worse than what FutureTask does in that situation. Additionally, because the
         * Future was cancelled, its listeners have been run, so its consumers will not hang.
         *
         * Contrast this to the situation we have if setResult() throws, a situation described below.
         */
        I sourceResult;
        try {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. cmd/erasure-decode.go

    	readerIndex := 0
    	var wg sync.WaitGroup
    	// if readTrigger is true, it implies next disk.ReadAt() should be tried
    	// if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need
    	// to try reading the next disk.
    	for readTrigger := range readTriggerCh {
    		newBufLK.RLock()
    		canDecode := p.canDecode(newBuf)
    		newBufLK.RUnlock()
    		if canDecode {
    			break
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescTest.java

        void testConfigurationUsage() {
            querySecurityDesc = new NtTransQuerySecurityDesc(mockConfig, 0x1234, OWNER_SECURITY_INFORMATION);
    
            // Verify that the configuration was passed to parent constructor
            verify(mockConfig, atLeastOnce()).getTransactionBufferSize();
        }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 13.9K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java

                    DirectoryCacheScope.IMMEDIATE_CHILDREN);
    
            assertNotNull(leaseKey);
    
            // Step 2: Verify cache entry was created
            DirectoryCacheEntry cacheEntry = directoryLeaseManager.getCacheEntry(directoryPath);
            assertNotNull(cacheEntry);
            assertEquals(directoryPath, cacheEntry.getDirectoryPath());
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 01:47:47 UTC 2025
    - 14.2K bytes
    - Viewed (0)
Back to top