| 496 | } |
| 497 | |
| 498 | static int main_dispatch_report(ACL_VSTREAM *conn) |
| 499 | { |
| 500 | char buf[256]; |
| 501 | |
| 502 | snprintf(buf, sizeof(buf), "count=%lld&used=%llu&pid=%u&type=%s" |
| 503 | "&max_threads=%d&curr_threads=%d&busy_threads=%d&qlen=0\r\n", |
| 504 | acl_atomic_clock_users(__clock), |
| 505 | (unsigned long long) acl_atomic_clock_count(__clock), |
| 506 | (unsigned) getpid(), acl_var_fiber_dispatch_type, 1, 1, 1); |
| 507 | |
| 508 | if (acl_vstream_writen(conn, buf, strlen(buf)) == ACL_VSTREAM_EOF) { |
| 509 | acl_msg_warn("%s(%d), %s: write to master_dispatch(%s) failed", |
| 510 | __FILE__, __LINE__, __FUNCTION__, |
| 511 | acl_var_fiber_dispatch_addr); |
| 512 | return -1; |
| 513 | } |
| 514 | |
| 515 | return 0; |
| 516 | } |
| 517 | |
| 518 | static void main_dispatch_poll(ACL_VSTREAM *conn) |
| 519 | { |
no test coverage detected
searching dependent graphs…