Mirrors/fish-shell
2
0
Fork 0
mirror of https://github.com/fish-shell/fish-shell synced 2025-01-13 13:39:02 +00:00
Code Issues Projects Releases Packages Wiki Activity

Allow autosuggestions to do job expansion. Fixes

Browse source 
https://github.com/fish-shell/fish-shell/issues/1152
This commit is contained in:
ridiculousfish 2013-11-29 13:31:18 -08:00
parent e1608362d0
commit 4aaa9e7d9f
6 changed files with 174 additions and 146 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
complete.cpp
View file

@ -430,7 +430,7 @@ public:
/* Never do command substitution in autosuggestions. Sadly, we also can't yet do job expansion because it's not thread safe. */
expand_flags_t result = 0;
if (this->type() == COMPLETE_AUTOSUGGEST)
result |= EXPAND_SKIP_CMDSUBST | EXPAND_SKIP_JOBS;
result |= EXPAND_SKIP_CMDSUBST;
/* Allow fuzzy matching */
if (this->fuzzy())

91
expand.cpp
View file

@ -49,6 +49,7 @@ parameter expansion.
#include "signal.h"
#include "tokenizer.h"
#include "complete.h"
#include "iothread.h"
#include "parse_util.h"
@ -560,31 +561,25 @@ std::vector<wcstring> expand_get_all_process_names(void)
return result;
}
/**
Searches for a job with the specified job id, or a job or process
which has the string \c proc as a prefix of its commandline.
If the ACCEPT_INCOMPLETE flag is set, the remaining string for any matches
are inserted.
Otherwise, any job matching the specified string is matched, and
the job pgid is returned. If no job matches, all child processes
are searched. If no child processes match, and <tt>fish</tt> can
understand the contents of the /proc filesystem, all the users
processes are searched for matches.
*/
static int find_process(const wchar_t *proc,
expand_flags_t flags,
std::vector<completion_t> &out)
/* Helper function to do a job search. */
struct find_job_data_t
{
int found = 0;
const wchar_t *proc; /* The process to search for - possibly numeric, possibly a name */
expand_flags_t flags;
std::vector<completion_t> *completions;
};
if (!(flags & EXPAND_SKIP_JOBS))
{
/* The following function is invoked on the main thread, because the job list is not thread safe. It should search the job list for something matching the given proc, and then return 1 to stop the search, 0 to continue it */
static int find_job(const struct find_job_data_t *info)
{
ASSERT_IS_MAIN_THREAD();
const job_t *j;
const wchar_t * const proc = info->proc;
const expand_flags_t flags = info->flags;
std::vector<completion_t> &completions = *info->completions;
const job_t *j;
int found = 0;
// do the empty param check first, because an empty string passes our 'numeric' check
if (wcslen(proc)==0)
{
@ -597,7 +592,7 @@ static int find_process(const wchar_t *proc,
{
if (!j->command_is_empty())
{
append_completion(out, to_string<long>(j->pgid));
append_completion(completions, to_string<long>(j->pgid));
break;
}
}
@ -628,7 +623,7 @@ static int find_process(const wchar_t *proc,
if (wcsncmp(proc, jid, wcslen(proc))==0)
{
wcstring desc_buff = format_string(COMPLETE_JOB_DESC_VAL, j->command_wcstr());
append_completion(out,
append_completion(completions,
jid+wcslen(proc),
desc_buff,
0);
@ -647,7 +642,7 @@ static int find_process(const wchar_t *proc,
j = job_get(jid);
if ((j != 0) && (j->command_wcstr() != 0) && (!j->command_is_empty()))
{
append_completion(out, to_string<long>(j->pgid));
append_completion(completions, to_string<long>(j->pgid));
}
}
}
@ -657,9 +652,9 @@ static int find_process(const wchar_t *proc,
*/
found = 1;
}
if (found)
return 1;
if (! found)
{
job_iterator_t jobs;
while ((j = jobs.next()))
{
@ -672,24 +667,21 @@ static int find_process(const wchar_t *proc,
{
if (flags & ACCEPT_INCOMPLETE)
{
append_completion(out,
append_completion(completions,
j->command_wcstr() + offset + wcslen(proc),
COMPLETE_JOB_DESC,
0);
}
else
{
append_completion(out, to_string<long>(j->pgid));
append_completion(completions, to_string<long>(j->pgid));
found = 1;
}
}
}
if (found)
if (! found)
{
return 1;
}
jobs.reset();
while ((j = jobs.next()))
{
@ -706,14 +698,14 @@ static int find_process(const wchar_t *proc,
{
if (flags & ACCEPT_INCOMPLETE)
{
append_completion(out,
append_completion(completions,
wcstring(p->actual_cmd, offset + wcslen(proc)),
COMPLETE_CHILD_PROCESS_DESC,
0);
}
else
{
append_completion(out,
append_completion(completions,
to_string<long>(p->pid),
L"",
0);
@ -722,6 +714,37 @@ static int find_process(const wchar_t *proc,
}
}
}
}
}
return found;
}
/**
Searches for a job with the specified job id, or a job or process
which has the string \c proc as a prefix of its commandline.
If the ACCEPT_INCOMPLETE flag is set, the remaining string for any matches
are inserted.
Otherwise, any job matching the specified string is matched, and
the job pgid is returned. If no job matches, all child processes
are searched. If no child processes match, and <tt>fish</tt> can
understand the contents of the /proc filesystem, all the users
processes are searched for matches.
*/
static int find_process(const wchar_t *proc,
expand_flags_t flags,
std::vector<completion_t> &out)
{
int found = 0;
if (!(flags & EXPAND_SKIP_JOBS))
{
const struct find_job_data_t data = {proc, flags, &out};
found = iothread_perform_on_main(find_job, &data);
if (found)
{

6
highlight.cpp
View file

@ -873,7 +873,7 @@ bool autosuggest_validate_from_history(const history_item_t &item, file_detectio
{
/* We can possibly handle this specially */
wcstring dir = parsed_arguments.back();
if (expand_one(dir, EXPAND_SKIP_CMDSUBST | EXPAND_SKIP_JOBS))
if (expand_one(dir, EXPAND_SKIP_CMDSUBST))
{
handled = true;
bool is_help = string_prefixes_string(dir, L"--help") || string_prefixes_string(dir, L"-h");
@ -997,7 +997,7 @@ static void tokenize(const wchar_t * const buff, std::vector<int> &color, const
if (cmd == L"cd")
{
wcstring dir = tok_last(&tok);
if (expand_one(dir, EXPAND_SKIP_CMDSUBST | EXPAND_SKIP_JOBS))
if (expand_one(dir, EXPAND_SKIP_CMDSUBST))
{
int is_help = string_prefixes_string(dir, L"--help") || string_prefixes_string(dir, L"-h");
if (!is_help && ! is_potential_cd_path(dir, working_directory, PATH_EXPAND_TILDE, NULL))
@ -1182,7 +1182,7 @@ static void tokenize(const wchar_t * const buff, std::vector<int> &color, const
case TOK_STRING:
{
target_str = tok_last(&tok);
if (expand_one(target_str, EXPAND_SKIP_CMDSUBST | EXPAND_SKIP_JOBS))
if (expand_one(target_str, EXPAND_SKIP_CMDSUBST))
{
target = target_str.c_str();
}

6
iothread.cpp
View file

@ -305,7 +305,11 @@ static void iothread_service_main_thread_requests(void)
int iothread_perform_on_main_base(int (*handler)(void *), void *context)
{
ASSERT_IS_BACKGROUND_THREAD();
// If this is the main thread, just do it
if (is_main_thread())
{
return handler(context);
}
// Make a new request. Note we are synchronous, so this can be stack allocated!
MainThreadRequest_t req;

2
iothread.h
View file

@ -42,7 +42,7 @@ int iothread_perform(int (*handler)(T *), void (*completionCallback)(T *, int),
template<typename T>
int iothread_perform_on_main(int (*handler)(T *), T *context)
{
return iothread_perform_on_main_base((int (*)(void *))handler, static_cast<void *>(context));
return iothread_perform_on_main_base((int (*)(void *))handler, (void *)(context));
}

1
proc.cpp
View file

@ -106,6 +106,7 @@ job_iterator_t::job_iterator_t(job_list_t &jobs) : job_list(&jobs)
job_iterator_t::job_iterator_t() : job_list(&parser_t::principal_parser().job_list())
{
ASSERT_IS_MAIN_THREAD();
this->reset();
}