X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/c91b68ade95e42efb7a24f19fb5228bee0b618d0..187ba0c05f9fbe51175179b9f637b6554f947468:/examples/gras/mmrpc/mmrpc_server.c diff --git a/examples/gras/mmrpc/mmrpc_server.c b/examples/gras/mmrpc/mmrpc_server.c deleted file mode 100644 index d1585f5f90..0000000000 --- a/examples/gras/mmrpc/mmrpc_server.c +++ /dev/null @@ -1,84 +0,0 @@ -/* GridRPC - Fake Grid RPC thingy doing matrix multiplications (as expected)*/ - -/* Copyright (c) 2006, 2007, 2009, 2010. The SimGrid Team. - * All rights reserved. */ - -/* This program is free software; you can redistribute it and/or modify it - * under the terms of the license (GNU LGPL) which comes with this package. */ - -#define XBT_DEFINE_TYPE_EXTERN -#include "xbt/matrix.h" -#include "mmrpc.h" - -XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(MatMult); - - -typedef xbt_matrix_t request_t[2]; -static int server_cb_request_handler(gras_msg_cb_ctx_t ctx, - void *payload_data) -{ - - xbt_socket_t expeditor = gras_msg_cb_ctx_from(ctx); - - /* 1. Get the payload into the data variable */ - xbt_matrix_t *request = (xbt_matrix_t *) payload_data; - xbt_matrix_t result; - - /* 2. Do the computation */ - result = xbt_matrix_double_new_mult(request[0], request[1]); - - /* 3. Send it back as payload of a pong message to the expeditor */ - gras_msg_send(expeditor, "answer", &result); - - /* 4. Cleanups */ - xbt_matrix_free(request[0]); - xbt_matrix_free(request[1]); - xbt_matrix_free(result); - - return 0; -} /* end_of_server_cb_request_handler */ - -static xbt_socket_t try_gras_socket_server(int port) -{ - volatile xbt_socket_t sock = NULL; - TRY { - sock = gras_socket_server(port); - } - CATCH_ANONYMOUS { - RETHROWF("Unable to establish a server socket: %s"); - } - return sock; -} - -int server(int argc, char *argv[]) -{ - xbt_socket_t sock = NULL; - int port = 4002; - - /* 1. Init the GRAS infrastructure */ - gras_init(&argc, argv); - - /* 2. Get the port I should listen on from the command line, if specified */ - if (argc == 2) { - port = atoi(argv[1]); - } - - /* 3. Register the known messages and payloads. */ - mmrpc_register_messages(); - - /* 4. Register my callback */ - gras_cb_register("request", &server_cb_request_handler); - - /* 5. Create my master socket */ - XBT_INFO("Launch server (port=%d)", port); - sock = try_gras_socket_server(port); - - /* 6. Wait up to 10 minutes for an incoming message to handle */ - gras_msg_handle(600.0); - - /* 7. Free the allocated resources, and shut GRAS down */ - gras_socket_close(sock); - gras_exit(); - - return 0; -} /* end_of_server */