void signal_handler_init() { 
  // Create a signalling mechanism for SIGCHLD. 
  int s[2]; 
  //socketpair()創(chuàng)造一對(duì)未命名的、相互連接的UNIX域套接字 
  if (socketpair(AF_UNIX, SOCK_STREAM | SOCK_NONBLOCK | SOCK_CLOEXEC, 0, s) == -1) { 
    ERROR("socketpair failed: %s\n", strerror(errno)); 
    exit(1); 
  } 
 
  signal_write_fd = s[0]; 
  signal_read_fd = s[1]; 
 
  // Write to signal_write_fd if we catch SIGCHLD. 
  struct sigaction act; 
  memset(&act, 0, sizeof(act)); 
  act.sa_handler = SIGCHLD_handler;//設(shè)置信號(hào)處理函數(shù)句柄,當(dāng)有信號(hào)產(chǎn)生時(shí),會(huì)向上面創(chuàng)建的socket寫入數(shù)據(jù),epoll監(jiān)控到該socket對(duì)中的fd可讀時(shí),就會(huì)調(diào)用注冊(cè)的函數(shù)去處理該事件 
  act.sa_flags = SA_NOCLDSTOP;//設(shè)置標(biāo)志,表示只有當(dāng)子進(jìn)程終止時(shí)才接受SIGCHID信號(hào) 
  sigaction(SIGCHLD, &act, 0);//初始化SIGCHLD信號(hào)處理方式 
 
  reap_any_outstanding_children();//處理這之前退出的子進(jìn)程 
  register_epoll_handler(signal_read_fd, handle_signal); 
} 

static void SIGCHLD_handler(int) { 
  if (TEMP_FAILURE_RETRY(write(signal_write_fd, "1", 1)) == -1) { 
    ERROR("write(signal_write_fd) failed: %s\n", strerror(errno)); 
  } 
}

#define TEMP_FAILURE_RETRY(exp)      \ 
 ({                    \ 
  decltype(exp) _rc;           \ 
  do {                  \ 
   _rc = (exp);             \ 
  } while (_rc == -1 && errno == EINTR); \ 
  _rc;                  \ 
 }) 

static void reap_any_outstanding_children() { 
  while (wait_for_one_process()) { 
  } 
} 

register_epoll_handler(signal_read_fd, handle_signal); 

void register_epoll_handler(int fd, void (*fn)()) { 
  epoll_event ev; 
  ev.events = EPOLLIN;//對(duì)文件描述符可讀 
  ev.data.ptr = reinterpret_cast<void*>(fn);//保存指定的函數(shù)指針,用于后續(xù)的事件處理 
  if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd, &ev) == -1) {//向epoll_fd添加要監(jiān)聽的fd,比如property、keychord和signal事件監(jiān)聽 
    ERROR("epoll_ctl failed: %s\n", strerror(errno)); 
  } 
} 

static void handle_signal() { 
  // Clear outstanding requests. 
  char buf[32]; 
  read(signal_read_fd, buf, sizeof(buf)); 
 
  reap_any_outstanding_children(); 
} 

static void reap_any_outstanding_children() { 
  while (wait_for_one_process()) { 
  } 
} 

