/*

 * Copyright (C) Igor Sysoev

 * Copyright (C) NGINX, Inc.

 */

#include <nxt_main.h>

static const nxt_service_t  nxt_services[] = {

#if (NXT_HAVE_KQUEUE)

    { "engine", "kqueue", &nxt_kqueue_engine },

#endif

#if (NXT_HAVE_EPOLL_EDGE)

    { "engine", "epoll", &nxt_epoll_edge_engine },

    { "engine", "epoll_edge", &nxt_epoll_edge_engine },

    { "engine", "epoll_level", &nxt_epoll_level_engine },

#elif (NXT_HAVE_EPOLL)

    { "engine", "epoll", &nxt_epoll_level_engine },

    { "engine", "epoll_level", &nxt_epoll_level_engine },

#endif

#if (NXT_HAVE_EVENTPORT)

    { "engine", "eventport", &nxt_eventport_engine },

#endif

#if (NXT_HAVE_DEVPOLL)

    { "engine", "devpoll", &nxt_devpoll_engine },

    { "engine", "/dev/poll", &nxt_devpoll_engine },

#endif

#if (NXT_HAVE_POLLSET)

    { "engine", "pollset", &nxt_pollset_engine },

#endif

    { "engine", "poll", &nxt_poll_engine },

    { "engine", "select", &nxt_select_engine },

#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_mp_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_alert("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_alert("service \"%s%s%s\" not found",

                         type, (name != NULL) ? ":" : "", name);

    return NULL;

}