Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 618 for Clock (0.02 seconds)

  1. tests/prepared_stmt_test.go

    	if !ok {
    		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
    	}
    
    	pdb.Mux.Lock()
    	if len(pdb.Stmts.Keys()) == 0 {
    		pdb.Mux.Unlock()
    		t.Fatalf("prepared stmt can not be empty")
    	}
    	pdb.Mux.Unlock()
    
    	pdb.Close()
    	pdb.Mux.Lock()
    	defer pdb.Mux.Unlock()
    	if len(pdb.Stmts.Keys()) != 0 {
    		t.Fatalf("prepared stmt should be empty")
    	}
    }
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
  2. cmd/data-scanner_test.go

    	"sync"
    	"testing"
    	"time"
    
    	"github.com/google/uuid"
    	"github.com/minio/minio/internal/amztime"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	objectlock "github.com/minio/minio/internal/bucket/object/lock"
    	"github.com/minio/minio/internal/bucket/replication"
    	"github.com/minio/minio/internal/bucket/versioning"
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. .github/workflows/pre-commit.yml

              python-version: "3.14"
          - name: Setup uv
            uses: astral-sh/setup-uv@v7
            with:
              cache-dependency-glob: |
                requirements**.txt
                pyproject.toml
                uv.lock
          - name: Install Dependencies
            run: |
              uv venv
              uv pip install -r requirements.txt
          - name: Run prek - pre-commit
            id: precommit
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 23 11:17:16 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/io/IoTestCase.java

          } catch (Exception ignore) {
            // probably URISyntaxException or IllegalArgumentException
            // fall back to copying URLs to files in the testDir == null block below
          }
        }
    
        if (testDir == null) {
          // testdata resources aren't file:// urls, so create a directory to store them in and then
          // copy the resources to the filesystem as needed
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 5.6K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        for (Method method : FuturesTest.class.getDeclaredMethods()) {
          if (Modifier.isPublic(method.getModifiers())
              && method.getName().startsWith("test")
              /*
               * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on
               * AbstractFuture, since it declares methods that use that type in their signatures.
               */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  6. finisher_api.go

    				// Make sure to rollback when panic, Block error or Commit error
    				if panicked || err != nil {
    					db.RollbackTo(fmt.Sprintf("sp%d", spID))
    				}
    			}()
    		}
    		err = fc(db.Session(&Session{NewDB: db.clone == 1}))
    	} else {
    		tx := db.Begin(opts...)
    		if tx.Error != nil {
    			return tx.Error
    		}
    
    		defer func() {
    			// Make sure to rollback when panic, Block error or Commit error
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Sep 19 01:49:06 GMT 2025
    - 22.9K bytes
    - Click Count (0)
  7. mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt

    /*
     * Copyright (C) 2022 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: Wed Jun 18 12:28:21 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  8. api/maven-api-core/src/main/java/org/apache/maven/api/services/Transport.java

    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * Transport for specified remote repository (using provided remote repository base URI as root). Must be treated as a
     * resource, best in try-with-resource block.
     *
     * @since 4.0.0
     */
    @Experimental
    @Consumer
    public interface Transport extends Closeable {
        /**
         * GETs the source URI content into target (does not have to exist, or will be overwritten if exist). The
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Mar 23 05:29:39 GMT 2023
    - 4.4K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
        // Set the result in a separate thread since this test runs the function
        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
        // Set the result in a separate thread since this test runs the function
        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
Back to Top