Return to server-job.c CVS log

Up to [local] / src / usr.bin / tmux

Annotation of src/usr.bin/tmux/server-job.c, Revision 1.4

1.4     ! nicm        1: /* $OpenBSD: server-job.c,v 1.3 2009/11/01 23:20:37 nicm Exp $ */
1.1       nicm        2:
                      3: /*
                      4:  * Copyright (c) 2009 Nicholas Marriott <nicm@users.sourceforge.net>
                      5:  *
                      6:  * Permission to use, copy, modify, and distribute this software for any
                      7:  * purpose with or without fee is hereby granted, provided that the above
                      8:  * copyright notice and this permission notice appear in all copies.
                      9:  *
                     10:  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
                     11:  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
                     12:  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
                     13:  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
                     14:  * WHATSOEVER RESULTING FROM LOSS OF MIND, USE, DATA OR PROFITS, WHETHER
                     15:  * IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING
                     16:  * OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
                     17:  */
                     18:
                     19: #include <sys/types.h>
                     20:
1.4     ! nicm       21: #include <event.h>
1.1       nicm       22: #include <unistd.h>
                     23:
                     24: #include "tmux.h"
1.2       nicm       25:
                     26: /* Register jobs for poll. */
                     27: void
                     28: server_job_prepare(void)
                     29: {
                     30:        struct job      *job;
                     31:
                     32:        SLIST_FOREACH(job, &all_jobs, lentry) {
                     33:                if (job->fd == -1)
                     34:                        continue;
1.4     ! nicm       35:                event_del(&job->event);
        !            36:                event_set(
        !            37:                    &job->event, job->fd, EV_READ, server_job_callback, job);
        !            38:                event_add(&job->event, NULL);
1.2       nicm       39:        }
                     40: }
1.1       nicm       41:
                     42: /* Process a single job event. */
                     43: void
1.4     ! nicm       44: server_job_callback(int fd, short events, void *data)
1.1       nicm       45: {
                     46:        struct job      *job = data;
                     47:
                     48:        if (job->fd == -1)
                     49:                return;
                     50:
                     51:        if (buffer_poll(fd, events, job->out, NULL) != 0) {
                     52:                close(job->fd);
                     53:                job->fd = -1;
                     54:        }
                     55: }
                     56:
                     57: /* Job functions that happen once a loop. */
                     58: void
                     59: server_job_loop(void)
                     60: {
                     61:        struct job      *job;
1.4     ! nicm       62:
1.1       nicm       63: restart:
                     64:        SLIST_FOREACH(job, &all_jobs, lentry) {
                     65:                if (job->flags & JOB_DONE || job->fd != -1 || job->pid != -1)
                     66:                        continue;
                     67:                job->flags |= JOB_DONE;
                     68:
                     69:                if (job->callbackfn != NULL) {
                     70:                        job->callbackfn(job);
1.3       nicm       71:                        if ((!job->flags & JOB_PERSIST)) {
                     72:                                job_free(job);
                     73:                                goto restart;
                     74:                        }
1.1       nicm       75:                }
                     76:        }
                     77: }