diff options
Diffstat (limited to 'source4/torture')
| -rw-r--r-- | source4/torture/local/config.mk | 3 | ||||
| -rw-r--r-- | source4/torture/local/event.c | 126 | ||||
| -rw-r--r-- | source4/torture/torture.c | 1 |
3 files changed, 129 insertions, 1 deletions
diff --git a/source4/torture/local/config.mk b/source4/torture/local/config.mk index c795df1ff8..7bcd8070ca 100644 --- a/source4/torture/local/config.mk +++ b/source4/torture/local/config.mk @@ -16,7 +16,8 @@ OBJ_FILES = \ util_strlist.o \ util_file.o \ sddl.o \ - ndr.o + ndr.o \ + event.o PUBLIC_DEPENDENCIES = \ RPC_NDR_ECHO \ LIBCLI_SMB \ diff --git a/source4/torture/local/event.c b/source4/torture/local/event.c new file mode 100644 index 0000000000..92fb68c73e --- /dev/null +++ b/source4/torture/local/event.c @@ -0,0 +1,126 @@ +/* + Unix SMB/CIFS implementation. + + testing of the events subsystem + + Copyright (C) Stefan Metzmacher + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. +*/ + +#include "includes.h" +#include "lib/events/events.h" +#include "system/filesys.h" +#include "torture/torture.h" + +const struct event_ops *event_standard_get_ops(void); +const struct event_ops *event_liboop_get_ops(void); +const struct event_ops *gtk_event_get_ops(void); + +static int write_fd, read_fd; +static struct fd_event *fde; +static int te_count; +static int fde_count; +static BOOL ret = True; + +static void fde_handler(struct event_context *ev_ctx, struct fd_event *f, + uint16_t flags, void *private) +{ + int *fd = private; + + printf("event[%d] fd[%d] events[0x%08X]", fde_count, *fd, flags); + if (flags & EVENT_FD_READ) printf(" EVENT_FD_READ"); + if (flags & EVENT_FD_WRITE) printf(" EVENT_FD_WRITE"); + printf("\n"); + + if (fde_count > 5) { + printf("got more than fde 5 events - bug!\n"); + talloc_free(fde); + fde = NULL; + return; + } + + event_set_fd_flags(fde, 0); + fde_count++; +} + +static void timed_handler(struct event_context *ev_ctx, struct timed_event *te, + struct timeval tval, void *private) +{ + printf("timed_handler called[%d]\n", te_count); + if (te_count > 2) { + close(write_fd); + write_fd = -1; + } + if (te_count > 5) { + printf("remove fd event!\n"); + talloc_free(fde); + fde = NULL; + return; + } + te_count++; + event_add_timed(ev_ctx, ev_ctx, timeval_current_ofs(0,500), timed_handler, private); +} + + +static BOOL test_event_context(struct event_context *ev_ctx, const char *comment) +{ + int fd[2] = { -1, -1 }; + + printf("Testing '%s'\n", comment); + + /* reset globals */ + write_fd = -1; + read_fd = -1; + fde = NULL; + te_count = 0; + fde_count = 0; + ret = True; + + /* create a pipe */ + pipe(fd); + read_fd = fd[0]; + write_fd = fd[1]; + + fde = event_add_fd(ev_ctx, ev_ctx, read_fd, EVENT_FD_READ, fde_handler, &read_fd); + + event_add_timed(ev_ctx, ev_ctx, timeval_current_ofs(0,500), timed_handler, fde); + + event_loop_wait(ev_ctx); + + close(read_fd); + close(write_fd); + + return ret; +} + +BOOL torture_local_event(struct torture_context *torture) +{ + struct event_context *ev_ctx; + BOOL try_epoll; + BOOL retv = True; + + try_epoll = False; + ev_ctx = event_context_init_ops(NULL, event_standard_get_ops(), &try_epoll); + retv &= test_event_context(ev_ctx, "standard with select"); + talloc_free(ev_ctx); + + try_epoll = True; + ev_ctx = event_context_init_ops(NULL, event_standard_get_ops(), &try_epoll); + retv &= test_event_context(ev_ctx, "standard try epool (or select)"); + talloc_free(ev_ctx); + + return retv; +} diff --git a/source4/torture/torture.c b/source4/torture/torture.c index 706bb43e2a..b7cb74480c 100644 --- a/source4/torture/torture.c +++ b/source4/torture/torture.c @@ -652,6 +652,7 @@ static struct { {"LOCAL-RESOLVE", torture_local_resolve, 0}, {"LOCAL-SDDL", torture_local_sddl, 0}, {"LOCAL-NDR", torture_local_ndr, 0}, + {"LOCAL-EVENT", torture_local_event, 0}, /* ldap testers */ {"LDAP-BASIC", torture_ldap_basic, 0}, |