ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/root-tail/root-tail.c
(Generate patch)

Comparing root-tail/root-tail.c (file contents):
Revision 1.10 by chris_moore, Fri Mar 26 12:11:05 2004 UTC vs.
Revision 1.38 by pcg, Wed Mar 31 01:50:24 2004 UTC

1/* 1/*
2 * Copyright 2001 by Marco d'Itri <md@linux.it> 2 * Copyright 2001 by Marco d'Itri <md@linux.it>
3 * 3 * Copyright 2000,2001,2002,2003,2004
4 * Original version by Mike Baker, then maintained by pcg@goof.com. 4 * Marc Lehmann <pcg@goof.com>,
5 * and many others, see README
6 *
7 * Original version by Mike Baker.
5 * 8 *
6 * This program is free software; you can redistribute it and/or modify 9 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by 10 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or 11 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version. 12 * (at your option) any later version.
29#include <errno.h> 32#include <errno.h>
30#include <sys/time.h> 33#include <sys/time.h>
31#include <sys/stat.h> 34#include <sys/stat.h>
32#include <sys/types.h> 35#include <sys/types.h>
33#include <locale.h> 36#include <locale.h>
37#include <ctype.h>
38#include <stdarg.h>
39#include <X11/Xlib.h>
40#include <X11/Xatom.h>
41#include <X11/Xutil.h>
42
34#if HAS_REGEX 43#if HAS_REGEX
35#include <regex.h> 44#include <regex.h>
36#endif 45#endif
37#include <X11/Xlib.h> 46
38#include <X11/Xatom.h> 47#define SHADE_X 2
39#include <X11/Xutil.h> 48#define SHADE_Y 2
40 49
41/* data structures */ 50/* data structures */
42struct logfile_entry { 51struct logfile_entry
43 char *fname; /* name of file */ 52{
44 char *desc; /* alternative description */
45 char *buf; /* text read but not yet displayed */
46 FILE *fp; /* FILE struct associated with file */
47 ino_t inode; /* inode of the file opened */
48 off_t last_size; /* file size at the last check */
49 unsigned long color; /* color to be used for printing */
50 int partial; /* true if the last line isn't complete */
51 int lastpartial; /* true if the previous output wasn't complete */
52 int index; /* index into linematrix of a partial line */
53 struct logfile_entry *next; 53 struct logfile_entry *next;
54
55 char *fname; /* name of file */
56 char *desc; /* alternative description */
57 char *buf; /* text read but not yet displayed */
58 FILE *fp; /* FILE struct associated with file */
59 ino_t inode; /* inode of the file opened */
60 off_t last_size; /* file size at the last check */
61 unsigned long color; /* color to be used for printing */
62 int partial; /* true if the last line isn't complete */
63 int lastpartial; /* true if the previous output wasn't complete */
64 int index; /* index into linematrix of a partial line */
65 int modified; /* true if line is modified & needs displaying */
54}; 66};
55 67
56struct linematrix { 68struct linematrix
69{
57 char *line; 70 char *line;
71 int len;
58 unsigned long color; 72 unsigned long color;
59}; 73};
60 74
75struct displaymatrix
76{
77 char *line;
78 int len;
79 int buffer_size;
80};
61 81
62/* global variables */ 82/* global variables */
83struct linematrix *lines;
84struct displaymatrix *display;
63int width = STD_WIDTH, listlen = STD_HEIGHT; 85int width = STD_WIDTH, height = STD_HEIGHT, listlen;
64int win_x = LOC_X, win_y = LOC_Y; 86int win_x = LOC_X, win_y = LOC_Y;
65int w = -1, h = -1, font_width, font_height, font_descent; 87int font_ascent, font_height;
88int effect_x_space, effect_y_space; /* how much space does shading / outlining take up */
89int effect_x_offset, effect_y_offset; /* and how does it offset the usable space */
66int do_reopen; 90int do_reopen;
67struct timeval interval = { 3, 0 }; /* see Knuth */ 91struct timeval interval = { 2, 400000 };
68XFontSet fontset; 92XFontSet fontset;
69 93
70/* command line options */ 94/* command line options */
71int opt_noinitial, opt_shade, opt_frame, opt_reverse, opt_nofilename, 95int opt_noinitial, opt_shade, opt_frame, opt_reverse, opt_nofilename,
72 opt_whole, opt_update, geom_mask, reload = 0; 96 opt_outline, opt_noflicker, opt_whole, opt_update, opt_wordwrap,
97 geom_mask, reload = 0;
73const char *command = NULL, 98const char *command = NULL,
74 *fontname = USE_FONT, *dispname = NULL, *def_color = DEF_COLOR, 99 *fontname = USE_FONT, *dispname = NULL, *def_color = DEF_COLOR,
75 *continuation = "[+]"; 100 *continuation = "[+]";
76 101
77struct logfile_entry *loglist = NULL, *loglist_tail = NULL; 102struct logfile_entry *loglist = NULL, *loglist_tail = NULL;
78 103
79Display *disp; 104Display *disp;
80Window root; 105Window root;
81GC WinGC; 106GC WinGC;
82 107
83#if HAS_REGEX 108#if HAS_REGEX
84struct re_list { 109struct re_list
110{
85 regex_t from; 111 regex_t from;
86 const char *to; 112 const char *to;
87 struct re_list *next; 113 struct re_list *next;
88}; 114};
89struct re_list *re_head, *re_tail; 115struct re_list *re_head, *re_tail;
116char *transform_to = NULL;
117regex_t *transformre;
90#endif 118#endif
91 119
92 120
93/* prototypes */ 121/* prototypes */
94void list_files(int); 122void list_files (int);
95void force_reopen(int); 123void force_reopen (int);
96void force_refresh(int); 124void force_refresh (int);
97void blank_window(int); 125void blank_window (int);
98 126
99void InitWindow(void); 127void InitWindow (void);
100unsigned long GetColor(const char *); 128unsigned long GetColor (const char *);
101void redraw(void); 129void redraw (int);
102void refresh(struct linematrix *, int, int); 130void refresh (int, int, int, int);
103 131
104void transform_line(char *s); 132void transform_line (char *s);
105int lineinput(struct logfile_entry *); 133int lineinput (struct logfile_entry *);
106void reopen(void); 134void reopen (void);
107void check_open_files(void); 135void check_open_files (void);
108FILE *openlog(struct logfile_entry *); 136FILE *openlog (struct logfile_entry *);
109void main_loop(void); 137static void main_loop (void);
110 138
111void display_version(void); 139void display_version (void);
112void display_help(char *); 140void display_help (char *);
113void install_signal(int, void (*)(int)); 141void install_signal (int, void (*)(int));
114void *xstrdup(const char *); 142void *xstrdup (const char *);
115void *xmalloc(size_t); 143void *xmalloc (size_t);
144void *xrealloc (void *, size_t);
116int daemonize(void); 145int daemonize (void);
117 146
118/* signal handlers */ 147/* signal handlers */
148void
119void list_files(int dummy) 149list_files (int dummy)
120{ 150{
121 struct logfile_entry *e; 151 struct logfile_entry *e;
122 152
123 fprintf(stderr, "Files opened:\n"); 153 fprintf (stderr, "Files opened:\n");
124 for (e = loglist; e; e = e->next) 154 for (e = loglist; e; e = e->next)
125 fprintf(stderr, "\t%s (%s)\n", e->fname, e->desc); 155 fprintf (stderr, "\t%s (%s)\n", e->fname, e->desc);
126} 156}
127 157
158void
128void force_reopen(int dummy) 159force_reopen (int dummy)
129{ 160{
130 do_reopen = 1; 161 do_reopen = 1;
131} 162}
132 163
164void
133void force_refresh(int dummy) 165force_refresh (int dummy)
134{ 166{
135 XClearArea(disp, root, win_x, win_y, w, h + font_descent + 2, False);
136 redraw(); 167 redraw (1);
137} 168}
138 169
170void
139void blank_window(int dummy) 171blank_window (int dummy)
140{ 172{
141 XClearArea(disp, root, win_x, win_y, w, h + font_descent + 2, False); 173 XClearArea (disp, root, win_x - 2, win_y - 2, width + 5, height + 5, False);
142 XFlush(disp); 174 XFlush (disp);
143 exit(0); 175 exit (0);
144} 176}
145 177
146/* X related functions */ 178/* X related functions */
179unsigned long
147unsigned long GetColor(const char *ColorName) 180GetColor (const char *ColorName)
148{ 181{
149 XColor Color; 182 XColor Color;
150 XWindowAttributes Attributes; 183 XWindowAttributes Attributes;
151 184
152 XGetWindowAttributes(disp, root, &Attributes); 185 XGetWindowAttributes (disp, root, &Attributes);
153 Color.pixel = 0; 186 Color.pixel = 0;
154 187
155 if (!XParseColor(disp, Attributes.colormap, ColorName, &Color)) 188 if (!XParseColor (disp, Attributes.colormap, ColorName, &Color))
156 fprintf(stderr, "can't parse %s\n", ColorName); 189 fprintf (stderr, "can't parse %s\n", ColorName);
157 else if (!XAllocColor(disp, Attributes.colormap, &Color)) 190 else if (!XAllocColor (disp, Attributes.colormap, &Color))
158 fprintf(stderr, "can't allocate %s\n", ColorName); 191 fprintf (stderr, "can't allocate %s\n", ColorName);
159 192
160 return Color.pixel; 193 return Color.pixel;
161} 194}
162 195
196static Window
163static Window root_window (Display *display, int screen_number) 197root_window (Display * display, int screen_number)
164{ 198{
165 Atom __SWM_VROOT = XInternAtom (display, "__SWM_VROOT", False); 199 Atom SWM_VROOT = XInternAtom (display, "__SWM_VROOT", False);
166 Window real_root_window = RootWindow (display, screen_number); 200 Window real_root_window = RootWindow (display, screen_number);
167 201
168 if (root) /* root window set via option */ 202 if (root) /* root window set via option */
169 return root; 203 return root;
170 204
171 if (__SWM_VROOT != None) 205 if (SWM_VROOT != None)
172 { 206 {
173 Window unused, *windows; 207 Window unused, *windows;
174 unsigned int count; 208 unsigned int count;
175 209
176 if (XQueryTree (display, real_root_window, &unused, &unused, &windows, 210 if (XQueryTree (display, real_root_window, &unused, &unused, &windows,
177 &count)) 211 &count))
178 { 212 {
179 int i; 213 int i;
180 214
181 for (i = 0; i < count; i++) 215 for (i = 0; i < count; i++)
182 { 216 {
183 Atom type; 217 Atom type;
184 int format; 218 int format;
185 unsigned long nitems, bytes_after_return; 219 unsigned long nitems, bytes_after_return;
186 unsigned char *virtual_root_window; 220 unsigned char *virtual_root_window;
187 221
188 if (XGetWindowProperty (display, windows[i], __SWM_VROOT, 222 if (XGetWindowProperty (display, windows[i], SWM_VROOT,
189 0, 1, False, XA_WINDOW, &type, &format, 223 0, 1, False, XA_WINDOW, &type, &format,
190 &nitems, &bytes_after_return, 224 &nitems, &bytes_after_return,
191 &virtual_root_window) 225 &virtual_root_window) == Success)
192 == Success) 226 {
193 { 227 if (type != None)
194 if (type != None) 228 {
195 {
196 if (type == XA_WINDOW) 229 if (type == XA_WINDOW)
197 { 230 {
198 XFree (windows); 231 XFree (windows);
199 return (Window)virtual_root_window; 232 return (Window) virtual_root_window;
200 } 233 }
201 else 234 else
202 fprintf (stderr, "__SWM_VROOT property type mismatch"); 235 fprintf (stderr,
203 } 236 "__SWM_VROOT property type mismatch");
204 } 237 }
205 else 238 }
206 fprintf (stderr, 239 else
240 fprintf (stderr,
207 "failed to get __SWM_VROOT property on window 0x%lx", 241 "failed to get __SWM_VROOT property on window 0x%lx",
208 windows[i]); 242 windows[i]);
209 } 243 }
210 244
211 if (count) 245 if (count)
212 XFree (windows); 246 XFree (windows);
213 } 247 }
214 else 248 else
215 fprintf (stderr, "Can't query tree on root window 0x%lx", 249 fprintf (stderr, "Can't query tree on root window 0x%lx",
216 real_root_window); 250 real_root_window);
217 } 251 }
218 else 252 else
219 /* This shouldn't happen. The Xlib documentation is wrong BTW. */ 253 /* This shouldn't happen. The Xlib documentation is wrong BTW. */
220 fprintf (stderr, "Can't intern atom __SWM_VROOT"); 254 fprintf (stderr, "Can't intern atom __SWM_VROOT");
221 255
222 return real_root_window; 256 return real_root_window;
223} 257}
224 258
259void
225void InitWindow(void) 260InitWindow (void)
226{ 261{
227 XGCValues gcv; 262 XGCValues gcv;
228 Font font;
229 unsigned long gcm; 263 unsigned long gcm;
230 XFontStruct *info;
231 int screen, ScreenWidth, ScreenHeight; 264 int screen, ScreenWidth, ScreenHeight;
232 265
233 if (!(disp = XOpenDisplay(dispname))) { 266 if (!(disp = XOpenDisplay (dispname)))
267 {
234 fprintf(stderr, "Can't open display %s.\n", dispname); 268 fprintf (stderr, "Can't open display %s.\n", dispname);
235 exit(1); 269 exit (1);
236 } 270 }
271
237 screen = DefaultScreen(disp); 272 screen = DefaultScreen (disp);
238 ScreenHeight = DisplayHeight(disp, screen); 273 ScreenHeight = DisplayHeight (disp, screen);
239 ScreenWidth = DisplayWidth(disp, screen); 274 ScreenWidth = DisplayWidth (disp, screen);
240 275
241 root = root_window (disp, screen); 276 root = root_window (disp, screen);
242 277
243 gcm = GCBackground; 278 gcm = GCBackground;
244 gcv.graphics_exposures = True; 279 gcv.graphics_exposures = True;
245 WinGC = XCreateGC(disp, root, gcm, &gcv); 280 WinGC = XCreateGC (disp, root, gcm, &gcv);
246 XMapWindow(disp, root); 281 XMapWindow (disp, root);
247 XSetForeground(disp, WinGC, GetColor(DEF_COLOR)); 282 XSetForeground (disp, WinGC, GetColor (DEF_COLOR));
248 283
284 {
285 char **missing_charset_list;
286 int missing_charset_count;
287 char *def_string;
288
249 font = XLoadFont(disp, fontname); 289 fontset = XCreateFontSet (disp, fontname,
250 XSetFont(disp, WinGC, font); 290 &missing_charset_list, &missing_charset_count,
251 info = XQueryFont(disp, font); 291 &def_string);
252 font_width = info->max_bounds.width;
253 font_descent = info->max_bounds.descent;
254 font_height = info->max_bounds.ascent + font_descent;
255 292
256 w = width * font_width; 293 if (missing_charset_count)
257 h = listlen * font_height; 294 {
295 fprintf (stderr,
296 "Missing charsets in String to FontSet conversion (%s)\n",
297 missing_charset_list[0]);
298 XFreeStringList (missing_charset_list);
299 }
300 }
258 301
302 if (!fontset)
303 {
304 fprintf (stderr, "unable to create fontset, exiting.\n");
305 exit (1);
306 }
307
308 {
309 XFontSetExtents *xfe = XExtentsOfFontSet (fontset);
310
311 font_height = xfe->max_logical_extent.height;
312 font_ascent = -xfe->max_logical_extent.y;
313 }
314
259 if (geom_mask & XNegative) 315 if (geom_mask & XNegative)
260 win_x = win_x + ScreenWidth - w; 316 win_x = win_x + ScreenWidth - width;
261 if (geom_mask & YNegative) 317 if (geom_mask & YNegative)
262 win_y = win_y + ScreenHeight - h; 318 win_y = win_y + ScreenHeight - height;
263 319
320 if (opt_outline)
321 {
322 /* adding outline increases the total width and height by 2
323 pixels each, and offsets the text one pixel right and one
324 pixel down */
325 effect_x_space = effect_y_space = 2;
326 effect_x_offset = effect_y_offset = 1;
327 }
328 else if (opt_shade)
329 {
330 /* adding a shadow increases the space used */
331 effect_x_space = abs(SHADE_X);
332 effect_y_space = abs(SHADE_Y);
333 /* if the shadow is to the right and below then we don't need
334 * to move the text to make space for it, but shadows to the left
335 * and above need accomodating */
336 effect_x_offset = SHADE_X > 0 ? 0 : -SHADE_X;
337 effect_y_offset = SHADE_Y > 0 ? 0 : -SHADE_Y;
338 }
339 else
340 {
341 effect_x_space = effect_y_space = 0;
342 effect_x_offset = effect_y_offset = 0;
343 }
344
345 /* if we are using -shade or -outline, there will be less usable
346 * space for output */
347 listlen = (height - effect_y_space) / font_height;
348
349 if (!listlen)
350 {
351 fprintf (stderr, "height too small for a single line, setting to %d\n",
352 font_height);
353 listlen = 1;
354 }
355
356 /* leave the height how the user requested it. it might not all be
357 * used, but this will allow the geometry to be tuned more accurately
358 * (with the -frame option)
359 * the old code did this:
360 * height = listlen * font_height + effect_y_space; */
361
264 XSelectInput(disp, root, ExposureMask|FocusChangeMask); 362 XSelectInput (disp, root, ExposureMask | FocusChangeMask);
265}
266
267char *
268detabificate (char *s)
269{
270 char * out;
271 int i, j;
272
273 out = malloc (8 * strlen (s) + 1);
274
275 for(i = 0, j = 0; s[i]; i++)
276 {
277 if (s[i] == '\t')
278 do
279 out[j++] = ' ';
280 while (j % 8);
281 else
282 out[j++] = s[i];
283 }
284
285 out[j] = '\0';
286 return out;
287} 363}
288 364
289/* 365/*
290 * redraw does a complete redraw, rather than an update (i.e. the area 366 * if redraw() is passwd a non-zero argument, it does a complete
291 * gets cleared first) 367 * redraw, rather than an update. if the argument is zero (and
368 * -noflicker is in effect) then only the lines which have changed
369 * since the last draw are redrawn.
370 *
292 * the rest is handled by regular refresh()'es 371 * the rest is handled by regular refresh()'es
293 */ 372 */
294void redraw(void) 373void
374redraw (int redraw_all)
295{ 375{
296 XClearArea(disp, root, win_x, win_y, w, h + font_descent + 2, True); 376 XSetClipMask (disp, WinGC, None);
377 refresh (0, 32768, 1, redraw_all);
297} 378}
298 379
299/* Just redraw everything without clearing (i.e. after an EXPOSE event) */ 380/* Just redraw everything without clearing (i.e. after an EXPOSE event) */
300void refresh(struct linematrix *lines, int miny, int maxy) 381void
382refresh (int miny, int maxy, int clear, int refresh_all)
301{ 383{
302 int lin; 384 int lin;
303 int offset = (listlen + 1) * font_height; 385 int offset = listlen * font_height + font_ascent + effect_y_offset;
304 unsigned long black_color = GetColor("black"); 386 unsigned long black_color = GetColor ("black");
305 387
306 miny -= win_y + font_height; 388 miny -= win_y + font_height;
307 maxy -= win_y - font_height; 389 maxy -= win_y - font_height;
308 390
391 if (clear && !opt_noflicker)
392 XClearArea (disp, root, win_x, win_y, width, height, False);
393
309 for (lin = listlen; lin--;) 394 for (lin = listlen; lin--;)
310 { 395 {
311 char *temp; 396 struct linematrix *line = lines + (opt_reverse ? listlen - lin - 1 : lin);
397 struct displaymatrix *display_line = display + lin;
312 398
313 offset -= font_height; 399 offset -= font_height;
314 400
315 if (offset < miny || offset > maxy) 401 if (offset < miny || offset > maxy)
316 continue; 402 continue;
317 403
318#define LIN ((opt_reverse)?(listlen-lin-1):(lin)) 404 /* if this line is a different than it was, then it
319 temp = detabificate (lines[LIN].line); 405 * needs displaying */
406 if (!opt_noflicker
407 || refresh_all
408 || display_line->len != line->len
409 || memcmp (display_line->line, line->line, line->len))
410 {
411 /* don't bother updating the record of what has been
412 * displayed if -noflicker isn't in effect, since we redraw
413 * the whole display every time anyway */
414 if (opt_noflicker)
415 {
416 /* update the record of what has been displayed;
417 * first make sure the buffer is big enough */
418 if (display_line->buffer_size <= line->len)
419 {
420 display_line->buffer_size = line->len + 1;
421 display_line->line = xrealloc (display_line->line, display_line->buffer_size);
422 }
320 423
424 display_line->len = line->len;
425 memcpy (display_line->line, line->line, line->len);
426
427 if (clear)
428 XClearArea (disp, root, win_x, win_y + offset - font_ascent,
429 width + effect_x_space, font_height + effect_y_space, False);
430 }
431
321 if (opt_shade) 432 if (opt_outline)
322 { 433 {
434 int x, y;
323 XSetForeground (disp, WinGC, black_color); 435 XSetForeground (disp, WinGC, black_color);
324#if 0 436
437 for (x = -1; x < 2; x += 2)
438 for (y = -1; y < 2; y += 2)
439 XmbDrawString (disp, root, fontset, WinGC,
440 win_x + effect_x_offset + x,
441 win_y + y + offset,
442 line->line, line->len);
443 }
444 else if (opt_shade)
445 {
446 XSetForeground (disp, WinGC, black_color);
325 XmbDrawString (disp, root, fontset, WinGC, win_x + 2, win_y + offset + 2, 447 XmbDrawString (disp, root, fontset, WinGC,
326 temp, strlen (temp)); 448 win_x + effect_x_offset + SHADE_X,
449 win_y + offset + SHADE_Y,
450 line->line, line->len);
451 }
452
453 XSetForeground (disp, WinGC, line->color);
454 XmbDrawString (disp, root, fontset, WinGC,
455 win_x + effect_x_offset,
456 win_y + offset,
457 line->line, line->len);
458 }
459 }
460
461 if (opt_frame)
462 {
463 XSetForeground (disp, WinGC, GetColor (def_color));
464 XDrawRectangle (disp, root, WinGC, win_x - 0, win_y - 0, width - 1, height - 1);
465 }
466}
467
468#if HAS_REGEX
469void
470transform_line (char *s)
471{
472#ifdef I_AM_Md
473 int i;
474 if (1)
475 {
476 for (i = 16; s[i]; i++)
477 s[i] = s[i + 11];
478 }
479 s[i + 1] = '\0';
327#endif 480#endif
328 XDrawString (disp, root, WinGC, win_x + 2, win_y + offset + 2, 481
329 temp, strlen (temp)); 482 if (transformre)
483 {
484 int i;
485 regmatch_t matched[16];
486
487 i = regexec (transformre, s, 16, matched, 0);
488 if (i == 0)
489 { /* matched */
490 int match_start = matched[0].rm_so;
491 int match_end = matched[0].rm_eo;
492 int old_len = match_end - match_start;
493 int new_len = strlen(transform_to);
494 int old_whole_len = strlen(s);
495 printf("regexp was matched by '%s' - replace with '%s'\n", s, transform_to);
496 printf("match is from %d to %d\n",
497 match_start, match_end);
498 if (new_len > old_len) {
499 s = xrealloc(s, old_whole_len + new_len - old_len);
500 }
501 if (new_len != old_len) {
502 memcpy(s + match_end + new_len - old_len,
503 s + match_end,
504 old_whole_len - match_end);
505 s[old_whole_len + new_len - old_len] = '\0';
506 }
507 memcpy(s + match_start,
508 transform_to,
509 new_len);
510 printf("transformed to '%s'\n", s);
330 } 511 }
331 512 else
332 XSetForeground (disp, WinGC, lines[LIN].color); 513 {
333#if 0 514 printf("regexp was not matched by '%s'\n", s);
334 XmbDrawString (disp, root, fontset, WinGC, win_x, win_y + offset, 515 }
335 temp, strlen (temp)); 516 }
517}
336#endif 518#endif
337 XDrawString (disp, root, WinGC, win_x, win_y + offset, 519
338 temp, strlen (temp)); 520char *
339 free (temp); 521concat_line (const char *p1, const char *p2)
522{
523 int l1 = p1 ? strlen (p1) : 0;
524 int l2 = strlen (p2);
525 char *r = xmalloc (l1 + l2 + 1);
526
527 memcpy (r, p1, l1);
528 memcpy (r + l1, p2, l2);
529 r[l1 + l2] = 0;
530
531 return r;
532}
533
534/*
535 * HACK-1: This routine should read a single line, no matter how long.
536 */
537int
538lineinput (struct logfile_entry *logfile)
539{
540 char buff[1024], *p = buff;
541 int ch;
542 /* HACK-2: add on the length of any partial line which we will be appending to */
543 int ofs = logfile->buf ? strlen (logfile->buf) : 0;
544
545 do
340 } 546 {
547 ch = fgetc (logfile->fp);
341 548
342 if (opt_frame) { 549 if (ch == '\n' || ch == EOF)
343 int bot_y = win_y + h + font_descent + 2; 550 break;
344 551 else if (ch == '\r')
345 XDrawLine(disp, root, WinGC, win_x, win_y, win_x + w, win_y); 552 continue; /* skip */
346 XDrawLine(disp, root, WinGC, win_x + w, win_y, win_x + w, bot_y); 553 else if (ch == '\t')
347 XDrawLine(disp, root, WinGC, win_x + w, bot_y, win_x, bot_y); 554 {
348 XDrawLine(disp, root, WinGC, win_x, bot_y, win_x, win_y); 555 do
556 {
557 *p++ = ' ';
558 ofs++;
559 }
560 while (ofs & 7);
561 }
562 else
563 {
564 *p++ = ch;
565 ofs++;
566 }
349 } 567 }
350} 568 while (p < buff + (sizeof buff) - 8 - 1);
569
570 if (p == buff && ch == EOF)
571 return 0;
572
573 *p = 0;
574
575 p = concat_line (logfile->buf, buff);
576 free (logfile->buf); logfile->buf = p;
577
578 logfile->lastpartial = logfile->partial;
579 /* there are 3 ways we could have exited the loop: reading '\n',
580 * reaching EOF, or filling the buffer; the 2nd and 3rd of these
581 * both result in a partial line */
582 logfile->partial = ch != '\n';
583
584 if (logfile->partial && opt_whole)
585 return 0;
351 586
352#if HAS_REGEX 587#if HAS_REGEX
353void transform_line(char *s) 588 transform_line (logfile->buf);
354{
355#ifdef I_AM_Md
356 int i;
357 if (1) {
358 for (i = 16; s[i]; i++)
359 s[i] = s[i + 11];
360 }
361 s[i + 1] = '\0';
362#endif 589#endif
363
364 if (transformre) {
365 int i;
366 regmatch_t matched[16];
367
368 i = regexec(&transformre, string, 16, matched, 0);
369 if (i == 0) { /* matched */
370 }
371 }
372}
373#endif
374
375
376/*
377 * This routine should read 'width' characters and not more. However,
378 * we really want to read width + 1 characters if the last char is a '\n',
379 * which we should remove afterwards. So, read width+1 chars and ungetc
380 * the last character if it's not a newline. This means 'string' must be
381 * width + 2 wide!
382 */
383int lineinput(struct logfile_entry *logfile)
384{
385 char *string = logfile->buf;
386 int slen = width + 2;
387 FILE *f = logfile->fp;
388
389 int len = strlen(string);
390 int partial = logfile->partial;
391
392 do {
393 if (fgets(string + len, slen - len, f) == NULL) /* EOF or Error */
394 return 0; 590 return 1;
395
396 len = strlen(string);
397 } while (len == 0);
398
399 logfile->partial = 0;
400
401 /* if the string ends in a newline, delete the newline */
402 if (string[len - 1] == '\n')
403 string[len - 1] = '\0'; /* erase newline */
404 /* otherwise if we've read one too many characters, un-read the last one and delete it */
405 else if (len >= slen - 1) {
406 ungetc(string[len - 1], f);
407 string[len - 1] = '\0';
408 } else if (opt_whole)
409 return 0;
410 else
411 logfile->partial = 1;
412
413#if HAS_REGEX
414 transform_line(string);
415#endif
416 logfile->lastpartial = partial;
417 return len;
418} 591}
419 592
420/* input: reads file->fname 593/* input: reads file->fname
421 * output: fills file->fp, file->inode 594 * output: fills file->fp, file->inode
422 * returns file->fp 595 * returns file->fp
423 * in case of error, file->fp is NULL 596 * in case of error, file->fp is NULL
424 */ 597 */
598FILE *
425FILE *openlog(struct logfile_entry *file) 599openlog (struct logfile_entry * file)
426{ 600{
427 struct stat stats; 601 struct stat stats;
428 602
429 if ((file->fp = fopen(file->fname, "r")) == NULL) { 603 if ((file->fp = fopen (file->fname, "r")) == NULL)
604 {
430 file->fp = NULL; 605 file->fp = NULL;
431 return NULL; 606 return NULL;
432 } 607 }
433 608
434 fstat(fileno(file->fp), &stats); 609 fstat (fileno (file->fp), &stats);
435 if (S_ISFIFO(stats.st_mode)) { 610 if (S_ISFIFO (stats.st_mode))
611 {
436 if (fcntl(fileno(file->fp), F_SETFL, O_NONBLOCK) < 0) 612 if (fcntl (fileno (file->fp), F_SETFL, O_NONBLOCK) < 0)
437 perror("fcntl"), exit(1); 613 perror ("fcntl"), exit (1);
438 file->inode = 0; 614 file->inode = 0;
615 }
439 } else 616 else
440 file->inode = stats.st_ino; 617 file->inode = stats.st_ino;
441 618
442 if (opt_noinitial) 619 if (opt_noinitial)
443 fseek (file->fp, 0, SEEK_END); 620 fseek (file->fp, 0, SEEK_END);
444 else if (stats.st_size > (listlen + 1) * width) 621 else if (stats.st_size > (listlen + 1) * width)
445 fseek(file->fp, -((listlen + 2) * width), SEEK_END); 622 fseek (file->fp, -((listlen + 2) * width), SEEK_END);
446 623
447 file->last_size = stats.st_size; 624 file->last_size = stats.st_size;
448 return file->fp; 625 return file->fp;
449} 626}
450 627
628void
451void reopen(void) 629reopen (void)
452{ 630{
453 struct logfile_entry *e; 631 struct logfile_entry *e;
454 632
455 for (e = loglist; e; e = e->next) { 633 for (e = loglist; e; e = e->next)
634 {
456 if (!e->inode) 635 if (!e->inode)
457 continue; /* skip stdin */ 636 continue; /* skip stdin */
458 637
459 if (e->fp) 638 if (e->fp)
460 fclose(e->fp); 639 fclose (e->fp);
461 /* if fp is NULL we will try again later */ 640 /* if fp is NULL we will try again later */
462 openlog(e); 641 openlog (e);
463 } 642 }
464 643
465 do_reopen = 0; 644 do_reopen = 0;
466} 645}
467 646
647void
468void check_open_files(void) 648check_open_files (void)
469{ 649{
470 struct logfile_entry *e; 650 struct logfile_entry *e;
471 struct stat stats; 651 struct stat stats;
472 652
473 for (e = loglist; e; e = e->next) { 653 for (e = loglist; e; e = e->next)
654 {
474 if (!e->inode) 655 if (!e->inode)
475 continue; /* skip stdin */ 656 continue; /* skip stdin */
476 657
477 if (stat(e->fname, &stats) < 0) { /* file missing? */ 658 if (stat (e->fname, &stats) < 0)
659 { /* file missing? */
478 sleep(1); 660 sleep (1);
479 if (e->fp) 661 if (e->fp)
480 fclose(e->fp); 662 fclose (e->fp);
481 if (openlog(e) == NULL) 663 if (openlog (e) == NULL)
482 break; 664 continue;
665 if (fstat (fileno (e->fp), &stats) < 0)
666 continue;
667 }
668
669 if (stats.st_ino != e->inode)
670 { /* file renamed? */
671 if (e->fp)
672 fclose (e->fp);
673 if (openlog (e) == NULL)
674 continue;
675 }
676
677 if (stats.st_size < e->last_size)
678 { /* file truncated? */
679 fseek (e->fp, 0, SEEK_SET);
680 e->last_size = stats.st_size;
681 }
682 }
683}
684
685/*
686 * insert a single physical line (that must be short enough to fit)
687 * at position "idx" by pushing up lines above it. the caller
688 * MUST then fill in lines[idx] with valid data.
689 */
690static void
691insert_line (int idx)
692{
693 int cur_line;
694 struct logfile_entry *current;
695
696 free (lines[0].line);
697
698 for (cur_line = 0; cur_line < idx; cur_line++)
699 lines[cur_line] = lines[cur_line + 1];
700
701 for (current = loglist; current; current = current->next)
702 if (current->index <= idx)
703 current->index--;
704}
705
706/*
707 * remove a single physical line at position "idx" by moving the lines above it
708 * down and inserting a "~" line at the top.
709 */
710static void
711delete_line (int idx)
712{
713 int cur_line;
714 struct logfile_entry *current;
715
716 for (cur_line = idx; cur_line > 0; cur_line--)
717 lines[cur_line] = lines[cur_line - 1];
718
719 lines[0].line = xstrdup ("~");
720
721 for (current = loglist; current; current = current->next)
722 if (current->index >= 0 && current->index <= idx)
723 current->index++;
724}
725
726/*
727 * takes a logical log file line and splits it into multiple physical
728 * screen lines by splitting it whenever a part becomes too long.
729 * lal lines will be inserted at position "idx".
730 */
731static void
732split_line (int idx, const char *str, unsigned long color)
733{
734 int l = strlen (str);
735 int last_wrapped = 0;
736 const char *p = str;
737 static int continuation_width = -1;
738 static int continuation_length;
739
740 /* only calculate the continuation's width once */
741 if (continuation_width == -1)
742 {
743 continuation_length = strlen(continuation);
744 continuation_width = XmbTextEscapement (fontset, continuation, continuation_length);
745 }
746
747 do
748 {
749 const char *beg = p;
750 int w = last_wrapped ? continuation_width : 0;
751 int wrapped = 0;
752 const char *break_p = NULL;
753
754 while (*p)
755 {
756 /* find the length in bytes of the next multibyte character */
757 int len = mblen (p, l);
758 if (len <= 0)
759 len = 1; /* ignore (don't skip) illegal character sequences */
760
761 /* find the width in pixels of the next character */
762 int cw = XmbTextEscapement (fontset, p, len);
763 if (cw + w > width - effect_x_space)
764 {
765 if (p == beg)
766 {
767 fprintf(stderr, "we can't even fit a single character onto the line\n");
768 if (len == 1) fprintf(stderr, "(the character we couldn't fit was '%c')\n", *p);
769 exit(1);
770 }
771
772 wrapped = 1;
773 break;
774 }
775
776 if (opt_wordwrap && len == 1 && p[0] == ' ')
777 break_p = p;
778
779 w += cw;
780 p += len;
781 l -= len;
782 }
783
784 /* if we're wrapping at spaces, and the line is long enough to
785 * wrap, and we've seen a space already, and the space wasn't
786 * the first character on the line, then wrap at the space */
787 if (opt_wordwrap && wrapped && break_p && break_p != beg)
788 {
789 l += p - break_p;
790 p = break_p;
483 } 791 }
484 792
485 if (stats.st_ino != e->inode) { /* file renamed? */ 793 {
486 if (e->fp) 794 /* HACK-4 - consider inserting the 'continuation string'
487 fclose(e->fp); 795 * before the rest of the wrapped line */
488 if (openlog(e) == NULL) 796 int len = p - beg + (last_wrapped ? continuation_length : 0);
489 break; 797 char *s = xmalloc (len + 1);
798 if (last_wrapped)
799 {
800 memcpy (s, continuation, continuation_length);
801 memcpy (s + continuation_length, beg, p - beg);
802 }
803 else
804 memcpy (s, beg, len);
805
806 s[len] = 0;
807 insert_line (idx);
808 lines[idx].line = s;
809 lines[idx].len = len;
810 lines[idx].color = color;
811 }
812
813 /* if we wrapped at a space, don't display the space */
814 if (opt_wordwrap && wrapped && break_p && break_p != beg)
815 {
816 l--;
817 p++;
490 } 818 }
491 819
492 if (stats.st_size < e->last_size) { /* file truncated? */ 820 last_wrapped = wrapped;
493 fseek(e->fp, 0, SEEK_SET);
494 e->last_size = stats.st_size;
495 }
496 } 821 }
822 while (l);
497} 823}
498 824
499#define SCROLL_UP(lines, listlen) \ 825/*
500{ \ 826 * append something to an existing physical line. this is done
501 int cur_line; \ 827 * by deleting the file on-screen, concatenating the new data to it
502 struct logfile_entry *current; \ 828 * and splitting it again.
503 for (cur_line = 0; cur_line < (listlen - 1); cur_line++) { \ 829 */
504 strcpy(lines[cur_line].line, lines[cur_line + 1].line); \ 830static void
505 lines[cur_line].color = lines[cur_line + 1].color; \ 831append_line (int idx, const char *str)
506 } \ 832{
507 for (current = loglist; current; current = current->next) \ 833 unsigned long color = lines[idx].color;
508 if (current->partial && current->index) \ 834 char *old = lines[idx].line;
509 current->index--; \ 835 char *new = concat_line (old, str);
510}
511 836
837 free (old);
838
839 delete_line (idx);
840 split_line (idx, new, color);
841}
842
843static void
512void main_loop(void) 844main_loop (void)
513{ 845{
514 struct linematrix *lines = xmalloc(sizeof(struct linematrix) * listlen); 846 lines = xmalloc (sizeof (struct linematrix) * listlen);
515 int lin, miny, maxy; 847 display = xmalloc (sizeof (struct displaymatrix) * listlen);
848 int lin;
516 time_t lastreload; 849 time_t lastreload;
517 Region region = XCreateRegion(); 850 Region region = XCreateRegion ();
518 XEvent xev; 851 XEvent xev;
519 struct logfile_entry *lastprinted = NULL; 852 struct logfile_entry *lastprinted = NULL;
520 struct logfile_entry *current; 853 struct logfile_entry *current;
854 int need_update = 1;
521 855
522 maxy = 0;
523 miny = win_y + h;
524 lastreload = time(NULL); 856 lastreload = time (NULL);
525 857
526 /* Initialize linematrix */ 858 /* Initialize linematrix */
527 for (lin = 0; lin < listlen; lin++) { 859 for (lin = 0; lin < listlen; lin++)
528 lines[lin].line = xmalloc(width + 2); 860 {
529 strcpy(lines[lin].line, "~"); 861 lines[lin].line = xstrdup ("~");
862 lines[lin].len = 1;
863 display[lin].line = xstrdup("");
864 display[lin].len = 0;
865 display[lin].buffer_size = 1;
530 lines[lin].color = GetColor(def_color); 866 lines[lin].color = GetColor (def_color);
531 } 867 }
532 868
533 /* show the display full of empty lines ("~") in case the first
534 * time around the loop doesn't produce any output, as it won't if
535 * either (a) -noinitial is set or (b) all the files are currently
536 * empty */
537 redraw();
538
539 for (;;) { 869 for (;;)
540 int need_update = 0; 870 {
541
542 /* read logs */ 871 /* read logs */
543 for (current = loglist; current; current = current->next) { 872 for (current = loglist; current; current = current->next)
873 {
544 if (!current->fp) 874 if (!current->fp)
545 continue; /* skip missing files */ 875 continue; /* skip missing files */
546 876
547 clearerr(current->fp); 877 clearerr (current->fp);
548 878
549 while (lineinput(current) != 0) { 879 while (lineinput (current))
550 880 {
881 need_update = 1;
551 /* if we're trying to update old partial lines in 882 /* if we're trying to update old partial lines in
552 * place, and the last time this file was updated the 883 * place, and the last time this file was updated the
553 * output was partial, and that partial line is not 884 * output was partial, and that partial line is not
554 * too close to the top of the screen, then update 885 * too close to the top of the screen, then update
555 * that partial line */ 886 * that partial line */
556 if (opt_update && current->lastpartial && current->index >= 3) { 887 if (opt_update && current->lastpartial && current->index >= 0)
557 int old_len = strlen(lines[current->index].line); 888 {
558 int new_len = strlen(current->buf); 889 int idx = current->index;
559 int space_on_old_line = width - old_len; 890 append_line (idx, current->buf);
560 strncat(lines[current->index].line, current->buf, width - old_len); 891 current->index = idx;
561 /* if we can't fit the whole update into the old 892 free (current->buf), current->buf = 0;
562 * partial line then we're going to have to print 893 continue;
563 * the rest of it at the bottom on the screen */ 894 }
564 if (new_len > space_on_old_line) { 895
565 /* strcpy() doesn't like the strings to 896 /* print filename if any, and if last line was from
566 * overlap in memory, but memmove() doesn't 897 * different file */
567 * care */ 898 if (!opt_nofilename && lastprinted != current && current->desc[0])
568 memmove(current->buf, 899 {
569 current->buf + space_on_old_line, 900 char buf[1024]; /* HACK-5 */
570 new_len - space_on_old_line + 1); 901 snprintf (buf, sizeof (buf), "[%s]", current->desc);
571 } else { 902 split_line (listlen - 1, buf, current->color);
572 need_update = 1; 903 }
573 strcpy(current->buf, ""); 904
574 continue; 905 /* if we're dealing with partial lines, and the last
906 * time we showed the line it wasn't finished ... */
907 if (!opt_whole && current->lastpartial)
908 {
909 /* if this is the same file we showed last then
910 append to the last line shown */
911 if (lastprinted == current)
912 append_line (listlen - 1, current->buf);
913 else
914 {
915 /* but if a different file has been shown in the
916 * mean time, make a new line, starting with the
917 * continuation string */
918 split_line (listlen - 1, continuation, current->color);
919 append_line (listlen - 1, current->buf);
575 } 920 }
576 } 921 }
922 else
923 /* otherwise just make a plain and simple new line */
924 split_line (listlen - 1, current->buf, current->color);
577 925
578 /* print filename if any, and if last line was from 926 free (current->buf), current->buf = 0;
579 * different file */ 927 current->index = listlen - 1;
580 if (!opt_nofilename && 928 lastprinted = current;
581 lastprinted != current && 929 }
582 current->desc[0]) { 930 }
583 SCROLL_UP(lines, listlen);
584 sprintf(lines[listlen - 1].line, "[%s]", current->desc);
585 lines[listlen - 1].color = current->color;
586 }
587 931
588 /* if this is the same file we showed last, and the 932 if (need_update)
589 * last time we showed it, it wasn't finished, then 933 {
590 * append to the last line shown */ 934 redraw (0);
591 if (lastprinted == current && current->lastpartial) { 935 need_update = 0;
592 int old_len = strlen(lines[listlen - 1].line); 936 }
593 int new_len = strlen(current->buf); 937 else
594 strncat(lines[listlen - 1].line, current->buf, width - old_len); 938 {
595 /* if it doesn't all fit, then put the part that 939 XFlush (disp);
596 * doesn't fit on a new line */ 940
597 if (new_len > width - old_len) { 941 if (!XPending (disp))
598 SCROLL_UP(lines, listlen); 942 {
599 strcpy(lines[listlen - 1].line, current->buf + width - old_len); 943 fd_set fdr;
944 struct timeval to = interval;
945
946 FD_ZERO (&fdr);
947 FD_SET (ConnectionNumber (disp), &fdr);
948 select (ConnectionNumber (disp) + 1, &fdr, 0, 0, &to);
949 }
950 }
951
952 check_open_files ();
953
954 if (do_reopen)
955 reopen ();
956
957 /* we ignore possible errors due to window resizing &c */
958 while (XPending (disp))
959 {
960 XNextEvent (disp, &xev);
961
962 switch (xev.type)
963 {
964 case Expose:
965 {
966 XRectangle r;
967
968 r.x = xev.xexpose.x;
969 r.y = xev.xexpose.y;
970 r.width = xev.xexpose.width;
971 r.height = xev.xexpose.height;
972
973 XUnionRectWithRegion (&r, region, region);
974 }
975 break;
976 default:
977#ifdef DEBUGMODE
978 fprintf (stderr, "PANIC! Unknown event %d\n", xev.type);
979#endif
980 break;
981 }
982 }
983
984 /* reload if requested */
985 if (reload && lastreload + reload < time (NULL))
986 {
987 if (command && command[0])
988 system (command);
989
990 reopen ();
991 lastreload = time (NULL);
992 }
993
994 if (!XEmptyRegion (region))
995 {
996 XRectangle r;
997
998 XSetRegion (disp, WinGC, region);
999 XClipBox (region, &r);
1000
1001 refresh (r.y, r.y + r.height, 0, 1);
1002
1003 XDestroyRegion (region);
1004 region = XCreateRegion ();
1005 }
600 } 1006 }
601 /* show the 'continuation' string because we've got a 1007}
602 * continued partial line, but we weren't able to
603 * append it to the old displayed partial line */
604 } else if (current->lastpartial) {
605 int old_len = strlen(continuation);
606 int new_len = strlen(current->buf);
607 SCROLL_UP(lines, listlen);
608 strcpy(lines[listlen - 1].line, continuation);
609 strncat(lines[listlen - 1].line, current->buf, width - old_len);
610 /* it might not fit, now that we've displayed the
611 * continuation string, so we may need to 'wrap' it */
612 if (new_len > width - old_len) {
613 SCROLL_UP(lines, listlen);
614 strcpy(lines[listlen - 1].line, current->buf + width - old_len);
615 }
616 } else {
617 SCROLL_UP(lines, listlen);
618 strcpy(lines[listlen - 1].line, current->buf);
619 }
620 1008
621 /* we've shown the line now. clear the buffer for the next line */
622 strcpy(current->buf, "");
623 current->index = listlen - 1;
624 lines[listlen - 1].color = current->color;
625 1009
626 lastprinted = current; 1010int
627 need_update = 1; 1011main (int argc, char *argv[])
1012{
1013 int i;
1014 int opt_daemonize = 0;
1015 int opt_partial = 0, file_count = 0;
1016#if HAS_REGEX
1017 char *transform = NULL;
1018#endif
1019
1020 setlocale (LC_CTYPE, ""); /* try to initialize the locale. */
1021
1022 /* window needs to be initialized before colorlookups can be done */
1023 /* just a dummy to get the color lookups right */
1024 geom_mask = NoValue;
1025 InitWindow ();
1026
1027 for (i = 1; i < argc; i++)
1028 {
1029 const char *arg = argv[i];
1030
1031 if (arg[0] == '-' && arg[1] != '\0' && arg[1] != ',')
1032 {
1033 if (arg[1] == '-')
1034 arg++;
1035
1036 if (!strcmp (arg, "-?") ||
1037 !strcmp (arg, "-help") || !strcmp (arg, "-h"))
1038 display_help (argv[0]);
1039 else if (!strcmp (arg, "-V"))
1040 display_version ();
1041 else if (!strcmp (arg, "-g") || !strcmp (arg, "-geometry"))
1042 geom_mask =
1043 XParseGeometry (argv[++i], &win_x, &win_y, &width, &height);
1044 else if (!strcmp (arg, "-display"))
1045 dispname = argv[++i];
1046 else if (!strcmp (arg, "-cont"))
1047 continuation = argv[++i];
1048 else if (!strcmp (arg, "-font") || !strcmp (arg, "-fn"))
1049 fontname = argv[++i];
1050#if HAS_REGEX
1051 else if (!strcmp (arg, "-t"))
1052 {
1053 transform = argv[++i];
1054 transform_to = argv[++i];
1055 printf("transform: '%s' to '%s'\n", transform, transform_to);
628 } 1056 }
1057#endif
1058 else if (!strcmp (arg, "-fork") || !strcmp (arg, "-f"))
1059 opt_daemonize = 1;
1060 else if (!strcmp (arg, "-reload"))
1061 {
1062 reload = atoi (argv[++i]);
1063 command = argv[++i];
1064 }
1065 else if (!strcmp (arg, "-shade"))
1066 opt_shade = 1;
1067 else if (!strcmp (arg, "-outline"))
1068 opt_outline = 1;
1069 else if (!strcmp (arg, "-noflicker"))
1070 opt_noflicker = 1;
1071 else if (!strcmp (arg, "-frame"))
1072 opt_frame = 1;
1073 else if (!strcmp (arg, "-no-filename"))
1074 opt_nofilename = 1;
1075 else if (!strcmp (arg, "-reverse"))
1076 opt_reverse = 1;
1077 else if (!strcmp (arg, "-whole"))
1078 opt_whole = 1;
1079 else if (!strcmp (arg, "-partial"))
1080 opt_partial = 1;
1081 else if (!strcmp (arg, "-update"))
1082 opt_update = opt_partial = 1;
1083 else if (!strcmp (arg, "-wordwrap"))
1084 opt_wordwrap = 1;
1085 else if (!strcmp (arg, "-color"))
1086 def_color = argv[++i];
1087 else if (!strcmp (arg, "-noinitial"))
1088 opt_noinitial = 1;
1089 else if (!strcmp (arg, "-id"))
1090 root = atoi (argv[++i]);
1091 else if (!strcmp (arg, "-interval") || !strcmp (arg, "-i"))
1092 {
1093 double iv = atof (argv[++i]);
1094
1095 interval.tv_sec = (int) iv;
1096 interval.tv_usec = (iv - interval.tv_sec) * 1e6;
1097 }
1098 else
1099 {
1100 fprintf (stderr, "Unknown option '%s'.\n"
1101 "Try --help for more information.\n", arg);
1102 exit (1);
1103 }
1104 }
1105 else
1106 { /* it must be a filename */
1107 struct logfile_entry *e;
1108 const char *fname, *desc, *fcolor = def_color;
1109 char *p;
1110
1111 file_count++;
1112
1113 /* this is not foolproof yet (',' in filenames are not allowed) */
1114 fname = desc = arg;
1115 if ((p = strchr (arg, ',')))
1116 {
1117 *p = '\0';
1118 fcolor = p + 1;
1119
1120 if ((p = strchr (fcolor, ',')))
1121 {
1122 *p = '\0';
1123 desc = p + 1;
1124 }
1125 }
1126
1127 e = xmalloc (sizeof (struct logfile_entry));
1128 e->partial = 0;
1129 e->buf = 0;
1130 e->index = -1;
1131
1132 if (arg[0] == '-' && arg[1] == '\0')
1133 {
1134 if ((e->fp = fdopen (0, "r")) == NULL)
1135 perror ("fdopen"), exit (1);
1136 if (fcntl (0, F_SETFL, O_NONBLOCK) < 0)
1137 perror ("fcntl"), exit (1);
1138 e->fname = NULL;
1139 e->inode = 0;
1140 e->desc = xstrdup ("stdin");
1141 }
1142 else
1143 {
1144 int l;
1145
1146 e->fname = xstrdup (fname);
1147 if (openlog (e) == NULL)
1148 perror (fname), exit (1);
1149
1150 e->desc = xstrdup (desc);
1151 }
1152
1153 e->color = GetColor (fcolor);
1154 e->partial = 0;
1155 e->next = NULL;
1156
1157 if (!loglist)
1158 loglist = e;
1159 if (loglist_tail)
1160 loglist_tail->next = e;
1161 loglist_tail = e;
1162 }
1163 }
1164
1165 if (!loglist)
1166 {
1167 fprintf (stderr, "You did not specify any files to tail\n"
1168 "use %s --help for help\n", argv[0]);
1169 exit (1);
1170 }
1171
1172 if (opt_partial && opt_whole)
1173 {
1174 fprintf (stderr, "Specify at most one of -partial and -whole\n");
1175 exit (1);
1176 }
1177
1178 /* HACK-7: do we want to allow both -shade and -outline? */
1179 if (opt_shade && opt_outline)
1180 {
1181 fprintf (stderr, "Specify at most one of -shade and -outline\n");
1182 exit (1);
1183 }
1184
1185 if (opt_partial)
1186 /* if we specifically requested to see partial lines then don't insist on whole lines */
1187 opt_whole = 0;
1188 else if (file_count > 1)
1189 /* otherwise, if we're viewing multiple files, default to showing whole lines */
1190 opt_whole = 1;
1191
1192#if HAS_REGEX
1193 if (transform)
1194 {
1195 int i;
1196
1197 printf("compiling regexp '%s'\n", transform);
1198 transformre = xmalloc (sizeof (regex_t));
1199 i = regcomp (transformre, transform, REG_EXTENDED);
1200 if (i != 0)
1201 {
1202 char buf[512];
1203
1204 regerror (i, transformre, buf, sizeof (buf));
1205 fprintf (stderr, "Cannot compile regular expression: %s\n", buf);
1206 }
1207 else
1208 {
1209 printf("compiled '%s' OK to %x\n", transform, (int)transformre);
629 } 1210 }
630
631 if (need_update)
632 redraw();
633 else {
634 XFlush(disp);
635 if (!XPending(disp)) {
636 fd_set fdr;
637 struct timeval to = interval;
638
639 FD_ZERO(&fdr);
640 FD_SET(ConnectionNumber(disp), &fdr);
641 select(ConnectionNumber(disp) + 1, &fdr, 0, 0, &to);
642 } 1211 }
643 }
644
645 check_open_files();
646
647 if (do_reopen)
648 reopen();
649
650 /* we ignore possible errors due to window resizing &c */
651 while (XPending(disp)) {
652 XNextEvent(disp, &xev);
653 switch (xev.type) {
654 case Expose:
655 {
656 XRectangle r;
657
658 r.x = xev.xexpose.x;
659 r.y = xev.xexpose.y;
660 r.width = xev.xexpose.width;
661 r.height = xev.xexpose.height;
662 XUnionRectWithRegion(&r, region, region);
663 if (miny > r.y)
664 miny = r.y;
665 if (maxy < r.y + r.height)
666 maxy = r.y + r.height;
667 }
668 break;
669 default:
670#ifdef DEBUGMODE
671 fprintf(stderr, "PANIC! Unknown event %d\n", xev.type);
672#endif 1212#endif
673 break;
674 }
675 }
676 1213
677 /* reload if requested */
678 if (reload && lastreload + reload < time(NULL)) {
679 if (command && command[0])
680 system(command);
681
682 reopen();
683 lastreload = time(NULL);
684 }
685
686 if (!XEmptyRegion(region)) {
687 XSetRegion(disp, WinGC, region);
688 refresh(lines, miny, maxy);
689 XDestroyRegion(region);
690 region = XCreateRegion();
691 maxy = 0;
692 miny = win_y + h;
693 }
694 }
695}
696
697
698int main(int argc, char *argv[])
699{
700 int i;
701 int opt_daemonize = 0;
702 int opt_partial = 0, file_count = 0;
703#if HAS_REGEX
704 char *transform = NULL;
705#endif
706
707 setlocale (LC_CTYPE, ""); /* try to initialize the locale. */
708
709 /* window needs to be initialized before colorlookups can be done */
710 /* just a dummy to get the color lookups right */
711 geom_mask = NoValue;
712 InitWindow(); 1214 InitWindow ();
713 1215
714 for (i = 1; i < argc; i++) {
715 const char *arg = argv[i];
716
717 if (arg[0] == '-' && arg[1] != '\0' && arg[1] != ',') {
718 if (arg[1] == '-')
719 arg++;
720
721 if (!strcmp(arg, "-?") ||
722 !strcmp(arg, "-help") || !strcmp(arg, "-h"))
723 display_help(argv[0]);
724 else if (!strcmp(arg, "-V"))
725 display_version();
726 else if (!strcmp(arg, "-g") || !strcmp(arg, "-geometry"))
727 geom_mask = XParseGeometry(argv[++i],
728 &win_x, &win_y, &width, &listlen);
729 else if (!strcmp(arg, "-display"))
730 dispname = argv[++i];
731 else if (!strcmp(arg, "-cont"))
732 continuation = argv[++i];
733 else if (!strcmp(arg, "-font") || !strcmp(arg, "-fn"))
734 fontname = argv[++i];
735#if HAS_REGEX
736 else if (!strcmp(arg, "-t"))
737 transform = argv[++i];
738#endif
739 else if (!strcmp(arg, "-fork") || !strcmp(arg, "-f"))
740 opt_daemonize = 1;
741 else if (!strcmp(arg, "-reload")) {
742 reload = atoi(argv[++i]);
743 command = argv[++i];
744 }
745 else if (!strcmp(arg, "-shade"))
746 opt_shade = 1;
747 else if (!strcmp(arg, "-frame"))
748 opt_frame = 1;
749 else if (!strcmp(arg, "-no-filename"))
750 opt_nofilename = 1;
751 else if (!strcmp(arg, "-reverse"))
752 opt_reverse = 1;
753 else if (!strcmp(arg, "-whole"))
754 opt_whole = 1;
755 else if (!strcmp(arg, "-partial"))
756 opt_partial = 1;
757 else if (!strcmp(arg, "-update"))
758 opt_update = opt_partial = 1;
759 else if (!strcmp(arg, "-color"))
760 def_color = argv[++i];
761 else if (!strcmp(arg, "-noinitial"))
762 opt_noinitial = 1;
763 else if (!strcmp(arg, "-id"))
764 root = atoi (argv[++i]);
765 else if (!strcmp(arg, "-interval") || !strcmp(arg, "-i")) {
766 double iv = atof(argv[++i]);
767
768 interval.tv_sec = (int) iv;
769 interval.tv_usec = (iv - interval.tv_sec) * 1e6;
770 } else {
771 fprintf(stderr, "Unknown option '%s'.\n"
772 "Try --help for more information.\n", arg);
773 exit(1);
774 }
775 } else { /* it must be a filename */
776 struct logfile_entry *e;
777 const char *fname, *desc, *fcolor = def_color;
778 char *p;
779
780 file_count++;
781
782 /* this is not foolproof yet (',' in filenames are not allowed) */
783 fname = desc = arg;
784 if ((p = strchr(arg, ','))) {
785 *p = '\0';
786 fcolor = p + 1;
787
788 if ((p = strchr(fcolor, ','))) {
789 *p = '\0';
790 desc = p + 1;
791 }
792 }
793
794 e = xmalloc(sizeof(struct logfile_entry));
795 if (arg[0] == '-' && arg[1] == '\0') {
796 if ((e->fp = fdopen(0, "r")) == NULL)
797 perror("fdopen"), exit(1);
798 if (fcntl(0, F_SETFL, O_NONBLOCK) < 0)
799 perror("fcntl"), exit(1);
800 e->fname = NULL;
801 e->inode = 0;
802 e->desc = xstrdup("stdin");
803 } else {
804 int l;
805
806 e->fname = xstrdup(fname);
807 if (openlog(e) == NULL)
808 perror(fname), exit(1);
809
810 l = strlen(desc);
811 if (l > width - 2) /* must account for [ ] */
812 l = width - 2;
813 e->desc = xmalloc(l + 1);
814 memcpy(e->desc, desc, l);
815 *(e->desc + l) = '\0';
816 }
817
818 e->color = GetColor(fcolor);
819 e->buf = xmalloc(width + 2);
820 e->partial = 0;
821 e->buf[0] = '\0';
822 e->next = NULL;
823
824 if (!loglist)
825 loglist = e;
826 if (loglist_tail)
827 loglist_tail->next = e;
828 loglist_tail = e;
829 }
830 }
831
832 if (!loglist) {
833 fprintf(stderr, "You did not specify any files to tail\n"
834 "use %s --help for help\n", argv[0]);
835 exit(1);
836 }
837
838 if (opt_partial && opt_whole) {
839 fprintf(stderr, "Specify at most one of -partial and -whole\n");
840 exit(1);
841 }
842
843 /* if we specifically requested to see partial lines then don't insist on whole lines */
844 if (opt_partial) {
845 opt_whole = 0;
846 /* otherwise, if we've viewing multiple files, default to showing whole lines */
847 } else if (file_count > 1) {
848 opt_whole = 1;
849 }
850
851#if HAS_REGEX
852 if (transform) {
853 int i;
854
855 transformre = xmalloc(sizeof(transformre));
856 i = regcomp(&transformre, transform, REG_EXTENDED);
857 if (i != 0) {
858 char buf[512];
859
860 regerror(i, &transformre, buf, sizeof(buf));
861 fprintf(stderr, "Cannot compile regular expression: %s\n", buf);
862 }
863 }
864#endif
865
866 InitWindow();
867
868 install_signal(SIGINT, blank_window); 1216 install_signal (SIGINT, blank_window);
869 install_signal(SIGQUIT, blank_window); 1217 install_signal (SIGQUIT, blank_window);
870 install_signal(SIGTERM, blank_window); 1218 install_signal (SIGTERM, blank_window);
871 install_signal(SIGHUP, force_reopen); 1219 install_signal (SIGHUP, force_reopen);
872 install_signal(SIGUSR1, list_files); 1220 install_signal (SIGUSR1, list_files);
873 install_signal(SIGUSR2, force_refresh); 1221 install_signal (SIGUSR2, force_refresh);
874 1222
875 if (opt_daemonize) 1223 if (opt_daemonize)
876 daemonize(); 1224 daemonize ();
877 1225
878 main_loop(); 1226 main_loop ();
879 1227
880 exit(1); /* to make gcc -Wall stop complaining */ 1228 exit (1); /* to make gcc -Wall stop complaining */
881} 1229}
882 1230
1231void
883void install_signal(int sig, void (*handler)(int)) 1232install_signal (int sig, void (*handler) (int))
884{ 1233{
885 struct sigaction action; 1234 struct sigaction action;
886 1235
887 action.sa_handler = handler; 1236 action.sa_handler = handler;
888 sigemptyset(&action.sa_mask); 1237 sigemptyset (&action.sa_mask);
889 action.sa_flags = SA_RESTART; 1238 action.sa_flags = SA_RESTART;
1239
890 if (sigaction(sig, &action, NULL) < 0) 1240 if (sigaction (sig, &action, NULL) < 0)
891 fprintf(stderr, "sigaction(%d): %s\n", sig, strerror(errno)), exit(1); 1241 fprintf (stderr, "sigaction(%d): %s\n", sig, strerror (errno)), exit (1);
892} 1242}
893 1243
1244void *
894void *xstrdup(const char *string) 1245xstrdup (const char *string)
895{ 1246{
896 void *p; 1247 void *p;
897 1248
898 while ((p = strdup(string)) == NULL) { 1249 while ((p = strdup (string)) == NULL)
1250 {
899 fprintf(stderr, "Memory exausted."); 1251 fprintf (stderr, "Memory exausted.");
900 sleep(10); 1252 sleep (10);
901 } 1253 }
1254
902 return p; 1255 return p;
903} 1256}
904 1257
1258void *
905void *xmalloc(size_t size) 1259xmalloc (size_t size)
906{ 1260{
907 void *p; 1261 void *p;
908 1262
909 while ((p = malloc(size)) == NULL) { 1263 while ((p = malloc (size)) == NULL)
1264 {
910 fprintf(stderr, "Memory exausted."); 1265 fprintf (stderr, "Memory exausted.");
911 sleep(10); 1266 sleep (10);
912 } 1267 }
1268
913 return p; 1269 return p;
914} 1270}
915 1271
1272void *
1273xrealloc (void *ptr, size_t size)
1274{
1275 void *p;
1276
1277 while ((p = realloc (ptr, size)) == NULL)
1278 {
1279 fprintf (stderr, "Memory exausted.");
1280 sleep (10);
1281 }
1282
1283 return p;
1284}
1285
1286void
916void display_help(char *myname) 1287display_help (char *myname)
917{ 1288{
918 printf("Usage: %s [options] file1[,color[,desc]] " 1289 printf ("Usage: %s [options] file1[,color[,desc]] "
919 "[file2[,color[,desc]] ...]\n", myname); 1290 "[file2[,color[,desc]] ...]\n", myname);
920 printf(" -g | -geometry geometry -g WIDTHxHEIGHT+X+Y\n" 1291 printf (" -g | -geometry geometry -g WIDTHxHEIGHT+X+Y\n"
921 " -color color use color $color as default\n" 1292 " -color color use color $color as default\n"
922 " -reload sec command reload after $sec and run command\n" 1293 " -reload sec command reload after $sec and run command\n"
923 " -id id window id to use instead of the root window\n" 1294 " -id id window id to use instead of the root window\n"
924 " -font FONTSPEC (-fn) font to use\n" 1295 " -font FONTSPEC (-fn) font to use\n"
925 " -f | -fork fork into background\n" 1296 " -f | -fork fork into background\n"
926 " -reverse print new lines at the top\n" 1297 " -reverse print new lines at the top\n"
927 " -whole wait for \\n before showing a line\n" 1298 " -whole wait for \\n before showing a line\n"
928 " -partial show lines even if they don't end with a \\n\n" 1299 " -partial show lines even if they don't end with a \\n\n"
929 " -update allow updates to old partial lines\n" 1300 " -update allow updates to old partial lines\n"
930 " -cont string to prefix continued partial lines with\n" 1301 " -cont string to prefix continued partial lines with\n"
1302 " -wordwrap wrap long lines at spaces to avoid breaking words\n"
931 " defaults to \"[+]\"\n" 1303 " defaults to \"[+]\"\n"
932 " -shade add shading to font\n" 1304 " -shade add shading to font\n"
933 " -noinitial don't display the last file lines on\n" 1305 " -noinitial don't display the last file lines on\n"
934 " startup\n" 1306 " startup\n"
935 " -i | -interval seconds interval between checks (fractional\n" 1307 " -i | -interval seconds interval between checks (fractional\n"
936 " values o.k.). Default 3 seconds\n" 1308 " values o.k.). Default 2.4 seconds\n"
937 " -V display version information and exit\n" 1309 " -V display version information and exit\n"
938 "\n"); 1310 "\n");
939 printf("Example:\n%s -g 80x25+100+50 -font fixed /var/log/messages,green " 1311 printf ("Example:\n%s -g 80x25+100+50 -font fixed /var/log/messages,green "
940 "/var/log/secure,red,'ALERT'\n", myname); 1312 "/var/log/secure,red,'ALERT'\n", myname);
941 exit(0); 1313 exit (0);
942} 1314}
943 1315
1316void
944void display_version(void) { 1317display_version (void)
1318{
945 printf("root-tail version " VERSION "\n"); 1319 printf ("root-tail version " VERSION "\n");
946 exit(0); 1320 exit (0);
947} 1321}
948 1322
1323int
949int daemonize(void) { 1324daemonize (void)
1325{
1326 pid_t pid;
1327
950 switch (fork()) { 1328 switch (pid = fork ())
1329 {
951 case -1: 1330 case -1:
952 return -1; 1331 return -1;
953 case 0: 1332 case 0:
954 break; 1333 break;
955 default: 1334 default:
956 _exit(0); 1335 /*printf("%d\n", pid);*/
1336 exit (0);
957 } 1337 }
958 1338
959 if (setsid() == -1) 1339 if (setsid () == -1)
960 return -1; 1340 return -1;
961 1341
962 return 0; 1342 return 0;
963} 1343}

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines