Return to IMon.c++ CVS log

Up to [Development] / fam / fam

Annotation of fam/fam/IMon.c++, Revision 1.1

1.1     ! trev        1: //  Copyright (C) 1999 Silicon Graphics, Inc.  All Rights Reserved.
        !             2: //
        !             3: //  This program is free software; you can redistribute it and/or modify it
        !             4: //  under the terms of version 2 of the GNU General Public License as
        !             5: //  published by the Free Software Foundation.
        !             6: //
        !             7: //  This program is distributed in the hope that it would be useful, but
        !             8: //  WITHOUT ANY WARRANTY; without even the implied warranty of
        !             9: //  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  Further, any
        !            10: //  license provided herein, whether implied or otherwise, is limited to
        !            11: //  this program in accordance with the express provisions of the GNU
        !            12: //  General Public License.  Patent licenses, if any, provided herein do not
        !            13: //  apply to combinations of this program with other product or programs, or
        !            14: //  any other product whatsoever.  This program is distributed without any
        !            15: //  warranty that the program is delivered free of the rightful claim of any
        !            16: //  third person by way of infringement or the like.  See the GNU General
        !            17: //  Public License for more details.
        !            18: //
        !            19: //  You should have received a copy of the GNU General Public License along
        !            20: //  with this program; if not, write the Free Software Foundation, Inc., 59
        !            21: //  Temple Place - Suite 330, Boston MA 02111-1307, USA.
        !            22:
        !            23: #include "IMon.h"
        !            24:
        !            25: #include <assert.h>
        !            26: #include <errno.h>
        !            27: #include <fcntl.h>
        !            28:
        !            29: #if HAVE_IMON
        !            30: #ifdef __sgi
        !            31: #include <sys/imon.h>
        !            32: #else
        !            33: #include <linux/imon.h>
        !            34: #endif
        !            35: #endif
        !            36:
        !            37: #if !defined(__FreeBSD__)
        !            38: #  include <sys/sysmacros.h>
        !            39: #endif
        !            40: #include <unistd.h>
        !            41:
        !            42: #include "Interest.h"
        !            43: #include "Log.h"
        !            44: #include "Scheduler.h"
        !            45: #include "alloc.h"
        !            46:
        !            47: int		   IMon::imonfd = -2;
        !            48: IMon::EventHandler IMon::ehandler = NULL;
        !            49:
        !            50: IMon::IMon(EventHandler h)
        !            51: {
        !            52:     assert(ehandler == NULL);
        !            53:     ehandler = h;
        !            54: }
        !            55:
        !            56: IMon::~IMon()
        !            57: {
        !            58:     if (imonfd >= 0)
        !            59:     {
        !            60: 	//  Tell the scheduler.
        !            61:
        !            62: 	(void) Scheduler::remove_read_handler(imonfd);
        !            63:
        !            64: 	//  Close the inode monitor device.
        !            65:
        !            66: 	if (close(imonfd) < 0)
        !            67: 	    Log::perror("can't close /dev/imon");
        !            68: 	else
        !            69: 	    Log::debug("closed /dev/imon");
        !            70: 	imonfd = -1;
        !            71:     }
        !            72:     ehandler = NULL;
        !            73: }
        !            74:
        !            75: bool
        !            76: IMon::is_active()
        !            77: {
        !            78:     if (imonfd == -2)
        !            79:     {   imonfd = imon_open();
        !            80: 	if (imonfd >= 0)
        !            81: 	{   Log::debug("opened /dev/imon");
        !            82: 	    (void) Scheduler::install_read_handler(imonfd, read_handler, NULL);
        !            83: 	}
        !            84:     }
        !            85:     return imonfd >= 0;
        !            86: }
        !            87:
        !            88: IMon::Status
        !            89: IMon::express(const char *name, struct stat *status)
        !            90: {
        !            91:     if (!is_active())
        !            92: 	return BAD;
        !            93:
        !            94:     return imon_express(name, status);
        !            95: }
        !            96:
        !            97: IMon::Status
        !            98: IMon::revoke(const char *name, dev_t dev, ino_t ino)
        !            99: {
        !           100:     if (!is_active())
        !           101: 	return BAD;
        !           102:
        !           103:     return imon_revoke(name, dev, ino);
        !           104: }
        !           105:
        !           106: void
        !           107: IMon::read_handler(int fd, void *)
        !           108: {
        !           109: #if HAVE_IMON
        !           110:     qelem_t readbuf[20];
        !           111:     int rc = read(fd, readbuf, sizeof readbuf);
        !           112:     if (rc < 0)
        !           113:         Log::perror("/dev/imon read");
        !           114:     else
        !           115:     {   assert(rc % sizeof (qelem_t) == 0);
        !           116: 	rc /= sizeof (qelem_t);
        !           117: 	for (int i = 0; i < rc; i++)
        !           118: 	    if (readbuf[i].qe_what == IMON_OVER)
        !           119: 		Log::error("imon event queue overflow");
        !           120: 	    else
        !           121: 	    {	dev_t dev = readbuf[i].qe_dev;
        !           122: 		ino_t ino = readbuf[i].qe_inode;
        !           123: 		intmask_t what = readbuf[i].qe_what;
        !           124: 		Log::debug("imon said dev %d/%d, ino %ld changed%s%s%s%s%s%s",
        !           125: 			   major(dev), minor(dev), ino,
        !           126: 			   what & IMON_CONTENT   ? " CONTENT"   : "",
        !           127: 			   what & IMON_ATTRIBUTE ? " ATTRIBUTE" : "",
        !           128: 			   what & IMON_DELETE    ? " DELETE"    : "",
        !           129: 			   what & IMON_EXEC      ? " EXEC"      : "",
        !           130: 			   what & IMON_EXIT      ? " EXIT"      : "",
        !           131: #ifdef IMON_RENAME
        !           132: 			   what & IMON_RENAME    ? " RENAME"    : "",
        !           133: #endif
        !           134: 			   ""
        !           135: 		    );
        !           136: 		if (what & IMON_EXEC)
        !           137: 		    (*ehandler)(dev, ino, EXEC);
        !           138: 		if (what & IMON_EXIT)
        !           139: 		    (*ehandler)(dev, ino, EXIT);
        !           140: 		if (what & (IMON_CONTENT | IMON_ATTRIBUTE |
        !           141: 			    IMON_DELETE
        !           142: #ifdef IMON_RENAME
        !           143: 			    | IMON_RENAME
        !           144: #endif
        !           145: 		    ))
        !           146: 		    (*ehandler)(dev, ino, CHANGE);
        !           147: 	    }
        !           148:     }
        !           149: #else
        !           150:     //  I forget why/how this happens, but I know it's happened to me
        !           151:     //  (something about building fam without imon support, but then it
        !           152:     //  tries and succeeds? in opening /dev/imon?)  Anyway, it shouldn't
        !           153:     //  do that.  This should be fixed.
        !           154:     Log::critical("imon event received by fam built without imon support... "
        !           155:                   "tell fam@oss.sgi.com to fix this!");
        !           156:     int i_dont_have_IMON = 0;
        !           157:     assert(i_dont_have_IMON);
        !           158: #endif  //  HAVE_IMON
        !           159: }