Commit a5ebf0d5 authored by Philip Carns's avatar Philip Carns

print info about RPCs triggered

parent c93313ba
...@@ -27,7 +27,7 @@ static void my_rpc_shutdown_ult(hg_handle_t handle) ...@@ -27,7 +27,7 @@ static void my_rpc_shutdown_ult(hg_handle_t handle)
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
printf("Got RPC request to shutdown\n"); //printf("Got RPC request to shutdown\n");
hgi = HG_Get_info(handle); hgi = HG_Get_info(handle);
assert(hgi); assert(hgi);
......
...@@ -5,6 +5,7 @@ ...@@ -5,6 +5,7 @@
*/ */
#include <assert.h> #include <assert.h>
#include <pthread.h>
#include "svc1-proto.h" #include "svc1-proto.h"
#include "svc1-server.h" #include "svc1-server.h"
...@@ -19,12 +20,21 @@ static void svc1_do_thing_ult(hg_handle_t handle) ...@@ -19,12 +20,21 @@ static void svc1_do_thing_ult(hg_handle_t handle)
hg_bulk_t bulk_handle; hg_bulk_t bulk_handle;
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
ABT_thread my_ult;
ABT_xstream my_xstream;
pthread_t my_tid;
ret = HG_Get_input(handle, &in); ret = HG_Get_input(handle, &in);
assert(ret == HG_SUCCESS); assert(ret == HG_SUCCESS);
hgi = HG_Get_info(handle);
assert(hgi);
ABT_xstream_self(&my_xstream);
ABT_thread_self(&my_ult);
my_tid = pthread_self();
printf("svc1: do_thing: mplex_id: %u, ult: %p, xstream %p, tid: %lu\n",
hgi->mplex_id, my_ult, my_xstream, my_tid);
/* TODO: print handler name, mplex_id, and pool */
printf("Got RPC request with input_val: %d\n", in.input_val);
out.ret = 0; out.ret = 0;
/* set up target buffer for bulk transfer */ /* set up target buffer for bulk transfer */
...@@ -33,8 +43,6 @@ static void svc1_do_thing_ult(hg_handle_t handle) ...@@ -33,8 +43,6 @@ static void svc1_do_thing_ult(hg_handle_t handle)
assert(buffer); assert(buffer);
/* register local target buffer for bulk access */ /* register local target buffer for bulk access */
hgi = HG_Get_info(handle);
assert(hgi);
ret = HG_Bulk_create(hgi->hg_class, 1, &buffer, ret = HG_Bulk_create(hgi->hg_class, 1, &buffer,
&size, HG_BULK_WRITE_ONLY, &bulk_handle); &size, HG_BULK_WRITE_ONLY, &bulk_handle);
assert(ret == 0); assert(ret == 0);
...@@ -71,12 +79,21 @@ static void svc1_do_other_thing_ult(hg_handle_t handle) ...@@ -71,12 +79,21 @@ static void svc1_do_other_thing_ult(hg_handle_t handle)
hg_bulk_t bulk_handle; hg_bulk_t bulk_handle;
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
ABT_thread my_ult;
ABT_xstream my_xstream;
pthread_t my_tid;
ret = HG_Get_input(handle, &in); ret = HG_Get_input(handle, &in);
assert(ret == HG_SUCCESS); assert(ret == HG_SUCCESS);
hgi = HG_Get_info(handle);
assert(hgi);
ABT_xstream_self(&my_xstream);
ABT_thread_self(&my_ult);
my_tid = pthread_self();
printf("svc1: do_other_thing: mplex_id: %u, ult: %p, xstream %p, tid: %lu\n",
hgi->mplex_id, my_ult, my_xstream, my_tid);
/* TODO: print handler name, mplex_id, and pool */
printf("Got RPC request with input_val: %d\n", in.input_val);
out.ret = 0; out.ret = 0;
/* set up target buffer for bulk transfer */ /* set up target buffer for bulk transfer */
...@@ -85,8 +102,6 @@ static void svc1_do_other_thing_ult(hg_handle_t handle) ...@@ -85,8 +102,6 @@ static void svc1_do_other_thing_ult(hg_handle_t handle)
assert(buffer); assert(buffer);
/* register local target buffer for bulk access */ /* register local target buffer for bulk access */
hgi = HG_Get_info(handle);
assert(hgi);
ret = HG_Bulk_create(hgi->hg_class, 1, &buffer, ret = HG_Bulk_create(hgi->hg_class, 1, &buffer,
&size, HG_BULK_WRITE_ONLY, &bulk_handle); &size, HG_BULK_WRITE_ONLY, &bulk_handle);
assert(ret == 0); assert(ret == 0);
......
...@@ -5,6 +5,7 @@ ...@@ -5,6 +5,7 @@
*/ */
#include <assert.h> #include <assert.h>
#include <pthread.h>
#include "svc2-proto.h" #include "svc2-proto.h"
#include "svc2-server.h" #include "svc2-server.h"
...@@ -19,12 +20,21 @@ static void svc2_do_thing_ult(hg_handle_t handle) ...@@ -19,12 +20,21 @@ static void svc2_do_thing_ult(hg_handle_t handle)
hg_bulk_t bulk_handle; hg_bulk_t bulk_handle;
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
ABT_thread my_ult;
ABT_xstream my_xstream;
pthread_t my_tid;
ret = HG_Get_input(handle, &in); ret = HG_Get_input(handle, &in);
assert(ret == HG_SUCCESS); assert(ret == HG_SUCCESS);
hgi = HG_Get_info(handle);
assert(hgi);
ABT_xstream_self(&my_xstream);
ABT_thread_self(&my_ult);
my_tid = pthread_self();
printf("svc1: do_thing: mplex_id: %u, ult: %p, xstream %p, tid: %lu\n",
hgi->mplex_id, my_ult, my_xstream, my_tid);
/* TODO: print handler name, mplex_id, and pool */
printf("Got RPC request with input_val: %d\n", in.input_val);
out.ret = 0; out.ret = 0;
/* set up target buffer for bulk transfer */ /* set up target buffer for bulk transfer */
...@@ -33,8 +43,6 @@ static void svc2_do_thing_ult(hg_handle_t handle) ...@@ -33,8 +43,6 @@ static void svc2_do_thing_ult(hg_handle_t handle)
assert(buffer); assert(buffer);
/* register local target buffer for bulk access */ /* register local target buffer for bulk access */
hgi = HG_Get_info(handle);
assert(hgi);
ret = HG_Bulk_create(hgi->hg_class, 1, &buffer, ret = HG_Bulk_create(hgi->hg_class, 1, &buffer,
&size, HG_BULK_WRITE_ONLY, &bulk_handle); &size, HG_BULK_WRITE_ONLY, &bulk_handle);
assert(ret == 0); assert(ret == 0);
...@@ -71,12 +79,21 @@ static void svc2_do_other_thing_ult(hg_handle_t handle) ...@@ -71,12 +79,21 @@ static void svc2_do_other_thing_ult(hg_handle_t handle)
hg_bulk_t bulk_handle; hg_bulk_t bulk_handle;
struct hg_info *hgi; struct hg_info *hgi;
margo_instance_id mid; margo_instance_id mid;
ABT_thread my_ult;
ABT_xstream my_xstream;
pthread_t my_tid;
ret = HG_Get_input(handle, &in); ret = HG_Get_input(handle, &in);
assert(ret == HG_SUCCESS); assert(ret == HG_SUCCESS);
hgi = HG_Get_info(handle);
assert(hgi);
ABT_xstream_self(&my_xstream);
ABT_thread_self(&my_ult);
my_tid = pthread_self();
printf("svc1: do_other_thing: mplex_id: %u, ult: %p, xstream %p, tid: %lu\n",
hgi->mplex_id, my_ult, my_xstream, my_tid);
/* TODO: print handler name, mplex_id, and pool */
printf("Got RPC request with input_val: %d\n", in.input_val);
out.ret = 0; out.ret = 0;
/* set up target buffer for bulk transfer */ /* set up target buffer for bulk transfer */
...@@ -85,8 +102,6 @@ static void svc2_do_other_thing_ult(hg_handle_t handle) ...@@ -85,8 +102,6 @@ static void svc2_do_other_thing_ult(hg_handle_t handle)
assert(buffer); assert(buffer);
/* register local target buffer for bulk access */ /* register local target buffer for bulk access */
hgi = HG_Get_info(handle);
assert(hgi);
ret = HG_Bulk_create(hgi->hg_class, 1, &buffer, ret = HG_Bulk_create(hgi->hg_class, 1, &buffer,
&size, HG_BULK_WRITE_ONLY, &bulk_handle); &size, HG_BULK_WRITE_ONLY, &bulk_handle);
assert(ret == 0); assert(ret == 0);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment