Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 584 for Flock (0.01 seconds)

  1. android/guava-tests/test/com/google/common/collect/LockHeldAssertingSet.java

    import java.util.Collection;
    import java.util.Set;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * {@link Set} implementation that asserts that a given lock is held whenever one of its methods is
     * called.
     */
    @NullUnmarked
    class LockHeldAssertingSet<E> extends ForwardingSet<E> implements Serializable {
      final Set<E> delegate;
      final Object mutex;
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/ResourcePublicSuffixList.kt

    /*
     * Copyright (C) 2024 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue May 27 22:00:49 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  3. android-test/src/test/kotlin/okhttp/android/test/ShadowDnsResolver.kt

    /*
     * Copyright (C) 2024 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  4. maven-tests/src/test/java/com/squareup/okhttp3/maventest/AppTest.java

    /*
     * Copyright (C) 2025 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Jul 12 12:05:57 GMT 2025
    - 1.1K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/FlowControlListener.kt

    /*
     * Copyright (C) 2023 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  6. docs/assets/css/app.css

        line-height: normal;
        font-weight: bold;
    }
    
    button.dl {
      font-weight: 300;
      font-size: 25px;
      line-height: 40px;
      padding: 3px 10px;
      display: inline-block;
      border-radius: 6px;
      color: #f0f0f0;
      margin: 5px 0;
      width: auto;
    }
    
    .logo {
      text-align: center;
      margin-top: 150px;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Feb 08 07:57:03 GMT 2022
    - 1.1K bytes
    - Click Count (2)
  7. internal/once/singleton.go

    package once
    
    // Singleton contains a pointer to T that must be set once.
    // Until the value is set all Get() calls will block.
    type Singleton[T any] struct {
    	v   *T
    	set chan struct{}
    }
    
    // NewSingleton creates a new unset singleton.
    func NewSingleton[T any]() *Singleton[T] {
    	return &Singleton[T]{set: make(chan struct{}), v: nil}
    }
    
    // Get will return the singleton value.
    func (s *Singleton[T]) Get() *T {
    	<-s.set
    	return s.v
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 952 bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformToAsciiData.kt

    /*
     * Copyright (C) 2023 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.4K bytes
    - Click Count (0)
  9. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/PlatformRegistry.kt

    /*
     * Copyright (C) 2024 Block, Inc.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 07:33:49 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

          },
          logger = logger,
        )
    
      /** Runs all tasks that are ready. Used by the test thread only. */
      fun runTasks() {
        advanceUntil(nanoTime)
      }
    
      /** Advance the simulated clock, then runs tasks that are ready. Used by the test thread only. */
      fun advanceUntil(newTime: Long) {
        taskRunner.assertLockNotHeld()
    
        taskRunner.withLock {
          check(currentTask == TestThreadSerialTask)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
Back to Top