diff options
| author | Sergey Poznyakoff <gray@gnu.org> | 2020-04-15 16:26:34 +0300 |
|---|---|---|
| committer | Sergey Poznyakoff <gray@gnu.org> | 2020-04-15 20:25:49 +0300 |
| commit | 2cc5b63b5f90d2dd9b05f50ac28e379d417f1a8c (patch) | |
| tree | 38238377b042a159fb9bf633e7b8e3853f0fd980 /src/wydawca.h | |
| parent | 44ad5cfe84f1cd1d7b6de35ae251f1caf69450d8 (diff) | |
| download | wydawca-2cc5b63b5f90d2dd9b05f50ac28e379d417f1a8c.tar.gz wydawca-2cc5b63b5f90d2dd9b05f50ac28e379d417f1a8c.tar.bz2 | |
Use job scheduler when processing all spools.alpha-3.1.90
* src/job.c (job_printable): Improve job identification.
(wydawca_scanner): Don't log statistics in single process mode.
(job_queue_wait): New function.
* src/net.c (wydawca_listener): Move the call to job_init to main.
* src/process.c (scan_spool_unlocked): Enqueue the triplet.
Don't call spool_commit_triplets
* src/triplet.c (remove_triplet): Omit checks in dry-run mode.
(triplet_processor,spool_commit_triplets)
(count_collected_triplets): Remove.
* src/wydawca.c (main): Call job_queue_wait if not daemon.
* tests/inotify-unatt01.at: Update expected output.
* tests/upload-dry.at: Likewise.
Diffstat (limited to 'src/wydawca.h')
| -rw-r--r-- | src/wydawca.h | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/src/wydawca.h b/src/wydawca.h index 1f64623..6cc71f1 100644 --- a/src/wydawca.h +++ b/src/wydawca.h @@ -387,9 +387,6 @@ int for_each_spool(int (*fun) (struct spool *, void *), void *data); void register_spool(struct spool *spool); struct spool *wydawca_find_spool(const char *name); struct wy_triplet *register_file(struct file_info *finfo, struct spool *spool); -void spool_commit_triplets(struct spool *); -struct wy_triplet *link_processable_triplets(void); -size_t count_collected_triplets(void); char *triplet_expand_dictionary_query(struct dictionary *dict, void *handle, @@ -546,6 +543,8 @@ job_schedule_spool(struct spool *spool) void job_init(void); void job_queue_runner(time_t min_timeout); +void job_queue_wait(void); + /* profile.c */ void check_pidfile(void); @@ -573,10 +572,6 @@ int tcpwrap_access(int fd); /* userprivs.c */ int wydawca_userprivs(uid_t uid, gid_t gid, gid_t * grplist, size_t ngrp); -int push_dir(const char *dirname); -int pop_dir(void); -char *getcwd_alloc(void); - #ifdef WITH_INOTIFY int watcher_init(void); int watcher_run(int); |