Lines Matching defs:proc
79 time_t disabled_until; /* this proc is disabled until, use something else until then */
87 don't send anything to this proc for the next 2 seconds */
333 fcgi_proc *proc;
381 static void fastcgi_status_copy_procname(buffer *b, fcgi_extension_host *host, fcgi_proc *proc) {
384 if (proc) {
386 buffer_append_int(b, proc->id);
392 hctx->proc->load++;
396 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
399 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->proc->load);
404 hctx->proc->load--;
408 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
411 status_counter_set(srv, CONST_BUF_LEN(p->statuskey), hctx->proc->load);
440 if (hctx->host->disable_time || hctx->proc->is_local) {
441 if (hctx->proc->state == PROC_STATE_RUNNING) hctx->host->active_procs--;
442 hctx->proc->disabled_until = srv->cur_ts + hctx->host->disable_time;
443 hctx->proc->state = hctx->proc->is_local ? PROC_STATE_DIED_WAIT_FOR_PID : PROC_STATE_DIED;
452 static int fastcgi_status_init(server *srv, buffer *b, fcgi_extension_host *host, fcgi_proc *proc) {
454 fastcgi_status_copy_procname(b, host, proc); \
490 hctx->proc = NULL;
706 fcgi_proc *proc;
711 for (proc = host->first; proc; proc = proc->next) {
712 if (proc->pid != 0) {
713 kill(proc->pid, host->kill_signal);
716 if (proc->is_local &&
717 !buffer_string_is_empty(proc->unixsocket)) {
718 unlink(proc->unixsocket->ptr);
722 for (proc = host->unused_procs; proc; proc = proc->next) {
723 if (proc->pid != 0) {
724 kill(proc->pid, host->kill_signal);
726 if (proc->is_local &&
727 !buffer_string_is_empty(proc->unixsocket)) {
728 unlink(proc->unixsocket->ptr);
840 fcgi_proc *proc) {
858 "new proc, socket:", proc->port, proc->unixsocket);
861 if (!buffer_string_is_empty(proc->unixsocket)) {
865 if (buffer_string_length(proc->unixsocket) + 1 > sizeof(fcgi_addr_un.sun_path)) {
868 proc->unixsocket);
871 memcpy(fcgi_addr_un.sun_path, proc->unixsocket->ptr, buffer_string_length(proc->unixsocket) + 1);
877 servlen = buffer_string_length(proc->unixsocket) + 1 + sizeof(fcgi_addr_un.sun_family);
882 buffer_copy_string_len(proc->connection_name, CONST_STR_LEN("unix:"));
883 buffer_append_string_buffer(proc->connection_name, proc->unixsocket);
923 fcgi_addr_in.sin_port = htons(proc->port);
929 buffer_copy_string_len(proc->connection_name, CONST_STR_LEN("tcp:"));
931 buffer_append_string_buffer(proc->connection_name, host->host);
933 buffer_append_string_len(proc->connection_name, CONST_STR_LEN("localhost"));
935 buffer_append_string_len(proc->connection_name, CONST_STR_LEN(":"));
936 buffer_append_int(proc->connection_name, proc->port);
951 !buffer_string_is_empty(proc->unixsocket)) {
952 unlink(proc->unixsocket->ptr);
976 proc->connection_name,
1132 proc->pid = child;
1133 proc->is_local = 1;
1139 proc->is_local = 0;
1140 proc->pid = 0;
1145 proc->connection_name);
1149 proc->state = PROC_STATE_RUNNING;
1372 fcgi_proc *proc;
1374 proc = fastcgi_process_init();
1375 proc->id = host->num_procs++;
1379 proc->port = host->port + pno;
1381 buffer_copy_buffer(proc->unixsocket, host->unixsocket);
1382 buffer_append_string_len(proc->unixsocket, CONST_STR_LEN("-"));
1383 buffer_append_int(proc->unixsocket, pno);
1394 if (fcgi_spawn_connection(srv, p, host, proc)) {
1397 fastcgi_process_free(proc);
1401 fastcgi_status_init(srv, p->statuskey, host, proc);
1403 proc->next = host->first;
1404 if (host->first) host->first->prev = proc;
1406 host->first = proc;
1409 fcgi_proc *proc;
1411 proc = fastcgi_process_init();
1412 proc->id = host->num_procs++;
1415 proc->state = PROC_STATE_RUNNING;
1418 proc->port = host->port;
1420 buffer_copy_buffer(proc->unixsocket, host->unixsocket);
1423 fastcgi_status_init(srv, p->statuskey, host, proc);
1425 host->first = proc;
1488 if (hctx->host && hctx->proc) {
1495 "released proc:",
1496 "pid:", hctx->proc->pid,
1497 "socket:", hctx->proc->connection_name,
1498 "load:", hctx->proc->load);
1544 if (hctx->proc) {
1546 "release proc for reconnect:",
1547 hctx->proc->pid, hctx->proc->connection_name);
1550 "release proc for reconnect:",
1555 if (hctx->proc && hctx->got_proc) {
1660 fcgi_proc *proc = hctx->proc;
1663 if (!buffer_string_is_empty(proc->unixsocket)) {
1668 if (buffer_string_length(proc->unixsocket) + 1 > sizeof(fcgi_addr_un.sun_path)) {
1671 proc->unixsocket);
1674 memcpy(fcgi_addr_un.sun_path, proc->unixsocket->ptr, buffer_string_length(proc->unixsocket) + 1);
1680 servlen = buffer_string_length(proc->unixsocket) + 1 + sizeof(fcgi_addr_un.sun_family);
1684 if (buffer_string_is_empty(proc->connection_name)) {
1686 buffer_copy_string_len(proc->connection_name, CONST_STR_LEN("unix:"));
1687 buffer_append_string_buffer(proc->connection_name, proc->unixsocket);
1706 fcgi_addr_in.sin_port = htons(proc->port);
1711 if (buffer_string_is_empty(proc->connection_name)) {
1713 buffer_copy_string_len(proc->connection_name, CONST_STR_LEN("tcp:"));
1715 buffer_append_string_buffer(proc->connection_name, host->host);
1717 buffer_append_string_len(proc->connection_name, CONST_STR_LEN("localhost"));
1719 buffer_append_string_len(proc->connection_name, CONST_STR_LEN(":"));
1720 buffer_append_int(proc->connection_name, proc->port);
1730 "connect delayed; will continue later:", proc->connection_name);
1739 "The load for this FastCGI backend", proc->connection_name, "is", proc->load);
1747 proc->connection_name);
2361 fcgi_proc *proc = hctx->proc;
2392 "pid:", proc->pid,
2393 "socket:", proc->connection_name);
2549 fcgi_proc *proc;
2551 for (proc = host->first; proc; proc = proc->next) {
2556 "proc:",
2557 proc->connection_name,
2558 proc->state,
2559 proc->is_local,
2560 proc->load,
2561 proc->pid);
2568 switch (proc->state) {
2578 if (srv->cur_ts <= proc->disabled_until) break;
2580 proc->state = PROC_STATE_RUNNING;
2590 if (!proc->is_local) {
2591 proc->state = PROC_STATE_DIED;
2596 switch(waitpid(proc->pid, &status, WNOHANG)) {
2599 if (srv->cur_ts <= proc->disabled_until) break;
2601 proc->state = PROC_STATE_RUNNING;
2615 proc->state = PROC_STATE_DIED;
2621 "child exited, pid:", proc->pid,
2634 proc->state = PROC_STATE_DIED;
2641 /* fall through if we have a dead proc now */
2642 if (proc->state != PROC_STATE_DIED) break;
2649 /* we still have connections bound to this proc,
2651 if (proc->load != 0) break;
2658 "\n\tsocket", proc->connection_name,
2662 if (fcgi_spawn_connection(srv, p, host, proc)) {
2668 if (srv->cur_ts <= proc->disabled_until) break;
2670 proc->state = PROC_STATE_RUNNING;
2675 proc->connection_name);
2688 fcgi_proc *proc;
2722 if (!hctx->proc->is_local || p->conf.debug) {
2727 "socket:", hctx->proc->connection_name);
2736 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
2754 hctx->proc = NULL;
2756 for (proc = hctx->host->first;
2757 proc && proc->state != PROC_STATE_RUNNING;
2758 proc = proc->next);
2761 if (proc == NULL) {
2767 hctx->proc = proc;
2770 for (proc = proc->next; proc; proc = proc->next) {
2771 if (proc->state != PROC_STATE_RUNNING) continue;
2772 if (proc->load < hctx->proc->load) hctx->proc = proc;
2803 if (hctx->proc->is_local) {
2804 hctx->pid = hctx->proc->pid;
2825 hctx->proc->disabled_until = srv->cur_ts + hctx->host->disable_time;
2826 if (hctx->proc->state == PROC_STATE_RUNNING) hctx->host->active_procs--;
2827 hctx->proc->state = PROC_STATE_OVERLOADED;
2830 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
2851 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
2873 fastcgi_status_copy_procname(p->statuskey, hctx->host, hctx->proc);
2880 "got proc:",
2881 "pid:", hctx->proc->pid,
2882 "socket:", hctx->proc->connection_name,
2883 "load:", hctx->proc->load);
2886 /* move the proc-list entry down the list */
2915 "socket:", hctx->proc->connection_name);
2979 /* we should have at least one proc that can do something */
3016 hctx->proc = NULL;
3073 fcgi_proc *proc = hctx->proc;
3110 if (proc->pid && proc->state != PROC_STATE_DIED) {
3115 switch(waitpid(proc->pid, &status, WNOHANG)) {
3125 "child exited, pid:", proc->pid,
3140 "\n\tsocket", proc->connection_name,
3144 if (fcgi_spawn_connection(srv, p, host, proc)) {
3146 proc->state = PROC_STATE_DIED;
3165 "on socket:", proc->connection_name,
3173 "on socket:", proc->connection_name,
3188 "on socket:", proc->connection_name,
3232 hctx->proc->port == 0) {
3242 "(no fastcgi process on socket:", proc->connection_name, "?)",
3395 /* we should have at least one proc that can do something */
3441 hctx->proc = NULL;
3506 hctx->proc = NULL;
3602 fcgi_proc *proc;
3609 for (proc = host->unused_procs; proc; proc = proc->next) {
3612 if (proc->pid == 0) continue;
3614 switch (waitpid(proc->pid, &status, WNOHANG)) {
3622 "pid ", proc->pid, proc->state,
3628 proc->pid = 0;
3629 proc->state = PROC_STATE_UNSET;
3637 if (proc->state != PROC_STATE_KILLED) {
3640 WEXITSTATUS(status), proc->connection_name);
3653 proc->pid = 0;
3654 if (proc->state == PROC_STATE_RUNNING) host->active_procs--;
3655 proc->state = PROC_STATE_UNSET;