2 This file is part of GNUnet
3 (C) 2002, 2003, 2004, 2005, 2006 Christian Grothoff (and other contributing authors)
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 2, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA.
22 * @file util/os/priority.c
23 * @brief Methods to set process priority
28 #include "gnunet_common.h"
29 #include "gnunet_os_lib.h"
32 * Set our process priority
35 GNUNET_OS_set_process_priority (pid_t proc,
36 enum GNUNET_SCHEDULER_Priority eprio)
40 GNUNET_assert (eprio < GNUNET_SCHEDULER_PRIORITY_COUNT);
41 if (eprio == GNUNET_SCHEDULER_PRIORITY_KEEP)
43 /* convert to MINGW/Unix values */
46 case GNUNET_SCHEDULER_PRIORITY_DEFAULT:
48 prio = NORMAL_PRIORITY_CLASS;
53 case GNUNET_SCHEDULER_PRIORITY_HIGH:
55 prio = ABOVE_NORMAL_PRIORITY_CLASS;
60 case GNUNET_SCHEDULER_PRIORITY_BACKGROUND:
62 prio = BELOW_NORMAL_PRIORITY_CLASS;
67 case GNUNET_SCHEDULER_PRIORITY_UI:
68 case GNUNET_SCHEDULER_PRIORITY_URGENT:
70 prio = HIGH_PRIORITY_CLASS;
75 case GNUNET_SCHEDULER_PRIORITY_IDLE:
77 prio = IDLE_PRIORITY_CLASS;
86 /* Set process priority */
88 SetPriorityClass (GetCurrentProcess (), prio);
90 if (proc == getpid ())
93 if ((-1 == nice (prio)) && (errno != 0))
95 GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING |
96 GNUNET_ERROR_TYPE_BULK, "nice");
102 if (0 != setpriority (PRIO_PROCESS, proc, prio))
105 GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING |
106 GNUNET_ERROR_TYPE_BULK, "setpriority");
107 return GNUNET_SYSERR;
119 * @param filename name of the binary
120 * @param ... NULL-terminated list of arguments to the process
121 * @return process ID of the new process, -1 on error
124 GNUNET_OS_start_process (const char *filename, ...)
137 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "fork");
141 va_start (ap, filename);
142 while (NULL != va_arg (ap, char *))
145 argv = GNUNET_malloc (sizeof (char *) * (argc + 1));
147 va_start (ap, filename);
148 while (NULL != (argv[argc] = va_arg (ap, char *)))
151 execvp (filename, argv);
152 GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, "execvp", filename);
159 PROCESS_INFORMATION proc;
162 va_start (ap, filename);
163 while (NULL != (arg = va_arg (ap, char *)))
164 cmdlen = cmdlen + strlen (arg) + 3;
167 cmd = idx = GNUNET_malloc (sizeof(char) * cmdlen);
168 va_start (ap, filename);
169 while (NULL != (arg = va_arg (ap, char *)))
170 idx += sprintf (idx, "\"%s\" ", arg);
173 memset (&start, 0, sizeof(start));
174 start.cb = sizeof(start);
176 if (!CreateProcess (filename, cmd, NULL, NULL, FALSE, DETACHED_PROCESS, NULL,
177 NULL, &start, &proc))
179 SetErrnoFromWinError (GetLastError ());
180 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "fork");
183 CloseHandle (proc.hProcess);
184 CloseHandle (proc.hThread);
188 return proc.dwProcessId;
198 * @param filename name of the binary
199 * @param argv NULL-terminated list of arguments to the process
200 * @return process ID of the new process, -1 on error
203 GNUNET_OS_start_process_v (const char *filename, char *const argv[])
212 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "fork");
215 execvp (filename, argv);
216 GNUNET_log_strerror_file (GNUNET_ERROR_TYPE_ERROR, "execvp", filename);
223 PROCESS_INFORMATION proc;
229 cmdlen = cmdlen + strlen (*arg) + 3;
233 cmd = idx = GNUNET_malloc (sizeof(char) * cmdlen);
237 idx += sprintf (idx, "\"%s\" ", *arg);
241 memset (&start, 0, sizeof(start));
242 start.cb = sizeof(start);
244 if (!CreateProcess (filename, cmd, NULL, NULL, FALSE, DETACHED_PROCESS, NULL,
245 NULL, &start, &proc))
247 SetErrnoFromWinError (GetLastError ());
248 GNUNET_log_strerror (GNUNET_ERROR_TYPE_ERROR, "fork");
251 CloseHandle (proc.hProcess);
252 CloseHandle (proc.hThread);
256 return proc.dwProcessId;
261 * Retrieve the status of a process
262 * @param proc process ID
263 * @param type status type
264 * @param code return code/signal number
265 * @return GNUNET_OK on success, GNUNET_NO if the process is still running, GNUNET_SYSERR otherwise
268 GNUNET_OS_process_status (pid_t proc, enum GNUNET_OS_ProcessStatusType *type,
275 GNUNET_assert (0 != proc);
276 ret = waitpid (proc, &status, WNOHANG);
279 *type = GNUNET_OS_PROCESS_RUNNING;
285 GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid");
286 return GNUNET_SYSERR;
288 if (WIFEXITED (status))
290 *type = GNUNET_OS_PROCESS_EXITED;
291 *code = WEXITSTATUS (status);
293 else if (WIFSIGNALED (status))
295 *type = GNUNET_OS_PROCESS_SIGNALED;
296 *code = WTERMSIG (status);
298 else if (WIFSTOPPED (status))
300 *type = GNUNET_OS_PROCESS_SIGNALED;
301 *code = WSTOPSIG (status);
303 else if (WIFCONTINUED (status))
305 *type = GNUNET_OS_PROCESS_RUNNING;
310 *type = GNUNET_OS_PROCESS_UNKNOWN;
317 h = OpenProcess (PROCESS_QUERY_INFORMATION, FALSE, proc);
318 if (INVALID_HANDLE_VALUE == h)
320 SetErrnoFromWinError (GetLastError ());
321 GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "OpenProcess");
322 return GNUNET_SYSERR;
325 c = GetExitCodeProcess (proc, &c);
326 if (STILL_ACTIVE == c)
328 *type = GNUNET_OS_PROCESS_RUNNING;
333 *type = GNUNET_OS_PROCESS_EXITED;
343 * @param proc process ID to wait for
344 * @return GNUNET_OK on success, GNUNET_SYSERR otherwise
347 GNUNET_OS_process_wait (pid_t proc)
350 if (proc != waitpid (proc, NULL, 0))
351 return GNUNET_SYSERR;
359 h = OpenProcess (PROCESS_QUERY_INFORMATION, FALSE, proc);
360 if (INVALID_HANDLE_VALUE == h)
362 SetErrnoFromWinError (GetLastError ());
363 return GNUNET_SYSERR;
366 if (WAIT_OBJECT_0 != WaitForSingleObject (h, INFINITE))
368 SetErrnoFromWinError (GetLastError ());
381 /* end of os_priority.c */