void refresh()

in src/main/java/org/apache/skywalking/banyandb/v1/client/grpc/channel/ChannelManager.java [93:105]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    void refresh() throws IOException {
        Entry entry = entryRef.get();
        if (entry.needReconnect) {
            if (entry.isConnected(entry.reconnectCount.incrementAndGet() > this.settings.forceReconnectionThreshold())) {
                // Reconnect to the same server is automatically done by GRPC
                // clear the flags
                entry.reset();
            } else {
                Entry replacedEntry = entryRef.getAndSet(new Entry(this.channelFactory.create()));
                replacedEntry.shutdown();
            }
        }
    }