Annotation of embedaddon/tmux/alerts.c, revision 1.1.1.1

1.1       misho       1: /* $OpenBSD$ */
                      2: 
                      3: /*
                      4:  * Copyright (c) 2015 Nicholas Marriott <nicholas.marriott@gmail.com>
                      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 <event.h>
                     22: #include <stdlib.h>
                     23: 
                     24: #include "tmux.h"
                     25: 
                     26: static int     alerts_fired;
                     27: 
                     28: static void    alerts_timer(int, short, void *);
                     29: static int     alerts_enabled(struct window *, int);
                     30: static void    alerts_callback(int, short, void *);
                     31: static void    alerts_reset(struct window *);
                     32: 
                     33: static int     alerts_check_all(struct window *);
                     34: static int     alerts_check_bell(struct window *);
                     35: static int     alerts_check_activity(struct window *);
                     36: static int     alerts_check_silence(struct window *);
                     37: static void printflike(2, 3) alerts_set_message(struct session *, const char *,
                     38:                    ...);
                     39: static void    alerts_ring_bell(struct session *);
                     40: 
                     41: static TAILQ_HEAD(, window) alerts_list = TAILQ_HEAD_INITIALIZER(alerts_list);
                     42: 
                     43: static void
                     44: alerts_timer(__unused int fd, __unused short events, void *arg)
                     45: {
                     46:        struct window   *w = arg;
                     47: 
                     48:        log_debug("@%u alerts timer expired", w->id);
                     49:        alerts_reset(w);
                     50:        alerts_queue(w, WINDOW_SILENCE);
                     51: }
                     52: 
                     53: static void
                     54: alerts_callback(__unused int fd, __unused short events, __unused void *arg)
                     55: {
                     56:        struct window   *w, *w1;
                     57:        int              alerts;
                     58: 
                     59:        TAILQ_FOREACH_SAFE(w, &alerts_list, alerts_entry, w1) {
                     60:                alerts = alerts_check_all(w);
                     61:                log_debug("@%u alerts check, alerts %#x", w->id, alerts);
                     62: 
                     63:                w->alerts_queued = 0;
                     64:                TAILQ_REMOVE(&alerts_list, w, alerts_entry);
                     65: 
                     66:                w->flags &= ~WINDOW_ALERTFLAGS;
                     67:                window_remove_ref(w);
                     68:        }
                     69:        alerts_fired = 0;
                     70: }
                     71: 
                     72: static int
                     73: alerts_check_all(struct window *w)
                     74: {
                     75:        int     alerts;
                     76: 
                     77:        alerts  = alerts_check_bell(w);
                     78:        alerts |= alerts_check_activity(w);
                     79:        alerts |= alerts_check_silence(w);
                     80:        return (alerts);
                     81: }
                     82: 
                     83: void
                     84: alerts_check_session(struct session *s)
                     85: {
                     86:        struct winlink  *wl;
                     87: 
                     88:        RB_FOREACH(wl, winlinks, &s->windows)
                     89:                alerts_check_all(wl->window);
                     90: }
                     91: 
                     92: static int
                     93: alerts_enabled(struct window *w, int flags)
                     94: {
                     95:        if (flags & WINDOW_BELL)
                     96:                return (1);
                     97:        if (flags & WINDOW_ACTIVITY) {
                     98:                if (options_get_number(w->options, "monitor-activity"))
                     99:                        return (1);
                    100:        }
                    101:        if (flags & WINDOW_SILENCE) {
                    102:                if (options_get_number(w->options, "monitor-silence") != 0)
                    103:                        return (1);
                    104:        }
                    105:        return (0);
                    106: }
                    107: 
                    108: void
                    109: alerts_reset_all(void)
                    110: {
                    111:        struct window   *w;
                    112: 
                    113:        RB_FOREACH(w, windows, &windows)
                    114:                alerts_reset(w);
                    115: }
                    116: 
                    117: static void
                    118: alerts_reset(struct window *w)
                    119: {
                    120:        struct timeval  tv;
                    121: 
                    122:        w->flags &= ~WINDOW_SILENCE;
                    123:        event_del(&w->alerts_timer);
                    124: 
                    125:        timerclear(&tv);
                    126:        tv.tv_sec = options_get_number(w->options, "monitor-silence");
                    127: 
                    128:        log_debug("@%u alerts timer reset %u", w->id, (u_int)tv.tv_sec);
                    129:        if (tv.tv_sec != 0)
                    130:                event_add(&w->alerts_timer, &tv);
                    131: }
                    132: 
                    133: void
                    134: alerts_queue(struct window *w, int flags)
                    135: {
                    136:        if (w->flags & WINDOW_ACTIVITY)
                    137:                alerts_reset(w);
                    138: 
                    139:        if (!event_initialized(&w->alerts_timer))
                    140:                evtimer_set(&w->alerts_timer, alerts_timer, w);
                    141: 
                    142:        if ((w->flags & flags) != flags) {
                    143:                w->flags |= flags;
                    144:                log_debug("@%u alerts flags added %#x", w->id, flags);
                    145:        }
                    146: 
                    147:        if (!w->alerts_queued) {
                    148:                w->alerts_queued = 1;
                    149:                TAILQ_INSERT_TAIL(&alerts_list, w, alerts_entry);
                    150:                w->references++;
                    151:        }
                    152: 
                    153:        if (!alerts_fired && alerts_enabled(w, flags)) {
                    154:                log_debug("alerts check queued (by @%u)", w->id);
                    155:                event_once(-1, EV_TIMEOUT, alerts_callback, NULL, NULL);
                    156:                alerts_fired = 1;
                    157:        }
                    158: }
                    159: 
                    160: static int
                    161: alerts_check_bell(struct window *w)
                    162: {
                    163:        struct window   *ws;
                    164:        struct winlink  *wl;
                    165:        struct session  *s;
                    166:        struct client   *c;
                    167:        int              action, visual;
                    168: 
                    169:        if (~w->flags & WINDOW_BELL)
                    170:                return (0);
                    171: 
                    172:        TAILQ_FOREACH(wl, &w->winlinks, wentry)
                    173:                wl->session->flags &= ~SESSION_ALERTED;
                    174: 
                    175:        TAILQ_FOREACH(wl, &w->winlinks, wentry) {
                    176:                if (wl->flags & WINLINK_BELL)
                    177:                        continue;
                    178:                s = wl->session;
                    179:                if (s->curw != wl) {
                    180:                        wl->flags |= WINLINK_BELL;
                    181:                        notify_winlink("alert-bell", s, wl);
                    182:                }
                    183: 
                    184:                if (s->flags & SESSION_ALERTED)
                    185:                        continue;
                    186:                s->flags |= SESSION_ALERTED;
                    187: 
                    188:                action = options_get_number(s->options, "bell-action");
                    189:                if (action == BELL_NONE)
                    190:                        return (0);
                    191: 
                    192:                visual = options_get_number(s->options, "visual-bell");
                    193:                TAILQ_FOREACH(c, &clients, entry) {
                    194:                        if (c->session != s || c->flags & CLIENT_CONTROL)
                    195:                                continue;
                    196:                        ws = c->session->curw->window;
                    197: 
                    198:                        if (action == BELL_CURRENT && ws != w)
                    199:                                action = BELL_NONE;
                    200:                        if (action == BELL_OTHER && ws != w)
                    201:                                action = BELL_NONE;
                    202: 
                    203:                        if (!visual) {
                    204:                                if (action != BELL_NONE)
                    205:                                        tty_putcode(&c->tty, TTYC_BEL);
                    206:                                continue;
                    207:                        }
                    208:                        if (action == BELL_CURRENT)
                    209:                                status_message_set(c, "Bell in current window");
                    210:                        else if (action != BELL_NONE) {
                    211:                                status_message_set(c, "Bell in window %d",
                    212:                                    wl->idx);
                    213:                        }
                    214:                }
                    215:        }
                    216: 
                    217:        return (WINDOW_BELL);
                    218: }
                    219: 
                    220: static int
                    221: alerts_check_activity(struct window *w)
                    222: {
                    223:        struct winlink  *wl;
                    224:        struct session  *s;
                    225: 
                    226:        if (~w->flags & WINDOW_ACTIVITY)
                    227:                return (0);
                    228:        if (!options_get_number(w->options, "monitor-activity"))
                    229:                return (0);
                    230: 
                    231:        TAILQ_FOREACH(wl, &w->winlinks, wentry)
                    232:                wl->session->flags &= ~SESSION_ALERTED;
                    233: 
                    234:        TAILQ_FOREACH(wl, &w->winlinks, wentry) {
                    235:                if (wl->flags & WINLINK_ACTIVITY)
                    236:                        continue;
                    237:                s = wl->session;
                    238:                if (s->curw == wl)
                    239:                        continue;
                    240: 
                    241:                wl->flags |= WINLINK_ACTIVITY;
                    242:                notify_winlink("alert-activity", s, wl);
                    243: 
                    244:                if (s->flags & SESSION_ALERTED)
                    245:                        continue;
                    246:                s->flags |= SESSION_ALERTED;
                    247: 
                    248:                if (options_get_number(s->options, "bell-on-alert"))
                    249:                        alerts_ring_bell(s);
                    250:                if (options_get_number(s->options, "visual-activity"))
                    251:                        alerts_set_message(s, "Activity in window %d", wl->idx);
                    252:        }
                    253: 
                    254:        return (WINDOW_ACTIVITY);
                    255: }
                    256: 
                    257: static int
                    258: alerts_check_silence(struct window *w)
                    259: {
                    260:        struct winlink  *wl;
                    261:        struct session  *s;
                    262: 
                    263:        if (~w->flags & WINDOW_SILENCE)
                    264:                return (0);
                    265:        if (!options_get_number(w->options, "monitor-silence"))
                    266:                return (0);
                    267: 
                    268:        TAILQ_FOREACH(wl, &w->winlinks, wentry)
                    269:                wl->session->flags &= ~SESSION_ALERTED;
                    270: 
                    271:        TAILQ_FOREACH(wl, &w->winlinks, wentry) {
                    272:                if (wl->flags & WINLINK_SILENCE)
                    273:                        continue;
                    274:                s = wl->session;
                    275:                if (s->curw == wl)
                    276:                        continue;
                    277:                wl->flags |= WINLINK_SILENCE;
                    278:                notify_winlink("alert-silence", s, wl);
                    279: 
                    280:                if (s->flags & SESSION_ALERTED)
                    281:                        continue;
                    282:                s->flags |= SESSION_ALERTED;
                    283: 
                    284:                if (options_get_number(s->options, "bell-on-alert"))
                    285:                        alerts_ring_bell(s);
                    286: 
                    287:                if (!options_get_number(s->options, "visual-silence"))
                    288:                        alerts_set_message(s, "Silence in window %d", wl->idx);
                    289:        }
                    290: 
                    291:        return (WINDOW_SILENCE);
                    292: }
                    293: 
                    294: static void
                    295: alerts_set_message(struct session *s, const char *fmt, ...)
                    296: {
                    297:        struct client   *c;
                    298:        va_list          ap;
                    299:        char            *message;
                    300: 
                    301:        va_start(ap, fmt);
                    302:        xvasprintf(&message, fmt, ap);
                    303:        va_end(ap);
                    304: 
                    305:        TAILQ_FOREACH(c, &clients, entry) {
                    306:                if (c->session == s)
                    307:                        status_message_set(c, "%s", message);
                    308:        }
                    309: 
                    310:        free(message);
                    311: }
                    312: 
                    313: static void
                    314: alerts_ring_bell(struct session *s)
                    315: {
                    316:        struct client   *c;
                    317: 
                    318:        TAILQ_FOREACH(c, &clients, entry) {
                    319:                if (c->session == s && !(c->flags & CLIENT_CONTROL))
                    320:                        tty_putcode(&c->tty, TTYC_BEL);
                    321:        }
                    322: }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>