Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 660 for calling (0.14 sec)

  1. tests/prepared_stmt_test.go

    	// https://github.com/golang/go/blob/e705a2d16e4ece77e08e80c168382cdb02890f5b/src/database/sql/sql.go#L2717
    	return err.Error() == "sql: statement is closed"
    }
    
    // TestPreparedStmtConcurrentClose test calling close and executing SQL concurrently
    // this test making sure that the gorm would not get a Segmentation Fault, and the only error cause by this is using a closed Stmt
    func TestPreparedStmtConcurrentClose(t *testing.T) {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 8K bytes
    - Viewed (0)
  2. cmd/data-scanner_test.go

    		Validity:    12 * time.Hour,
    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    			case noncurrentVersionsTask:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/graph/AbstractNetwork.java

              }
    
              @Override
              public int size() {
                return AbstractNetwork.this.edges().size();
              }
    
              // Mostly safe: We check contains(u) before calling successors(u), so we perform unsafe
              // operations only in weird cases like checking for an EndpointPair<ArrayList> in a
              // Network<LinkedList>.
              @SuppressWarnings("unchecked")
              @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 10K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

        }
        @RetainedLocalRef Object localValue = valueField;
        if (localValue != null & notInstanceOfDelegatingToFuture(localValue)) {
          return getDoneValue(localValue);
        }
        // we delay calling nanoTime until we know we will need to either park or spin
        long endNanos = remainingNanos > 0 ? System.nanoTime() + remainingNanos : 0;
        long_wait_loop:
        if (remainingNanos >= SPIN_THRESHOLD_NANOS) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              //
              // If an exception is thrown by the subclass then we need to make sure that the service
              // notices and transitions to the FAILED state. We do it by calling notifyFailed directly
              // because the service does not monitor the state of the future so if the exception is not
              // caught and forwarded to the service the task would stop executing but the service would
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  6. tensorflow/c/c_api.h

    //   of stdbool.h is avoided and unsigned char is used instead.
    // * size_t is used to represent byte sizes of objects that are
    //   materialized in the address space of the calling process.
    // * int is used as an index into arrays.
    // * Deletion functions are safe to call on nullptr.
    //
    // Questions left to address:
    // * Might at some point need a way for callers to provide their own Env.
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java

                assertTrue(e instanceof IOException);
                assertTrue(e.getMessage().contains("GCS_PROJECT_ID is blank"));
            }
        }
    
        /**
         * Test that connect() is idempotent - calling it multiple times should be safe.
         */
        public void test_connect_idempotent() throws Exception {
            URL url = new URL("gcs://mybucket/object.txt");
            Handler handler = new Handler();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationResponseTest.java

        void testHasMoreElements() {
            // Initially should have more elements if error code is 0
            assertTrue(response.hasMoreElements());
    
            // After calling nextElement once, isPrimary becomes false but hasMore is still true initially
            response.nextElement();
    
            // Can still have more elements
            assertTrue(response.hasMoreElements());
        }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/cache/Cache.java

       *
       * @since 11.0
       */
      void put(K key, V value);
    
      /**
       * Copies all of the mappings from the specified map to the cache. The effect of this call is
       * equivalent to that of calling {@code put(k, v)} on this map once for each mapping from key
       * {@code k} to value {@code v} in the specified map. The behavior of this operation is undefined
       * if the specified map is modified while the operation is in progress.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/graph/AbstractNetwork.java

              }
    
              @Override
              public int size() {
                return AbstractNetwork.this.edges().size();
              }
    
              // Mostly safe: We check contains(u) before calling successors(u), so we perform unsafe
              // operations only in weird cases like checking for an EndpointPair<ArrayList> in a
              // Network<LinkedList>.
              @SuppressWarnings("unchecked")
              @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 10.3K bytes
    - Viewed (0)
Back to top