sun_fc/common/FCSyseventBridge.cc

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#include "FCSyseventBridge.h"
#include "Exceptions.h"
#include "Trace.h"
#include "AdapterAddEvent.h"
#include "AdapterEvent.h"
#include "AdapterPortEvent.h"
#include "AdapterDeviceEvent.h"
#include "TargetEvent.h"
#include "sun_fc.h"
#include <libnvpair.h>
#include <iostream>
#include <climits>

using namespace std;

FCSyseventBridge* FCSyseventBridge::_instance = NULL;

FCSyseventBridge* FCSyseventBridge::getInstance() {
    Trace log("FCSyseventBridge::getInstance");
    if (_instance == NULL) {
    _instance = new FCSyseventBridge();
    }
    return (_instance);

}


void FCSyseventBridge::addListener(AdapterAddEventListener *listener) {
    lock();
    try {
    adapterAddEventListeners.insert(adapterAddEventListeners.begin(),
        listener);
    validateRegistration();
    unlock();
    } catch (...) {
    unlock();
    throw;
    }
}
void FCSyseventBridge::addListener(AdapterEventListener *listener, HBA *hba) {
    lock();
    try {
    adapterEventListeners.insert(adapterEventListeners.begin(), listener);
    validateRegistration();
    unlock();
    } catch (...) {
    unlock();
    throw;
    }
}
void FCSyseventBridge::addListener(AdapterPortEventListener *listener,
        HBAPort *port) {
    lock();
    try {
    adapterPortEventListeners.insert(adapterPortEventListeners.begin(),
        listener);
    validateRegistration();
    unlock();
    } catch (...) {
    unlock();
    throw;
    }
}
void FCSyseventBridge::addListener(AdapterDeviceEventListener *listener,
    HBAPort *port) {
    lock();
    try {
        adapterDeviceEventListeners.insert(adapterDeviceEventListeners.begin(),
            listener);
        validateRegistration();
        unlock();
    } catch (...) {
        unlock();
        throw;
    }
}
void FCSyseventBridge::addListener(TargetEventListener *listener,
        HBAPort *port, uint64_t targetWWN, bool filter) {
    lock();
    try {
    targetEventListeners.insert(targetEventListeners.begin(), listener);
    validateRegistration();
    unlock();
    } catch (...) {
    unlock();
    throw;
    }
}

void FCSyseventBridge::removeListener(AdapterAddEventListener *listener) {
    lock();
    try {
    typedef vector<AdapterAddEventListener *>::iterator Iter;
    for (Iter tmp = adapterAddEventListeners.begin();
        tmp != adapterAddEventListeners.end(); tmp++) {
        if (*tmp == listener) {
        adapterAddEventListeners.erase(tmp);
        unlock();
        return;
        }
    }
    throw InvalidHandleException();
    } catch (...) {
    unlock();
    throw;
    }
}

void FCSyseventBridge::removeListener(AdapterEventListener *listener) {
    lock();
    try {
    typedef vector<AdapterEventListener *>::iterator Iter;
    for (Iter tmp = adapterEventListeners.begin();
        tmp != adapterEventListeners.end(); tmp++) {
        if (*tmp == listener) {
        adapterEventListeners.erase(tmp);
        unlock();
        return;
        }
    }
    throw InvalidHandleException();
    } catch (...) {
    unlock();
    throw;
    }
}

void FCSyseventBridge::removeListener(AdapterPortEventListener *listener) {
    lock();
    try {
    typedef vector<AdapterPortEventListener *>::iterator Iter;
    for (Iter tmp = adapterPortEventListeners.begin();
        tmp != adapterPortEventListeners.end(); tmp++) {
        if (*tmp == listener) {
        adapterPortEventListeners.erase(tmp);
        unlock();
        return;
        }
    }
    throw InvalidHandleException();
    } catch (...) {
    unlock();
    throw;
    }
}

void FCSyseventBridge::removeListener(AdapterDeviceEventListener *listener) {
    lock();
    try {
        typedef vector<AdapterDeviceEventListener *>::iterator Iter;
        for (Iter tmp = adapterDeviceEventListeners.begin();
            tmp != adapterDeviceEventListeners.end(); tmp++) {
            if (*tmp == listener) {
                adapterDeviceEventListeners.erase(tmp);
                unlock();
                return;
            }
        }
        throw InvalidHandleException();
    } catch (...) {
        unlock();
        throw;
    }
}

void FCSyseventBridge::removeListener(TargetEventListener *listener) {
    lock();
    try {
    typedef vector<TargetEventListener *>::iterator Iter;
    for (Iter tmp = targetEventListeners.begin();
        tmp != targetEventListeners.end(); tmp++) {
        if (*tmp == listener) {
        targetEventListeners.erase(tmp);
        unlock();
        return;
        }
    }
    throw InvalidHandleException();
    } catch (...) {
    unlock();
    throw;
    }
}

