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.2

1.2     ! nicm        1: /* $OpenBSD: server-job.c,v 1.1 2009/10/22 19:41:51 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:
                     21: #include <unistd.h>
                     22:
                     23: #include "tmux.h"
1.2     ! nicm       24:
        !            25: /* Register jobs for poll. */
        !            26: void
        !            27: server_job_prepare(void)
        !            28: {
        !            29:        struct job      *job;
        !            30:
        !            31:        SLIST_FOREACH(job, &all_jobs, lentry) {
        !            32:                if (job->fd == -1)
        !            33:                        continue;
        !            34:                server_poll_add(job->fd, POLLIN, server_job_callback, job);
        !            35:        }
        !            36: }
1.1       nicm       37:
                     38: /* Process a single job event. */
                     39: void
                     40: server_job_callback(int fd, int events, void *data)
                     41: {
                     42:        struct job      *job = data;
                     43:
                     44:        if (job->fd == -1)
                     45:                return;
                     46:
                     47:        if (buffer_poll(fd, events, job->out, NULL) != 0) {
                     48:                close(job->fd);
                     49:                job->fd = -1;
                     50:        }
                     51: }
                     52:
                     53: /* Job functions that happen once a loop. */
                     54: void
                     55: server_job_loop(void)
                     56: {
                     57:        struct job      *job;
                     58:
                     59: restart:
                     60:        SLIST_FOREACH(job, &all_jobs, lentry) {
                     61:                if (job->flags & JOB_DONE || job->fd != -1 || job->pid != -1)
                     62:                        continue;
                     63:                job->flags |= JOB_DONE;
                     64:
                     65:                if (job->callbackfn != NULL) {
                     66:                        job->callbackfn(job);
                     67:                        goto restart;   /* could be freed by callback */
                     68:                }
                     69:        }
                     70: }