// -*- c++ -*-
/*
 *  MICO --- an Open Source CORBA implementation
 *  Copyright (c) 1997-2018 by The Mico Team
 *
 *  This library is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU Library General Public
 *  License as published by the Free Software Foundation; either
 *  version 2 of the License, or (at your option) any later version.
 *
 *  This library is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *  Library General Public License for more details.
 *
 *  You should have received a copy of the GNU Library General Public
 *  License along with this library; if not, write to the Free
 *  Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 *  For more information, visit the MICO Home Page at
 *  http://www.mico.org/
 */

#ifndef __mico_orb_impl_h__
#define __mico_orb_impl_h__

namespace MICO {

class LocalRequest : public CORBA::ORBRequest {
    CORBA::Request_ptr _req;
    CORBA::Boolean _have_except;
    CORBA::Boolean _have_result;
public:
    LocalRequest ();
    LocalRequest (CORBA::Request_ptr);
    ~LocalRequest ();
    
    const char *op_name();
    
    CORBA::Boolean get_in_args (CORBA::NVList_ptr iparams,
                                CORBA::Context_ptr &ctx);
    CORBA::Boolean get_in_args (StaticAnyList *iparams,
                                CORBA::Context_ptr &ctx);
    CORBA::Boolean get_in_args (CORBA::DataEncoder *);
    
    CORBA::Boolean get_out_args (CORBA::Any *res,
                                 CORBA::NVList_ptr oparams,
                                 CORBA::Exception *&ex);
    CORBA::Boolean get_out_args (CORBA::StaticAny *res, StaticAnyList *oparams,
                                 CORBA::Exception *&ex);
    CORBA::Boolean get_out_args (CORBA::DataEncoder *,
                                 CORBA::Boolean &is_except);
    
    CORBA::Boolean set_out_args (CORBA::Any *res, CORBA::NVList_ptr oparams);
    CORBA::Boolean set_out_args (CORBA::StaticAny *res,
                                 StaticAnyList *oparams);
    void set_out_args (CORBA::Exception *ex);
    CORBA::Boolean set_out_args (CORBA::DataDecoder *,
                                 CORBA::Boolean is_except);
    
    CORBA::Boolean copy_out_args (CORBA::ORBRequest *);
    CORBA::Boolean copy_in_args (CORBA::ORBRequest *);
    
    const char *type ();

    CORBA::Request_ptr request ();

    static LocalRequest* _nil ()
    {
	return 0;
    }
    static LocalRequest* _duplicate (LocalRequest *o)
    {
	if (o)
	    o->_ref();
	return o;
    }
};


class ReqQueueRec {
private:
    CORBA::RequestType _type;
    std::string _repoid;
    CORBA::ORBRequest *_request;
    CORBA::Object_ptr _obj;
    CORBA::Principal_ptr _pr;
    CORBA::ORBMsgId_var _id;
    CORBA::Boolean _response_exp;
    CORBA::ORB::ObjectTag _tag;
public:
    ReqQueueRec (CORBA::ORBMsgId id, CORBA::ORBRequest *, CORBA::Object_ptr,
		 CORBA::Principal_ptr, CORBA::Boolean resp); // invoke
    ReqQueueRec (CORBA::ORBMsgId id, const char *repoid,
		 const CORBA::ORB::ObjectTag &); // bind
    ReqQueueRec (CORBA::ORBMsgId id, CORBA::Object_ptr obj); // locate
    ~ReqQueueRec ();

    void exec (CORBA::ObjectAdapter *, CORBA::ORB_ptr);
    void fail (CORBA::ObjectAdapter *, CORBA::ORB_ptr);

    CORBA::Object_ptr target ();
    CORBA::ORBMsgId id ()
    { return CORBA::ORBInvokeRec::_duplicate(_id); }
};

class RequestQueue : public CORBA::DispatcherCallback {
public:
    typedef CORBA::ULong MsgId;
private:
    template <class T> struct ORBMsgIdComparator : std::binary_function<T, T, bool> {
        bool operator() (const T& x, const T& y) const
        { return x->id() < y->id(); }
    };
    typedef std::list<ReqQueueRec *> InvokeList;
    CORBA::ORBMsgId_var _current_id;
    InvokeList _invokes;
    MICOMT::Mutex _invokes_lock;
    CORBA::ObjectAdapter *_oa;
    CORBA::ORB_ptr _orb;
    MICOMT::Mutex _lock;
public:
    RequestQueue (CORBA::ObjectAdapter *, CORBA::ORB_ptr);
    ~RequestQueue ();

    void add (ReqQueueRec *);
    void exec_now ();
    void exec_later ();
    void exec_stop ();
    void fail ();
    void clear ();

    CORBA::Boolean iscurrent (CORBA::ORBMsgId id) const
    { return !CORBA::is_nil(_current_id) && id == _current_id; }

    CORBA::ULong size () const
    {
      // The CORBA::ULong cast is needed for Win64/VC++ 10.0
      return (CORBA::ULong)_invokes.size();
    }

    // dispatcher callback
    virtual void callback (CORBA::Dispatcher *,
			   CORBA::DispatcherCallback::Event);
};

}

#endif // __mico_orb_impl_h__