isOpen - Code Search

src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

        if (len <= 0) {
            return 0;
        }
        final long start = fp;

        // ensure file is open
        if (!file.isOpen()) {
            file.open(openFlags, 0, SmbFile.ATTR_NORMAL, options);
        }

        int r, n;
        final SmbComReadAndXResponse response = new SmbComReadAndXResponse(b, off);
        do {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 14.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/taglib/FessFunctions.java

    /**
     * Generates an HTML opening or closing tag with appropriate language attribute.
     *
     * @param isOpen true to generate opening HTML tag, false for closing tag
     * @return HTML opening tag with language attribute or closing tag
     */
    public static String html(final boolean isOpen) {
        if (isOpen) {
            return "<html lang=\"" + LaRequestUtil.getOptionalRequest().map(req -> {

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Aug 07 03:06:29 UTC 2025

- 25.3K bytes

- Viewed (1)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbFileOutputStream.java

        write(b, 0, b.length);
    }

    /**
     * Tests whether the output stream is currently open.
     *
     * @return whether the stream is open
     */
    public boolean isOpen() {
        return this.handle != null && this.handle.isValid();
    }

    /**
     * Ensures that the file handle is open and returns it.
     *
     * @return the open file handle

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 12.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

   *
   * Note that the input stream may continue to yield data even after a stream reports itself as
   * not open. This is because input data is buffered.
   */
  val isOpen: Boolean
    get() {
      withLock {
        if (errorCode != null) {
          return false
        }
        if ((source.finished || source.closed) &&
          (sink.finished || sink.closed) &&

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Mon Jul 07 18:57:05 UTC 2025

- 22.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/SmbPipeHandle.java

     */
    @Override
    void close() throws CIFSException;

    /**
     * Tests whether this file descriptor is open and valid.
     *
     * @return whether the FD is open and valid
     */
    boolean isOpen();

    /**
     * Tests whether this file descriptor was previously open but has become invalid.
     *
     * @return whether the FD was previously open but became invalid
     */
    boolean isStale();

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 2.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

                  override fun peek() = exchange.peekTrailers()

                  override fun get(): Headers {
                    val source = responseBody.source()
                    if (source.isOpen) {
                      source.skipAll()
                    }
                    return peek() ?: error("null trailers after exhausting response body?!")
                  }
                },

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Tue Jul 29 22:04:11 UTC 2025

- 7.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbTree.java

     */
    int connectionState;
    int tid;

    String share;
    String service = "?????";
    String service0;
    SmbSession session;
    boolean inDfs, inDomainDfs;
    int tree_num; // used by SmbFile.isOpen

    SmbTree(final SmbSession session, final String share, final String service) {
        this.session = session;
        this.share = share.toUpperCase();
        if (service != null && !service.startsWith("??")) {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 8.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/DcerpcPipeHandle.java

    }

    @Override
    protected void doSendFragment(final byte[] buf, final int off, final int length, final boolean isDirect) throws IOException {
        if (out != null && !out.isOpen()) {
            throw new IOException("DCERPC pipe is no longer open");
        }

        if (in == null) {
            in = (SmbFileInputStream) pipe.getNamedPipeInputStream();
        }
        if (out == null) {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 4.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

        return response;
    }

    @Override
    public void reset() throws IOException {
        if (socketChannel != null && socketChannel.isOpen()) {
            socketChannel.close();
        }
        connect();
    }

    @Override
    public int read(ByteBuffer buffer, long remoteAddress, int remoteKey, int length) throws IOException {

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 23 05:11:12 UTC 2025

- 8.8K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        } else {
          writePing(false, INTERVAL_PING, 0)
          return@schedule pingIntervalNanos
        }
      }
    }
  }

  /**
   * Returns the number of [open streams][Http2Stream.isOpen] on this connection.
   */
  fun openStreamCount(): Int = withLock { streams.size }

  fun getStream(id: Int): Http2Stream? = withLock { streams[id] }

  internal fun removeStream(streamId: Int): Http2Stream? {

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Thu Jul 31 04:18:40 UTC 2025

- 31.8K bytes

- Viewed (0)

Search Options