4 XBT_LOG_NEW_DEFAULT_CATEGORY(test,"My little example");
6 void message_declaration(void) {
7 gras_msgtype_declare("request", NULL);
8 gras_msgtype_declare("grant", NULL);
9 gras_msgtype_declare("release", NULL);
14 xbt_dynar_t waiting_queue;
17 int server_request_cb(gras_msg_cb_ctx_t ctx, void *payload) {
18 server_data_t *globals=(server_data_t*)gras_userdata_get();
19 gras_socket_t s = gras_msg_cb_ctx_from(ctx);
21 if (globals->process_in_CS) {
22 xbt_dynar_push(globals->waiting_queue, &s);
23 INFO2("put %s:%d in waiting queue",gras_socket_peer_name(s),gras_socket_peer_port(s));
25 globals->process_in_CS = 1;
26 INFO2("grant %s:%d since nobody wanted it",gras_socket_peer_name(s),gras_socket_peer_port(s));
27 gras_msg_send(s, "grant", NULL);
30 } /* end_of_request_callback */
32 int server_release_cb(gras_msg_cb_ctx_t ctx, void *payload) {
33 server_data_t *globals=(server_data_t*)gras_userdata_get();
35 if (xbt_dynar_length(globals->waiting_queue)) {
37 xbt_dynar_pop(globals->waiting_queue, &s);
39 INFO2("grant %s:%d since token released",gras_socket_peer_name(s),gras_socket_peer_port(s));
40 gras_msg_send(s, "grant", NULL);
42 globals->process_in_CS = 0;
46 } /* end_of_release_callback */
48 int server(int argc, char *argv[]) {
49 gras_socket_t mysock; /* socket on which I listen */
50 server_data_t *globals;
53 gras_init(&argc,argv);
54 mysock = gras_socket_server(atoi(argv[1]));
56 globals=gras_userdata_new(server_data_t);
57 globals->process_in_CS=0;
58 globals->waiting_queue=xbt_dynar_new( sizeof(gras_socket_t), NULL /* not closing sockets */);
60 message_declaration();
61 gras_cb_register("request",&server_request_cb);
62 gras_cb_register("release",&server_release_cb);
64 for (i=0; i<20; i++) /* 5 requests of each process, 2 processes, 2 messages per request */
71 void lock(gras_socket_t toserver) {
72 gras_msg_send(toserver,"request",NULL);
73 gras_msg_wait(-1, "grant",NULL,NULL);
74 INFO0("Granted by server");
77 void unlock(gras_socket_t toserver) {
78 INFO0("Release the token");
79 gras_msg_send(toserver,"release",NULL);
82 int client(int argc, char *argv[]) {
84 gras_socket_t mysock; /* socket on which I listen */
85 gras_socket_t toserver; /* socket used to write to the server */
87 gras_init(&argc,argv);
89 mysock = gras_socket_server_range(1024, 10000, 0, 0);
91 VERB1("Client ready; listening on %d", gras_socket_my_port(mysock));
93 gras_os_sleep(1.5); /* sleep 1 second and half */
94 message_declaration();
95 toserver = gras_socket_client(argv[1], atoi(argv[2]));