Cock - Code Search

internal/dsync/lock-args_gen.go

Klaus Post <******@****.***> 1700528975 -0800

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 9.5K bytes

- Viewed (0)

github.com/golang/go

src/cmd/cgo/internal/test/cgo_thread_lock.go

Austin Clements <******@****.***> 1684423194 -0400

Go

- Registered: Tue Apr 23 11:13:09 GMT 2024

- Last Modified: Thu May 18 16:55:07 GMT 2023

- 939 bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/lock-args_gen_test.go

Klaus Post <******@****.***> 1700528975 -0800

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 4.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

    final Lock lock;

    LockingThread(Lock lock) {
      this.lock = lock;
    }

    @Override
    public void run() {
      lock.lock();
      try {
        locked.countDown();
        finishLatch.await(1, TimeUnit.MINUTES);
      } catch (InterruptedException e) {
        fail(e.toString());
      } finally {
        lock.unlock();
      }
    }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 16.1K bytes

- Viewed (1)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

    final Lock lock;

    LockingThread(Lock lock) {
      this.lock = lock;
    }

    @Override
    public void run() {
      lock.lock();
      try {
        locked.countDown();
        finishLatch.await(1, TimeUnit.MINUTES);
      } catch (InterruptedException e) {
        fail(e.toString());
      } finally {
        lock.unlock();
      }
    }

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 16.1K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

requirements_lock_3_10.txt

dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> 1712896733 +0000

Plain Text

- Registered: Tue Apr 30 12:39:09 GMT 2024

- Last Modified: Fri Apr 12 04:38:53 GMT 2024

- 43.8K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    MockExecutor mock = new MockExecutor();
    TestExecutor testExecutor = new TestExecutor(mock);
    assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS));
    mock.assertLastMethodCalled("awaitTermination");
    assertFalse(testExecutor.isTerminated());
    mock.assertLastMethodCalled("isTerminated");
    assertFalse(testExecutor.isShutdown());
    mock.assertLastMethodCalled("isShutdown");

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Jan 05 19:41:03 GMT 2023

- 9.8K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    MockExecutor mock = new MockExecutor();
    TestExecutor testExecutor = new TestExecutor(mock);
    assertFalse(testExecutor.awaitTermination(10, TimeUnit.MILLISECONDS));
    mock.assertLastMethodCalled("awaitTermination");
    assertFalse(testExecutor.isTerminated());
    mock.assertLastMethodCalled("isTerminated");
    assertFalse(testExecutor.isShutdown());
    mock.assertLastMethodCalled("isShutdown");

Java

- Registered: Fri Apr 05 12:43:09 GMT 2024

- Last Modified: Thu Jan 05 19:41:03 GMT 2023

- 9.8K bytes

- Viewed (0)

github.com/minio/minio

internal/kms/kes.go

func (c *kesClient) Metrics(ctx context.Context) (kes.Metric, error) {
	c.lock.RLock()
	defer c.lock.RUnlock()

	return c.client.Metrics(ctx)
}

// Version retrieves version information
func (c *kesClient) Version(ctx context.Context) (string, error) {
	c.lock.RLock()
	defer c.lock.RUnlock()

	return c.client.Version(ctx)
}

// APIs retrieves a list of supported API endpoints

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Apr 16 15:43:39 GMT 2024

- 14.9K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/dsync_test.go

	dm1st := NewDRWMutex(ds, "aap")
	dm2nd := NewDRWMutex(ds, "aap")

	dm1st.Lock(id, source)

	// Release lock after 10 seconds
	go func() {
		time.Sleep(5 * testDrwMutexAcquireTimeout)
		// fmt.Println("Unlocking dm1")

		dm1st.Unlock(context.Background())
	}()

	dm2nd.Lock(id, source)

	// fmt.Printf("2nd lock obtained after 1st lock is released\n")
	time.Sleep(testDrwMutexRefreshCallTimeout * 2)

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Sat Dec 24 03:49:07 GMT 2022

- 11K bytes

- Viewed (0)

Search Options