private int checkSessionEnd()

in grpc/syneroex/src/main/java/deltix/ember/connector/grpc/syneroex/session/Session.java [317:330]

• 12 lines of code
• 7 McCabe index (conditional complexity)

    private int checkSessionEnd(@Timestamp final long now) {
        int work = 0;

        final long end = schedule.getEndTime(state.sessionStartTime());
        if (!keepSessionAlive || !enabled || now >= end || closing) {
            final SessionStatus status = state.status();
            if (status != SessionStatus.DISCONNECTED && status != SessionStatus.UNSUBSCRIBE_SENT) {
                disconnect("Session end");
                work += 1;
            }
        }

        return work;
    }