cmd_tasks.c File Reference

#include <rz_cmd.h>
#include <rz_core.h>
#include <cmd_descs.h>

Go to the source code of this file.

Functions
static int	task_enqueue (RzCore *core, const char *cmd, bool transient)
static int	task_output (RzCore *core, int tid)
static int	task_break (RzCore *core, int tid)
RZ_IPI RzCmdStatus	rz_tasks_handler (RzCore *core, int argc, const char **argv, RzOutputMode mode)
RZ_IPI RzCmdStatus	rz_tasks_transient_handler (RzCore *core, int argc, const char **argv)
RZ_IPI RzCmdStatus	rz_tasks_output_handler (RzCore *core, int argc, const char **argv)
RZ_IPI RzCmdStatus	rz_tasks_break_handler (RzCore *core, int argc, const char **argv)
RZ_IPI RzCmdStatus	rz_tasks_delete_handler (RzCore *core, int argc, const char **argv)
RZ_IPI RzCmdStatus	rz_tasks_delete_all_handler (RzCore *core, int argc, const char **argv)
RZ_IPI RzCmdStatus	rz_tasks_wait_handler (RzCore *core, int argc, const char **argv)

Function Documentation

rz_tasks_break_handler()

RZ_IPI RzCmdStatus rz_tasks_break_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 66 of file cmd_tasks.c.

                                                                                     {
    int tid = rz_num_math(core->num, argv[1]);
    return rz_cmd_int2status(task_break(core, tid));
}

References argv, rz_core_t::num, rz_num_math(), and task_break().

Referenced by rzshell_cmddescs_init().

rz_tasks_delete_all_handler()

RZ_IPI RzCmdStatus rz_tasks_delete_all_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 79 of file cmd_tasks.c.

                                                                                          {
    rz_core_task_del_all_done(core);
    return RZ_CMD_STATUS_OK;
}

References RZ_CMD_STATUS_OK, and rz_core_task_del_all_done().

Referenced by rzshell_cmddescs_init().

rz_tasks_delete_handler()

RZ_IPI RzCmdStatus rz_tasks_delete_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 71 of file cmd_tasks.c.

                                                                                      {
    int tid = rz_num_math(core->num, argv[1]);
    if (!rz_core_task_is_cmd(core, tid)) {
        return RZ_CMD_STATUS_ERROR;
    }
    return rz_core_task_del(&core->tasks, tid) ? RZ_CMD_STATUS_OK : RZ_CMD_STATUS_ERROR;
}

References argv, rz_core_t::num, RZ_CMD_STATUS_ERROR, RZ_CMD_STATUS_OK, rz_core_task_del(), rz_core_task_is_cmd(), rz_num_math(), and rz_core_t::tasks.

Referenced by rzshell_cmddescs_init().

rz_tasks_handler()

RZ_IPI RzCmdStatus rz_tasks_handler	(	RzCore *	core,
		int	argc,
		const char **	argv,
		RzOutputMode	mode
	)

Definition at line 47 of file cmd_tasks.c.

                                                                                                  {
    if (argc == 1) {
        rz_core_task_list(core, mode == RZ_OUTPUT_MODE_STANDARD ? '\0' : 'j');
        return RZ_CMD_STATUS_OK;
    } else if (argc == 2) {
        return rz_cmd_int2status(task_enqueue(core, argv[1], false));
    }
    return RZ_CMD_STATUS_ERROR;
}

References argv, RZ_CMD_STATUS_ERROR, RZ_CMD_STATUS_OK, rz_core_task_list(), RZ_OUTPUT_MODE_STANDARD, and task_enqueue().

Referenced by rzshell_cmddescs_init().

rz_tasks_output_handler()

RZ_IPI RzCmdStatus rz_tasks_output_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 61 of file cmd_tasks.c.

                                                                                      {
    int tid = rz_num_math(core->num, argv[1]);
    return rz_cmd_int2status(task_output(core, tid));
}

References argv, rz_core_t::num, rz_num_math(), and task_output().

Referenced by rzshell_cmddescs_init().

rz_tasks_transient_handler()

RZ_IPI RzCmdStatus rz_tasks_transient_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 57 of file cmd_tasks.c.

                                                                                         {
    return rz_cmd_int2status(task_enqueue(core, argv[1], true));
}

References argv, and task_enqueue().

Referenced by rzshell_cmddescs_init().

rz_tasks_wait_handler()

RZ_IPI RzCmdStatus rz_tasks_wait_handler	(	RzCore *	core,
		int	argc,
		const char **	argv
	)

Definition at line 84 of file cmd_tasks.c.

                                                                                    {
    int tid = 0;
    if (argc == 2) {
        tid = rz_num_math(core->num, argv[1]);
    }
    if (!rz_core_task_is_cmd(core, tid)) {
        return RZ_CMD_STATUS_ERROR;
    }
    rz_core_task_join(&core->tasks, core->tasks.current_task, tid ? tid : -1);
    return RZ_CMD_STATUS_OK;
}

References argv, rz_core_tasks_t::current_task, rz_core_t::num, RZ_CMD_STATUS_ERROR, RZ_CMD_STATUS_OK, rz_core_task_is_cmd(), rz_core_task_join(), rz_num_math(), and rz_core_t::tasks.

Referenced by rzshell_cmddescs_init().

task_break()

static int task_break ( RzCore *  core, int  tid  )

static

Definition at line 36 of file cmd_tasks.c.

                                             {
    if (!tid) {
        return -1;
    }
    if (!rz_core_task_is_cmd(core, tid)) {
        return -1;
    }
    rz_core_task_break(&core->tasks, tid);
    return 0;
}

References rz_core_task_break(), rz_core_task_is_cmd(), and rz_core_t::tasks.

Referenced by rz_tasks_break_handler().

task_enqueue()

static int task_enqueue ( RzCore *  core, const char *  cmd, bool  transient  )

static

Definition at line 8 of file cmd_tasks.c.

                                                                       {
    RzCoreTask *task = rz_core_cmd_task_new(core, cmd, NULL, NULL);
    if (!task) {
        return -1;
    }
    task->transient = transient;
    rz_core_task_enqueue(&core->tasks, task);
    return 0;
}

References cmd, NULL, rz_core_cmd_task_new(), rz_core_task_enqueue(), and rz_core_t::tasks.

Referenced by rz_tasks_handler(), and rz_tasks_transient_handler().

task_output()

static int task_output ( RzCore *  core, int  tid  )

static

Definition at line 18 of file cmd_tasks.c.

                                              {
    if (!tid) {
        return -1;
    }
    RzCoreTask *task = rz_core_task_get_incref(&core->tasks, tid);
    if (task) {
        const char *res = rz_core_cmd_task_get_result(task);
        if (res) {
            rz_cons_println(res);
        }
        rz_core_task_decref(task);
    } else {
        eprintf("Cannot find task\n");
        return -1;
    }
    return 0;
}

References eprintf, rz_cons_println(), rz_core_cmd_task_get_result(), rz_core_task_decref(), rz_core_task_get_incref(), and rz_core_t::tasks.

Referenced by rz_tasks_output_handler().