Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1681 - 1690 of 2,109 for collect (0.04 sec)

  1. src/test/java/jcifs/util/transport/ConnectionTimeoutExceptionTest.java

        }
    
        @Test
        void testStringAndThrowableConstructor() {
            // Test the constructor with both message and cause
            String message = "Failed to connect due to timeout.";
            Throwable cause = new IllegalStateException("Network unreachable");
            ConnectionTimeoutException exception = new ConnectionTimeoutException(message, cause);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaProvider.java

        }
    
        @Override
        public RdmaConnection connect(String hostname, int port) throws IOException {
            InetSocketAddress remoteAddress = new InetSocketAddress(hostname, port);
            RdmaConnection connection = createConnection(remoteAddress, null);
            connection.connect();
            return connection;
        }
    
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 24 00:12:28 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  3. tests/count_test.go

    		t.Errorf("Count() method should get correct value, expect: %v, got %v", count, len(users))
    	}
    
    	if err := DB.Model(&User{}).Where("name = ?", user1.Name).Or("name = ?", user3.Name).Count(&count).Find(&users).Error; err != nil {
    		t.Errorf(fmt.Sprintf("Count should work, but got err %v", err))
    	}
    
    	if count != int64(len(users)) {
    		t.Errorf("Count() method should get correct value, expect: %v, got %v", count, len(users))
    	}
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    			// Timeout if no results consumed for too long.
    			case <-unconsumedTimer.C:
    				h.mutex.Unlock()
    				return errHealIdleTimeout
    			}
    		}
    		break
    	}
    
    	// Set the correct result index for the new result item
    	if itemsLen > 0 {
    		r.ResultIndex = 1 + h.currentStatus.Items[itemsLen-1].ResultIndex
    	} else {
    		r.ResultIndex = 1 + h.lastSentResultIndex
    	}
    
    	// append to results
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

                fail("Should be able to access protected constructor: " + e.getMessage());
            }
        }
    
        public void test_static_method_signatures() {
            // Verify all public static methods exist with correct signatures
            try {
                // printThreadDump()
                java.lang.reflect.Method printMethod = ThreadDumpUtil.class.getMethod("printThreadDump");
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. cmd/xl-storage-meta-inline.go

    			return fmt.Errorf("xlMetaInlineData: %w", err)
    		}
    	}
    
    	return nil
    }
    
    // repair will copy all seemingly valid data entries from a corrupted set.
    // This does not ensure that data is correct, but will allow all operations to complete.
    func (x *xlMetaInlineData) repair() {
    	data := *x
    	if len(data) == 0 {
    		return
    	}
    
    	if !data.versionOK() {
    		*x = nil
    		return
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  7. docs/distributed/README.md

    **NOTE:**
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     *
     *  * call ([callStart], [callEnd], [callFailed])
     *    * proxy selection ([proxySelectStart], [proxySelectEnd])
     *    * dns ([dnsStart], [dnsEnd])
     *    * connect ([connectStart], [connectEnd], [connectFailed])
     *      * secure connect ([secureConnectStart], [secureConnectEnd])
     *    * connection held ([connectionAcquired], [connectionReleased])
     *      * request ([requestFailed])
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/primitives/UnsignedLongs.java

        if (dividend >= 0) {
          return dividend / divisor;
        }
    
        /*
         * Otherwise, approximate the quotient, check, and correct if necessary. Our approximation is
         * guaranteed to be either exact or one less than the correct value. This follows from fact that
         * floor(floor(x)/i) == floor(x/i) for any real x and integer i != 0. The proof is not quite
         * trivial.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RetryTlsHandshake.kt

      when {
        // If there was a protocol problem, don't recover.
        e is ProtocolException -> false
    
        // If there was an interruption or timeout (SocketTimeoutException), don't recover.
        // For the socket connect timeout case we do not try the same host with a different
        // ConnectionSpec: we assume it is unreachable.
        e is InterruptedIOException -> false
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
Back to top