Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for Race (0.01 sec)

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

    import org.junit.jupiter.api.Test;
    import org.mockito.Mockito;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    import jcifs.Credentials;
    
    /**
     * Security-focused test cases for SmbSessionImpl to verify race condition fixes.
     */
    public class SmbSessionImplSecurityTest {
    
        private CIFSContext mockContext;
        private SmbTransportImpl mockTransport;
        private Configuration mockConfig;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 11K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        assertThrows(IllegalArgumentException.class, () -> multiset.add(KEY, COUNT_TO_ADD));
      }
    
      /**
       * Simulate some of the races that can happen on add. We can't easily simulate the race that
       * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where
       * the putIfAbsent returns a non-null value, and the case where the replace() of an observed zero
       * fails.
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 16.3K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

          "plan 1 TLS connected",
        )
    
        taskFaker.assertNoMoreTasks()
      }
    
      /**
       * This test performs two races:
       *
       *  * The first race is between plan0 and plan1, with a 250 ms head start for plan0.
       *  * The second race is between plan2 and plan3, with a 250 ms head start for plan2.
       *
       * We get plan0 and plan1 from the route planner.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      /**
       * This test is for a case where two Service.Listener callbacks for the same service would call
       * transitionService in the wrong order due to a race. Due to the fact that it is a race this test
       * isn't guaranteed to expose the issue, but it is at least likely to become flaky if the race
       * sneaks back in, and in this case flaky means something is definitely wrong.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      internal val connectionSpecIndex: Int,
      internal val isTlsFallback: Boolean,
    ) : RoutePlanner.Plan,
      ExchangeCodec.Carrier {
      /** True if this connect was canceled; typically because it lost a race. */
      @Volatile private var canceled = false
    
      // These properties are initialized by connect() and never reassigned.
    
      /** The low-level TCP socket. */
      private var rawSocket: JavaNetSocket? = null
    
      /**
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Oct 08 03:50:05 UTC 2025
    - 19.3K bytes
    - Viewed (2)
  6. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

       * - Both request discover no existing connection. They both make a connection.
       * - The first request "wins the race".
       * - The second request discovers it "lost the race" and closes the connection it just opened.
       * - The second request uses the coalesced connection from request1.
       * - The coalesced connection is violently closed after servicing the first request.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jun 19 11:44:16 UTC 2025
    - 19.1K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_4x.md

        of unacknowledged data per stream and no per-connection limit.
    
     *  Fix: Don't operate on a connection after it's been returned to the pool. This race occurred
        on failed web socket connection attempts.
    
     *  Upgrade: [Okio 3.6.0][okio_3_6_0].
    
     *  Upgrade: [Kotlin 1.8.21][kotlin_1_8_21].
    
    
    ## Version 4.11.0
    
    _2023-04-22_
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

            //
            // Note that there is a race condition here which can result in missing
            // a cyclic edge: it's possible for two threads to simultaneous find
            // "safe" edges which together form a cycle. Preventing this race
            // condition efficiently without _introducing_ deadlock is probably
            // tricky. For now, just accept the race condition---missing a warning
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

                  || countMap.replace(element, existingCounter, newCounter)) {
                return 0;
              }
              break;
            }
          }
    
          // If we're still here, there was a race, so just try again.
        }
      }
    
      /**
       * Removes a number of occurrences of the specified element from this multiset. If the multiset
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb2/lease/DirectoryLeasingIntegrationTest.java

                    for (int j = 0; j < 100; j++) {
                        List<DirectoryCacheEntry.FileInfo> children = entry.getChildren();
                        // Just read, don't assert specific counts due to race conditions
                        assertNotNull(children);
                    }
                });
                readThreads[i].start();
            }
    
            // Wait for all threads
    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