OpenMPI
0.1.1
|
Public Member Functions | |
TAILQ_HEAD (rlim_group_member_list, bufferevent_private) members | |
List of all members in the group. | |
Data Fields | |
struct ev_token_bucket | rate_limit |
Current limits for the group. More... | |
struct ev_token_bucket_cfg | rate_limit_cfg |
unsigned | read_suspended: 1 |
True iff we don't want to read from any member of the group.until the token bucket refills. More... | |
unsigned | write_suspended: 1 |
True iff we don't want to write from any member of the group.until the token bucket refills. More... | |
unsigned | pending_unsuspend_read: 1 |
True iff we were unable to suspend one of the bufferevents in the group for reading the last time we tried, and we should try again. More... | |
unsigned | pending_unsuspend_write: 1 |
True iff we were unable to suspend one of the bufferevents in the group for writing the last time we tried, and we should try again. More... | |
int | n_members |
The number of bufferevents in the group. More... | |
ev_ssize_t | min_share |
The smallest number of bytes that any member of the group should be limited to read or write at a time. More... | |
struct event | master_refill_event |
Timeout event that goes off once a tick, when the bucket is ready to refill. More... | |
void * | lock |
Lock to protect the members of this group. More... | |
ev_uint64_t | total_read |
Total number of bytes read or written in this group since last reset. More... | |
ev_uint64_t | total_written |
void* bufferevent_rate_limit_group::lock |
Lock to protect the members of this group.
This lock should nest within every bufferevent lock: if you are holding this lock, do not assume you can lock another bufferevent.
Referenced by bufferevent_rate_limit_group_free(), and bufferevent_rate_limit_group_new().
struct event bufferevent_rate_limit_group::master_refill_event |
Timeout event that goes off once a tick, when the bucket is ready to refill.
Referenced by bufferevent_rate_limit_group_free(), bufferevent_rate_limit_group_new(), and bufferevent_rate_limit_group_set_cfg().
ev_ssize_t bufferevent_rate_limit_group::min_share |
The smallest number of bytes that any member of the group should be limited to read or write at a time.
Referenced by bufferevent_rate_limit_group_new(), and bufferevent_rate_limit_group_set_min_share().
int bufferevent_rate_limit_group::n_members |
The number of bufferevents in the group.
Referenced by bufferevent_add_to_rate_limit_group(), and bufferevent_rate_limit_group_free().
unsigned bufferevent_rate_limit_group::pending_unsuspend_read |
True iff we were unable to suspend one of the bufferevents in the group for reading the last time we tried, and we should try again.
unsigned bufferevent_rate_limit_group::pending_unsuspend_write |
True iff we were unable to suspend one of the bufferevents in the group for writing the last time we tried, and we should try again.
struct ev_token_bucket bufferevent_rate_limit_group::rate_limit |
Current limits for the group.
Referenced by bufferevent_rate_limit_group_new(), and bufferevent_rate_limit_group_set_cfg().
unsigned bufferevent_rate_limit_group::read_suspended |
True iff we don't want to read from any member of the group.until the token bucket refills.
Referenced by bufferevent_add_to_rate_limit_group().
ev_uint64_t bufferevent_rate_limit_group::total_read |
Total number of bytes read or written in this group since last reset.
Referenced by bufferevent_rate_limit_group_get_totals(), and bufferevent_rate_limit_group_reset_totals().
unsigned bufferevent_rate_limit_group::write_suspended |
True iff we don't want to write from any member of the group.until the token bucket refills.
Referenced by bufferevent_add_to_rate_limit_group().