mirror of
https://github.com/ceph/ceph
synced 2025-01-05 02:32:59 +00:00
f473d57013
Defines asynchronous librados operations that satisfy all of the "Requirements on asynchronous operations" imposed by the C++ Networking TS [1] in section 13.2.7. These operations are implemented in terms of boost::asio, but the interfaces themselves are free of boost types - this makes the transition to std::net trivial when it's available. These interfaces conform to the Extensible Asynchronous Model [2] that originated in boost::asio. This model allows the last 'handler' argument to either be a callback that gets the result, a coroutine yield_context that will suspend until completion, or a 'use_future' tag to request the result in a std::future (see the unit tests for examples of each). The 'Extensible' part also enables further integration with new frameworks. For now, only async_read(), async_write(), and the read/write variants of async_operate() are provided. [1] Working Draft, C++ Extensions for Networking http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2017/n4711.pdf [2] "Library Foundations for Asynchronous Operations" http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2014/n3896.pdf Signed-off-by: Casey Bodley <cbodley@redhat.com>
53 lines
956 B
Bash
Executable File
53 lines
956 B
Bash
Executable File
#!/usr/bin/env bash
|
|
set -ex
|
|
|
|
parallel=1
|
|
[ "$1" = "--serial" ] && parallel=0
|
|
|
|
color=""
|
|
[ -t 1 ] && color="--gtest_color=yes"
|
|
|
|
function cleanup() {
|
|
pkill -P $$ || true
|
|
}
|
|
trap cleanup EXIT ERR HUP INT QUIT
|
|
|
|
declare -A pids
|
|
|
|
for f in \
|
|
api_aio api_io api_asio api_list api_lock api_misc \
|
|
api_tier api_pool api_snapshots api_stat api_watch_notify api_cmd \
|
|
api_service \
|
|
api_c_write_operations \
|
|
api_c_read_operations \
|
|
list_parallel \
|
|
open_pools_parallel \
|
|
delete_pools_parallel \
|
|
watch_notify
|
|
do
|
|
if [ $parallel -eq 1 ]; then
|
|
r=`printf '%25s' $f`
|
|
bash -o pipefail -exc "ceph_test_rados_$f $color 2>&1 | tee ceph_test_rados_$f.log | sed \"s/^/$r: /\"" &
|
|
pid=$!
|
|
echo "test $f on pid $pid"
|
|
pids[$f]=$pid
|
|
else
|
|
ceph_test_rados_$f
|
|
fi
|
|
done
|
|
|
|
ret=0
|
|
if [ $parallel -eq 1 ]; then
|
|
for t in "${!pids[@]}"
|
|
do
|
|
pid=${pids[$t]}
|
|
if ! wait $pid
|
|
then
|
|
echo "error in $t ($pid)"
|
|
ret=1
|
|
fi
|
|
done
|
|
fi
|
|
|
|
exit $ret
|