| /dports/net/norm/norm-1.5r6/src/pynorm/ |
| H A D | node.py | 41 grtt = libnorm.NormNodeGetGrtt(self)
42 if grtt == -1.0:
44 return grtt
58 grtt = property(getGrtt) variable in Node
|
| H A D | session.py | 107 libnorm.NormSetGrttEstimate(self, grtt)
190 grtt = property(getGrttEstimate, setGrttEstimate) variable in Session
|
| /dports/ftp/uftp/uftp-5.0/ |
| H A D | proxy_loop.c | 260 new_grtt = unquantize_grtt(header->grtt); in mainloop()
261 if (fabs(new_grtt - group->grtt) > 0.001) { in mainloop()
262 group->grtt = new_grtt; in mainloop()
266 glog4(group, "grtt: %.3f", group->grtt); in mainloop()
277 new_grtt = unquantize_grtt(header->grtt); in mainloop()
278 if (fabs(new_grtt - group->grtt) > 0.001) { in mainloop()
279 group->grtt = new_grtt; in mainloop()
283 glog4(group, "grtt: %.3f", group->grtt); in mainloop()
|
| H A D | server_phase.c | 267 add_timeval_d(&next_send, 3 * grtt); in announce_phase()
306 add_timeval_d(&next_send, 3 * grtt); in announce_phase()
344 add_timeval_d(&next_send, grtt); in announce_phase()
958 if (adv_grtt < grtt) { in transfer_receive_thread()
959 adv_grtt = grtt; in transfer_receive_thread()
1167 if (adv_grtt < grtt) { in transfer_phase()
1168 adv_grtt = grtt; in transfer_phase()
1182 adv_grtt = grtt; in transfer_phase()
1330 add_timeval_d(&next_send, 3 * grtt); in completion_phase()
1359 add_timeval_d(&next_send, 3 * grtt); in completion_phase()
[all …]
|
| H A D | server_common.c | 63 header->grtt = quantize_grtt(l_grtt); in set_uftp_header()
84 grtt, destcount); in send_abort()
428 if (grtt_set && (new_grtt < 0.9 * grtt)) { in recalculate_grtt()
429 grtt = 0.9 * grtt; in recalculate_grtt()
431 grtt = new_grtt; in recalculate_grtt()
433 glog3(finfo, "grtt = %.6f", grtt); in recalculate_grtt()
|
| H A D | server_transfer.c | 74 grtt, destcount); in send_doneconf()
380 if (destlist[hostidx].rtt > grtt) { in handle_tfmcc_ack_info()
381 grtt = destlist[hostidx].rtt; in handle_tfmcc_ack_info()
388 rate_1grtt = (int64_t)(datapacketsize / grtt); in handle_tfmcc_ack_info()
406 if (rate < (int64_t)(datapacketsize / grtt)) { in handle_tfmcc_ack_info()
408 rate = (int64_t)(datapacketsize / grtt); in handle_tfmcc_ack_info()
433 if (rate < (int64_t)(datapacketsize / grtt)) { in handle_tfmcc_ack_info()
435 rate = (int64_t)(datapacketsize / grtt); in handle_tfmcc_ack_info()
449 if (l_adv_grtt < grtt) { in handle_tfmcc_ack_info()
450 l_adv_grtt = grtt; in handle_tfmcc_ack_info()
|
| H A D | client_common.c | 596 add_timeval_d(&group->timeout_time, 5 * group->grtt); in set_timeout()
600 if (group->robust * group->grtt < 1.0) { in set_timeout()
603 add_timeval_d(&group->timeout_time, group->robust * group->grtt); in set_timeout()
607 add_timeval_d(&group->timeout_time, 4 * group->grtt); in set_timeout()
1074 grtt_usec = (int)(group->grtt * 1000000);
1080 rate = (int)(bytes / group->grtt);
1089 (rate * ((group->rtt != 0) ? group->rtt : group->grtt)) /
1131 grtt_usec = (int)(group->grtt * 1000000);
1234 rtt = group->grtt;
1239 thresh = (int)(group->grtt * 1000000 * 4);
[all …]
|
| H A D | server_config.c | 83 double grtt, min_grtt, max_grtt; variable
198 grtt = DEF_GRTT; in set_defaults()
739 grtt = atof(p); in process_args()
743 } else if ((grtt < CLIENT_RTT_MIN) || (grtt > 1000)) { in process_args()
775 } else if ((grtt > max_grtt) || (grtt < min_grtt)) { in process_args()
|
| H A D | client_loop.c | 343 new_grtt = unquantize_grtt(header->grtt); in mainloop()
344 if (fabs(new_grtt - group->grtt) > 0.001) { in mainloop()
345 group->grtt = new_grtt; in mainloop()
349 glog5(group, "grtt: %.3f", group->grtt); in mainloop()
|
| H A D | client_transfer.c | 618 backoff = 6 * group->grtt * (1 + log(urand) / log(group->gsize)); in init_tfmcc_fb_round()
642 (group->grtt > group->rtt)) { in handle_tfmcc_data_info()
731 add_timeval_d(&group->fileinfo.nak_time, 1 * group->grtt); in handle_fileseg()
944 if (4 * group->robust * group->grtt < 1.0) { in handle_done()
948 4 * group->robust * group->grtt); in handle_done()
969 group->grtt); in handle_done()
970 add_timeval_d(&group->fileinfo.nak_time, 1 * group->grtt); in handle_done()
987 add_timeval_d(&group->fileinfo.nak_time, 1 * group->grtt); in handle_done()
1096 (group->grtt > group->rtt)) { in handle_cong_ctrl()
|
| H A D | proxy_common.c | 183 header->grtt = quantize_grtt(group->grtt); in set_uftp_header()
202 add_timeval_d(&group->phase_timeout_time, 2 * group->grtt); in set_timeout()
219 add_timeval_d(&group->timeout_time, 1 * group->grtt); in set_timeout()
226 if (group->robust * group->grtt < 1.0) { in set_timeout()
229 add_timeval_d(&group->timeout_time, group->robust * group->grtt); in set_timeout()
935 header->grtt = quantize_grtt(group->grtt); in send_downstream_abort()
|
| H A D | server.h | 187 extern double grtt, min_grtt, max_grtt;
|
| H A D | client.h | 147 double rtt, grtt; /// Client's RTT and server's GRTT member
|
| H A D | proxy.h | 128 double grtt; /// Server's GRTT member
|
| H A D | server_announce.c | 148 grtt, destcount); in send_announce()
237 grtt, destcount); in send_regconf()
278 grtt, destcount); in send_keyinfo()
412 grtt, destcount); in send_fileinfo()
|
| H A D | client_announce.c | 817 group->grtt = unquantize_grtt(header->grtt); in read_announce()
908 if (5 * group->robust * group->grtt < 1.0) { in read_announce()
911 add_timeval_d(&group->expire_time, 5 * group->robust * group->grtt); in read_announce()
1016 glog3(group, "grtt = %.6f", group->grtt); in handle_announce()
|
| H A D | proxy_upstream.c | 365 group->grtt = unquantize_grtt(header->grtt); in read_announce()
426 if (group->robust * group->grtt < 1.0) { in read_announce()
429 add_timeval_d(&group->phase_expire_time, group->robust * group->grtt); in read_announce()
|
| /dports/net-mgmt/argus3-clients/argus-clients-3.0.8.3/include/ |
| H A D | argus_mdp.h | 135 unsigned char grtt; member
196 unsigned char grtt; member
|
| /dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rmt-norm.c | 221 double grtt; in dissect_grrtetc() local
224 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_grrtetc()
225 proto_tree_add_double(tree, hf_grtt, tvb, offset, 1, grtt); offset += 1; in dissect_grrtetc()
429 double grtt; in dissect_norm_cmd_cc() local
440 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_norm_cmd_cc()
441 proto_tree_add_double(cc_tree, hf_cc_rtt, tvb, offset, 1, grtt); offset += 1; in dissect_norm_cmd_cc()
442 grtt = rmt_decode_send_rate(tvb_get_ntohs(tvb, offset)); in dissect_norm_cmd_cc()
443 proto_tree_add_double(cc_tree, hf_cc_rate, tvb, offset, 2, grtt); offset += 2; in dissect_norm_cmd_cc()
|
| /dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rmt-norm.c | 221 double grtt;
224 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset));
225 proto_tree_add_double(tree, hf_grtt, tvb, offset, 1, grtt); offset += 1;
429 double grtt;
440 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset));
441 proto_tree_add_double(cc_tree, hf_cc_rtt, tvb, offset, 1, grtt); offset += 1;
442 grtt = rmt_decode_send_rate(tvb_get_ntohs(tvb, offset));
443 proto_tree_add_double(cc_tree, hf_cc_rate, tvb, offset, 2, grtt); offset += 2;
|
| /dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rmt-norm.c | 221 double grtt; in dissect_grrtetc() local
224 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_grrtetc()
225 proto_tree_add_double(tree, hf_grtt, tvb, offset, 1, grtt); offset += 1; in dissect_grrtetc()
429 double grtt; in dissect_norm_cmd_cc() local
440 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_norm_cmd_cc()
441 proto_tree_add_double(cc_tree, hf_cc_rtt, tvb, offset, 1, grtt); offset += 1; in dissect_norm_cmd_cc()
442 grtt = rmt_decode_send_rate(tvb_get_ntohs(tvb, offset)); in dissect_norm_cmd_cc()
443 proto_tree_add_double(cc_tree, hf_cc_rate, tvb, offset, 2, grtt); offset += 2; in dissect_norm_cmd_cc()
|
| /dports/net/tshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-rmt-norm.c | 221 double grtt; in dissect_grrtetc() local
224 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_grrtetc()
225 proto_tree_add_double(tree, hf_grtt, tvb, offset, 1, grtt); offset += 1; in dissect_grrtetc()
429 double grtt; in dissect_norm_cmd_cc() local
440 grtt = UnquantizeRtt(tvb_get_guint8(tvb, offset)); in dissect_norm_cmd_cc()
441 proto_tree_add_double(cc_tree, hf_cc_rtt, tvb, offset, 1, grtt); offset += 1; in dissect_norm_cmd_cc()
442 grtt = rmt_decode_send_rate(tvb_get_ntohs(tvb, offset)); in dissect_norm_cmd_cc()
443 proto_tree_add_double(cc_tree, hf_cc_rate, tvb, offset, 2, grtt); offset += 2; in dissect_norm_cmd_cc()
|
| /dports/net/norm/norm-1.5r6/src/pynorm/extra/ |
| H A D | logparser.py | 32 self.grtt = None
78 rep.local.txrate, rep.local.sent_rate, rep.local.grtt = map(float,
|
| /dports/net/norm/norm-1.5r6/src/java/src/mil/navy/nrl/norm/ |
| H A D | NormSession.java | 114 public native void setGrttEstimate(double grtt); in setGrttEstimate() argument
|
| /dports/net/norm/norm-1.5r6/src/java/jni/ |
| H A D | normSessionJni.cpp | 307 (JNIEnv *env, jobject obj, jdouble grtt) { in PKGNAME()
312 NormSetGrttEstimate(session, grtt); in PKGNAME()
|