Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 471 for blocking (0.06 seconds)

  1. src/test/java/jcifs/smb/SecurityBlobTest.java

            // Assert
            assertNotSame(original, copy, "clone should return a different instance");
            assertTrue(original.equals(copy), "Cloned instance should be equal by content");
    
            // Mutate original backing array; clone should remain based on previous snapshot
            data[0] = 99;
            assertFalse(original.equals(copy), "After mutation, original should not equal previous clone");
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  2. internal/config/dns/etcd_dns.go

    		return nil, err
    	}
    
    	if r.Count == 0 {
    		key = strings.TrimSuffix(key, etcdPathSeparator)
    		r, err = c.etcdClient.Get(ctx, key)
    		if err != nil {
    			return nil, err
    		}
    		// only if we are looking at `domain` as true
    		// we should return error here.
    		if domain && r.Count == 0 {
    			return nil, ErrDomainMissing
    		}
    	}
    
    	var srvRecords []SrvRecord
    	for _, n := range r.Kvs {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 8K bytes
    - Click Count (0)
  3. build-logic/documentation/src/test/groovy/gradlebuild/docs/FindBrokenInternalLinksTest.groovy

                this.file = file
                this.message = message
            }
    
            static DeadLink forSection(File file, String section) {
                return new DeadLink(file, "Looking for section named $section in ${file.name}")
            }
    
            static DeadLink forJavadoc(File file, String path) {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Aug 21 16:24:54 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/MutableClassToInstanceMap.java

      }
    
      /**
       * Returns a new {@code MutableClassToInstanceMap} instance backed by a given empty {@code
       * backingMap}. The caller surrenders control of the backing map, and thus should not allow any
       * direct references to it to remain accessible.
       */
      public static <B extends @Nullable Object> MutableClassToInstanceMap<B> create(
          Map<Class<? extends @NonNull B>, B> backingMap) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 22:10:29 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link BlockingDeque} which forwards all its method calls to another {@code BlockingDeque}.
     * Subclasses should override one or more methods to modify the behavior of the backing deque as
     * desired per the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p><b>Warning:</b> The methods of {@code ForwardingBlockingDeque} forward <b>indiscriminately</b>
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
  6. src/test/java/jcifs/dcerpc/msrpc/LsaPolicyHandleTest.java

    import jcifs.dcerpc.DcerpcHandle;
    import jcifs.smb.SmbException;
    
    @ExtendWith(MockitoExtension.class)
    class LsaPolicyHandleTest {
    
        @Mock
        private DcerpcHandle mockDcerpcHandle;
    
        // Mocking MsrpcLsarOpenPolicy2 and MsrpcLsarClose is tricky because they are created inside the constructor/method.
        // We need to use ArgumentCaptor or a custom Answer to control their behavior.
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

                noMoreParts = true
                return null
              }
    
              2, 3 -> {
                // " " or "\t" Ignore whitespace and keep looking.
                whitespace = true
                continue@afterBoundaryLoop
              }
    
              -1 -> throw ProtocolException("unexpected characters after boundary")
            }
          }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 02:11:14 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/ForwardingSortedMultiset.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * A sorted multiset which forwards all its method calls to another sorted multiset. Subclasses
     * should override one or more methods to modify the behavior of the backing multiset as desired per
     * the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
     * <p><b>Warning:</b> The methods of {@code ForwardingSortedMultiset} forward
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

          assertEquals("Counts not as expected", Ints.asList(deltas), actualCounts);
        } finally {
          pool.shutdownNow();
        }
    
        // Since we have access to the backing map, verify that there are no zeroes in the map
        for (AtomicInteger value : map.values()) {
          assertTrue("map should not contain a zero", value.get() != 0);
        }
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 08 22:42:14 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

       * All registered subscribers, indexed by event type.
       *
       * <p>The {@link CopyOnWriteArraySet} values make it easy and relatively lightweight to get an
       * immutable snapshot of all current subscribers to an event without any locking.
       */
      private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers =
          Maps.newConcurrentMap();
    
      /** The event bus this registry belongs to. */
      @Weak private final EventBus bus;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
Back to Top