// **********************************************************************
//
// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************

#include <Ice/ObserverHelper.h>
#include <Ice/Reference.h>
#include <Ice/Instance.h>
#include <Ice/Proxy.h>

using namespace std;
using namespace Ice;
using namespace Ice::Instrumentation;

namespace
{

Ice::Context emptyCtx;

}

IceInternal::InvocationObserver::InvocationObserver(IceProxy::Ice::Object* proxy, const string& op, const Context* ctx)
{
    const CommunicatorObserverPtr& obsv = proxy->__reference()->getInstance()->getObserver();
    if(!obsv)
    {
        return;
    }

    if(ctx)
    {
        attach(obsv->getInvocationObserver(proxy, op, *ctx));
    }
    else
    {
        attach(obsv->getInvocationObserver(proxy, op, emptyCtx));
    }
}

IceInternal::InvocationObserver::InvocationObserver(IceInternal::Instance* instance, const string& op)
{
    const CommunicatorObserverPtr& obsv = instance->getObserver();
    if(!obsv)
    {
        return;
    }

    attach(obsv->getInvocationObserver(0, op, emptyCtx));
}

void
IceInternal::InvocationObserver::attach(IceProxy::Ice::Object* proxy, const string& op, const Context* ctx)
{
    const CommunicatorObserverPtr& obsv = proxy->__reference()->getInstance()->getObserver();
    if(!obsv)
    {
        return;
    }

    if(ctx)
    {
        attach(obsv->getInvocationObserver(proxy, op, *ctx));
    }
    else
    {
        attach(obsv->getInvocationObserver(proxy, op, emptyCtx));
    }
}

void
IceInternal::InvocationObserver::attach(IceInternal::Instance* instance, const string& op)
{
    const CommunicatorObserverPtr& obsv = instance->getObserver();
    if(!obsv)
    {
        return;
    }

    attach(obsv->getInvocationObserver(0, op, emptyCtx));
}