diff options
author | mrfoxygmfr <mrfoxygmfr@sch9.ru> | 2025-05-22 23:41:29 +0300 |
---|---|---|
committer | mrfoxygmfr <mrfoxygmfr@sch9.ru> | 2025-05-22 23:41:29 +0300 |
commit | 5b2a6d3eae55ed2b45e6a5f12cd20ac5536e7692 (patch) | |
tree | ee0b6264f7dd29fcdd8e565f33282e108246c78a /worker.c | |
parent | 9c5ef0efeb0b6d1ad731958d48f3829f3720c301 (diff) |
feat(lib): faster protocol
now worker request 10 tasks in one request
Diffstat (limited to 'worker.c')
-rw-r--r-- | worker.c | 5 |
1 files changed, 3 insertions, 2 deletions
@@ -49,6 +49,7 @@ long double calculate_integral(func_t f, long double a, long double b, long doub x += 2 * delta; } + usleep(20000); // it's a very long task... long double prev_sum = (sum_by_1 + 2 * sum_by_2 + 4 * sum_by_4) * delta / 3; long double sum = prev_sum; @@ -74,7 +75,7 @@ long double calculate_integral(func_t f, long double a, long double b, long doub void worker_func(const char* task, size_t task_size, char** resp, size_t* resp_size) { long double* args = (long double*) task; - task_size = task_size * 2; + (void) task_size; long double res = calculate_integral(func, args[0], args[1], args[2]); printf("task %Lf %Lf -> %Lf\n", args[0], args[1], res); @@ -86,6 +87,6 @@ void worker_func(const char* task, size_t task_size, char** resp, size_t* resp_s int32_t main() { worker_init("127.0.0.1", "33554", 1, worker_func); - configure_timeout(10); + configure_timeout(100); worker_exec(); } |