static bool wait_for_one_process() { 
  int status; 
  pid_t pid = TEMP_FAILURE_RETRY(waitpid(-1, &status, WNOHANG));//等待子進(jìn)程結(jié)束,并獲取到它的pid進(jìn)程號(hào),WNOHANG表明若沒有進(jìn)程結(jié)束,則立即返回. 
  if (pid == 0) { 
    return false; 
  } else if (pid == -1) { 
    ERROR("waitpid failed: %s\n", strerror(errno)); 
    return false; 
  } 
 
  service* svc = service_find_by_pid(pid);//根據(jù)pid,在鏈表中找到這個(gè)服務(wù)信息 
 
  std::string name; 
  if (svc) { 
    name = android::base::StringPrintf("Service '%s' (pid %d)", svc->name, pid); 
  } else { 
    name = android::base::StringPrintf("Untracked pid %d", pid); 
  } 
 
  NOTICE("%s %s\n", name.c_str(), DescribeStatus(status).c_str()); 
 
  if (!svc) { 
    return true; 
  } 
 
  // TODO: all the code from here down should be a member function on service. 
  //如果該服務(wù)進(jìn)程沒有設(shè)定SVC_ONESHOT標(biāo)志,或者設(shè)置了SVC_RESTART標(biāo)志,則先殺掉當(dāng)前的進(jìn)程,在重新創(chuàng)建新的進(jìn)程; 
  //以避免后面重啟進(jìn)程時(shí),因當(dāng)前服務(wù)進(jìn)程已經(jīng)存在而發(fā)生錯(cuò)誤. 
  if (!(svc->flags & SVC_ONESHOT) || (svc->flags & SVC_RESTART)) { 
    NOTICE("Service '%s' (pid %d) killing any children in process group\n", svc->name, pid); 
    kill(-pid, SIGKILL); 
  } 
 
  // Remove any sockets we may have created. 
  //如果之前為這個(gè)服務(wù)進(jìn)程創(chuàng)建過socket,這時(shí)我們需要清除掉該socket 
  for (socketinfo* si = svc->sockets; si; si = si->next) { 
    char tmp[128]; 
    snprintf(tmp, sizeof(tmp), ANDROID_SOCKET_DIR"/%s", si->name); 
    unlink(tmp);//刪除這個(gè)socket設(shè)備文件 
  } 
 
  if (svc->flags & SVC_EXEC) {////服務(wù)完全退出,清除掉所有信息,并將該服務(wù)從svc-slist中移除 
    INFO("SVC_EXEC pid %d finished...\n", svc->pid); 
    waiting_for_exec = false; 
    list_remove(&svc->slist); 
    free(svc->name); 
    free(svc); 
    return true; 
  } 
 
  svc->pid = 0; 
  svc->flags &= (~SVC_RUNNING); 
 
  // Oneshot processes go into the disabled state on exit, 
  // except when manually restarted. 
  //如果該服務(wù)進(jìn)程帶有SVC_ONESHOT標(biāo)志,且沒有SVC_RESTART標(biāo)志,則表明該服務(wù)無需重啟 
  if ((svc->flags & SVC_ONESHOT) && !(svc->flags & SVC_RESTART)) { 
    svc->flags |= SVC_DISABLED; 
  } 
 
  // Disabled and reset processes do not get restarted automatically. 
  //如果服務(wù)帶有SVC_RESET標(biāo)志,表示服務(wù)無需重啟 
  if (svc->flags & (SVC_DISABLED | SVC_RESET)) {//從結(jié)果看SVC_RESET標(biāo)志的判斷優(yōu)先級(jí)最高 
    svc->NotifyStateChange("stopped"); 
    return true; 
  } 
 
  //到此,我們可以得知一個(gè)服務(wù)進(jìn)程在init.rc中只要沒有聲明SVC_ONESHOT和SVC_RESET標(biāo)志,當(dāng)該進(jìn)程死亡時(shí)，就會(huì)被重啟; 
  //但是,如果一個(gè)服務(wù)進(jìn)程帶有SVC_CRITICAL標(biāo)志,且沒有SVC_RESTART標(biāo)志,當(dāng)它c(diǎn)rash、重啟的次數(shù)超過4此時(shí),系統(tǒng)會(huì)自動(dòng)重啟并進(jìn)入recovery模式 
  time_t now = gettime(); 
  if ((svc->flags & SVC_CRITICAL) && !(svc->flags & SVC_RESTART)) { 
    if (svc->time_crashed + CRITICAL_CRASH_WINDOW >= now) { 
      if (++svc->nr_crashed > CRITICAL_CRASH_THRESHOLD) { 
        ERROR("critical process '%s' exited %d times in %d minutes; " 
           "rebooting into recovery mode\n", svc->name, 
           CRITICAL_CRASH_THRESHOLD, CRITICAL_CRASH_WINDOW / 60); 
        android_reboot(ANDROID_RB_RESTART2, 0, "recovery"); 
        return true; 
      } 
    } else { 
      svc->time_crashed = now; 
      svc->nr_crashed = 1; 
    } 
  } 
 
  svc->flags &= (~SVC_RESTART); 
  svc->flags |= SVC_RESTARTING;//為服務(wù)加上重啟標(biāo)志,表明它需要重啟;后續(xù)工作要以此判斷 
 
  // Execute all onrestart commands for this service. 
  struct listnode* node; 
  list_for_each(node, &svc->onrestart.commands) {//如果服務(wù)有onrestart選項(xiàng),則遍歷進(jìn)程重啟時(shí)需要執(zhí)行的命令列表,并執(zhí)行 
    command* cmd = node_to_item(node, struct command, clist); 
    cmd->func(cmd->nargs, cmd->args); 
  } 
  svc->NotifyStateChange("restarting"); 
  return true; 
} 

while (true) { 
   if (!waiting_for_exec) { 
     execute_one_command();//執(zhí)行命令列表中的命令 
     restart_processes();//啟動(dòng)服務(wù)列表中的進(jìn)程 
   } 
 
   int timeout = -1; 
   if (process_needs_restart) { 
     timeout = (process_needs_restart - gettime()) * 1000; 
     if (timeout < 0) 
       timeout = 0; 
   } 
 
   if (!action_queue_empty() || cur_action) { 
     timeout = 0; 
   } 
 
   bootchart_sample(&timeout);//bootchart是一個(gè)用可視化方式對(duì)啟動(dòng)過程進(jìn)行性能分析的工具;需要定時(shí)喚醒進(jìn)程 
 
   epoll_event ev; 
   int nr = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd, &ev, 1, timeout));//開始輪詢,epoll_wait()等待事件產(chǎn)生 
   if (nr == -1) { 
     ERROR("epoll_wait failed: %s\n", strerror(errno)); 
   } else if (nr == 1) { 
     ((void (*)()) ev.data.ptr)();//調(diào)用epoll_event事件存儲(chǔ)的函數(shù)指針處理事件 
   } 
 } 

static void restart_processes() 
{ 
  process_needs_restart = 0; 
  service_for_each_flags(SVC_RESTARTING, 
              restart_service_if_needed); 
} 
 
void service_for_each_flags(unsigned matchflags, 
              void (*func)(struct service *svc)) 
{ 
  struct listnode *node; 
  struct service *svc; 
  list_for_each(node, &service_list) { 
    svc = node_to_item(node, struct service, slist); 
    if (svc->flags & matchflags) { 
      func(svc); 
    } 
  } 
} 

static void restart_service_if_needed(struct service *svc) 
{ 
  time_t next_start_time = svc->time_started + 5; 
 
  if (next_start_time <= gettime()) { 
    svc->flags &= (~SVC_RESTARTING); 
    service_start(svc, NULL); 
    return; 
  } 
 
  if ((next_start_time < process_needs_restart) || 
    (process_needs_restart == 0)) { 
    process_needs_restart = next_start_time; 
  } 
}