Skip to content

make sender balancing smater #44

@wsky

Description

@wsky

#24

    protected int calculate(int pending) {
        if (!this.balancing)
            return this.maxFlushCount;
        //TODO make it smarter
        int flushCount = this.highwater / pending;
        if (flushCount > this.maxFlushCount)
            flushCount = this.maxFlushCount;
        if (flushCount < this.minFlushCount)
            flushCount = this.minFlushCount;
        return flushCount;
    }

Metadata

Metadata

Assignees

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions