Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 389 for CLOSED (0.41 seconds)

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

        Stopwatch stopwatch = Stopwatch.createStarted();
    
        String result = proxy.sleepThenReturnInput("x");
    
        assertThat(result).isEqualTo("x");
        assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(DELAY_MS, ENOUGH_MS));
        assertThat(target.finished).isTrue();
      }
    
      public void testNewProxy_goodMethodWithNotEnoughTime() throws Exception {
        SampleImpl target = new SampleImpl(9999);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 9.4K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java

        Stopwatch stopwatch = Stopwatch.createStarted();
    
        String result = proxy.sleepThenReturnInput("x");
    
        assertThat(result).isEqualTo("x");
        assertThat(stopwatch.elapsed(MILLISECONDS)).isIn(Range.closed(DELAY_MS, ENOUGH_MS));
        assertThat(target.finished).isTrue();
      }
    
      public void testNewProxy_goodMethodWithNotEnoughTime() throws Exception {
        SampleImpl target = new SampleImpl(9999);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 9.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/dcerpc/msrpc/lsarpc.java

            @Override
            public int getOpnum() {
                return 0x00;
            }
    
            /** Return value from the RPC call. */
            public int retval;
            /** Policy handle to be closed. */
            public rpc.policy_handle handle;
    
            /**
             * Creates a new LsarClose message.
             *
             * @param handle the policy handle to close
             */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 44.5K bytes
    - Click Count (0)
  4. cmd/peer-rest-client.go

    	conn := client.gridConn()
    	if conn == nil {
    		return false
    	}
    	return client.restClient.IsOnline() || conn.State() == grid.StateConnected
    }
    
    // Close - marks the client as closed.
    func (client *peerRESTClient) Close() error {
    	client.restClient.Close()
    	return nil
    }
    
    // GetLocks - fetch older locks for a remote node.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/primitives/Ints.java

          if (array[i] > max) {
            max = array[i];
          }
        }
        return max;
      }
    
      /**
       * Returns the value nearest to {@code value} which is within the closed range {@code [min..max]}.
       *
       * <p>If {@code value} is within the range {@code [min..max]}, {@code value} is returned
       * unchanged. If {@code value} is less than {@code min}, {@code min} is returned, and if {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:45:58 GMT 2026
    - 31.3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/ByteStreams.java

       * {@link ByteStreams} method returns a singleton stream whose {@code close} method has no effect,
       * while the {@link OutputStream} method returns a new instance whose {@code write} methods throw
       * if called on a closed stream.
       *
       * @since 14.0 (since 1.0 as com.google.common.io.NullOutputStream)
       */
      public static OutputStream nullOutputStream() {
        return NULL_OUTPUT_STREAM;
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/primitives/Floats.java

        for (int i = 1; i < array.length; i++) {
          max = Math.max(max, array[i]);
        }
        return max;
      }
    
      /**
       * Returns the value nearest to {@code value} which is within the closed range {@code [min..max]}.
       *
       * <p>If {@code value} is within the range {@code [min..max]}, {@code value} is returned
       * unchanged. If {@code value} is less than {@code min}, {@code min} is returned, and if {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 16:38:16 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  8. cmd/metacache-entries.go

    		}
    	}
    	m.o = m.o[idx:]
    }
    
    // mergeEntryChannels will merge entries from in and return them sorted on out.
    // To signify no more results are on an input channel, close it.
    // The output channel will be closed when all inputs are emptied.
    // If file names are equal, compareMeta is called to select which one to choose.
    // The entry not chosen will be discarded.
    // If the context is canceled the function will return the error,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
  9. cmd/bucket-lifecycle.go

    				if !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !xnet.IsNetworkOrHostDown(err, false) {
    					if !strings.Contains(err.Error(), "use of closed network connection") {
    						transitionLogIf(t.ctx, fmt.Errorf("Transition to %s failed for %s/%s version:%s with %w",
    							task.event.StorageClass, task.objInfo.Bucket, task.objInfo.Name, task.objInfo.VersionID, err))
    					}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        val out = stream.sink.buffer()
        source.close()
        assertFailsWith<IOException> {
          source.read(Buffer(), 1)
        }.also { expected ->
          assertThat(expected.message).isEqualTo("stream closed")
        }
        assertFailsWith<IOException> {
          out.writeUtf8("a")
          out.flush()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("stream finished")
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
Back to Top