qdp 263 fs/gfs2/quota.c struct gfs2_quota_data **qdp) qdp 269 fs/gfs2/quota.c *qdp = qd = gfs2_qd_search_bucket(hash, sdp, qid); qdp 281 fs/gfs2/quota.c *qdp = qd = gfs2_qd_search_bucket(hash, sdp, qid); qdp 283 fs/gfs2/quota.c *qdp = new_qd; qdp 444 fs/gfs2/quota.c static int qd_fish(struct gfs2_sbd *sdp, struct gfs2_quota_data **qdp) qdp 450 fs/gfs2/quota.c *qdp = NULL; qdp 479 fs/gfs2/quota.c *qdp = qd; qdp 495 fs/gfs2/quota.c struct gfs2_quota_data **qdp) qdp 499 fs/gfs2/quota.c error = qd_get(sdp, qid, qdp); qdp 503 fs/gfs2/quota.c error = slot_get(*qdp); qdp 507 fs/gfs2/quota.c error = bh_get(*qdp); qdp 514 fs/gfs2/quota.c slot_put(*qdp); qdp 516 fs/gfs2/quota.c qd_put(*qdp); qdp 65 samples/bpf/hbm_edt_kern.c struct hbm_vqueue *qdp; qdp 83 samples/bpf/hbm_edt_kern.c qdp = bpf_get_local_storage(&queue_state, 0); qdp 84 samples/bpf/hbm_edt_kern.c if (!qdp) qdp 86 samples/bpf/hbm_edt_kern.c if (qdp->lasttime == 0) qdp 87 samples/bpf/hbm_edt_kern.c hbm_init_edt_vqueue(qdp, 1024); qdp 92 samples/bpf/hbm_edt_kern.c bpf_spin_lock(&qdp->lock); qdp 93 samples/bpf/hbm_edt_kern.c delta = qdp->lasttime - curtime; qdp 97 samples/bpf/hbm_edt_kern.c qdp->lasttime = curtime - BURST_SIZE_NS; qdp 100 samples/bpf/hbm_edt_kern.c sendtime = qdp->lasttime; qdp 101 samples/bpf/hbm_edt_kern.c delta_send = BYTES_TO_NS(len, qdp->rate); qdp 102 samples/bpf/hbm_edt_kern.c __sync_add_and_fetch(&(qdp->lasttime), delta_send); qdp 103 samples/bpf/hbm_edt_kern.c bpf_spin_unlock(&qdp->lock); qdp 110 samples/bpf/hbm_edt_kern.c if (qsp != NULL && (qsp->rate * 128) != qdp->rate) qdp 111 samples/bpf/hbm_edt_kern.c qdp->rate = qsp->rate * 128; qdp 160 samples/bpf/hbm_edt_kern.c __sync_add_and_fetch(&(qdp->lasttime), -delta_send); qdp 140 samples/bpf/hbm_kern.h static __always_inline void hbm_init_vqueue(struct hbm_vqueue *qdp, int rate) qdp 143 samples/bpf/hbm_kern.h qdp->lasttime = bpf_ktime_get_ns(); qdp 144 samples/bpf/hbm_kern.h qdp->credit = INIT_CREDIT; qdp 145 samples/bpf/hbm_kern.h qdp->rate = rate * 128; qdp 148 samples/bpf/hbm_kern.h static __always_inline void hbm_init_edt_vqueue(struct hbm_vqueue *qdp, qdp 155 samples/bpf/hbm_kern.h qdp->lasttime = curtime - BURST_SIZE_NS; // support initial burst qdp 156 samples/bpf/hbm_kern.h qdp->credit = 0; // not used qdp 157 samples/bpf/hbm_kern.h qdp->rate = rate * 128; qdp 71 samples/bpf/hbm_out_kern.c struct hbm_vqueue *qdp; qdp 85 samples/bpf/hbm_out_kern.c qdp = bpf_get_local_storage(&queue_state, 0); qdp 86 samples/bpf/hbm_out_kern.c if (!qdp) qdp 88 samples/bpf/hbm_out_kern.c else if (qdp->lasttime == 0) qdp 89 samples/bpf/hbm_out_kern.c hbm_init_vqueue(qdp, 1024); qdp 94 samples/bpf/hbm_out_kern.c bpf_spin_lock(&qdp->lock); qdp 95 samples/bpf/hbm_out_kern.c credit = qdp->credit; qdp 96 samples/bpf/hbm_out_kern.c delta = curtime - qdp->lasttime; qdp 102 samples/bpf/hbm_out_kern.c qdp->lasttime = curtime; qdp 103 samples/bpf/hbm_out_kern.c new_credit = credit + CREDIT_PER_NS(delta, qdp->rate); qdp 110 samples/bpf/hbm_out_kern.c qdp->credit = credit; qdp 111 samples/bpf/hbm_out_kern.c bpf_spin_unlock(&qdp->lock); qdp 115 samples/bpf/hbm_out_kern.c if (qsp != NULL && (qsp->rate * 128) != qdp->rate) { qdp 116 samples/bpf/hbm_out_kern.c qdp->rate = qsp->rate * 128; qdp 118 samples/bpf/hbm_out_kern.c (int)qdp->rate, qdp 119 samples/bpf/hbm_out_kern.c CREDIT_PER_NS(1000000000, qdp->rate) * 8); qdp 171 samples/bpf/hbm_out_kern.c __sync_add_and_fetch(&(qdp->credit), len);