source: mainline/uspace/srv/sysman/units/unit_svc.c@ 8a74512

/*
 * Copyright (c) 2015 Michal Koutny
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#include <assert.h>
#include <errno.h>
#include <io/console.h> // temporary
#include <stdlib.h>
#include <task.h>
#include <str.h>

#include "log.h"
#include "unit.h"

static const char *section_name = "Service";

static config_item_t unit_configuration[] = {
        { "ExecStart", &util_parse_command, offsetof(unit_svc_t, exec_start), NULL },
        CONFIGURATION_ITEM_SENTINEL
};

static void unit_svc_init(unit_t *unit)
{
        unit_svc_t *u_svc = CAST_SVC(unit);
        assert(u_svc);
        util_command_init(&u_svc->exec_start);
}

static void unit_svc_destroy(unit_t *unit)
{
        assert(unit->type == UNIT_SERVICE);
        unit_svc_t *u_svc = CAST_SVC(unit);

        util_command_deinit(&u_svc->exec_start);
}

static errno_t unit_svc_load(unit_t *unit, ini_configuration_t *ini_conf,
    text_parse_t *text_parse)
{
        unit_svc_t *u_svc = CAST_SVC(unit);
        assert(u_svc);

        ini_section_t *section = ini_get_section(ini_conf, section_name);
        if (section == NULL) {
                sysman_log(LVL_ERROR,
                    "Expected section '%s' in configuration of unit '%s'",
                    section_name, unit_name(unit));
                return ENOENT;
        }

        return config_load_ini_section(unit_configuration, section, u_svc,
            text_parse);
}

static errno_t unit_svc_start(unit_t *unit)
{
        unit_svc_t *u_svc = CAST_SVC(unit);
        assert(u_svc);

        assert(unit->state == STATE_STOPPED);

        errno_t rc = task_spawnv(&u_svc->main_task_id, NULL, u_svc->exec_start.path,
            u_svc->exec_start.argv);

        if (rc != EOK) {
                sysman_log(LVL_ERROR, "%s: failed to spawn task '%s' for unit '%s'.",
                    __func__,
                    u_svc->exec_start.path,
                    unit_name(unit));
                unit->state = STATE_FAILED;
                return rc;
        }

        unit->state = STATE_STARTING;

        return EOK;
}

static errno_t unit_svc_stop(unit_t *unit)
{
        unit_svc_t *u_svc = CAST_SVC(unit);
        assert(u_svc);

        // note: May change when job cancellation is possible.
        assert(unit->state == STATE_STARTED);

        /*
         * Ugly trick -- critical service is running despite being stopped
         * circumvent killing ourselves during shutdown (TODO dependencies).
         */
        if (u_svc->critical) {
                unit->state = STATE_STOPPED;
                return EOK;
        }

        errno_t rc = task_kill(u_svc->main_task_id);

        if (rc != EOK) {
                /*
                 * Task may still be running, but be conservative about unit's
                 * state.
                 */
                unit->state = STATE_FAILED;
                return rc;
        }

        unit->state = STATE_STOPPING;

        return EOK;
}

static void unit_svc_exposee_created(unit_t *unit)
{
        assert(CAST_SVC(unit));
        assert(unit->state == STATE_STOPPED || unit->state == STATE_STARTING || unit->state == STATE_STARTED);

        /* Exposee itself doesn't represent started unit. */
        //unit->state = STATE_STARTED;
        //unit_notify_state(unit);
}

static void unit_svc_fail(unit_t *unit)
{
        // TODO implement
}

DEFINE_UNIT_VMT(unit_svc);