}
// Create a new job
- r = pakfire_job_create(&job, self->ctx, self, data);
+ r = pakfire_job_create(&job, self->ctx, self->client, self, data);
if (r) {
ERROR(self->ctx, "Could not create a new job: %s\n", strerror(-r));
goto ERROR;
}
int pakfire_job_create(struct pakfire_job** job, struct pakfire_ctx* ctx,
- struct pakfire_builder* builder, json_object* data) {
+ struct pakfire_client* client, struct pakfire_builder* builder, json_object* data) {
struct pakfire_job* j = NULL;
int r;
goto ERROR;
}
-#if 0
// Fetch a reference to the client
- j->client = pakfire_daemon_client(daemon);
-#endif
+ j->client = pakfire_client_ref(client);
// Initialize the PID file descriptor
j->pidfd = -EBADF;
#ifndef PAKFIRE_JOB_H
#define PAKFIRE_JOB_H
+#include <json.h>
+
#include <pakfire/builder.h>
+#include <pakfire/client.h>
#include <pakfire/ctx.h>
struct pakfire_job;
-int pakfire_job_create(struct pakfire_job** worker,
- struct pakfire_ctx* ctx, struct pakfire_builder* builder, json_object* data);
+int pakfire_job_create(struct pakfire_job** worker, struct pakfire_ctx* ctx,
+ struct pakfire_client* client, struct pakfire_builder* builder, json_object* data);
struct pakfire_job* pakfire_job_ref(struct pakfire_job* worker);
struct pakfire_job* pakfire_job_unref(struct pakfire_job* worker);