time_t lpq_time;
const char *lprm_command;
struct printif *print_if;
+ struct tevent_context *ev;
+ struct messaging_context *msg_ctx;
};
/****************************************************************************
if (i == ts->qcount) {
DEBUG(10,("traverse_fn_delete: pjob %u deleted due to !smbjob\n",
(unsigned int)jobid ));
- pjob_delete(server_event_context(),
- server_messaging_context(),
+ pjob_delete(ts->ev, ts->msg_ctx,
ts->sharename, jobid);
return 0;
}
if (!process_exists_by_pid(pjob.pid)) {
DEBUG(10,("traverse_fn_delete: pjob %u deleted due to !process_exists (%u)\n",
(unsigned int)jobid, (unsigned int)pjob.pid ));
- pjob_delete(server_event_context(),
- server_messaging_context(),
+ pjob_delete(ts->ev, ts->msg_ctx,
ts->sharename, jobid);
} else
ts->total_jobs++;
if ( result != 0 ) {
/* if we can't delete, then reset the job status */
pjob.status = LPQ_QUEUED;
- pjob_store(server_event_context(),
- server_messaging_context(),
+ pjob_store(ts->ev, ts->msg_ctx,
ts->sharename, jobid, &pjob);
}
else {
/* if we deleted the job, the remove the tdb record */
- pjob_delete(server_event_context(),
- server_messaging_context(),
+ pjob_delete(ts->ev,
+ ts->msg_ctx,
ts->sharename, jobid);
pjob.status = LPQ_DELETED;
}
(unsigned int)jobid,
(unsigned int)pjob.starttime,
(unsigned int)ts->lpq_time ));
- pjob_delete(server_event_context(),
- server_messaging_context(),
+ pjob_delete(ts->ev, ts->msg_ctx,
ts->sharename, jobid);
} else
ts->total_jobs++;
tstruct.sharename = sharename;
tstruct.lprm_command = lprm_command;
tstruct.print_if = current_printif;
+ tstruct.ev = server_event_context();
+ tstruct.msg_ctx = server_messaging_context();
tdb_traverse(pdb->tdb, traverse_fn_delete, (void *)&tstruct);