shaba/systemd
1
0
Fork 0
mirror of https://github.com/systemd/systemd.git synced 2024-11-07 18:27:04 +03:00
Code

automount: ack automount requests even when already mounted (#5916)

Browse Source 
If a process accesses an autofs filesystem while systemd is in the
middle of starting the mount unit on top of it, it is possible for the
autofs_ptype_missing_direct request from the kernel to be received after
the mount unit has been fully started:

  systemd forks and execs mount             ...
            ...                     access autofs, blocks
  mount exits                               ...
  systemd receives SIGCHLD                  ...
            ...                     kernel sends request
  systemd receives request                  ...

systemd needs to respond to this request, otherwise the kernel will
continue to block access to the mount point.
This commit is contained in:
Anchor Cat 2017-05-10 21:23:58 +10:00 committed by Lennart Poettering
parent 9a4eeb4a0c
commit e7d54bf587
1 changed files with 18 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/core/automount.c
View File

@ -742,8 +742,9 @@ static void automount_stop_expire(Automount *a) {
(void) sd_event_source_set_enabled(a->expire_event_source, SD_EVENT_OFF); (void) sd_event_source_set_enabled(a->expire_event_source, SD_EVENT_OFF);
} }
static void automount_enter_runnning(Automount *a) { static void automount_enter_running(Automount *a) {
_cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL; _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
Unit *trigger;
struct stat st; struct stat st;
int r; int r;
@ -772,22 +773,24 @@ static void automount_enter_runnning(Automount *a) {
goto fail; goto fail;
} }
if (!S_ISDIR(st.st_mode) || st.st_dev != a->dev_id) /* The mount unit may have been explicitly started before we got the
* autofs request. Ack it to unblock anything waiting on the mount point. */
if (!S_ISDIR(st.st_mode) || st.st_dev != a->dev_id) {
log_unit_info(UNIT(a), "Automount point already active?"); log_unit_info(UNIT(a), "Automount point already active?");
else { automount_send_ready(a, a->tokens, 0);
Unit *trigger; return;
}
trigger = UNIT_TRIGGER(UNIT(a)); trigger = UNIT_TRIGGER(UNIT(a));
if (!trigger) { if (!trigger) {
log_unit_error(UNIT(a), "Unit to trigger vanished."); log_unit_error(UNIT(a), "Unit to trigger vanished.");
goto fail; goto fail;
} }
r = manager_add_job(UNIT(a)->manager, JOB_START, trigger, JOB_REPLACE, &error, NULL); r = manager_add_job(UNIT(a)->manager, JOB_START, trigger, JOB_REPLACE, &error, NULL);
if (r < 0) { if (r < 0) {
log_unit_warning(UNIT(a), "Failed to queue mount startup job: %s", bus_error_message(&error, r)); log_unit_warning(UNIT(a), "Failed to queue mount startup job: %s", bus_error_message(&error, r));
goto fail; goto fail;
}
} }
automount_set_state(a, AUTOMOUNT_RUNNING); automount_set_state(a, AUTOMOUNT_RUNNING);
@ -1012,7 +1015,7 @@ static int automount_dispatch_io(sd_event_source *s, int fd, uint32_t events, vo
goto fail; goto fail;
} }
automount_enter_runnning(a); automount_enter_running(a);
break; break;
case autofs_ptype_expire_direct: case autofs_ptype_expire_direct: