mirror of
https://github.com/fish-shell/fish-shell.git
synced 2024-11-23 06:05:39 +08:00
7b1321f9a1
Cancellation groups were meant to reflect the following idea: if you ran a
simple block:
begin
cmd1
cmd2
end
then under job control, cmd1 and cmd2 would get separate groups; however if
either exits due to SIGINT or SIGQUIT we also want to propagate that to the
outer block. So the outermost block and its interior jobs would share a
cancellation group. However this is more complex than necessary; it's
sufficient for the execution context to just store an int internally.
This ought not to affect anything user-visible.
67 lines
2.4 KiB
C++
67 lines
2.4 KiB
C++
#include "config.h"
|
|
|
|
#include "job_group.h"
|
|
|
|
#include "common.h"
|
|
#include "fallback.h" // IWYU pragma: keep
|
|
#include "flog.h"
|
|
#include "proc.h"
|
|
|
|
// Basic thread safe sorted vector of job IDs in use.
|
|
// This is deliberately leaked to avoid dtor ordering issues - see #6539.
|
|
static const auto locked_consumed_job_ids = new owning_lock<std::vector<job_id_t>>();
|
|
|
|
static job_id_t acquire_job_id() {
|
|
auto consumed_job_ids = locked_consumed_job_ids->acquire();
|
|
|
|
// The new job ID should be larger than the largest currently used ID (#6053).
|
|
job_id_t jid = consumed_job_ids->empty() ? 1 : consumed_job_ids->back() + 1;
|
|
consumed_job_ids->push_back(jid);
|
|
return jid;
|
|
}
|
|
|
|
static void release_job_id(job_id_t jid) {
|
|
assert(jid > 0);
|
|
auto consumed_job_ids = locked_consumed_job_ids->acquire();
|
|
|
|
// Our job ID vector is sorted, but the number of jobs is typically 1 or 2 so a binary search
|
|
// isn't worth it.
|
|
auto where = std::find(consumed_job_ids->begin(), consumed_job_ids->end(), jid);
|
|
assert(where != consumed_job_ids->end() && "Job ID was not in use");
|
|
consumed_job_ids->erase(where);
|
|
}
|
|
|
|
job_group_t::job_group_t(wcstring command, job_id_t job_id, bool job_control, bool wants_terminal)
|
|
: job_control_(job_control),
|
|
wants_terminal_(wants_terminal),
|
|
command_(std::move(command)),
|
|
job_id_(job_id) {}
|
|
|
|
job_group_t::~job_group_t() {
|
|
if (job_id_ > 0) {
|
|
release_job_id(job_id_);
|
|
}
|
|
}
|
|
|
|
// static
|
|
job_group_ref_t job_group_t::create(wcstring command, bool wants_job_id) {
|
|
job_id_t jid = wants_job_id ? acquire_job_id() : 0;
|
|
return job_group_ref_t(new job_group_t(std::move(command), jid));
|
|
}
|
|
|
|
// static
|
|
job_group_ref_t job_group_t::create_with_job_control(wcstring command, bool wants_terminal) {
|
|
return job_group_ref_t(new job_group_t(std::move(command), acquire_job_id(),
|
|
true /* job_control */, wants_terminal));
|
|
}
|
|
|
|
void job_group_t::set_pgid(pid_t pgid) {
|
|
// Note we need not be concerned about thread safety. job_groups are intended to be shared
|
|
// across threads, but any pgid should always have been set beforehand, since it's set
|
|
// immediately after thfe first process launches.
|
|
assert(pgid >= 0 && "invalid pgid");
|
|
assert(wants_job_control() && "should not set a pgid for this group");
|
|
assert(!pgid_.has_value() && "pgid already set");
|
|
pgid_ = pgid;
|
|
}
|