@@ -126,7 +126,8 @@ bool ProxySupervisor::send(
126
126
}
127
127
128
128
nlohmann::basic_json<> ProxySupervisor::readReply () {
129
- while (!this ->hasReplied );
129
+ while (!this ->hasReplied )
130
+ ;
130
131
this ->hasReplied = false ;
131
132
return this ->proxyResult ;
132
133
}
@@ -214,20 +215,20 @@ void ProxySupervisor::deserializeRFCResult(RFC *rfc) {
214
215
nlohmann::basic_json<> call_result = this ->readReply (); // blocking
215
216
rfc->success = *call_result.find (" success" ) == 1 ;
216
217
217
- // if (!rfc->success) {
218
- // uint16_t msg_size = 0;
219
- // memcpy(&msg_size, call_result + 1, sizeof(uint16_t));
220
- // if (msg_size > rfc->exception_size) {
221
- // delete[] rfc->exception;
222
- // rfc->exception = new char[msg_size];
223
- // rfc->exception_size = msg_size;
224
- // }
225
- // memcpy(rfc->exception, call_result + 1 + sizeof(uint16_t), msg_size);
226
- // return;
227
- // }
218
+ // if (!rfc->success) {
219
+ // uint16_t msg_size = 0;
220
+ // memcpy(&msg_size, call_result + 1, sizeof(uint16_t));
221
+ // if (msg_size > rfc->exception_size) {
222
+ // delete[] rfc->exception;
223
+ // rfc->exception = new char[msg_size];
224
+ // rfc->exception_size = msg_size;
225
+ // }
226
+ // memcpy(rfc->exception, call_result + 1 + sizeof(uint16_t),
227
+ // msg_size); return;
228
+ // }
228
229
229
230
uint8_t type = *call_result.find (" type" );
230
- auto *result = (StackValue *)malloc (sizeof (struct StackValue ));
231
+ auto *result = (StackValue *)malloc (sizeof (struct StackValue ));
231
232
result->value_type = type;
232
233
result->value = {*call_result.find (" value" )};
233
234
rfc->result = result;
0 commit comments