MCPcopy Create free account
hub / github.com/antirez/ds4 / dist_worker_handle_work

Function dist_worker_handle_work

ds4_distributed.c:7592–7609  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

7590 "ds4: dist decode profile: worker request=%llu pos=%u layers=%u:%u input_decode=%.3fms lock_wait=%.3fms eval=%.3fms send=%.3fms total=%.3fms input=%.2fMiB output=%.2fMiB rc=%d\n",
7591 (unsigned long long)request_id,
7592 work.pos0,
7593 work.layer_start,
7594 work.layer_end,
7595 (decode_t1 - decode_t0) * 1000.0,
7596 (lock_t1 - lock_t0) * 1000.0,
7597 (eval_t1 - eval_t0) * 1000.0,
7598 (send_t1 - send_t0) * 1000.0,
7599 (send_t1 - total_t0) * 1000.0,
7600 (double)(work.token_bytes + work.input_hc_bytes) / (1024.0 * 1024.0),
7601 (double)result_wire_bytes / (1024.0 * 1024.0),
7602 send_rc);
7603 }
7604 DIST_DEBUG("worker send complete request=%llu has_next=%d send_rc=%d",
7605 (unsigned long long)request_id,
7606 has_next ? 1 : 0,
7607 send_rc);
7608 if (!input_hc_uses_wire) free(input_hc);
7609 free(result);
7610 free(route_blob);
7611 free(tokens);
7612 return send_rc;

Callers 1

dist_worker_read_loopFunction · 0.85

Calls 4

dist_discard_bytesFunction · 0.85
dist_read_fullFunction · 0.85

Tested by

no test coverage detected