From 16cbf3c076a0aca6d47adaf3f719493674cf2363 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Tue, 17 Jan 2017 20:00:00 +0300 Subject: Initial version. --- src/nxt_service.c | 165 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 165 insertions(+) create mode 100644 src/nxt_service.c (limited to 'src/nxt_service.c') diff --git a/src/nxt_service.c b/src/nxt_service.c new file mode 100644 index 00000000..a911f53e --- /dev/null +++ b/src/nxt_service.c @@ -0,0 +1,165 @@ + +/* + * Copyright (C) Igor Sysoev + * Copyright (C) NGINX, Inc. + */ + +#include + + +static const nxt_service_t nxt_services[] = { + +#if (NXT_HAVE_KQUEUE) + { "engine", "kqueue", &nxt_kqueue_event_set }, +#endif + +#if (NXT_HAVE_EPOLL_EDGE) + { "engine", "epoll", &nxt_epoll_edge_event_set }, + { "engine", "epoll_edge", &nxt_epoll_edge_event_set }, + { "engine", "epoll_level", &nxt_epoll_level_event_set }, + +#elif (NXT_HAVE_EPOLL) + { "engine", "epoll", &nxt_epoll_level_event_set }, + { "engine", "epoll_level", &nxt_epoll_level_event_set }, +#endif + +#if (NXT_HAVE_EVENTPORT) + { "engine", "eventport", &nxt_eventport_event_set }, +#endif + +#if (NXT_HAVE_DEVPOLL) + { "engine", "devpoll", &nxt_devpoll_event_set }, + { "engine", "/dev/poll", &nxt_devpoll_event_set }, +#endif + +#if (NXT_HAVE_POLLSET) + { "engine", "pollset", &nxt_pollset_event_set }, +#endif + + { "engine", "poll", &nxt_poll_event_set }, + { "engine", "select", &nxt_select_event_set }, + +#if (NXT_HAVE_OPENSSL) + { "SSL/TLS", "OpenSSL", &nxt_openssl_lib }, + { "SSL/TLS", "openssl", &nxt_openssl_lib }, +#endif + +#if (NXT_HAVE_GNUTLS) + { "SSL/TLS", "GnuTLS", &nxt_gnutls_lib }, + { "SSL/TLS", "gnutls", &nxt_gnutls_lib }, +#endif + +#if (NXT_HAVE_CYASSL) + { "SSL/TLS", "CyaSSL", &nxt_cyassl_lib }, + { "SSL/TLS", "cyassl", &nxt_cyassl_lib }, +#endif + +}; + + +nxt_array_t * +nxt_services_init(nxt_mem_pool_t *mp) +{ + nxt_uint_t n; + nxt_array_t *services; + nxt_service_t *s; + const nxt_service_t *service; + + services = nxt_array_create(mp, 32, sizeof(nxt_service_t)); + + if (nxt_fast_path(services != NULL)) { + + service = nxt_services; + n = nxt_nitems(nxt_services); + + while (n != 0) { + s = nxt_array_add(services); + if (nxt_slow_path(s == NULL)) { + return NULL; + } + + *s = *service; + + service++; + n--; + } + } + + return services; +} + + +nxt_int_t +nxt_service_add(nxt_array_t *services, const nxt_service_t *service) +{ + nxt_uint_t n; + nxt_service_t *s; + + s = services->elts; + n = services->nelts; + + while (n != 0) { + if (nxt_strcmp(s->type, service->type) != 0) { + goto next; + } + + if (nxt_strcmp(s->name, service->name) != 0) { + goto next; + } + + nxt_thread_log_emerg("service \"%s:%s\" is duplicate", + service->type, service->name); + return NXT_ERROR; + + next: + + s++; + n--; + } + + s = nxt_array_add(services); + if (nxt_fast_path(s != NULL)) { + *s = *service; + return NXT_OK; + } + + return NXT_ERROR; +} + + +const void * +nxt_service_get(nxt_array_t *services, const char *type, const char *name) +{ + nxt_uint_t n; + const nxt_service_t *s; + + if (services != NULL) { + s = services->elts; + n = services->nelts; + + } else { + s = nxt_services; + n = nxt_nitems(nxt_services); + } + + while (n != 0) { + if (nxt_strcmp(s->type, type) == 0) { + + if (name == NULL) { + return s->service; + } + + if (nxt_strcmp(s->name, name) == 0) { + return s->service; + } + } + + s++; + n--; + } + + nxt_thread_log_emerg("service \"%s%s%s\" not found", + type, (name != NULL) ? ":" : "", name); + + return NULL; +} -- cgit