From a04d4d01eb8e38b8ec5367114b5581bd64eee17e Mon Sep 17 00:00:00 2001 From: lichao <lichao@aiotlink.com> Date: 星期五, 23 四月 2021 15:44:12 +0800 Subject: [PATCH] mutex unlock check timeout to avoid double unlock. --- src/bh_api.h | 22 +++++++++++++--------- 1 files changed, 13 insertions(+), 9 deletions(-) diff --git a/src/bh_api.h b/src/bh_api.h index 2b3e15f..33a70cb 100644 --- a/src/bh_api.h +++ b/src/bh_api.h @@ -37,22 +37,22 @@ const int timeout_ms); typedef void (*FSubDataCallback)(const void *proc_id, - const int proc_id_len, + int proc_id_len, const void *data, - const int data_len); + int data_len); typedef void (*FServerCallback)(const void *proc_id, - const int proc_id_len, + int proc_id_len, const void *data, - const int data_len, + int data_len, void *src); typedef void (*FClientCallback)(const void *proc_id, - const int proc_id_len, + int proc_id_len, const void *msg_id, - const int msg_id_len, + int msg_id_len, const void *data, - const int data_len); + int data_len); void BHStartWorker(FServerCallback server_cb, FSubDataCallback sub_cb, FClientCallback client_cb); @@ -73,12 +73,16 @@ int *msgpub_len, const int timeout_ms); -int BHAsyncRequest(const void *request, +int BHAsyncRequest(const void *remote, + const int remote_len, + const void *request, const int request_len, void **msg_id, int *msg_id_len); -int BHRequest(const void *request, +int BHRequest(const void *remote, + const int remote_len, + const void *request, const int request_len, void **proc_id, int *proc_id_len, -- Gitblit v1.8.0