//+-------------------------------------------------------------------------
//
//  Microsoft Windows
//  Copyright (C) Microsoft Corporation, 1992 - 1993.
//
//  File:       DdeChC.cxx
//
//  Contents:   CDdeChannelControl implementation for DDE. This
//		implementation requires no instance data, therefore it is
//		intended to be static.
//
//  Functions:
//
//  History:    08-May-94 Johann Posch (johannp)    Created
//  		10-May-94 KevinRo  Made simpler
//		29-May-94 KevinRo  Added DDE Server support
//
//--------------------------------------------------------------------------
#include "ddeproxy.h"

//
// All threads can use a single instance of this class. Therefore, we
// provide the following global variable that generates the instance.
//

CDdeChannelControl g_CDdeChannelControl;

STDMETHODIMP CDdeChannelControl::QueryInterface( THIS_ REFIID riid, LPVOID FAR* ppvObj)
{
    if (IsEqualIID(riid, IID_IUnknown)
//    || IsEqualIID(riid, IID_IChannelControl)
     )
    {
	*ppvObj = (IChannelControl *) this;
    }
    else
    {
        *ppvObj = NULL;
        return E_NOINTERFACE;
    }

    return S_OK;
}

STDMETHODIMP_(ULONG) CDdeChannelControl::Release( THIS )
{
    return(1);
}

STDMETHODIMP_(ULONG) CDdeChannelControl::AddRef( THIS )
{
    return 1;
}


//+---------------------------------------------------------------------------
//
//  Method:     CDdeChannelControl::DispatchCall
//
//  Synopsis:   DispatchCall is called to handle incoming calls.
//
//  Effects:    Dispatches a call to the specified in the DispatchData.
//		This function is the result of a call in OnData(), which
//		processes incoming calls from the OLE 1.0 server.
//
//  Arguments:  [pDispData] -- Points to the dispatch data structure
//
//  Requires:
//
//  Returns:
//
//  Signals:
//
//  Modifies:
//
//  Derivation:
//
//  Algorithm:
//
//  History:    5-16-94   JohannP Created
//
//  Notes:
//
//----------------------------------------------------------------------------
STDMETHODIMP CDdeChannelControl::DispatchCall( PDISPATCHDATA pDispData )
{
    intrDebugOut((DEB_ITRACE,
		  "CDdeChannelControl::DispatchCall(%x,pDispData=%x)\n",
		  this,
		  pDispData));

    intrAssert(pDispData != NULL);
    POLE1DISPATCHDATA pData = (POLE1DISPATCHDATA)pDispData->pData;
    intrAssert(pData != NULL);

    switch (pData->wDispFunc)
    {
    case DDE_DISP_SENDONDATACHANGE: // OnDataChange
	{
	    PDDEDISPATCHDATA pDData = (PDDEDISPATCHDATA)pDispData->pData;
	    return pDData->pCDdeObject->SendOnDataChange(pDData->iArg);
	}

    case DDE_DISP_OLECALLBACK: // OleCallBack
	{
	    PDDEDISPATCHDATA pDData = (PDDEDISPATCHDATA)pDispData->pData;
	    return  pDData->pCDdeObject->OleCallBack(pDData->iArg,NULL);
	}

    //
    // The server window has an incoming call. Look in dde\server\srvr.cxx
    //
    case DDE_DISP_SRVRWNDPROC:
	return(SrvrDispatchIncomingCall((PSRVRDISPATCHDATA)pDispData->pData));
    //
    // This dispatches to a Document window
    //
    case DDE_DISP_DOCWNDPROC:
	return(DocDispatchIncomingCall((PDOCDISPATCHDATA)pDispData->pData));

    default:
	intrAssert(!"Unknown wDispFunc");
    }
    return E_FAIL;
}

//+---------------------------------------------------------------------------
//
//  Method:     CDdeChannelControl::OnEvent
//
//  Synopsis:   OnEvent should never be called on this channel
//
//  Effects:
//
//  Arguments:  [pCallData] --
//
//  Requires:
//
//  Returns:
//
//  Signals:
//
//  Modifies:
//
//  Derivation:
//
//  Algorithm:
//
//  History:    5-16-94   JohannP   Created
//
//  Notes:
//
//----------------------------------------------------------------------------
STDMETHODIMP CDdeChannelControl::OnEvent( PCALLDATA pCallData )
{
    // should be never called

    intrAssert(!"CDdeChannelControl::OnEvent( PCALLDATA pCallData ) not implemented\n");
    return E_FAIL;
}

//+---------------------------------------------------------------------------
//
//  Method:     CDdeChannelControl::TransmitCall
//
//  Synopsis:   Transmit the parameters to the server.
//
//  Effects:    This function transmits the pCallData to the server. This
//		may be called multiple times, if a retry is required.
//
//		A by product of the way the DDE channel was implemented
//		atop existing code is that the existing code may transmit
//		the first round of data on its own. If it does this, it
//		will set the fInitialSend to TRUE. Therefore, if this
//		routine sees the flag as true, it will not send the data,
//		but will set the flag to FALSE for a possible retry later.
//
//  Arguments:  [pCallData] -- Points to the DDE specific call data
//
//  Requires:
//
//  Returns:    If the Post fails, this function returns E_FAIL
//
//  Signals:
//
//  Modifies:
//
//  Derivation:
//
//  Algorithm:
//
//  History:    5-16-94   JohannP   Created
//
//  Notes:
//
//----------------------------------------------------------------------------
STDMETHODIMP CDdeChannelControl::TransmitCall( PCALLDATA pCallData )
{
    intrDebugOut((DEB_ITRACE,
		  "CDdeChannelControl::TransmitCall(%x,pCallData=%x)\n",
		  this,
		  pCallData));
    // reset the event
    pCallData->Event = 0;
    pCallData->fDirectedYield = FALSE;

    PDDECALLDATA pDdeCD = (PDDECALLDATA)pCallData->pRpcMsg;

    //
    // If the routine wPostServerMessage has already posted the
    // first send, then fInitialSend will be TRUE. In that case,
    // don't TransmitCall() this time, but reset the flag for
    // future retries.
    //

    if (!pDdeCD->fInitialSend)
    {
	intrDebugOut((DEB_ITRACE,
		      "::TransmitCall(%x) PostMessage(%x,%x,%x,%x)\n",
		      this,
		      pDdeCD->hwndSvr,
		      pDdeCD->wMsg,
	     (WPARAM) pDdeCD->hwndCli,
		      pDdeCD->lParam));

	if(!PostMessage (pDdeCD->hwndSvr,
		         pDdeCD->wMsg,
		(WPARAM) pDdeCD->hwndCli,
			 pDdeCD->lParam))
	{
	    return(E_FAIL);
	}
    }
    else
    {
	intrDebugOut((DEB_ITRACE,
		      "::TransmitCall(%x) Already Posted Message\n",
		      this));

	pDdeCD->fInitialSend = FALSE;
    }

    //
    // Figure out if we want the call control to do a directed yield.
    // Do this only if the server is in the same VDM as us.
    //


    if (IsWOWProcess())
    {
	DWORD dwPID, dwTID;
	dwTID = GetWindowThreadProcessId(pDdeCD->hwndSvr, &dwPID);

	if (dwPID == GetCurrentProcessId())
	{
            // Make sure we have the right thread id to yield to
            pCallData->TIDCallee = dwTID;

	    // same VDM so do directed yield
	    pCallData->fDirectedYield = TRUE;
	}
    }

    return NOERROR;
}