/** * Copyright © 2015 Mattias Andrée * * Permission is hereby granted, free of charge, to any person obtaining a * copy of this software and associated documentation files (the "Software"), * to deal in the Software without restriction, including without limitation * the rights to use, copy, modify, merge, publish, distribute, sublicense, * and/or sell copies of the Software, and to permit persons to whom the * Software is furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER * DEALINGS IN THE SOFTWARE. */ #include #include #include #include #include #include /** * The file descriptor for the socket. */ #define SOCK_FILENO 3 /** * The file descriptor for the state file. */ #define STATE_FILENO 4 /** * Command: queue a job. */ #define SAT_QUEUE 0 /** * Command: remove jobs. */ #define SAT_REMOVE 1 /** * Command: print job queue. */ #define SAT_PRINT 2 /** * Command: run jobs. */ #define SAT_RUN 3 #ifndef t /** * Go to `fail` if a statement evaluates to non-zero. * * @param ... The statement. */ # define t(...) do { if (__VA_ARGS__) goto fail; } while (0) #endif /** * A queued job. */ struct job { /** * The job number. */ size_t no; /** * The number of “argv” elements in `payload`. */ int argc; /** * The clock in which `ts` is measured. */ clockid_t clk; /** * The time when the job shall be executed. */ struct timespec ts; /** * The number of bytes in `payload`. */ size_t n; /** * “argv” followed by “envp”. */ char payload[0]; }; /** * Wrapper for `read` that reads all available data. * * Sets `errno` to `EBADMSG` on success. * * @param fd The file descriptor from which to to read. * @param buf Output parameter for the data. * @param n Output parameter for the number of read bytes. * @return 0 on success, -1 on error. * * @throws Any exception specified for read(3). * @throws Any exception specified for realloc(3). */ int readall(int fd, char **buf, size_t *n); /** * Unmarshal a `NULL`-terminated string array. * * The elements are not actually copied, subpointers * to `buf` are stored in the returned list. * * @param buf The marshalled array. Must end with a NUL byte. * @param len The length of `buf`. * @param n Output parameter for the number of elements. May be `NULL` * @return The list, `NULL` on error. * * @throws Any exception specified for realloc(3). */ char **restore_array(char *buf, size_t len, size_t *n); /** * Create `NULL`-terminate subcopy of an list, * * @param list The list. * @param n The number of elements in the new sublist. * @return The sublist, `NULL` on error. * * @throws Any exception specified for malloc(3). */ char **sublist(char *const *list, size_t n);