Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,049 for closes (0.04 sec)

  1. 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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java

        assertFalse(rangeSet.intersects(Range.greaterThan(8)));
    
        assertTrue(rangeSet.encloses(Range.closed(1, 2)));
        assertTrue(rangeSet.encloses(Range.open(5, 8)));
        assertFalse(rangeSet.encloses(Range.closed(1, 8)));
        assertFalse(rangeSet.encloses(Range.greaterThan(5)));
    
        RangeSet<Integer> expectedComplement =
            ImmutableRangeSet.<Integer>builder()
                .add(Range.lessThan(1))
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Jan 25 16:19:30 UTC 2025
    - 21.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    	reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts)
    	if err != nil {
    		return nil, err
    	}
    	closer := func() {
    		timeTierAction(reader.Close())
    	}
    	return fn(reader, h, closer)
    }
    
    // RestoreRequestType represents type of restore.
    type RestoreRequestType string
    
    const (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetNavigationTester.java

        testEmptyRangeSubMultiset(
            sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), OPEN));
        testEmptyRangeSubMultiset(
            sortedMultiset.subMultiset(a.getElement(), OPEN, a.getElement(), CLOSED));
        testEmptyRangeSubMultiset(
            sortedMultiset.subMultiset(b.getElement(), CLOSED, a.getElement(), CLOSED));
        testEmptyRangeSubMultiset(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 20:14:36 UTC 2024
    - 26K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

       */
      private fun planReuseCallConnection(): ReusePlan? {
        // This may be mutated by releaseConnectionNoEvents()!
        val candidate = connectionUser.candidateConnection() ?: return null
    
        // Make sure this connection is healthy & eligible for new exchanges. If it's no longer needed
        // then we're on the hook to close it.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbRandomAccessFile.java

            try (SmbFileHandleImpl fh = ensureOpen()) {}
        }
    
        @Override
        public synchronized void close() throws SmbException {
            try {
                if (this.handle != null) {
                    try {
                        this.handle.close();
                    } catch (final CIFSException e) {
                        throw SmbException.wrap(e);
                    }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb1/smb1/SmbComCloseTest.java

        void testReadWriteMethodsReturnValues() {
            SmbComClose close = new SmbComClose(10, 5000L);
            assertEquals(0, close.readParameterWordsWireFormat(new byte[10], 0));
            assertEquals(0, close.readBytesWireFormat(new byte[10], 0));
            assertEquals(0, close.writeBytesWireFormat(new byte[10], 0));
            assertEquals(6, close.writeParameterWordsWireFormat(new byte[10], 0));
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  8. src/test/java/jcifs/SmbFileHandleTest.java

            doThrow(new CIFSException("Failed to close")).when(smbFileHandle).close(lastWriteTime);
            assertThrows(CIFSException.class, () -> smbFileHandle.close(lastWriteTime),
                    "close(long) should throw CIFSException when closing fails.");
            verify(smbFileHandle, times(1)).close(lastWriteTime);
        }
    
        /**
         * Test close() successfully.
         *
         * @throws CIFSException
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/SmbTreeTest.java

            doNothing().when(smbTree).close();
            doNothing().when(customTree).close();
    
            // Unwrap then close both
            CustomSmbTree unwrapped = smbTree.unwrap(CustomSmbTree.class);
            smbTree.close();
            unwrapped.close();
    
            verify(smbTree).unwrap(CustomSmbTree.class);
            verify(smbTree).close();
            verify(customTree).close();
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/BoundType.java

     * ("open"). If a range is unbounded on a side, it is neither open nor closed on that side; the
     * bound simply does not exist.
     *
     * @since 10.0
     */
    @GwtCompatible
    public enum BoundType {
      /** The endpoint value <i>is not</i> considered part of the set ("exclusive"). */
      OPEN(false),
      CLOSED(true);
    
      final boolean inclusive;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top