external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

Refactor stat for frames

Browse source
This commit is contained in:
winlin 2020-04-14 14:22:30 +08:00
parent 7574dbefb1
commit ba3d293bfd
2 changed files with 41 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

6
trunk/src/app/srs_app_http_api.cpp
View file

@ -1622,12 +1622,12 @@ srs_error_t SrsGoApiPerf::serve_http(ISrsHttpResponseWriter* w, ISrsHttpMessage*
data->set("query", p); data->set("query", p);
p->set("target", SrsJsonAny::str(target.c_str())); p->set("target", SrsJsonAny::str(target.c_str()));
p->set("help", SrsJsonAny::str("?target=writev|sendmmsg|gso")); p->set("help", SrsJsonAny::str("?target=frames|sendmmsg|gso"));
} }
if (target.empty() || target == "writev") { if (target.empty() || target == "frames") {
SrsJsonObject* p = SrsJsonAny::object(); SrsJsonObject* p = SrsJsonAny::object();
data->set("writev", p); data->set("frames", p);
if ((err = stat->dumps_perf_writev(p)) != srs_success) { if ((err = stat->dumps_perf_writev(p)) != srs_success) {
int code = srs_error_code(err); srs_error_reset(err); int code = srs_error_code(err); srs_error_reset(err);
return srs_api_response_code(w, r, code); return srs_api_response_code(w, r, code);

76
trunk/src/app/srs_app_statistic.cpp
View file

@ -621,33 +621,33 @@ void SrsStatistic::perf_mw_on_msgs(int nb_msgs, int bytes_msgs, int nb_iovs)
} }
// For perf iovs, the nb_iovs stat. // For perf iovs, the nb_iovs stat.
// a: <=2 // a: <3
// b: <10 // b: <5
// c: <20 // c: <9
// d: <200 // d: <16
// e: <300 // e: <32
// f: <500 // f: <64
// g: <700 // g: <128
// h: <900 // h: <256
// i: <1024 // i: <1000
// j: >=1024 // j: >=1000
if (nb_iovs <= 2) { if (nb_iovs < 3) {
perf_iovs->a++; perf_iovs->a++;
} else if (nb_iovs < 10) { } else if (nb_iovs < 5) {
perf_iovs->b++; perf_iovs->b++;
} else if (nb_iovs < 20) { } else if (nb_iovs < 9) {
perf_iovs->c++; perf_iovs->c++;
} else if (nb_iovs < 200) { } else if (nb_iovs < 16) {
perf_iovs->d++; perf_iovs->d++;
} else if (nb_iovs < 300) { } else if (nb_iovs < 32) {
perf_iovs->e++; perf_iovs->e++;
} else if (nb_iovs < 500) { } else if (nb_iovs < 64) {
perf_iovs->f++; perf_iovs->f++;
} else if (nb_iovs < 700) { } else if (nb_iovs < 128) {
perf_iovs->g++; perf_iovs->g++;
} else if (nb_iovs < 900) { } else if (nb_iovs < 256) {
perf_iovs->h++; perf_iovs->h++;
} else if (nb_iovs < 1024) { } else if (nb_iovs < 1000) {
perf_iovs->i++; perf_iovs->i++;
} else { } else {
perf_iovs->j++; perf_iovs->j++;
@ -690,26 +690,26 @@ srs_error_t SrsStatistic::dumps_perf_writev(SrsJsonObject* obj)
obj->set("iovs", p); obj->set("iovs", p);
// For perf iovs, the nb_iovs stat. // For perf iovs, the nb_iovs stat.
// a: <=2 // a: <3
// b: <10 // b: <5
// c: <20 // c: <9
// d: <200 // d: <16
// e: <300 // e: <32
// f: <500 // f: <64
// g: <700 // g: <128
// h: <900 // h: <256
// i: <1024 // i: <1000
// j: >=1024 // j: >=1000
if (perf_iovs->a) p->set("lt_3", SrsJsonAny::integer(perf_iovs->a)); if (perf_iovs->a) p->set("lt_3", SrsJsonAny::integer(perf_iovs->a));
if (perf_iovs->b) p->set("lt_10", SrsJsonAny::integer(perf_iovs->b)); if (perf_iovs->b) p->set("lt_5", SrsJsonAny::integer(perf_iovs->b));
if (perf_iovs->c) p->set("lt_20", SrsJsonAny::integer(perf_iovs->c)); if (perf_iovs->c) p->set("lt_9", SrsJsonAny::integer(perf_iovs->c));
if (perf_iovs->d) p->set("lt_200", SrsJsonAny::integer(perf_iovs->d)); if (perf_iovs->d) p->set("lt_16", SrsJsonAny::integer(perf_iovs->d));
if (perf_iovs->e) p->set("lt_300", SrsJsonAny::integer(perf_iovs->e)); if (perf_iovs->e) p->set("lt_32", SrsJsonAny::integer(perf_iovs->e));
if (perf_iovs->f) p->set("lt_500", SrsJsonAny::integer(perf_iovs->f)); if (perf_iovs->f) p->set("lt_64", SrsJsonAny::integer(perf_iovs->f));
if (perf_iovs->g) p->set("lt_700", SrsJsonAny::integer(perf_iovs->g)); if (perf_iovs->g) p->set("lt_128", SrsJsonAny::integer(perf_iovs->g));
if (perf_iovs->h) p->set("lt_900", SrsJsonAny::integer(perf_iovs->h)); if (perf_iovs->h) p->set("lt_256", SrsJsonAny::integer(perf_iovs->h));
if (perf_iovs->i) p->set("lt_1024", SrsJsonAny::integer(perf_iovs->i)); if (perf_iovs->i) p->set("lt_1000", SrsJsonAny::integer(perf_iovs->i));
if (perf_iovs->j) p->set("gt_1024", SrsJsonAny::integer(perf_iovs->j)); if (perf_iovs->j) p->set("gt_1000", SrsJsonAny::integer(perf_iovs->j));
} }
return err; return err;