451 uint64_t prev_deficit;
473 deficit = need < 0 ? 0 : need;
474 if (deficit > prev_deficit)
476 deficit - prev_deficit;
uint64_t nqs_num_f_events
m0_bcount_t ntm_recv_queue_min_recv_size
uint32_t ntm_recv_queue_min_length
M0_INTERNAL void m0_mutex_unlock(struct m0_mutex *mutex)
struct m0_net_buffer_pool * nb_pool
M0_INTERNAL bool m0_mutex_is_not_locked(const struct m0_mutex *mutex)
M0_INTERNAL struct m0_net_buffer * m0_net_buffer_pool_get(struct m0_net_buffer_pool *pool, uint32_t colour)
M0_INTERNAL void m0_net_buffer_pool_unlock(struct m0_net_buffer_pool *pool)
struct m0_net_qstats ntm_qstats[M0_NET_QT_NR]
enum m0_net_tm_state ntm_state
m0_bcount_t nb_min_receive_size
M0_INTERNAL void m0_mutex_lock(struct m0_mutex *mutex)
M0_INTERNAL void m0_net_domain_buffer_pool_not_empty(struct m0_net_buffer_pool *pool)
M0_INTERNAL void m0_net__tm_provision_recv_q(struct m0_net_transfer_mc *tm)
const struct m0_net_buffer_callbacks * ntm_recv_pool_callbacks
M0_INTERNAL int m0_net__tm_provision_buf(struct m0_net_transfer_mc *tm)
M0_INTERNAL bool m0_net_buffer_pool_is_locked(const struct m0_net_buffer_pool *pool)
enum m0_net_queue_type nb_qtype
uint32_t ntm_recv_queue_max_recv_msgs
static void tm_provision_recv_q(struct m0_net_transfer_mc *tm)
uint32_t nb_max_receive_msgs
#define m0_list_for_each_entry(head, pos, type, member)
M0_INTERNAL bool m0_mutex_is_locked(const struct m0_mutex *mutex)
M0_INTERNAL bool m0_net_buffer_pool_is_not_locked(const struct m0_net_buffer_pool *pool)
static struct m0_stob_domain * dom
struct m0_atomic64 ntm_recv_queue_deficit
M0_INTERNAL void m0_net_buffer_pool_lock(struct m0_net_buffer_pool *pool)
uint32_t ntm_callback_counter
struct m0_list_link ntm_dom_linkage
const struct m0_net_buffer_callbacks * nb_callbacks
struct m0_tl ntm_q[M0_NET_QT_NR]
static struct m0_pool pool
static int64_t m0_atomic64_get(const struct m0_atomic64 *a)
M0_INTERNAL int m0_net__buffer_add(struct m0_net_buffer *buf, struct m0_net_transfer_mc *tm)
M0_INTERNAL bool m0_net__tm_invariant(const struct m0_net_transfer_mc *tm)
static void m0_atomic64_set(struct m0_atomic64 *a, int64_t num)
struct m0_net_end_point * nb_ep
struct m0_net_buffer_pool * ntm_recv_pool