This is an automated email from the git hooks/post-receive script. It was generated because a ref change was pushed to the repository containing the project "Triton Repository". The branch, master has been updated via 1ad903fef7370077c04df140b91716a17010d95a (commit) from d8c6a8764b3cdbc9a30acd8998feef230275486d (commit) Those revisions listed above that are new to this repository have not appeared on any other notification email; so we list those revisions in full, below. - Log ----------------------------------------------------------------- commit 1ad903fef7370077c04df140b91716a17010d95a Author: Phil Carns <[email protected]> Date: Thu Feb 17 16:33:55 2011 -0500 use shutdown rpc and turn off fakess for now ----------------------------------------------------------------------- Summary of changes: code/src/replicated-osd/tests/rosd-create-bench.ae | 48 ++++++++++++++++++++ 1 files changed, 48 insertions(+), 0 deletions(-) Diff of changes: diff --git a/code/src/replicated-osd/tests/rosd-create-bench.ae b/code/src/replicated-osd/tests/rosd-create-bench.ae index 4b0f0d2..0ecb3dc 100644 --- a/code/src/replicated-osd/tests/rosd-create-bench.ae +++ b/code/src/replicated-osd/tests/rosd-create-bench.ae @@ -48,6 +48,16 @@ char *hostfile; __blocking void do_remote_server(void) { + /* run service engine to process requests */ + assert(AER_DEFAULT_CTX); + aer_service_engine_start(AER_DEFAULT_CTX); + + return; +} + +#if 0 +__blocking void do_remote_server(void) +{ triton_ret_t ret; int32_t result; int rank; @@ -93,9 +103,37 @@ __blocking void do_remote_server(void) } } } +#endif triton_mutex_t oid_mutex = TRITON_MUTEX_INITIALIZER; +__blocking void do_remote_shutdown(void) +{ + triton_ret_t ret; + triton_map_t *mapping; + triton_map_t *scratch; + triton_list_t *map; + uint32_t out; + int i; + + /* get all the server addrs */ + ret = triton_map_get(&map); + + pwait + { + triton_list_for_each_entry(mapping, scratch, map, triton_map_t, link) + { + pbranch + { + ret = remote_triton_server_shutdown(AER_DEFAULT_CTX, mapping->addr, 0, &out); + triton_error_assert(ret); + } + } + } + + return; +} + __blocking void do_remote_noop(void) { triton_ret_t ret; @@ -721,12 +759,22 @@ int main(int argc, char *argv[]) printf("remove\t%d\t%d\t%d\t%d\t%f\t%f\t%f\t%d\n", nclients, nservers, nobjects, nconcurrent, remove_min_elapsed_time, remove_elapsed_time, (double)nobjects*(double)(nclients)/remove_elapsed_time, use_niids); + done = 0; + ret = ae_post_blocking(do_remote_shutdown, cb, NULL, NULL, mpi_resource_ctx, &op_id); + + while(!done) + { + ae_poll(mpi_resource_ctx, 0); + } + +#if 0 /* send a message to each server to tell it we are done */ for(i=0; i<nservers; i++) { mpi_ret = MPI_Send(&done_signal, 1, MPI_CHAR, i, 0, MPI_COMM_WORLD); assert(mpi_ret == MPI_SUCCESS); } +#endif } } hooks/post-receive -- Triton Repository