f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor#include "util/util.h"

3f08db06526d6901aa08c110b5bc7dde6bc39905nd#include "util/child_common.h"

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/types.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/wait.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/time.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/param.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <time.h>

f086b4b402fa9a2fefc7dda85de2a3cc1cd0a654rjung#include <string.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#ifdef HAVE_SYS_INOTIFY_H

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include <sys/inotify.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#endif

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/types.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <sys/stat.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <unistd.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <fcntl.h>

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor#include <netinet/in.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <arpa/nameser.h>

f072359f493a5209335799da85ac16d6a273303bgryzor#include <resolv.h>

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor#include "popt.h"

f072359f493a5209335799da85ac16d6a273303bgryzor#include "tevent.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "confdb/confdb.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "confdb/confdb_setup.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "collection.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "ini_config.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "db/sysdb.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "monitor/monitor.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "dbus/dbus.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "sbus/sssd_dbus.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "monitor/monitor_interfaces.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include "responder/nss/nsssrv.h"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#ifdef USE_KEYRING

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#include <keyutils.h>

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#endif

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#define MONITOR_DEF_PING_TIME 10

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#define MONITOR_DEF_FORCE_TIME 60

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#define MONITOR_NAME "sssd"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#define SSSD_PIDFILE_PATH PID_PATH"/"MONITOR_NAME".pid"

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic#define KRB5_RCACHE_DIR_DISABLE "__LIBKRB5_DEFAULTS__"

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalicint cmdline_debug_level;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalicint cmdline_debug_timestamps;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalicint cmdline_debug_microseconds;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalicstruct svc_spy;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalicenum mt_svc_type {

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic MT_SVC_SERVICE,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim MT_SVC_PROVIDER

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstruct mt_svc {

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *prev;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *next;

f072359f493a5209335799da85ac16d6a273303bgryzor enum mt_svc_type type;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor struct sbus_connection *conn;

f072359f493a5209335799da85ac16d6a273303bgryzor struct svc_spy *conn_spy;

f072359f493a5209335799da85ac16d6a273303bgryzor

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen struct mt_ctx *mt_ctx;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh

f072359f493a5209335799da85ac16d6a273303bgryzor char *provider;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim char *command;

f072359f493a5209335799da85ac16d6a273303bgryzor char *name;

f072359f493a5209335799da85ac16d6a273303bgryzor char *identity;

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic pid_t pid;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor int ping_time;

f072359f493a5209335799da85ac16d6a273303bgryzor int kill_time;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor bool svc_started;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor int restarts;

f072359f493a5209335799da85ac16d6a273303bgryzor time_t last_restart;

f072359f493a5209335799da85ac16d6a273303bgryzor int failed_pongs;

f072359f493a5209335799da85ac16d6a273303bgryzor DBusPendingCall *pending;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor int debug_level;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *ping_ev;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor struct sss_child_ctx *child_ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *sigkill_ev;

f072359f493a5209335799da85ac16d6a273303bgryzor};

ee649f9236fe7fcf255bbfa11f2cce080f996521sf

f072359f493a5209335799da85ac16d6a273303bgryzorstruct config_file_callback {

f072359f493a5209335799da85ac16d6a273303bgryzor int wd;

f072359f493a5209335799da85ac16d6a273303bgryzor int retries;

f072359f493a5209335799da85ac16d6a273303bgryzor monitor_reconf_fn fn;

f072359f493a5209335799da85ac16d6a273303bgryzor char *filename;

f072359f493a5209335799da85ac16d6a273303bgryzor time_t modified;

f072359f493a5209335799da85ac16d6a273303bgryzor struct config_file_callback *next;

f072359f493a5209335799da85ac16d6a273303bgryzor struct config_file_callback *prev;

f072359f493a5209335799da85ac16d6a273303bgryzor};

ac2a72149b423e2e84596098d7e47af88ebd215asf

f072359f493a5209335799da85ac16d6a273303bgryzorstruct config_file_ctx {

f072359f493a5209335799da85ac16d6a273303bgryzor TALLOC_CTX *parent_ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *timer;

f072359f493a5209335799da85ac16d6a273303bgryzor bool needs_update;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_ctx *mt_ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor struct config_file_callback *callbacks;

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstruct mt_ctx {

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_context *ev;

f072359f493a5209335799da85ac16d6a273303bgryzor struct confdb_ctx *cdb;

f072359f493a5209335799da85ac16d6a273303bgryzor TALLOC_CTX *domain_ctx; /* Memory context for domain list */

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic struct sss_domain_info *domains;

f072359f493a5209335799da85ac16d6a273303bgryzor TALLOC_CTX *service_ctx; /* Memory context for services */

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic char **services;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic int num_services;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic int started_services;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic struct mt_svc *svc_list;

f072359f493a5209335799da85ac16d6a273303bgryzor struct sbus_connection *sbus_srv;

f072359f493a5209335799da85ac16d6a273303bgryzor struct config_file_ctx *file_ctx;

30471a4650391f57975f60bbb6e4a90be7b284bfhumbedooh int inotify_fd;

f072359f493a5209335799da85ac16d6a273303bgryzor int service_id_timeout;

f072359f493a5209335799da85ac16d6a273303bgryzor bool check_children;

f072359f493a5209335799da85ac16d6a273303bgryzor bool services_started;

f072359f493a5209335799da85ac16d6a273303bgryzor struct netlink_ctx *nlctx;

48c64aeceef385e19025b384bd719b2a9789592dnd const char *conf_path;

f072359f493a5209335799da85ac16d6a273303bgryzor struct sss_sigchild_ctx *sigchld_ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor bool is_daemon;

f072359f493a5209335799da85ac16d6a273303bgryzor pid_t parent_pid;

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int start_service(struct mt_svc *mt_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_service_init(struct sbus_connection *conn, void *data);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_send_ping(struct mt_svc *svc);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_reset_offline(struct mt_svc *svc);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void ping_check(DBusPendingCall *pending, void *data);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void set_tasks_checker(struct mt_svc *srv);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_kill_service (struct mt_svc *svc);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int get_service_config(struct mt_ctx *ctx, const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc **svc_cfg);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int get_provider_config(struct mt_ctx *ctx, const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc **svc_cfg);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int add_new_service(struct mt_ctx *ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor int restarts);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int add_new_provider(struct mt_ctx *ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor int restarts);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int mark_service_as_started(struct mt_svc *svc);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_cleanup(void);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void network_status_change_cb(void *cb_data)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *iter;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_ctx *ctx = (struct mt_ctx *) cb_data;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_TRACE_INTERNAL, ("A networking status change detected "

f072359f493a5209335799da85ac16d6a273303bgryzor "signaling providers to reset offline status\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor for (iter = ctx->svc_list; iter; iter = iter->next) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* Don't signal services, only providers */

f072359f493a5209335799da85ac16d6a273303bgryzor if (iter->provider) {

f072359f493a5209335799da85ac16d6a273303bgryzor service_signal_reset_offline(iter);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int get_monitor_version(DBusMessage *message,

f072359f493a5209335799da85ac16d6a273303bgryzor struct sbus_connection *conn)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_uint16_t version = MONITOR_VERSION;

f072359f493a5209335799da85ac16d6a273303bgryzor DBusMessage *reply;

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_bool_t ret;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor reply = dbus_message_new_method_return(message);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!reply) return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor ret = dbus_message_append_args(reply,

f072359f493a5209335799da85ac16d6a273303bgryzor DBUS_TYPE_UINT16, &version,

f072359f493a5209335799da85ac16d6a273303bgryzor DBUS_TYPE_INVALID);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!ret) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim dbus_message_unref(reply);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return EIO;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* send reply back */

2d39a41e98476f5235b7c37ce745a4aa0904b1cbrbowen sbus_conn_send_reply(conn, reply);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim dbus_message_unref(reply);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return EOK;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim}

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjimstruct mon_init_conn {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct mt_ctx *ctx;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct sbus_connection *conn;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct tevent_timer *timeout;

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

ac2a72149b423e2e84596098d7e47af88ebd215asfstatic int add_svc_conn_spy(struct mt_svc *svc);

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asfstatic int client_registration(DBusMessage *message,

ac2a72149b423e2e84596098d7e47af88ebd215asf struct sbus_connection *conn)

ac2a72149b423e2e84596098d7e47af88ebd215asf{

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_uint16_t version = MONITOR_VERSION;

ac2a72149b423e2e84596098d7e47af88ebd215asf struct mon_init_conn *mini;

ac2a72149b423e2e84596098d7e47af88ebd215asf struct mt_svc *svc;

ac2a72149b423e2e84596098d7e47af88ebd215asf void *data;

ac2a72149b423e2e84596098d7e47af88ebd215asf DBusMessage *reply;

ac2a72149b423e2e84596098d7e47af88ebd215asf DBusError dbus_error;

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_uint16_t svc_ver;

ac2a72149b423e2e84596098d7e47af88ebd215asf char *svc_name;

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_bool_t dbret;

ac2a72149b423e2e84596098d7e47af88ebd215asf int ret;

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf data = sbus_conn_get_private_data(conn);

ac2a72149b423e2e84596098d7e47af88ebd215asf mini = talloc_get_type(data, struct mon_init_conn);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (!mini) {

ac2a72149b423e2e84596098d7e47af88ebd215asf DEBUG(0, ("Connection holds no valid init data\n"));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return EINVAL;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

ac2a72149b423e2e84596098d7e47af88ebd215asf /* First thing, cancel the timeout */

ac2a72149b423e2e84596098d7e47af88ebd215asf talloc_zfree(mini->timeout);

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_error_init(&dbus_error);

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf dbret = dbus_message_get_args(message, &dbus_error,

ac2a72149b423e2e84596098d7e47af88ebd215asf DBUS_TYPE_STRING, &svc_name,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DBUS_TYPE_UINT16, &svc_ver,

ac2a72149b423e2e84596098d7e47af88ebd215asf DBUS_TYPE_INVALID);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (!dbret) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(1, ("Failed to parse message, killing connection\n"));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (dbus_error_is_set(&dbus_error)) dbus_error_free(&dbus_error);

ac2a72149b423e2e84596098d7e47af88ebd215asf sbus_disconnect(conn);

ac2a72149b423e2e84596098d7e47af88ebd215asf /* FIXME: should we just talloc_zfree(conn) ? */

ac2a72149b423e2e84596098d7e47af88ebd215asf goto done;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(4, ("Received ID registration: (%s,%d)\n", svc_name, svc_ver));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* search this service in the list */

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc = mini->ctx->svc_list;

ac2a72149b423e2e84596098d7e47af88ebd215asf while (svc) {

ac2a72149b423e2e84596098d7e47af88ebd215asf ret = strcasecmp(svc->identity, svc_name);

ac2a72149b423e2e84596098d7e47af88ebd215asf if (ret == 0) {

ac2a72149b423e2e84596098d7e47af88ebd215asf break;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf svc = svc->next;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf if (!svc) {

ac2a72149b423e2e84596098d7e47af88ebd215asf DEBUG(0, ("Unable to find peer [%s] in list of services,"

ac2a72149b423e2e84596098d7e47af88ebd215asf " killing connection!\n", svc_name));

ac2a72149b423e2e84596098d7e47af88ebd215asf sbus_disconnect(conn);

ac2a72149b423e2e84596098d7e47af88ebd215asf /* FIXME: should we just talloc_zfree(conn) ? */

ac2a72149b423e2e84596098d7e47af88ebd215asf goto done;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* Fill in svc structure with connection data */

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->conn = mini->conn;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim ret = mark_service_as_started(svc);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (ret) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(1, ("Failed to mark service [%s]!\n", svc_name));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim goto done;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* reply that all is ok */

ac2a72149b423e2e84596098d7e47af88ebd215asf reply = dbus_message_new_method_return(message);

ac2a72149b423e2e84596098d7e47af88ebd215asf if (!reply) return ENOMEM;

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf dbret = dbus_message_append_args(reply,

ac2a72149b423e2e84596098d7e47af88ebd215asf DBUS_TYPE_UINT16, &version,

ac2a72149b423e2e84596098d7e47af88ebd215asf DBUS_TYPE_INVALID);

ac2a72149b423e2e84596098d7e47af88ebd215asf if (!dbret) {

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_message_unref(reply);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return EIO;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* send reply back */

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim sbus_conn_send_reply(conn, reply);

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_message_unref(reply);

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asfdone:

ac2a72149b423e2e84596098d7e47af88ebd215asf /* init complete, get rid of temp init context */

ac2a72149b423e2e84596098d7e47af88ebd215asf talloc_zfree(mini);

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf return EOK;

ac2a72149b423e2e84596098d7e47af88ebd215asf}

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asfstruct svc_spy {

ac2a72149b423e2e84596098d7e47af88ebd215asf struct mt_svc *svc;

ac2a72149b423e2e84596098d7e47af88ebd215asf};

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asfstatic int svc_destructor(void *mem)

ac2a72149b423e2e84596098d7e47af88ebd215asf{

ac2a72149b423e2e84596098d7e47af88ebd215asf struct mt_svc *svc = talloc_get_type(mem, struct mt_svc);

ac2a72149b423e2e84596098d7e47af88ebd215asf if (!svc) {

ac2a72149b423e2e84596098d7e47af88ebd215asf /* ?!?!? */

ac2a72149b423e2e84596098d7e47af88ebd215asf return 0;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* try to delist service */

ac2a72149b423e2e84596098d7e47af88ebd215asf if (svc->mt_ctx) {

ac2a72149b423e2e84596098d7e47af88ebd215asf DLIST_REMOVE(svc->mt_ctx->svc_list, svc);

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* Cancel any pending pings */

ac2a72149b423e2e84596098d7e47af88ebd215asf if (svc->pending) {

ac2a72149b423e2e84596098d7e47af88ebd215asf dbus_pending_call_cancel(svc->pending);

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* svc is beeing freed, neutralize the spy */

ac2a72149b423e2e84596098d7e47af88ebd215asf if (svc->conn_spy) {

ac2a72149b423e2e84596098d7e47af88ebd215asf talloc_set_destructor((TALLOC_CTX *)svc->conn_spy, NULL);

ac2a72149b423e2e84596098d7e47af88ebd215asf talloc_zfree(svc->conn_spy);

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf if (svc->type == MT_SVC_SERVICE && svc->svc_started

ac2a72149b423e2e84596098d7e47af88ebd215asf && svc->mt_ctx != NULL && svc->mt_ctx->started_services > 0) {

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->mt_ctx->started_services--;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf return 0;

ac2a72149b423e2e84596098d7e47af88ebd215asf}

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asfstatic int svc_spy_destructor(void *mem)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct svc_spy *spy = talloc_get_type(mem, struct svc_spy);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!spy) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* ?!?!? */

f072359f493a5209335799da85ac16d6a273303bgryzor return 0;

f072359f493a5209335799da85ac16d6a273303bgryzor }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* svc->conn has been freed, NULL the pointer in svc */

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim spy->svc->conn_spy = NULL;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim spy->svc->conn = NULL;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return 0;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int add_svc_conn_spy(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct svc_spy *spy;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor spy = talloc(svc->conn, struct svc_spy);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!spy) return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor spy->svc = svc;

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_set_destructor((TALLOC_CTX *)spy, svc_spy_destructor);

f072359f493a5209335799da85ac16d6a273303bgryzor svc->conn_spy = spy;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int mark_service_as_started(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_ctx *ctx = svc->mt_ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *iter;

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor int i;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(5, ("Marking %s as started.\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor svc->svc_started = true;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* we need to attach a spy to the connection structure so that if some code

f072359f493a5209335799da85ac16d6a273303bgryzor ret = add_svc_conn_spy(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret) {

48c64aeceef385e19025b384bd719b2a9789592dnd DEBUG(0, ("Failed to attch spy\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor goto done;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (!ctx->services_started) {

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* check if all providers are up */

f072359f493a5209335799da85ac16d6a273303bgryzor for (iter = ctx->svc_list; iter; iter = iter->next) {

f072359f493a5209335799da85ac16d6a273303bgryzor if (iter->provider && !iter->svc_started) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(5, ("Still waiting on %s provider.\n", iter->name));

f072359f493a5209335799da85ac16d6a273303bgryzor break;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (iter) {

eef716e54c415709ca9d53aad4678bf9d96186e6nd /* there are still unstarted providers */

f072359f493a5209335799da85ac16d6a273303bgryzor goto done;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ctx->services_started = true;

48c64aeceef385e19025b384bd719b2a9789592dnd

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(4, ("Now starting services!\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor /* then start all services */

f072359f493a5209335799da85ac16d6a273303bgryzor for (i = 0; ctx->services[i]; i++) {

f072359f493a5209335799da85ac16d6a273303bgryzor add_new_service(ctx, ctx->services[i], 0);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (svc->type == MT_SVC_SERVICE) {

f072359f493a5209335799da85ac16d6a273303bgryzor ctx->started_services++;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (ctx->started_services == ctx->num_services) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* Initialization is complete, terminate parent process if in daemon

f072359f493a5209335799da85ac16d6a273303bgryzor if (ctx->is_daemon) {

f072359f493a5209335799da85ac16d6a273303bgryzor if (ctx->parent_pid <= 1 || ctx->parent_pid != getppid()) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* the parent process was already terminated */

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_MINOR_FAILURE, ("Invalid parent pid: %d\n",

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim ctx->parent_pid));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim goto done;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(SSSDBG_TRACE_FUNC, ("SSSD is initialized, "

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim "terminating parent process\n"));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim errno = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor ret = kill(ctx->parent_pid, SIGTERM);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor ret = errno;

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_FATAL_FAILURE, ("Unable to terminate parent "

f072359f493a5209335799da85ac16d6a273303bgryzor "process [%d]: %s\n", ret, strerror(ret)));

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzordone:

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void services_startup_timeout(struct tevent_context *ev,

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *te,

f072359f493a5209335799da85ac16d6a273303bgryzor struct timeval t, void *ptr)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_ctx *ctx = talloc_get_type(ptr, struct mt_ctx);

f072359f493a5209335799da85ac16d6a273303bgryzor int i;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(6, ("Handling timeout\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (!ctx->services_started) {

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic DEBUG(1, ("Providers did not start in time, "

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic "forcing services startup!\n"));

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic ctx->services_started = true;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic DEBUG(4, ("Now starting services!\n"));

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic /* then start all services */

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic for (i = 0; ctx->services[i]; i++) {

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic add_new_service(ctx, ctx->services[i], 0);

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic }

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic }

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic}

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int add_services_startup_timeout(struct mt_ctx *ctx)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *to;

f072359f493a5209335799da85ac16d6a273303bgryzor struct timeval tv;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* 5 seconds should be plenty */

f072359f493a5209335799da85ac16d6a273303bgryzor tv = tevent_timeval_current_ofs(5, 0);

f072359f493a5209335799da85ac16d6a273303bgryzor to = tevent_add_timer(ctx->ev, ctx, tv, services_startup_timeout, ctx);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!to) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0,("Out of memory?!\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstruct sbus_method monitor_methods[] = {

f072359f493a5209335799da85ac16d6a273303bgryzor { MON_SRV_METHOD_VERSION, get_monitor_version },

f072359f493a5209335799da85ac16d6a273303bgryzor { MON_SRV_METHOD_REGISTER, client_registration },

f072359f493a5209335799da85ac16d6a273303bgryzor { NULL, NULL }

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstruct sbus_interface monitor_server_interface = {

f072359f493a5209335799da85ac16d6a273303bgryzor MON_SRV_INTERFACE,

f072359f493a5209335799da85ac16d6a273303bgryzor MON_SRV_PATH,

f072359f493a5209335799da85ac16d6a273303bgryzor SBUS_DEFAULT_VTABLE,

f072359f493a5209335799da85ac16d6a273303bgryzor monitor_methods,

f072359f493a5209335799da85ac16d6a273303bgryzor NULL

f072359f493a5209335799da85ac16d6a273303bgryzor};

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_dbus_init(struct mt_ctx *ctx)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor char *monitor_address;

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen int ret;

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen ret = monitor_get_sbus_address(ctx, &monitor_address);

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen if (ret != EOK) {

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen return ret;

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen }

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen ret = sbus_new_server(ctx, ctx->ev,

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen monitor_address, &monitor_server_interface,

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen false, &ctx->sbus_srv, monitor_service_init, ctx);

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen talloc_free(monitor_address);

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen return ret;

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen}

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowenstatic void tasks_check_handler(struct tevent_context *ev,

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh struct tevent_timer *te,

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh struct timeval t, void *ptr)

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh{

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh struct mt_svc *svc = talloc_get_type(ptr, struct mt_svc);

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh int ret;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh ret = service_send_ping(svc);

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh switch (ret) {

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh case EOK:

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh /* all fine */

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh break;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh case ENXIO:

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh DEBUG(1,("Child (%s) not responding! (yet)\n", svc->name));

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh break;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh default:

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh /* TODO: should we tear it down ? */

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh DEBUG(1,("Sending a message to service (%s) failed!!\n", svc->name));

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh break;

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen }

45a544a8bb3fa1f95e5edac9fb3e723e2bb7001drbowen

f072359f493a5209335799da85ac16d6a273303bgryzor if (svc->failed_pongs >= 3) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* too long since we last heard of this process */

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_CRIT_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Killing service [%s], not responding to pings!\n",

f072359f493a5209335799da85ac16d6a273303bgryzor svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* Kill the service. The SIGCHLD handler will restart it */

f072359f493a5209335799da85ac16d6a273303bgryzor monitor_kill_service(svc);

48c64aeceef385e19025b384bd719b2a9789592dnd return;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* all fine, set up the task checker again */

f072359f493a5209335799da85ac16d6a273303bgryzor set_tasks_checker(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void set_tasks_checker(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *te = NULL;

f072359f493a5209335799da85ac16d6a273303bgryzor struct timeval tv;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor gettimeofday(&tv, NULL);

f072359f493a5209335799da85ac16d6a273303bgryzor tv.tv_sec += svc->ping_time;

f072359f493a5209335799da85ac16d6a273303bgryzor tv.tv_usec = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor te = tevent_add_timer(svc->mt_ctx->ev, svc, tv, tasks_check_handler, svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (te == NULL) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("failed to add event, monitor offline for [%s]!\n",

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc->name));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* FIXME: shutdown ? */

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh }

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh svc->ping_ev = te;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh}

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjimstatic void mt_svc_sigkill(struct tevent_context *ev,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct tevent_timer *te,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct timeval t, void *ptr);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjimstatic int monitor_kill_service (struct mt_svc *svc)

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh{

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh int ret;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh struct timeval tv;

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh ret = kill(svc->pid, SIGTERM);

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh if (ret != EOK) {

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh DEBUG(SSSDBG_FATAL_FAILURE,

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh ("Sending signal to child (%s:%d) failed! "

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh "Ignore and pretend child is dead.\n",

15e38d431fea66258ef33960b39edee496c3c9c2humbedooh svc->name, svc->pid));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* Set up a timer to send SIGKILL if this process

f072359f493a5209335799da85ac16d6a273303bgryzor tv = tevent_timeval_current_ofs(svc->kill_time, 0);

f072359f493a5209335799da85ac16d6a273303bgryzor svc->sigkill_ev = tevent_add_timer(svc->mt_ctx->ev, svc, tv,

f072359f493a5209335799da85ac16d6a273303bgryzor mt_svc_sigkill, svc);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

48c64aeceef385e19025b384bd719b2a9789592dnd}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void mt_svc_sigkill(struct tevent_context *ev,

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_timer *te,

f072359f493a5209335799da85ac16d6a273303bgryzor struct timeval t, void *ptr)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *svc = talloc_get_type(ptr, struct mt_svc);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(SSSDBG_FATAL_FAILURE,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim ("[%s][%d] is not responding to SIGTERM. Sending SIGKILL.\n",

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc->name, svc->pid));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

f072359f493a5209335799da85ac16d6a273303bgryzor ret = kill(svc->pid, SIGKILL);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_FATAL_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Sending signal to child (%s:%d) failed! "

f072359f493a5209335799da85ac16d6a273303bgryzor "Ignore and pretend child is dead.\n",

f072359f493a5209335799da85ac16d6a273303bgryzor svc->name, svc->pid));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void reload_reply(DBusPendingCall *pending, void *data)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor DBusMessage *reply;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *svc = talloc_get_type(data, struct mt_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor reply = dbus_pending_call_steal_reply(pending);

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic if (!reply) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* reply should never be null. This function shouldn't be called

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("A reply callback was called but no reply was received"

f072359f493a5209335799da85ac16d6a273303bgryzor " and no timeout occurred\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor /* Destroy this connection */

f072359f493a5209335799da85ac16d6a273303bgryzor sbus_disconnect(svc->conn);

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_pending_call_unref(pending);

f072359f493a5209335799da85ac16d6a273303bgryzor return;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

e797af4d7b0cada1278d72d6c8ac77210ef78632minfrin /* TODO: Handle cases where the call has timed out or returned

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_pending_call_unref(pending);

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_message_unref(reply);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_dns_reload(struct mt_svc *svc);

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_update_resolv(struct config_file_ctx *file_ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor const char *filename)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *cur_svc;

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(2, ("Resolv.conf has been updated. Reloading.\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = res_init();

f072359f493a5209335799da85ac16d6a273303bgryzor if(ret != 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor return EIO;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* Signal all services to reload their DNS configuration */

f072359f493a5209335799da85ac16d6a273303bgryzor for(cur_svc = file_ctx->mt_ctx->svc_list; cur_svc; cur_svc = cur_svc->next) {

f072359f493a5209335799da85ac16d6a273303bgryzor service_signal_dns_reload(cur_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal(struct mt_svc *svc, const char *svc_signal)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor DBusMessage *msg;

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor

b71e5eae594d54e9e56dc20208c6a7fb52610e29rbowen if (svc->provider && strcasecmp(svc->provider, "local") == 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* The local provider requires no signaling */

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->conn) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* Avoid a race condition where we are trying to

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(1,("Could not signal service [%s].\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor return EIO;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor msg = dbus_message_new_method_call(NULL,

f072359f493a5209335799da85ac16d6a273303bgryzor MONITOR_PATH,

f072359f493a5209335799da85ac16d6a273303bgryzor MONITOR_INTERFACE,

f072359f493a5209335799da85ac16d6a273303bgryzor svc_signal);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!msg) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0,("Out of memory?!\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor monitor_kill_service(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = sbus_conn_send(svc->conn, msg,

f072359f493a5209335799da85ac16d6a273303bgryzor svc->mt_ctx->service_id_timeout,

f072359f493a5209335799da85ac16d6a273303bgryzor reload_reply, svc, NULL);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor dbus_message_unref(msg);

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_dns_reload(struct mt_svc *svc)

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic{

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic return service_signal(svc, MON_CLI_METHOD_RES_INIT);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_offline(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor return service_signal(svc, MON_CLI_METHOD_OFFLINE);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_reset_offline(struct mt_svc *svc)

48c64aeceef385e19025b384bd719b2a9789592dnd{

f072359f493a5209335799da85ac16d6a273303bgryzor return service_signal(svc, MON_CLI_METHOD_RESET_OFFLINE);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int service_signal_rotate(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor return service_signal(svc, MON_CLI_METHOD_ROTATE);

e797af4d7b0cada1278d72d6c8ac77210ef78632minfrin}

eef716e54c415709ca9d53aad4678bf9d96186e6ndstatic int service_signal_clear_memcache(struct mt_svc *svc)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor return service_signal(svc, MON_CLI_METHOD_CLEAR_MEMCACHE);

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int check_domain_ranges(struct sss_domain_info *domains)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor struct sss_domain_info *dom = domains, *other = NULL;

f072359f493a5209335799da85ac16d6a273303bgryzor uint32_t id_min, id_max;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor while (dom) {

f072359f493a5209335799da85ac16d6a273303bgryzor other = dom->next;

f072359f493a5209335799da85ac16d6a273303bgryzor if (dom->id_max && dom->id_min > dom->id_max) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_CRIT_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Domain '%s' does not have a valid ID range\n", dom->name));

f072359f493a5209335799da85ac16d6a273303bgryzor return EINVAL;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor while (other) {

f072359f493a5209335799da85ac16d6a273303bgryzor id_min = MAX(dom->id_min, other->id_min);

f072359f493a5209335799da85ac16d6a273303bgryzor id_max = MIN((dom->id_max ? dom->id_max : UINT32_MAX),

f072359f493a5209335799da85ac16d6a273303bgryzor (other->id_max ? other->id_max : UINT32_MAX));

f072359f493a5209335799da85ac16d6a273303bgryzor if (id_min <= id_max) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_MINOR_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Domains '%s' and '%s' overlap in range %u - %u\n",

eef716e54c415709ca9d53aad4678bf9d96186e6nd dom->name, other->name, id_min, id_max));

f072359f493a5209335799da85ac16d6a273303bgryzor }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim other = other->next;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim dom = dom->next;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

eef716e54c415709ca9d53aad4678bf9d96186e6ndstatic int check_local_domain_unique(struct sss_domain_info *domains)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor uint8_t count = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim struct sss_domain_info *dom = domains;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim while (dom) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (strcasecmp(dom->provider, "local") == 0) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim count++;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (count > 1) {

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd break;

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd }

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd dom = dom->next;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic if (count > 1) {

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic return EINVAL;

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf }

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic return EOK;

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic}

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalicstatic char *check_services(char **services)

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic{

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf const char *known_services[] = { "nss", "pam", "sudo", "autofs", "ssh",

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf "pac", NULL };

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf int i;

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf int ii;

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf /* Check if services we are about to start are in the list if known */

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf for (i = 0; services[i]; i++) {

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf for (ii=0; known_services[ii]; ii++) {

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf if (strcasecmp(services[i], known_services[ii]) == 0) {

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf break;

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf }

4c47688d73a9a5ef2735cd84f334b8eb814c74f0igalic }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (known_services[ii] == NULL) {

f072359f493a5209335799da85ac16d6a273303bgryzor return services[i];

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return NULL;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

48c64aeceef385e19025b384bd719b2a9789592dndint get_monitor_config(struct mt_ctx *ctx)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor int timeout_seconds;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic char *badsrv = NULL;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic int i;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_int(ctx->cdb,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_MONITOR_CONF_ENTRY,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_MONITOR_SBUS_TIMEOUT,

f072359f493a5209335799da85ac16d6a273303bgryzor 10, &timeout_seconds);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ctx->service_id_timeout = timeout_seconds * 1000; /* service_id_timeout is in ms */

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ctx->service_ctx = talloc_new(ctx);

f072359f493a5209335799da85ac16d6a273303bgryzor if(!ctx->service_ctx) {

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_string_as_list(ctx->cdb, ctx->service_ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_MONITOR_CONF_ENTRY,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_MONITOR_ACTIVE_SERVICES,

f072359f493a5209335799da85ac16d6a273303bgryzor &ctx->services);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("No services configured!\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor return EINVAL;

f072359f493a5209335799da85ac16d6a273303bgryzor }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick badsrv = check_services(ctx->services);

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if (badsrv != NULL) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("Invalid service %s\n", badsrv));

f072359f493a5209335799da85ac16d6a273303bgryzor return EINVAL;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ctx->started_services = 0;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ctx->num_services = 0;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick for (i = 0; ctx->services[i] != NULL; i++) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ctx->num_services++;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ctx->domain_ctx = talloc_new(ctx);

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if(!ctx->domain_ctx) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick return ENOMEM;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ret = confdb_get_domains(ctx->cdb, &ctx->domains);

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if (ret != EOK) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick DEBUG(0, ("No domains configured.\n"));

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick return ret;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ret = check_local_domain_unique(ctx->domains);

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if (ret != EOK) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick DEBUG(0, ("More than one local domain configured.\n"));

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick return ret;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick /* Check UID/GID overlaps */

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick ret = check_domain_ranges(ctx->domains);

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if (ret != EOK) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick return ret;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick }

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick return EOK;

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick}

f072359f493a5209335799da85ac16d6a273303bgryzor

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjimstatic errno_t get_ping_config(struct mt_ctx *ctx, const char *path,

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic struct mt_svc *svc)

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim{

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim errno_t ret;

f072359f493a5209335799da85ac16d6a273303bgryzor

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic ret = confdb_get_int(ctx->cdb, path,

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic CONFDB_DOMAIN_TIMEOUT,

f072359f493a5209335799da85ac16d6a273303bgryzor MONITOR_DEF_PING_TIME, &svc->ping_time);

3739b903eb6f5b0944056b2e98d5d8877d003c6figalic if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_CRIT_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Failed to get ping timeout for '%s'\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

f072359f493a5209335799da85ac16d6a273303bgryzor

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim /* 'timeout = 0' should be translated to the default */

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (svc->ping_time == 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->ping_time = MONITOR_DEF_PING_TIME;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_int(ctx->cdb, path,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_SERVICE_FORCE_TIMEOUT,

f072359f493a5209335799da85ac16d6a273303bgryzor MONITOR_DEF_FORCE_TIME, &svc->kill_time);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_CRIT_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Failed to get kill timeout for %s\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* 'force_timeout = 0' should be translated to the default */

f072359f493a5209335799da85ac16d6a273303bgryzor if (svc->kill_time == 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->kill_time = MONITOR_DEF_FORCE_TIME;

48c64aeceef385e19025b384bd719b2a9789592dnd }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int get_service_config(struct mt_ctx *ctx, const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc **svc_cfg)

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor char *path;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *svc;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim time_t now = time(NULL);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

f072359f493a5209335799da85ac16d6a273303bgryzor *svc_cfg = NULL;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc = talloc_zero(ctx, struct mt_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc) {

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor svc->mt_ctx = ctx;

f072359f493a5209335799da85ac16d6a273303bgryzor svc->type = MT_SVC_SERVICE;

f072359f493a5209335799da85ac16d6a273303bgryzor

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen talloc_set_destructor((TALLOC_CTX *)svc, svc_destructor);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc->name = talloc_strdup(svc, name);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->name) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc->identity = talloc_strdup(svc, name);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->identity) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor path = talloc_asprintf(svc, CONFDB_SERVICE_PATH_TMPL, svc->name);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!path) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_string(ctx->cdb, svc, path,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_SERVICE_COMMAND,

f072359f493a5209335799da85ac16d6a273303bgryzor NULL, &svc->command);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0,("Failed to start service '%s'\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command = talloc_asprintf(

f072359f493a5209335799da85ac16d6a273303bgryzor svc, "%s/sssd_%s", SSSD_LIBEXEC_PATH, svc->name

f072359f493a5209335799da85ac16d6a273303bgryzor );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (cmdline_debug_level != SSSDBG_UNRESOLVED) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command = talloc_asprintf_append(

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command, " -d %#.4x", cmdline_debug_level

f072359f493a5209335799da85ac16d6a273303bgryzor );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (cmdline_debug_timestamps != SSSDBG_TIMESTAMP_UNRESOLVED) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command = talloc_asprintf_append(

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command, " --debug-timestamps=%d", cmdline_debug_timestamps

f072359f493a5209335799da85ac16d6a273303bgryzor );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (cmdline_debug_microseconds != SSSDBG_MICROSECONDS_UNRESOLVED) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command = talloc_asprintf_append(

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command, " --debug-microseconds=%d",

f072359f493a5209335799da85ac16d6a273303bgryzor cmdline_debug_microseconds

f072359f493a5209335799da85ac16d6a273303bgryzor );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd talloc_free(svc);

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd return ENOMEM;

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd }

7cc5e8f14e6ab2d8b60bb0eaba4b68b00d320b29nd }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor if (debug_to_file) {

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command = talloc_strdup_append(

f072359f493a5209335799da85ac16d6a273303bgryzor svc->command, " --debug-to-files"

f072359f493a5209335799da85ac16d6a273303bgryzor );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

48c64aeceef385e19025b384bd719b2a9789592dnd

f072359f493a5209335799da85ac16d6a273303bgryzor ret = get_ping_config(ctx, path, svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_CRIT_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Failed to get ping timeouts for %s\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc->last_restart = now;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

f072359f493a5209335799da85ac16d6a273303bgryzor *svc_cfg = svc;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_free(path);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int add_new_service(struct mt_ctx *ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor const char *name,

48c64aeceef385e19025b384bd719b2a9789592dnd int restarts)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *svc;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = get_service_config(ctx, name, &svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor svc->restarts = restarts;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = start_service(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

44a442483c2ae67ab94061b87ca3312bc83b059crbowen DEBUG(0,("Failed to start service '%s'\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int get_provider_config(struct mt_ctx *ctx, const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc **svc_cfg)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor char *path;

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *svc;

f072359f493a5209335799da85ac16d6a273303bgryzor time_t now = time(NULL);

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor *svc_cfg = NULL;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc = talloc_zero(ctx, struct mt_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc) {

eef716e54c415709ca9d53aad4678bf9d96186e6nd return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc->mt_ctx = ctx;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc->type = MT_SVC_PROVIDER;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_set_destructor((TALLOC_CTX *)svc, svc_destructor);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim svc->name = talloc_strdup(svc, name);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->name) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

eef716e54c415709ca9d53aad4678bf9d96186e6nd return ENOMEM;

eef716e54c415709ca9d53aad4678bf9d96186e6nd }

f072359f493a5209335799da85ac16d6a273303bgryzor

44a442483c2ae67ab94061b87ca3312bc83b059crbowen svc->identity = talloc_asprintf(svc, "%%BE_%s", svc->name);

44a442483c2ae67ab94061b87ca3312bc83b059crbowen if (!svc->identity) {

44a442483c2ae67ab94061b87ca3312bc83b059crbowen talloc_free(svc);

44a442483c2ae67ab94061b87ca3312bc83b059crbowen return ENOMEM;

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen path = talloc_asprintf(svc, CONFDB_DOMAIN_PATH_TMPL, name);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (!path) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_free(svc);

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_string(ctx->cdb, svc, path,

f072359f493a5209335799da85ac16d6a273303bgryzor CONFDB_DOMAIN_ID_PROVIDER,

f072359f493a5209335799da85ac16d6a273303bgryzor NULL, &svc->provider);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("Failed to find ID provider from [%s] configuration\n", name));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor ret = confdb_get_string(ctx->cdb, svc, path,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim CONFDB_DOMAIN_COMMAND,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim NULL, &svc->command);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (ret != EOK) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(0, ("Failed to find command from [%s] configuration\n", name));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_free(svc);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return ret;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim }

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim ret = get_ping_config(ctx, path, svc);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (ret != EOK) {

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim DEBUG(SSSDBG_CRIT_FAILURE,

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim ("Failed to get ping timeouts for %s\n", svc->name));

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim talloc_free(svc);

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim return ret;

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(path);

eef716e54c415709ca9d53aad4678bf9d96186e6nd

f072359f493a5209335799da85ac16d6a273303bgryzor /* if no provider is present do not run the domain */

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->provider) {

ac2a72149b423e2e84596098d7e47af88ebd215asf talloc_free(svc);

ac2a72149b423e2e84596098d7e47af88ebd215asf return EIO;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf /* if there are no custom commands, build a default one */

ac2a72149b423e2e84596098d7e47af88ebd215asf if (!svc->command) {

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->command = talloc_asprintf(

ac2a72149b423e2e84596098d7e47af88ebd215asf svc, "%s/sssd_be --domain %s", SSSD_LIBEXEC_PATH, svc->name

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen );

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen if (!svc->command) {

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen talloc_free(svc);

92fd3fe66fb218b9fdf129e7555bd851e5cbf487rbowen return ENOMEM;

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf if (cmdline_debug_level != SSSDBG_UNRESOLVED) {

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->command = talloc_asprintf_append(

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->command, " -d %#.4x", cmdline_debug_level

ac2a72149b423e2e84596098d7e47af88ebd215asf );

f072359f493a5209335799da85ac16d6a273303bgryzor if (!svc->command) {

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe talloc_free(svc);

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe return ENOMEM;

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe }

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe }

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe if (cmdline_debug_timestamps != SSSDBG_TIMESTAMP_UNRESOLVED) {

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe svc->command = talloc_asprintf_append(

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe svc->command, " --debug-timestamps=%d", cmdline_debug_timestamps

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe );

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe if (!svc->command) {

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe talloc_free(svc);

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe return ENOMEM;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe }

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe }

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe if (cmdline_debug_microseconds != SSSDBG_MICROSECONDS_UNRESOLVED) {

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe svc->command = talloc_asprintf_append(

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe svc->command, " --debug-microseconds=%d",

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe cmdline_debug_microseconds

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe );

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe if (!svc->command) {

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe talloc_free(svc);

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe return ENOMEM;

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe }

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe }

cd34a6fbf0a2619544a72eadb73f309370bf6682wrowe

f072359f493a5209335799da85ac16d6a273303bgryzor if (debug_to_file) {

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick svc->command = talloc_strdup_append(

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe svc->command, " --debug-to-files"

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim );

737a1f4117ce00c29a1b78b93db08e4a273ab2edtrawick if (!svc->command) {

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

7f0952c0239ea2d6e37b472db6fde4ef2718343dsf return ENOMEM;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor svc->last_restart = now;

f072359f493a5209335799da85ac16d6a273303bgryzor

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe *svc_cfg = svc;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe return EOK;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe}

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowestatic int add_new_provider(struct mt_ctx *ctx,

f072359f493a5209335799da85ac16d6a273303bgryzor const char *name,

f072359f493a5209335799da85ac16d6a273303bgryzor int restarts)

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe{

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe int ret;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe struct mt_svc *svc;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe ret = get_provider_config(ctx, name, &svc);

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("Could not get provider configuration for [%s]\n",

f072359f493a5209335799da85ac16d6a273303bgryzor name));

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe return ret;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe }

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe svc->restarts = restarts;

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe if (strcasecmp(svc->provider, "local") == 0) {

7e9c796f2dc0dba993a817b3a58cfd56b4e511edwrowe /* The LOCAL provider requires no back-end currently

f072359f493a5209335799da85ac16d6a273303bgryzor svc->svc_started = true;

f072359f493a5209335799da85ac16d6a273303bgryzor DLIST_ADD(ctx->svc_list, svc);

f072359f493a5209335799da85ac16d6a273303bgryzor return ENOENT;

f072359f493a5209335799da85ac16d6a273303bgryzor }

48c64aeceef385e19025b384bd719b2a9789592dnd

f072359f493a5209335799da85ac16d6a273303bgryzor ret = start_service(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret != EOK) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0,("Failed to start service '%s'\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor talloc_free(svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

48c64aeceef385e19025b384bd719b2a9789592dnd

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void monitor_hup(struct tevent_context *ev,

f072359f493a5209335799da85ac16d6a273303bgryzor struct tevent_signal *se,

f072359f493a5209335799da85ac16d6a273303bgryzor int signum,

f072359f493a5209335799da85ac16d6a273303bgryzor int count,

f072359f493a5209335799da85ac16d6a273303bgryzor void *siginfo,

f072359f493a5209335799da85ac16d6a273303bgryzor void *private_data)

f072359f493a5209335799da85ac16d6a273303bgryzor{

48c64aeceef385e19025b384bd719b2a9789592dnd struct mt_ctx *ctx = talloc_get_type(private_data, struct mt_ctx);

f072359f493a5209335799da85ac16d6a273303bgryzor struct mt_svc *cur_svc;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(1, ("Received SIGHUP.\n"));

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor /* Send D-Bus message to other services to rotate their logs.

f072359f493a5209335799da85ac16d6a273303bgryzor for(cur_svc = ctx->svc_list; cur_svc; cur_svc = cur_svc->next) {

f072359f493a5209335799da85ac16d6a273303bgryzor service_signal_rotate(cur_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!strcmp(NSS_SBUS_SERVICE_NAME, cur_svc->name)) {

f072359f493a5209335799da85ac16d6a273303bgryzor service_signal_clear_memcache(cur_svc);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic int monitor_cleanup(void)

f072359f493a5209335799da85ac16d6a273303bgryzor{

f072359f493a5209335799da85ac16d6a273303bgryzor int ret;

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor errno = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor ret = unlink(SSSD_PIDFILE_PATH);

f072359f493a5209335799da85ac16d6a273303bgryzor if (ret == -1) {

f072359f493a5209335799da85ac16d6a273303bgryzor ret = errno;

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(SSSDBG_FATAL_FAILURE,

f072359f493a5209335799da85ac16d6a273303bgryzor ("Error removing pidfile! (%d [%s])\n", ret, strerror(ret)));

f072359f493a5209335799da85ac16d6a273303bgryzor return ret;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor return EOK;

f072359f493a5209335799da85ac16d6a273303bgryzor}

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzorstatic void monitor_quit(struct mt_ctx *mt_ctx, int ret)

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic{

48c64aeceef385e19025b384bd719b2a9789592dnd struct mt_svc *svc;

f072359f493a5209335799da85ac16d6a273303bgryzor pid_t pid;

f072359f493a5209335799da85ac16d6a273303bgryzor int status;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic errno_t error;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic int kret;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic bool killed;

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic DEBUG(SSSDBG_IMPORTANT_INFO, ("Returned with: %d\n", ret));

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic /* Kill all of our known children manually */

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic DLIST_FOR_EACH(svc, mt_ctx->svc_list) {

70f5253b24dd333c67fb6502d557a8b48ad3ba87igalic if (svc->pid == 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* The local provider has no PID */

f072359f493a5209335799da85ac16d6a273303bgryzor continue;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor killed = false;

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(1, ("Terminating [%s][%d]\n", svc->name, svc->pid));

f072359f493a5209335799da85ac16d6a273303bgryzor do {

f072359f493a5209335799da85ac16d6a273303bgryzor errno = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor kret = kill(svc->pid, SIGTERM);

f072359f493a5209335799da85ac16d6a273303bgryzor if (kret < 0) {

ac2a72149b423e2e84596098d7e47af88ebd215asf error = errno;

ac2a72149b423e2e84596098d7e47af88ebd215asf DEBUG(1, ("Couldn't kill [%s][%d]: [%s]\n",

ac2a72149b423e2e84596098d7e47af88ebd215asf svc->name, svc->pid, strerror(error)));

ac2a72149b423e2e84596098d7e47af88ebd215asf }

ac2a72149b423e2e84596098d7e47af88ebd215asf

ac2a72149b423e2e84596098d7e47af88ebd215asf error = 0;

ac2a72149b423e2e84596098d7e47af88ebd215asf do {

ac2a72149b423e2e84596098d7e47af88ebd215asf errno = 0;

ac2a72149b423e2e84596098d7e47af88ebd215asf pid = waitpid(svc->pid, &status, WNOHANG);

ac2a72149b423e2e84596098d7e47af88ebd215asf if (pid == -1) {

ac2a72149b423e2e84596098d7e47af88ebd215asf /* An error occurred while waiting */

ac2a72149b423e2e84596098d7e47af88ebd215asf error = errno;

27a7b74f8c50bd6074b0c71fae9927a71fde5b3fjim if (error != EINTR) {

ac2a72149b423e2e84596098d7e47af88ebd215asf DEBUG(0, ("[%d][%s] while waiting for [%s]\n",

f072359f493a5209335799da85ac16d6a273303bgryzor error, strerror(error), svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor /* Forcibly kill this child */

ac2a72149b423e2e84596098d7e47af88ebd215asf kill(svc->pid, SIGKILL);

ac2a72149b423e2e84596098d7e47af88ebd215asf break;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor } else if (pid != 0) {

f072359f493a5209335799da85ac16d6a273303bgryzor error = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor if WIFEXITED(status) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(1, ("Child [%s] exited gracefully\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor } else if WIFSIGNALED(status) {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(1, ("Child [%s] terminated with a signal\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor } else {

f072359f493a5209335799da85ac16d6a273303bgryzor DEBUG(0, ("Child [%s] did not exit cleanly\n", svc->name));

f072359f493a5209335799da85ac16d6a273303bgryzor /* Forcibly kill this child */

f072359f493a5209335799da85ac16d6a273303bgryzor kill(svc->pid, SIGKILL);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor killed = true;

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor } while (error == EINTR);

f072359f493a5209335799da85ac16d6a273303bgryzor if (!killed) {

f072359f493a5209335799da85ac16d6a273303bgryzor /* Sleep 10ms and try again */

f072359f493a5209335799da85ac16d6a273303bgryzor usleep(10000);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor } while (!killed);

f072359f493a5209335799da85ac16d6a273303bgryzor }

f072359f493a5209335799da85ac16d6a273303bgryzor

f072359f493a5209335799da85ac16d6a273303bgryzor#if HAVE_GETPGRP

f072359f493a5209335799da85ac16d6a273303bgryzor /* Kill any remaining children in our process group, just in case

f072359f493a5209335799da85ac16d6a273303bgryzor error = 0;

f072359f493a5209335799da85ac16d6a273303bgryzor if (getpgrp() == getpid()) {

f072359f493a5209335799da85ac16d6a273303bgryzor kill(-getpgrp(), SIGTERM);