@@ -26,8 +26,6 @@ class BridgeClass {
2626
2727 struct k_mutex read_mutex;
2828 struct k_mutex write_mutex;
29- // struct k_mutex server_mutex;
30- // struct k_mutex client_mutex;
3129
3230 k_tid_t upd_tid;
3331 k_thread_stack_t *upd_stack_area;
@@ -46,8 +44,6 @@ class BridgeClass {
4644
4745 k_mutex_init (&read_mutex);
4846 k_mutex_init (&write_mutex);
49- // k_mutex_init(&server_mutex);
50- // k_mutex_init(&client_mutex);
5147
5248 client = new RPCClient (*transport);
5349 server = new RPCServer (*transport);
@@ -85,8 +81,6 @@ class BridgeClass {
8581
8682 void update () {
8783
88- // if (k_mutex_lock(&server_mutex, K_MSEC(10)) != 0) return;
89-
9084 // Lock read mutex
9185 if (k_mutex_lock (&read_mutex, K_MSEC (10 )) != 0 ) return ;
9286
@@ -115,16 +109,13 @@ class BridgeClass {
115109
116110 }
117111
118- // k_mutex_unlock(&server_mutex);
119-
120112 }
121113
122114 template <typename RType, typename ... Args>
123115 bool call (const MsgPack::str_t method, RType& result, Args&&... args) {
124116
125- // k_mutex_lock(&client_mutex, K_FOREVER);
126117 uint32_t msg_id_wait;
127-
118+
128119 // Lock write mutex
129120 while (true ) {
130121 if (k_mutex_lock (&write_mutex, K_MSEC (10 )) == 0 ) {
@@ -155,8 +146,6 @@ class BridgeClass {
155146
156147 return (client->lastError .code == NO_ERR);
157148
158- // k_mutex_unlock(&client_mutex);
159-
160149 }
161150
162151 template <typename ... Args>
@@ -176,8 +165,6 @@ class BridgeClass {
176165
177166 void update_safe () {
178167
179- // if (k_mutex_lock(&server_mutex, K_MSEC(10)) != 0) return;
180-
181168 // Lock read mutex
182169 if (k_mutex_lock (&read_mutex, K_MSEC (10 )) != 0 ) return ;
183170
@@ -205,8 +192,6 @@ class BridgeClass {
205192 }
206193
207194 }
208-
209- // k_mutex_unlock(&server_mutex);
210195
211196 }
212197
0 commit comments