rh.method_index = req->method_ind;
rh.source = forb_object_to_forb(req->obj)->server_id;
ret = forb_iop_request_header_serialize(&req->cdr_request, &rh);
- *index = req->cdr_request.wptr;
if (ret) {
/* Request body is 8 byte aligned */
ret = FORB_CDR_put_align(&req->cdr_request, 8);
forb_server_id_to_string(str, &req->obj->server, sizeof(str)),
rh.iface, rh.method_index);
}
+ *index = req->cdr_request.wptr;
return ret;
}
exec_req->method_index = req->method_ind;
exec_req->interface = req->interface;
req->cdr_request.rptr = index;
- exec_req->codec = req->cdr_request;
+ exec_req->codec = req->cdr_request;
+ req->cdr_request.release_buffer = CORBA_FALSE;
exec_req->request_id = req->request_id;
forb_exec_req_ins_tail(forb_object_get_executor(exec_req->obj), exec_req);
return;
forb_t *forb = forb_object_to_forb(req->obj);
forb_request_delete(forb, req);
- FORB_CDR_codec_release_buffer(&req->cdr_request);
+ //FORB_CDR_codec_release_buffer(&req->cdr_request);
forb_syncobj_destroy(&req->reply_ready);
}
WVPASS(forb_object_is_local(testobj2));
/* Inter-thread invocation: application->executor */
- WVPASSEQ(executor_test_add(testobj1, 1, &env), 2);
+ WVPASSEQ(executor_test_add(testobj1, 2, &env), 3);
WVFAIL(forb_exception_occurred(&env));
/* Inter-thread invocation: (application->)executor->executor */