Lines Matching refs:job
71 /* Structure for holding information about a running job. */
108 * Report state of a job.
113 struct jobs *job;
115 job = yppush_joblist;
117 while (job != NULL) {
118 if (job->tid == tid)
120 job = job->next;
123 if (job == NULL) {
129 if (job->polled) {
137 job->tid);
142 job->map, job->server, status == YPPUSH_SUCC ?
149 job->polled = 1;
151 svc_unregister(job->prognum, 1);
281 yppush_send_xfr(struct jobs *job)
315 req.map_parms.map = job->map;
316 req.transid = job->tid;
317 req.prog = job->prognum;
318 req.port = job->port;
321 if ((clnt = clnt_create(job->server, YPPROG, YPVERS, "udp")) == NULL) {
322 yp_error("%s: %s",job->server,clnt_spcreateerror("couldn't \
326 job->stat = YPPUSH_NOHOST;
329 job->stat = YPPUSH_PMAP;
332 job->stat = YPPUSH_RPC;
350 yp_error("%s: %s", job->server, clnt_sperror(clnt,
352 job->stat = YPPUSH_YPSERV;
374 struct jobs *job;
376 /* Register the job in our linked list of jobs. */
378 /* First allocate job structure */
379 if ((job = (struct jobs *)malloc(sizeof (struct jobs))) == NULL) {
399 /* Initialize the info for this job. */
400 job->stat = 0;
401 job->tid = tid;
402 job->port = xprt->xp_port;
403 job->server = strdup(server);
404 job->map = strdup(map);
405 job->prognum = prognum;
406 job->polled = 0;
407 job->next = yppush_joblist;
408 yppush_joblist = job;
420 if (yppush_send_xfr(job)){
422 yppush_show_status(job->stat ? job->stat :
423 YPPUSH_YPSERV,job->tid);
461 /* Bump the job counter and transaction ID. */