Method get

tools/cdb2_sqlreplay/cdb2_sqlreplay.cpp:971–986

        return true;
    }
    cson_value *get() {
        int64_t min_timestamp = LLONG_MAX;
        int minix = -1;
        for (int i = 0; i < sources.size(); i++) {
            if (!sources[i].is_done()) {
                if (sources[i].timestamp < min_timestamp) {
                    minix = i;
                    min_timestamp = sources[i].timestamp;
                }
            }
        }
        cson_value *ret = sources[minix].consume();
        if (minix != -1)
            sources[minix].get();
        return ret;
    }

protected:
    std::vector<event_source> sources;