Annotation of fam/fam/ClientInterest.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 "ClientInterest.h"
! 24:
! 25: #include <assert.h>
! 26: #include <errno.h>
! 27:
! 28: #include "Client.h"
! 29: #include "Event.h"
! 30: #include "FileSystem.h"
! 31: #include "FileSystemTable.h"
! 32:
! 33: ClientInterest::ClientInterest(const char *name,
! 34: Client *c, Request r, const Cred& cr, Type type)
! 35: : Interest(name, myfilesystem = FileSystemTable::find(name, cr),
! 36: c->host(), VERIFY_EXPORTED),
! 37: myclient(c), request(r), mycred(cr), fs_request(0)
! 38: {
! 39: ci_bits() = ACTIVE_STATE;
! 40: if (exported_to_host())
! 41: {
! 42: // This is so horribly lame. If this interest doesn't exist,
! 43: // and someone somewhere set errno to EACCES, let's assume the
! 44: // interest exists but this client doesn't have permission to
! 45: // monitor it. (The actual imon_express and lstat are done in
! 46: // in the Interest constructor.) This use of errno probably
! 47: // makes it easy to become confused and suggest_insecure_compat
! 48: // even when we shouldn't.
! 49: if ((!exists()) && (errno == EACCES) && (c != NULL))
! 50: {
! 51: c->suggest_insecure_compat(name);
! 52: }
! 53: post_event(exists() ? Event::Exists : Event::Deleted);
! 54: fs_request = myfilesystem->monitor(this, type);
! 55: }
! 56: else
! 57: {
! 58: post_event(Event::Deleted);
! 59: }
! 60: }
! 61:
! 62: ClientInterest::~ClientInterest()
! 63: {
! 64: myfilesystem->cancel(this, fs_request);
! 65: }
! 66:
! 67: void
! 68: ClientInterest::filesystem(FileSystem *fs)
! 69: {
! 70: myfilesystem->cancel(this, fs_request);
! 71: myfilesystem = fs;
! 72: verify_exported_to_host();
! 73: if (exported_to_host())
! 74: {
! 75: fs_request = fs->monitor(this, type());
! 76: scan();
! 77: }
! 78: else if (fs_request != 0)
! 79: {
! 80: // This Interest used to be on a filesystem which was mounted by
! 81: // the client, but now is not? Send a Deleted event.
! 82: post_event(Event::Deleted);
! 83: fs_request = 0;
! 84: }
! 85: }
! 86:
! 87: void
! 88: ClientInterest::findfilesystem()
! 89: {
! 90: FileSystem *new_fs = FileSystemTable::find(name(), mycred);
! 91: if (new_fs != myfilesystem)
! 92: {
! 93: filesystem(new_fs);
! 94: }
! 95: }
! 96:
! 97: //////////////////////////////////////////////////////////////////////////////
! 98: // Suspend/resume.
! 99:
! 100: bool
! 101: ClientInterest::active() const
! 102: {
! 103: return ci_bits() & ACTIVE_STATE;
! 104: }
! 105:
! 106: void
! 107: ClientInterest::suspend()
! 108: {
! 109: if (active())
! 110: { ci_bits() &= ~ACTIVE_STATE;
! 111: myfilesystem->hl_suspend(fs_request);
! 112: }
! 113: }
! 114:
! 115: void
! 116: ClientInterest::resume()
! 117: {
! 118: bool was_active = active();
! 119: ci_bits() |= ACTIVE_STATE; // Set state before generating events.
! 120: do_scan();
! 121: if (!was_active)
! 122: myfilesystem->hl_resume(fs_request);
! 123: }
! 124:
! 125: void
! 126: ClientInterest::post_event(const Event& event, const char *eventpath)
! 127: {
! 128: assert(active());
! 129: if (!eventpath)
! 130: eventpath = name();
! 131: myclient->post_event(event, request, eventpath);
! 132: }
! 133:
! 134: Interest *
! 135: ClientInterest::find_name(const char *)
! 136: {
! 137: // Ignore name.
! 138:
! 139: return this;
! 140: }
! 141:
! 142: bool
! 143: ClientInterest::scan(Interest *ip)
! 144: {
! 145: bool changed = false;
! 146: if (!ip)
! 147: ip = this;
! 148: ip->mark_for_scan();
! 149: if (myclient->ready_for_events())
! 150: changed = ip->do_scan();
! 151: else
! 152: myclient->enqueue_for_scan(ip);
! 153: return changed;
! 154: }
! 155:
! 156: void
! 157: ClientInterest::unscan(Interest *ip)
! 158: {
! 159: if (!ip)
! 160: ip = this;
! 161: if (ip->needs_scan())
! 162: myclient->dequeue_from_scan(ip);
! 163: }
! 164:
! 165: bool
! 166: ClientInterest::do_scan()
! 167: {
! 168: bool changed = false;
! 169: if (needs_scan() && active()) {
! 170: become_user();
! 171: changed = Interest::do_scan();
! 172: }
! 173: return changed;
! 174: }
! 175:
! 176: void
! 177: ClientInterest::notify_created(Interest *ip)
! 178: {
! 179: if (!ip)
! 180: ip = this;
! 181: myfilesystem->ll_notify_created(ip);
! 182: }
! 183:
! 184: void
! 185: ClientInterest::notify_deleted(Interest *ip)
! 186: {
! 187: if (!ip)
! 188: ip = this;
! 189: myfilesystem->ll_notify_deleted(ip);
! 190: }
! 191:
! 192: void
! 193: ClientInterest::cancel()
! 194: {
! 195: ci_bits() |= ACTIVE_STATE;
! 196: post_event(Event::Acknowledge);
! 197: unscan();
! 198: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/back.gif){kind=icon}
Return to ClientInterest.c++ CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [Development] / fam / fam