projects
/
apps
/
pfixtools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
continue to rework our jobs
[apps/pfixtools.git]
/
postfix.c
diff --git
a/postfix.c
b/postfix.c
index
d9b4930
..
5155471
100644
(file)
--- a/
postfix.c
+++ b/
postfix.c
@@
-37,6
+37,7
@@
#include <stdbool.h>
#include <unistd.h>
#include <stdbool.h>
#include <unistd.h>
+#include "job.h"
#include "postfix.h"
struct jpriv_t {
#include "postfix.h"
struct jpriv_t {
@@
-44,30
+45,23
@@
struct jpriv_t {
buffer_t obuf;
};
buffer_t obuf;
};
-task_t *postfix_create(void)
-{
- return NULL;
-}
-
-void postfix_release(task_t **task)
-{
- if (task) {
- *task = NULL;
- }
-}
+struct tpriv_t {
+ job_t *jobs;
+};
-void postfix_
run
(job_t *job, query_t *query)
+void postfix_
start
(job_t *job, query_t *query)
{
}
{
}
-void postfix_
done
(job_t *job)
+void postfix_
stop
(job_t *job)
{
}
void postfix_process(job_t *job)
{
if (job->state & JOB_LISTEN) {
{
}
void postfix_process(job_t *job)
{
if (job->state & JOB_LISTEN) {
- // TODO
+ /* TODO check return code */
+ job_accept(job, JOB_READ);
}
if (job->state & JOB_WRITE) {
}
if (job->state & JOB_WRITE) {
@@
-101,12
+95,3
@@
void postfix_process(job_t *job)
/* TODO: do the parse */
}
}
/* TODO: do the parse */
}
}
-
-task_t task_postfix = {
- postfix_create,
- postfix_release,
- postfix_run,
- postfix_done,
- NULL,
- postfix_process
-};