consumer.cc

支持组件模型CCM的开源中间件-mico

#include <CORBA.h>
#include <mico/util.h>
#include <coss/CosNaming.h>
#include <coss/CosEventComm.h>
#include <coss/CosEventChannelAdmin.h>
#include <coss/MobileTerminalNotification.h>

using namespace std;

int
main (int argc, char *argv[])
{
    CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
    CORBA::Object_var obj = orb->resolve_initial_references("NameService");
    CosNaming::NamingContext_var ns = CosNaming::NamingContext::_narrow(obj);

    assert(argc >= 2);
    CosNaming::Name name;
    name.length(2);
    name[0].id = CORBA::string_dup("MobilitySupport");
    name[1].id = CORBA::string_dup(argv[1]);
    obj = ns->resolve(name);
    CosEventChannelAdmin::EventChannel_var chan =
	CosEventChannelAdmin::EventChannel::_narrow(obj);
    CosEventChannelAdmin::ConsumerAdmin_var consumer = chan->for_consumers();
    CosEventChannelAdmin::ProxyPullSupplier_var supplier =
	consumer->obtain_pull_supplier();

    CORBA::String_var time_str = CORBA::string_alloc(20);
    time_t ev_time;

    for ( ; ; ) {
	CORBA::Any_var event = supplier->pull();
	CORBA::TypeCode_var tc = event->type();
	time(&ev_time);
	struct tm *evrec = localtime(&ev_time);
	strftime(time_str, 20, "%Y-%m-%dT%H:%M:%S", evrec);
	cout << "*** Mobility Event at " << time_str << endl;
	if (tc->equal(MobileTerminalNotification::_tc_HandoffDepartureEvent)) {
	    const MobileTerminalNotification::HandoffDepartureEvent *net_dep;
	    event >>= net_dep;
	    CORBA::String_var tid =
		mico_url_encode(net_dep->terminal_id.get_buffer(),
				net_dep->terminal_id.length());
	    CORBA::String_var new_ab;
	    if (!CORBA::is_nil(net_dep->new_access_bridge)) {
		CORBA::IORProfile *prof =
		    net_dep->new_access_bridge->_ior()->profile();
		CORBA::Long keylen;
		const CORBA::Octet *key = prof->objectkey(keylen);
		new_ab = mico_url_encode(key, keylen);
	    } else {
		new_ab = CORBA::string_dup("(NONE)");
	    }
	    cout << "*** Terminal Departure" << endl;
	    cout << "    Departing terminal: " << tid << endl;
	    cout << "    New Access Bridge:  " << new_ab << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_HandoffArrivalEvent)) {
	    const MobileTerminalNotification::HandoffArrivalEvent *net_arr;
	    event >>= net_arr;
	    CORBA::String_var tid =
		mico_url_encode(net_arr->terminal_id.get_buffer(),
				net_arr->terminal_id.length());
	    CORBA::String_var old_ab;
	    if (!CORBA::is_nil(net_arr->old_access_bridge)) {
		CORBA::IORProfile *prof =
		    net_arr->old_access_bridge->_ior()->profile();
		CORBA::Long keylen;
		const CORBA::Octet *key = prof->objectkey(keylen);
		old_ab = mico_url_encode(key, keylen);
	    } else {
		old_ab = CORBA::string_dup("(NONE)");
	    }
	    cout << "*** Terminal Arrival" << endl;
	    cout << "    Arriving terminal: " << tid << endl;
	    cout << "    Old Access Bridge: " << old_ab << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_AccessDropoutEvent)) {
	    const MobileTerminalNotification::AccessDropoutEvent *net_drop;
	    event >>= net_drop;
	    CORBA::String_var tid =
		mico_url_encode(net_drop->terminal_id.get_buffer(),
				net_drop->terminal_id.length());
	    cout << "*** Terminal Dropout" << endl;
	    cout << "    Terminal identifier: " << tid << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_AccessRecoveryEvent)) {
	    const MobileTerminalNotification::AccessRecoveryEvent *net_rec;
	    event >>= net_rec;
	    CORBA::String_var tid =
		mico_url_encode(net_rec->terminal_id.get_buffer(),
				net_rec->terminal_id.length());
	    cout << "*** Terminal Recovery" << endl;
	    cout << "    Terminal identifier: " << tid << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_TerminalHandoffEvent)) {
	    const MobileTerminalNotification::TerminalHandoffEvent *term_hoff;
	    event >>= term_hoff;
	    CORBA::String_var new_ab;
	    if (!CORBA::is_nil(term_hoff->new_access_bridge)) {
		CORBA::IORProfile *prof =
		    term_hoff->new_access_bridge->_ior()->profile();
		CORBA::Long keylen;
		const CORBA::Octet *key = prof->objectkey(keylen);
		new_ab = mico_url_encode(key, keylen);
	    } else {
		new_ab = CORBA::string_dup("(NONE)");
	    }
	    cout << "*** Access Handoff" << endl;
	    cout << "    New Access Bridge: " << new_ab << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_TerminalDropoutEvent)) {
	    const MobileTerminalNotification::TerminalDropoutEvent *term_drop;
	    event >>= term_drop;
	    CORBA::String_var tid =
		mico_url_encode(term_drop->terminal_id.get_buffer(),
				term_drop->terminal_id.length());
	    cout << "*** Access Dropout" << endl;
	    cout << "    Terminal identifier: " << tid << endl;
	} else if (tc->equal(MobileTerminalNotification::_tc_TerminalRecoveryEvent)) {
	    const MobileTerminalNotification::TerminalRecoveryEvent *term_rec;
	    event >>= term_rec;
	    CORBA::String_var tid =
		mico_url_encode(term_rec->terminal_id.get_buffer(),
				term_rec->terminal_id.length());
	    cout << "*** Access Recovery" << endl;
	    cout << "    Terminal identifier: " << tid << endl;
	} else {
	    cout << "*** Unknown Event" << endl;
	}
	cout << endl;
    }

    return 0;
}