- for (cpt=0; cpt<4; cpt++)
- if (header[cpt] != _GRAS_header[cpt])
- THROW2(mismatch_error,0,
- "Incoming bytes do not look like a GRAS message (header='%.4s' not '%.4s')",header,_GRAS_header);
- if (header[4] != _GRAS_header[4])
- THROW2(mismatch_error,0,"GRAS protocol mismatch (got %d, use %d)",
- (int)header[4], (int)_GRAS_header[4]);
- r_arch = (int)header[5];
- DEBUG2("Handle an incoming message using protocol %d (remote is %s)",
- (int)header[4],gras_datadesc_arch_name(r_arch));
-
- gras_datadesc_recv(sock, string_type, r_arch, &msg_name);
- TRY {
- *msgtype = (gras_msgtype_t)xbt_set_get_by_name(_gras_msgtype_set,msg_name);
- } CATCH(e) {
- / * FIXME: Survive unknown messages * /
- RETHROW1("Exception caught while retrieving the type associated to messages '%s' : %s",
- msg_name);
- }
- free(msg_name);
-
- if ((*msgtype)->ctn_type) {
- *payload_size=gras_datadesc_size((*msgtype)->ctn_type);
- xbt_assert2(*payload_size > 0,
- "%s %s",
- "Dynamic array as payload is forbided for now (FIXME?).",
- "Reference to dynamic array is allowed.");
- *payload = xbt_malloc(*payload_size);
- gras_datadesc_recv(sock, (*msgtype)->ctn_type, r_arch, *payload);
+ return msg;
+}
+
+
+void gras_msg_send_ext(xbt_socket_t sock,
+ e_gras_msg_kind_t kind,
+ unsigned long int ID,
+ gras_msgtype_t msgtype, void *payload)
+{
+ int whole_payload_size = 0; /* msg->payload_size is used to memcpy the payload.
+ This is used to report the load onto the simulator. It also counts the size of pointed stuff */
+ gras_msg_t msg; /* message to send */
+ smx_action_t comm;
+ gras_trp_sg_sock_data_t sock_data = (gras_trp_sg_sock_data_t) sock->data;
+
+ smx_rdv_t target_rdv =
+ (sock_data->server == SIMIX_process_self())?
+ sock_data->rdv_client :
+ sock_data->rdv_server;
+
+ /*initialize gras message */
+ msg = xbt_new(s_gras_msg_t, 1);
+ sock->refcount++;
+ msg->expe = sock;
+ msg->kind = kind;
+ msg->type = msgtype;
+ msg->ID = ID;
+ XBT_PUBLIC(xbt_datadesc_type_t) xbt_datadesc_by_id(long int code);
+
+ /* to debug */
+ XBT_PUBLIC(void) xbt_datadesc_type_dump(const xbt_datadesc_type_t ddt);
+ XBT_PUBLIC(const char *) xbt_datadesc_arch_name(int code);
+
+ /* compare two data type description */
+ XBT_PUBLIC(int)
+ xbt_datadesc_type_cmp(const xbt_datadesc_type_t d1,
+ const xbt_datadesc_type_t d2);
+
+ /* Access function */
+ XBT_PUBLIC(int) xbt_datadesc_size(xbt_datadesc_type_t type);
+ /* Described data exchanges: direct use */
+ XBT_PUBLIC(int) xbt_datadesc_memcpy(xbt_datadesc_type_t type, void *src,
+ void *dst);
+ XBT_PUBLIC(void) xbt_datadesc_send(xbt_socket_t sock,
+ xbt_datadesc_type_t type, void *src);
+ XBT_PUBLIC(void) xbt_datadesc_recv(xbt_socket_t sock,
+ xbt_datadesc_type_t type, int r_arch,
+ void *dst);
+
+ /* Described data exchanges: IDL compilation FIXME: not implemented*/
+ void xbt_datadesc_gen_cpy(xbt_datadesc_type_t type, void *src,
+ void **dst);
+ void xbt_datadesc_gen_send(xbt_socket_t sock,
+ xbt_datadesc_type_t type, void *src);
+ void xbt_datadesc_gen_recv(xbt_socket_t sock,
+ xbt_datadesc_type_t type, int r_arch,
+ void *dst);
+
+
+ XBT_VERB("Send msg %s (%s) to rdv %p sock %p",
+ msgtype->name, e_gras_msg_kind_names[kind], target_rdv, sock);
+
+ if (kind == e_gras_msg_kind_rpcerror) {
+ /* error on remote host, careful, payload is an exception */
+ msg->payl_size = xbt_datadesc_size(xbt_datadesc_by_name("ex_t"));
+ msg->payl = xbt_malloc(msg->payl_size);
+ whole_payload_size =
+ xbt_datadesc_memcpy(xbt_datadesc_by_name("ex_t"), payload,
+ msg->payl);
+ } else if (kind == e_gras_msg_kind_rpcanswer) {
+ msg->payl_size = xbt_datadesc_size(msgtype->answer_type);
+ if (msg->payl_size)
+ msg->payl = xbt_malloc(msg->payl_size);
+ else
+ msg->payl = NULL;
+
+ if (msgtype->answer_type)
+ whole_payload_size = xbt_datadesc_memcpy(msgtype->answer_type,
+ payload, msg->payl);