1*8462SApril.Chin@Sun.COM#!/usr/bin/ksh93
2*8462SApril.Chin@Sun.COM
3*8462SApril.Chin@Sun.COM#
4*8462SApril.Chin@Sun.COM# CDDL HEADER START
5*8462SApril.Chin@Sun.COM#
6*8462SApril.Chin@Sun.COM# The contents of this file are subject to the terms of the
7*8462SApril.Chin@Sun.COM# Common Development and Distribution License (the "License").
8*8462SApril.Chin@Sun.COM# You may not use this file except in compliance with the License.
9*8462SApril.Chin@Sun.COM#
10*8462SApril.Chin@Sun.COM# You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
11*8462SApril.Chin@Sun.COM# or http://www.opensolaris.org/os/licensing.
12*8462SApril.Chin@Sun.COM# See the License for the specific language governing permissions
13*8462SApril.Chin@Sun.COM# and limitations under the License.
14*8462SApril.Chin@Sun.COM#
15*8462SApril.Chin@Sun.COM# When distributing Covered Code, include this CDDL HEADER in each
16*8462SApril.Chin@Sun.COM# file and include the License file at usr/src/OPENSOLARIS.LICENSE.
17*8462SApril.Chin@Sun.COM# If applicable, add the following below this CDDL HEADER, with the
18*8462SApril.Chin@Sun.COM# fields enclosed by brackets "[]" replaced with your own identifying
19*8462SApril.Chin@Sun.COM# information: Portions Copyright [yyyy] [name of copyright owner]
20*8462SApril.Chin@Sun.COM#
21*8462SApril.Chin@Sun.COM# CDDL HEADER END
22*8462SApril.Chin@Sun.COM#
23*8462SApril.Chin@Sun.COM
24*8462SApril.Chin@Sun.COM#
25*8462SApril.Chin@Sun.COM# Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
26*8462SApril.Chin@Sun.COM# Use is subject to license terms.
27*8462SApril.Chin@Sun.COM#
28*8462SApril.Chin@Sun.COM
29*8462SApril.Chin@Sun.COM# Solaris needs /usr/xpg6/bin:/usr/xpg4/bin because the tools in /usr/bin are not POSIX-conformant
30*8462SApril.Chin@Sun.COMexport PATH=/usr/xpg6/bin:/usr/xpg4/bin:/bin:/usr/bin
31*8462SApril.Chin@Sun.COM
32*8462SApril.Chin@Sun.COM# Make sure all math stuff runs in the "C" locale to avoid problems
33*8462SApril.Chin@Sun.COM# with alternative # radix point representations (e.g. ',' instead of
34*8462SApril.Chin@Sun.COM# '.' in de_DE.*-locales). This needs to be set _before_ any
35*8462SApril.Chin@Sun.COM# floating-point constants are defined in this script).
36*8462SApril.Chin@Sun.COMif [[ "${LC_ALL}" != "" ]] ; then
37*8462SApril.Chin@Sun.COM    export \
38*8462SApril.Chin@Sun.COM        LC_MONETARY="${LC_ALL}" \
39*8462SApril.Chin@Sun.COM        LC_MESSAGES="${LC_ALL}" \
40*8462SApril.Chin@Sun.COM        LC_COLLATE="${LC_ALL}" \
41*8462SApril.Chin@Sun.COM        LC_CTYPE="${LC_ALL}"
42*8462SApril.Chin@Sun.COM        unset LC_ALL
43*8462SApril.Chin@Sun.COMfi
44*8462SApril.Chin@Sun.COMexport LC_NUMERIC=C
45*8462SApril.Chin@Sun.COM
46*8462SApril.Chin@Sun.COMfunction fatal_error
47*8462SApril.Chin@Sun.COM{
48*8462SApril.Chin@Sun.COM    print -u 2 "${progname}: $@"
49*8462SApril.Chin@Sun.COM    exit 1
50*8462SApril.Chin@Sun.COM}
51*8462SApril.Chin@Sun.COM
52*8462SApril.Chin@Sun.COM
53*8462SApril.Chin@Sun.COMfunction usage
54*8462SApril.Chin@Sun.COM{
55*8462SApril.Chin@Sun.COM    OPTIND=0
56*8462SApril.Chin@Sun.COM    getopts -a "${progname}" "${multifollow_usage}" OPT '-?'
57*8462SApril.Chin@Sun.COM    exit 2
58*8462SApril.Chin@Sun.COM}
59*8462SApril.Chin@Sun.COM
60*8462SApril.Chin@Sun.COM# program start
61*8462SApril.Chin@Sun.COMbuiltin basename
62*8462SApril.Chin@Sun.COMbuiltin cat
63*8462SApril.Chin@Sun.COM
64*8462SApril.Chin@Sun.COMtypeset progname="$(basename "${0}")"
65*8462SApril.Chin@Sun.COM
66*8462SApril.Chin@Sun.COMtypeset -r multifollow_usage=$'+
67*8462SApril.Chin@Sun.COM[-?\n@(#)\$Id: multifollow (Roland Mainz) 2008-10-14 \$\n]
68*8462SApril.Chin@Sun.COM[-author?Roland Mainz <roland.mainz@nrubsig.org>]
69*8462SApril.Chin@Sun.COM[+NAME?multifollow - use tail -f on multiple files]
70*8462SApril.Chin@Sun.COM[+DESCRIPTION?\bmultifollow\b is a small utilty which can "follow" multiple
71*8462SApril.Chin@Sun.COM	files similar to tail -f.]
72*8462SApril.Chin@Sun.COM
73*8462SApril.Chin@Sun.COM[ file ... ]
74*8462SApril.Chin@Sun.COM
75*8462SApril.Chin@Sun.COM[+SEE ALSO?\bksh93\b(1), \btail\b(1)]
76*8462SApril.Chin@Sun.COM'
77*8462SApril.Chin@Sun.COM
78*8462SApril.Chin@Sun.COMwhile getopts -a "${progname}" "${multifollow_usage}" OPT ; do
79*8462SApril.Chin@Sun.COM#    printmsg "## OPT=|${OPT}|, OPTARG=|${OPTARG}|"
80*8462SApril.Chin@Sun.COM    case ${OPT} in
81*8462SApril.Chin@Sun.COM        *)    usage ;;
82*8462SApril.Chin@Sun.COM    esac
83*8462SApril.Chin@Sun.COMdone
84*8462SApril.Chin@Sun.COMshift $((OPTIND-1))
85*8462SApril.Chin@Sun.COM
86*8462SApril.Chin@Sun.COM# expecting at least one more arguments
87*8462SApril.Chin@Sun.COM(($# >= 1)) || usage
88*8462SApril.Chin@Sun.COM
89*8462SApril.Chin@Sun.COMbuiltin -f libshell.so.1 poll || fatal_error "poll builtin not found."
90*8462SApril.Chin@Sun.COM
91*8462SApril.Chin@Sun.COMtypeset -a files
92*8462SApril.Chin@Sun.COMinteger numfiles=0
93*8462SApril.Chin@Sun.COMinteger i
94*8462SApril.Chin@Sun.COM
95*8462SApril.Chin@Sun.COM# register trap to cleanup child processes
96*8462SApril.Chin@Sun.COMtrap 'for ((i=0 ; i < numfiles ; i++ )) ; do kill -TERM ${files[i].childpid} ; done' EXIT
97*8462SApril.Chin@Sun.COM
98*8462SApril.Chin@Sun.COM# setup "tail -f" childs, FIFOs and information for the "poll" builtin
99*8462SApril.Chin@Sun.COMfor (( ; $# > 0 ; numfiles++ )) ; do
100*8462SApril.Chin@Sun.COM    typeset files[${numfiles}]=(
101*8462SApril.Chin@Sun.COM        typeset name="$1"
102*8462SApril.Chin@Sun.COM        typeset pipename="/tmp/multifollow_pipe_${PPID}_$$_${numfiles}"
103*8462SApril.Chin@Sun.COM        integer childpid=-1
104*8462SApril.Chin@Sun.COM
105*8462SApril.Chin@Sun.COM        # poll(1) information
106*8462SApril.Chin@Sun.COM        integer fd="-1"
107*8462SApril.Chin@Sun.COM	typeset events="POLLIN"
108*8462SApril.Chin@Sun.COM	typeset revents=""
109*8462SApril.Chin@Sun.COM    )
110*8462SApril.Chin@Sun.COM
111*8462SApril.Chin@Sun.COM    mkfifo "${files[${numfiles}].pipename}"
112*8462SApril.Chin@Sun.COM    redirect {files[numfiles].fd}<>"${files[numfiles].pipename}"
113*8462SApril.Chin@Sun.COM
114*8462SApril.Chin@Sun.COM    tail -f "${files[${numfiles}].name}" >"${files[${numfiles}].pipename}" &
115*8462SApril.Chin@Sun.COM    files[${numfiles}].childpid=$!
116*8462SApril.Chin@Sun.COM
117*8462SApril.Chin@Sun.COM    rm "${files[${numfiles}].pipename}"
118*8462SApril.Chin@Sun.COM
119*8462SApril.Chin@Sun.COM    shift
120*8462SApril.Chin@Sun.COMdone
121*8462SApril.Chin@Sun.COM
122*8462SApril.Chin@Sun.COMtypeset do_poll=true
123*8462SApril.Chin@Sun.COM
124*8462SApril.Chin@Sun.COM# event loop
125*8462SApril.Chin@Sun.COMwhile true ; do
126*8462SApril.Chin@Sun.COM    if ${do_poll} ; then
127*8462SApril.Chin@Sun.COM        for ((i=0 ; i < numfiles ; i++ )) ; do
128*8462SApril.Chin@Sun.COM	    files[i].revents=""
129*8462SApril.Chin@Sun.COM	done
130*8462SApril.Chin@Sun.COM        poll files
131*8462SApril.Chin@Sun.COM    fi
132*8462SApril.Chin@Sun.COM    do_poll=true
133*8462SApril.Chin@Sun.COM
134*8462SApril.Chin@Sun.COM    for ((i=0 ; i < numfiles ; i++ )) ; do
135*8462SApril.Chin@Sun.COM        if [[ "${files[i].revents}" != "" ]] ; then
136*8462SApril.Chin@Sun.COM	    # todo: investigate why we have to use "do_poll" at all - AFAIK it
137*8462SApril.Chin@Sun.COM	    # should be sufficient to call "poll" and get "revents" set if there
138*8462SApril.Chin@Sun.COM	    # are any remaining data...
139*8462SApril.Chin@Sun.COM	    if read -t0 -u${files[i].fd} line ; then
140*8462SApril.Chin@Sun.COM	        print -- "#${i}: ${line}"
141*8462SApril.Chin@Sun.COM		do_poll=false
142*8462SApril.Chin@Sun.COM	    fi
143*8462SApril.Chin@Sun.COM	fi
144*8462SApril.Chin@Sun.COM    done
145*8462SApril.Chin@Sun.COMdone
146*8462SApril.Chin@Sun.COM
147*8462SApril.Chin@Sun.COMfatal_error "not reached."
148*8462SApril.Chin@Sun.COM# EOF.
149