*
   * 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() {
      this.withLock {
        if (errorCode != null) {
          return false
        }
        if ((source.finished || source.closed) &&
          (sink.finished || sink.closed) &&

    }
    sink1.writeUtf8("def")
    sink1.close()
    assertFailsWith<ConnectionShutdownException> {
      connection.newStream(headerEntries("c", "cola"), true)
    }
    assertThat(stream1.isOpen).isTrue()
    assertThat(stream2.isOpen).isFalse()
    assertThat(connection.openStreamCount()).isEqualTo(1)

    // Verify the peer received what was expected.
    val synStream1 = peer.takeFrame()

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

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

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

    private volatile int tid = -1;
    private volatile String service = "?????";
    private volatile boolean inDfs, inDomainDfs;
    private volatile long treeNum; // used by SmbFile.isOpen

    private final AtomicLong usageCount = new AtomicLong(0);
    private final AtomicBoolean sessionAcquired = new AtomicBoolean(true);

    private final boolean traceResource;

        return f;
    }
    void open( int flags, int access, int attrs, int options ) throws SmbException {
        if( isOpen() ) {
            return;
        }
        fid = open0( flags, access, attrs, options );
        opened = true;
        tree_num = tree.tree_num;
    }
    boolean isOpen() {
        boolean ans = opened && isConnected() && tree_num == tree.tree_num;
        return ans;
    }

Collapse._getTargetFromElement(element),\n        [element]\n      )\n    })\n\n    return parent\n  }\n\n  _addAriaAndCollapsedClass(element, triggerArray) {\n    const isOpen = $(element).hasClass(CLASS_NAME_SHOW)\n\n    if (triggerArray.length) {\n      $(triggerArray)\n        .toggleClass(CLASS_NAME_COLLAPSED, !isOpen)\n        .attr('aria-expanded', isOpen)\n    }\n  }\n\n  // Static\n  static _getTargetFromElement(element) {\n    const selector = Util.getSelectorFromElement(element)\n    return selector ?...

${SELECTOR_TREEVIEW_MENU}`)\n      }\n\n      if (!treeviewMenu.is(SELECTOR_TREEVIEW_MENU)) {\n        return\n      }\n    }\n\n    event.preventDefault()\n\n    const parentLi = $relativeTarget.parents(SELECTOR_LI).first()\n    const isOpen = parentLi.hasClass(CLASS_NAME_OPEN)\n\n    if (isOpen) {\n      this.collapse($(treeviewMenu), parentLi)\n    } else {\n      this.expand($(treeviewMenu), parentLi)\n    }\n  }\n\n  // Private\n\n  _setupListeners() {\n    const elementId = this._element.attr('id') !== undefined...

HSPLokhttp3/internal/http2/Http2Stream;->getSink()Lokio/Sink;
HSPLokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z
HSPLokhttp3/internal/http2/Http2Stream;->isOpen()Z
HSPLokhttp3/internal/http2/Http2Stream;->receiveHeaders(Lokhttp3/Headers;Z)V
HSPLokhttp3/internal/http2/Http2Stream;->waitForIo$okhttp()V
HSPLokhttp3/internal/http2/Http2Writer;-><clinit>()V

import (
	"io"
	"io/fs"
	"os"

	"github.com/minio/minio/internal/disk"
)

var (
	// OpenFileDirectIO allows overriding default function.
	OpenFileDirectIO = disk.OpenFileDirectIO
	// OsOpen allows overriding default function.
	OsOpen = os.Open
	// OsOpenFile allows overriding default function.
	OsOpenFile = os.OpenFile
)

// ReadFileWithFileInfo reads the named file and returns the contents.

	// .... add more

	osMetricLast
)

var globalOSMetrics osMetrics

func init() {
	// Inject metrics.
	ioutilx.OsOpenFile = OpenFile
	ioutilx.OpenFileDirectIO = OpenFileDirectIO
	ioutilx.OsOpen = Open
}

type osMetrics struct {
	// All fields must be accessed atomically and aligned.
	operations [osMetricLast]uint64
	latency    [osMetricLast]lockedLastMinuteLatency
}

// time an os action.