diff --git a/.github/workflows/daily.yml b/.github/workflows/daily.yml index 8824256..9763745 100644 --- a/.github/workflows/daily.yml +++ b/.github/workflows/daily.yml @@ -77,7 +77,7 @@ jobs: uses: actions/checkout@v3 - name: Test Vine Serverless Mode run: ./test-vine-serverless.sh - + parrot-cvmfs-job: runs-on: ubuntu-20.04 timeout-minutes: 10 @@ -96,6 +96,23 @@ jobs: - name: Test TopEFT + Work Queue run: ./test-topeft.sh + vine-task-throughput: + runs-on: ubuntu-20.04 + timeout-minutes: 20 + steps: + - name: Checkout + uses: actions/checkout@v3 + - name: Test Vine Throughput + run: ./test-vine-task-throughput.sh + + vine-throughput-capi-job: + runs-on: ubuntu-20.04 + timeout-minutes: 20 + steps: + - name: Checkout + uses: actions/checkout@v3 + - name: Test Vine Throughput Test C API + run: ./test-vine-task-throughput-capi.sh # Removed plain coffea test 7/24/2023 to replace with coffea-dask-taskvine when ready. # coffea-job: # runs-on: ubuntu-20.04 diff --git a/test-vine-task-throughput-capi.sh b/test-vine-task-throughput-capi.sh new file mode 100755 index 0000000..4c27acf --- /dev/null +++ b/test-vine-task-throughput-capi.sh @@ -0,0 +1,12 @@ + +#!/bin/sh + +# Build the sources from github +. ./install-github.sh + +# Compile C API test using environment +gcc test-vine-task-throughput.c -o test-vine-task-throughput -I $PREFIX/include/cctools/ -L $PREFIX/lib -ltaskvine -ldttools -lm -lcrypto -lssl -lz + +./test-vine-task-throughput & + +vine_worker localhost 9123 --single-shot \ No newline at end of file diff --git a/test-vine-task-throughput.c b/test-vine-task-throughput.c new file mode 100644 index 0000000..9eb4671 --- /dev/null +++ b/test-vine-task-throughput.c @@ -0,0 +1,75 @@ +#include "taskvine.h" + +#include +#include +#include +#include +#include +#include +#include +int main(int argc, char *argv[]) +{ + struct vine_manager *m; + int i; + int tasksC = 5000; + + m = vine_create(VINE_DEFAULT_PORT); + + if(!m) { + printf("couldn't create manager: %s\n", strerror(errno)); + return 1; + } + printf("TaskVine listening on %d\n", vine_port(m)); + + for(i=0;i