extern "C" void static_dispatch(sysevent_t *ev) {
    Trace log("static_dispatch");
    FCSyseventBridge::getInstance()->dispatch(ev);
}

void FCSyseventBridge::dispatch(sysevent_t *ev) {
    Trace log("FCSyseventBridge::dispatch");
    nvlist_t            *list = NULL;
    hrtime_t            when;

    if (ev == NULL) {
    log.debug("Null event.");
    return;
    }

    if (sysevent_get_attr_list(ev, &list) || list == NULL) {
    log.debug("Empty event.");
    return;
    }

    string eventVendor = sysevent_get_vendor_name(ev);
    string eventPublisher = sysevent_get_pub_name(ev);
    string eventClass = sysevent_get_class_name(ev);
    string eventSubClass = sysevent_get_subclass_name(ev);

    sysevent_get_time(ev, &when);

    // Now that we know what type of event it is, handle it accordingly
    if (eventClass == "EC_sunfc") {

    // All events of this class type have instance and port-wwn for
    // the HBA port.
    uint32_t    instance;
    if (nvlist_lookup_uint32(list, (char *)"instance",
        &instance)) {
        log.genericIOError(
        "Improperly formed event: no instance field.");
        nvlist_free(list);
        return;
    }
    uchar_t     *rawPortWWN;
    uint32_t    rawPortWWNLength;

    if (nvlist_lookup_byte_array(list, (char *)"port-wwn",
        &rawPortWWN, &rawPortWWNLength)) {
        log.genericIOError(
        "Improperly formed event: no port-wwn field.");
        nvlist_free(list);
        return;
    }

    // Now deal with the specific details of each subclass type
    if (eventSubClass == "ESC_sunfc_port_offline") {

        // Create event instance
        AdapterPortEvent event(
        wwnConversion(rawPortWWN),
        AdapterPortEvent::OFFLINE,
        0);

        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<AdapterPortEventListener *>::iterator Iter;
        for (Iter tmp = adapterPortEventListeners.begin();
            tmp != adapterPortEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();

    } else if (eventSubClass == "ESC_sunfc_port_online") {

        // Create event instance
        AdapterPortEvent event(
        wwnConversion(rawPortWWN),
        AdapterPortEvent::ONLINE,
        0);

        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<AdapterPortEventListener *>::iterator Iter;
        for (Iter tmp = adapterPortEventListeners.begin();
            tmp != adapterPortEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();

    } else if (eventSubClass == "ESC_sunfc_device_online") {
        AdapterDeviceEvent event(
            wwnConversion(rawPortWWN),
            AdapterDeviceEvent::ONLINE,
            0);
        lock();
        try {
            typedef vector<AdapterDeviceEventListener *>::iterator Iter;
            for (Iter tmp = adapterDeviceEventListeners.begin();
                tmp != adapterDeviceEventListeners.end(); tmp++) {
                (*tmp)->dispatch(event);
            }
        } catch (...) {
            unlock();
            nvlist_free(list);
            throw;
        }
        unlock();

    } else if (eventSubClass == "ESC_sunfc_device_offline") {
        AdapterDeviceEvent event(
            wwnConversion(rawPortWWN),
            AdapterDeviceEvent::OFFLINE,
            0);
        lock();
        try {
            typedef vector<AdapterDeviceEventListener *>::iterator Iter;
            for (Iter tmp = adapterDeviceEventListeners.begin();
                tmp != adapterDeviceEventListeners.end(); tmp++) {
                (*tmp)->dispatch(event);
            }
        } catch (...) {
            unlock();
            nvlist_free(list);
            throw;
        }
        unlock();

    } else if (eventSubClass == "ESC_sunfc_port_rscn") {
        /*
         * RSCNs are a little tricky.  There can be multiple
         * affected page properties, each numbered.  To make sure
         * we get them all, we loop through all properties
         * in the nvlist and if their name begins with "affected_page_"
         * then we send an event for them.
         */
        uint32_t    affected_page;
        nvpair_t    *attr = NULL;
        for (attr = nvlist_next_nvpair(list, NULL);
            attr != NULL;
            attr = nvlist_next_nvpair(list, attr)) {
        string name = nvpair_name(attr);
        if (name.find("affected_page_") != name.npos) {

            if (nvpair_value_uint32(attr, &affected_page)) {
            log.genericIOError(
                "Improperly formed event: "
                "corrupt affected_page field");
            continue;
            }
            // Create event instance
            AdapterPortEvent event(
            wwnConversion(rawPortWWN),
            AdapterPortEvent::FABRIC,
            affected_page);

            // Dispatch to interested parties.
            lock();
            typedef vector<AdapterPortEventListener *>::iterator Iter;
            try {
            for (Iter tmp = adapterPortEventListeners.begin();
                tmp != adapterPortEventListeners.end(); tmp++) {
                (*tmp)->dispatch(event);
            }
            } catch (...) {
            unlock();
            nvlist_free(list);
            throw;
            }
            unlock();
        }
        }
    } else if (eventSubClass == "ESC_sunfc_target_add") {
        uchar_t *rawTargetPortWWN;
        uint32_t    rawTargetPortWWNLength;

        if (nvlist_lookup_byte_array(list, (char *)"target-port-wwn",
            &rawTargetPortWWN, &rawTargetPortWWNLength)) {
        log.genericIOError(
            "Improperly formed event: no target-port-wwn field.");
        nvlist_free(list);
        return;
        }

        // Create event instance
        AdapterPortEvent event(
        wwnConversion(rawPortWWN),
        AdapterPortEvent::NEW_TARGETS,
        0);

        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<AdapterPortEventListener *>::iterator Iter;
        for (Iter tmp = adapterPortEventListeners.begin();
            tmp != adapterPortEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();
    } else if (eventSubClass == "ESC_sunfc_target_remove") {
        uchar_t *rawTargetPortWWN;
        uint32_t    rawTargetPortWWNLength;

        if (nvlist_lookup_byte_array(list, (char *)"target-port-wwn",
            &rawTargetPortWWN, &rawTargetPortWWNLength)) {
        log.genericIOError(
            "Improperly formed event: no target-port-wwn field.");
        nvlist_free(list);
        return;
        }
        // Create event instance
        TargetEvent event(
        wwnConversion(rawPortWWN),
        wwnConversion(rawTargetPortWWN),
        TargetEvent::REMOVED);

        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<TargetEventListener *>::iterator Iter;
        for (Iter tmp = targetEventListeners.begin();
            tmp != targetEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();
    } else if (eventSubClass == "ESC_sunfc_port_attach") {
        // Create event instance
        AdapterAddEvent event(wwnConversion(rawPortWWN));
        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<AdapterAddEventListener *>::iterator Iter;
        for (Iter tmp = adapterAddEventListeners.begin();
            tmp != adapterAddEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();
    } else if (eventSubClass == "ESC_sunfc_port_detach") {
        // Technically, we should probably try to coalesce
        // all detach events for the same multi-ported adapter
        // and only send one event to the client, but for now,
        // we'll just blindly send duplicates.

        // Create event instance
        AdapterEvent event(
        wwnConversion(rawPortWWN),
        AdapterEvent::REMOVE);

        // Dispatch to interested parties.
        lock();
        try {
        typedef vector<AdapterEventListener *>::iterator Iter;
        for (Iter tmp = adapterEventListeners.begin();
            tmp != adapterEventListeners.end(); tmp++) {
            (*tmp)->dispatch(event);
        }
        } catch (...) {
        unlock();
        nvlist_free(list);
        throw;
        }
        unlock();

    } else {
        log.genericIOError(
            "Unrecognized subclass \"%s\": Ignoring event",
            eventSubClass.c_str());
    }
    } else {
    // This should not happen, as we only asked for specific classes.
    log.genericIOError(
        "Unrecognized class \"%s\": Ignoring event",
        eventClass.c_str());
    }
    nvlist_free(list);
}

void FCSyseventBridge::validateRegistration() {
    Trace log("FCSyseventBridge::validateRegistration");
    uint64_t count = 0;
    count = adapterAddEventListeners.size() +
        adapterEventListeners.size() +
        adapterPortEventListeners.size() +
        targetEventListeners.size();
    if (count == 1) {
    handle = sysevent_bind_handle(static_dispatch);
    if (handle == NULL) {
        log.genericIOError(
        "Unable to bind sysevent handle.");
        return;
    }
    const char *subclass_list[9] = {
        "ESC_sunfc_port_attach",
        "ESC_sunfc_port_detach",
        "ESC_sunfc_port_offline",
        "ESC_sunfc_port_online",
        "ESC_sunfc_port_rscn",
        "ESC_sunfc_target_add",
        "ESC_sunfc_target_remove",
        "ESC_sunfc_device_online",
        "ESC_sunfc_device_offline"
        };
    if (sysevent_subscribe_event(handle,
        "EC_sunfc", (const char **)subclass_list, 9)) {
        log.genericIOError(
        "Unable to subscribe to sun_fc events.");
        sysevent_unbind_handle(handle);
        handle = NULL;
    }
    } else if (count == 0 && handle != NULL) {
    // Remove subscription
    sysevent_unbind_handle(handle);
    handle == NULL;
    } // Else do nothing
}

int32_t FCSyseventBridge::getMaxListener() {
    return (INT_MAX);
}