wn/smmapdfw
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add missing functions

Browse Source
This commit is contained in:
whottgen
2004-11-23 15:34:16 +00:00
parent d383a66530
commit ec836e7873
1 changed files with 16 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
pgworker/pgworker/pg_worker.c
View File

@ -26,20 +26,22 @@
#include <containers_public.h> #include <containers_public.h>
#include "htmalloc.h" #include "htmalloc.h"
#include "smmapd.h"
int pg_worker_init(cfgl_t *cfg, void **handle); int pg_worker_init(cfgl_t *cfg, void **handle);
int pg_worker_setup(void *handle, void **work_handle); int pg_worker_destroy(void *handle);
int pg_worker_destroy(void *handle, void *work_handle); int pg_worker_work_setup(void *handle, void **work_handle);
int pg_worker_work_destroy(void *handle, void *work_handle);
int pg_worker_work(void *handle, void *work_handle, char *input, char *output); int pg_worker_work(void *handle, void *work_handle, char *input, char *output);
class_descriptor_t pgworker = { class_descriptor_t pgworker = {
"pgworker", "pgworker",
&pg_worker_init, &pg_worker_init,
NULL, &pg_worker_destroy,
&pg_worker_setup, &pg_worker_work_setup,
&pg_worker_work, &pg_worker_work,
&pg_worker_destroy &pg_worker_work_destroy
}; };
@ -60,14 +62,20 @@ int pg_worker_init(cfgl_t *cfg, void **handle) {
return 0; return 0;
} }
int pg_worker_setup(void *handle, void **work_handle) { int pg_worker_destroy(void *handle) {
pg_container_handle_t *pch = (pg_container_handle_t*)handle;
free(pch);
return 0;
}
int pg_worker_work_setup(void *handle, void **work_handle) {
pg_worker_handle_t *pwh = (pg_worker_handle_t*)htmalloc(sizeof(pg_worker_handle_t)); pg_worker_handle_t *pwh = (pg_worker_handle_t*)htmalloc(sizeof(pg_worker_handle_t));
pwh->counter = 0; pwh->counter = 0;
*work_handle = pwh; *work_handle = pwh;
return 0; return 0;
} }
int pg_worker_destroy(void *handle, void *work_handle) { int pg_worker_work_destroy(void *handle, void *work_handle) {
syslog(LOG_DEBUG, "pg_worker_destroy: freeing the worker handle"); syslog(LOG_DEBUG, "pg_worker_destroy: freeing the worker handle");
free(work_handle); free(work_handle);
} }
@ -77,7 +85,7 @@ int pg_worker_work(void *handle, void *work_handle, char *input, char *output) {
pg_worker_handle_t *pwh = (pg_worker_handle_t*) work_handle; pg_worker_handle_t *pwh = (pg_worker_handle_t*) work_handle;
sprintf(output, "pg-worker receives %s (pch %p, pwh %p) (called %d)\n", sprintf(output, "pg-worker receives %s (pch %p, pwh %p) (called %d)\n",
input, pch, pwh, pwh->counter++); input, pch, pwh, pwh->counter++);
return 0; return SMM_OK;
} }