Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 652 for lose (0.01 sec)

  1. src/main/java/jcifs/internal/smb1/com/SmbComFindClose2.java

     *
     * This command is used to close a search handle that was
     * opened by a Trans2 Find First2 request.
     */
    public class SmbComFindClose2 extends ServerMessageBlock {
    
        private final int sid;
    
        /**
         * Creates a new SMB1 find close request to close a search handle.
         *
         * @param config the CIFS configuration
         * @param sid the search identifier to close
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketReaderTest.kt

        }
      }
    
      @Test fun closeReservedSetThrows() {
        data.write("880203ec".decodeHex()) // Close with code 1004
        data.write("880203ed".decodeHex()) // Close with code 1005
        data.write("880203ee".decodeHex()) // Close with code 1006
        for (i in 1015..2999) {
          data.write(("8802" + format("%04X", i)).decodeHex()) // Close with code 'i'
        }
        var count = 0
        while (!data.exhausted()) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. samples/slack/src/main/java/okhttp3/slack/RtmSession.java

        webSocket.close(1000, null);
        System.out.println("onClose (" + code + "): " + reason);
      }
    
      @Override public void onFailure(WebSocket webSocket, Throwable t, Response response) {
        // TODO(jwilson): can I read the response body? Do I have to?
        System.out.println("onFailure " + response);
      }
    
      @Override public void close() throws IOException {
        if (webSocket == null) return;
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Nov 19 20:16:58 UTC 2016
    - 2.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionListenerTest.kt

        server!!.enqueue(MockResponse())
        server!!.enqueue(MockResponse())
    
        client
          .newCall(Request(server!!.url("/")))
          .execute()
          .close()
    
        client
          .newCall(Request(server!!.url("/")))
          .execute()
          .close()
    
        assertThat(listener.recordedEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java

                closeableContext.close(); // Second call
                closeableContext.close(); // Third call
            });
        }
    
        @Test
        @DisplayName("Should maintain key isolation between instances")
        void testKeyIsolationBetweenInstances() {
            // Given
            byte[] key1 = new byte[16];
            byte[] key2 = new byte[16];
            new SecureRandom().nextBytes(key1);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 44.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ForwardingExecutorServiceTest.java

              @Override
              public void close() {
                throw new AssertionError(
                    "ForwardingExecutorService should have used the default method"
                        + " ExecutorService.close() (which would forward to methods like shutdown() on"
                        + " the delegate) instead of forwarding to delegate.close()");
              }
            };
        ExecutorService wrapper =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 18:45:52 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbPipeInputStreamTest.java

            InOrder inOrder = inOrder(handle, fd, tree);
            inOrder.verify(handle, times(1)).ensureOpen();
            inOrder.verify(fd, times(1)).getTree();
            inOrder.verify(tree, times(1)).send(any(Smb2IoctlRequest.class), eq(RequestParam.NO_RETRY));
            verify(fd, times(1)).close();
            verify(tree, times(1)).close();
        }
    
        @ParameterizedTest
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/io/CopyUtil.java

                try {
                    return copyInternal(is, os);
                } finally {
                    CloseableUtil.close(os);
                }
            } finally {
                CloseableUtil.close(is);
            }
        }
    
        /**
         * Copies from a file with the specified encoding to a file with the platform default encoding.
         *
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  9. docs/smb3-features/05-rdma-smb-direct-design.md

            RdmaMemoryRegion region;
            
            while ((region = availableSendRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
            
            while ((region = availableReceiveRegions.poll()) != null) {
                region.close();
                totalReleased.incrementAndGet();
            }
        }
        
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/dict/protwords/ProtwordsFileTest.java

                                return new FileInputStream(testFile);
                            }
    
                            @Override
                            public void close() throws IOException {
                                // Nothing to close
                            }
                        };
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 20.8K bytes
    - Viewed (0)
Back to top