mirror of
https://github.com/xen-project/xen.git
synced 2026-10-29 10:40:03 +01:00
Ian Jackson
d491d819d3
In 31c836f4 "libxl: events: Permit timeouts to signal ao abort",
timeout callbacks take an extra rc argument.
In that patch the wrong assertion is made about the rc in
test_timedereg's `occurs' callback. Fix this to make the test pass
again.
Signed-off-by: Ian Jackson <Ian.Jackson@eu.citrix.com>
Acked-by: Wei Liu <wei.liu2@citrix.com>
101 lines
2.3 KiB
C
101 lines
2.3 KiB
C
/*
|
|
* timedereg test case for the libxl event system
|
|
*
|
|
* To run this test:
|
|
* ./test_timedereg
|
|
* Success:
|
|
* program takes a few seconds, prints some debugging output and exits 0
|
|
* Failure:
|
|
* crash
|
|
*
|
|
* set up [0]-group timeouts 0 1 2
|
|
* wait for timeout 1 to occur
|
|
* deregister 0 and 2. 1 is supposed to be deregistered already
|
|
* register [1]-group 0 1 2
|
|
* deregister 1 (should be a no-op)
|
|
* wait for [1]-group 0 1 2 in turn
|
|
* on final callback assert that all have been deregistered
|
|
*/
|
|
|
|
#include "libxl_internal.h"
|
|
|
|
#include "libxl_test_timedereg.h"
|
|
|
|
#define NTIMES 3
|
|
static const int ms[2][NTIMES] = { { 2000,1000,2000 }, { 1000,2000,3000 } };
|
|
static libxl__ev_time et[2][NTIMES];
|
|
static libxl__ao *tao;
|
|
static int seq;
|
|
|
|
static void occurs(libxl__egc *egc, libxl__ev_time *ev,
|
|
const struct timeval *requested_abs, int rc);
|
|
|
|
static void regs(libxl__ao *ao, int j)
|
|
{
|
|
AO_GC;
|
|
int rc, i;
|
|
LOG(DEBUG,"regs(%d)", j);
|
|
for (i=0; i<NTIMES; i++) {
|
|
rc = libxl__ev_time_register_rel(ao, &et[j][i], occurs, ms[j][i]);
|
|
assert(!rc);
|
|
}
|
|
}
|
|
|
|
int libxl_test_timedereg(libxl_ctx *ctx, libxl_asyncop_how *ao_how)
|
|
{
|
|
int i;
|
|
AO_CREATE(ctx, 0, ao_how);
|
|
|
|
tao = ao;
|
|
|
|
for (i=0; i<NTIMES; i++) {
|
|
libxl__ev_time_init(&et[0][i]);
|
|
libxl__ev_time_init(&et[1][i]);
|
|
}
|
|
|
|
regs(ao, 0);
|
|
|
|
return AO_INPROGRESS;
|
|
}
|
|
|
|
static void occurs(libxl__egc *egc, libxl__ev_time *ev,
|
|
const struct timeval *requested_abs, int rc)
|
|
{
|
|
EGC_GC;
|
|
int i;
|
|
|
|
int off = ev - &et[0][0];
|
|
LOG(DEBUG,"occurs[%d][%d] seq=%d rc=%d", off/NTIMES, off%NTIMES, seq, rc);
|
|
|
|
assert(rc == ERROR_TIMEDOUT);
|
|
|
|
switch (seq) {
|
|
case 0:
|
|
assert(ev == &et[0][1]);
|
|
libxl__ev_time_deregister(gc, &et[0][0]);
|
|
libxl__ev_time_deregister(gc, &et[0][2]);
|
|
regs(tao, 1);
|
|
libxl__ev_time_deregister(gc, &et[0][1]);
|
|
break;
|
|
|
|
case 1:
|
|
case 2:
|
|
assert(ev == &et[1][seq-1]);
|
|
break;
|
|
|
|
case 3:
|
|
assert(ev == &et[1][2]);
|
|
for (i=0; i<NTIMES; i++) {
|
|
assert(!libxl__ev_time_isregistered(&et[0][i]));
|
|
assert(!libxl__ev_time_isregistered(&et[1][i]));
|
|
}
|
|
libxl__ao_complete(egc, tao, 0);
|
|
return;
|
|
|
|
default:
|
|
abort();
|
|
}
|
|
|
|
seq++;
|
|
}
|