/******************************************************************************* * Copyright (c) 2000, 2003 IBM Corporation and others. * All rights reserved. This program and the accompanying materials  * are made available under the terms of the Common Public License v1.0 * which accompanies this distribution, and is available at * http://www.eclipse.org/legal/cpl-v10.html *  * Contributors: *     IBM Corporation - initial API and implementation *******************************************************************************/package org.eclipse.swt.ole.win32;import org.eclipse.swt.*;import org.eclipse.swt.internal.ole.win32.*;final class OleEventSink{	private OleControlSite widget;		private COMObject iDispatch;	private int refCount;	private IUnknown objIUnknown;	private int  eventCookie;	private GUID eventGuid;	private OleEventTable eventTable;	OleEventSink(OleControlSite widget, int iUnknown, GUID riid) {	this.widget = widget;	this.eventGuid = riid;	this.objIUnknown = new IUnknown(iUnknown);		createCOMInterfaces();}void connect () {	int[] ppvObject = new int[1];	if (objIUnknown.QueryInterface(COM.IIDIConnectionPointContainer, ppvObject) == COM.S_OK) {		IConnectionPointContainer cpc = new IConnectionPointContainer(ppvObject[0]);		int[] ppCP = new int[1];		if (cpc.FindConnectionPoint(eventGuid, ppCP) == COM.S_OK) {			IConnectionPoint cp = new IConnectionPoint(ppCP[0]);			int[] pCookie = new int[1];			if (cp.Advise(iDispatch.getAddress(), pCookie) == COM.S_OK)				eventCookie = pCookie[0];			cp.Release();		}		cpc.Release();	}}void addListener(int eventID, OleListener listener) {	if (listener == null) OLE.error (SWT.ERROR_NULL_ARGUMENT);	if (eventTable == null) eventTable = new OleEventTable ();	eventTable.hook(eventID, listener);}int AddRef() {	refCount++;	return refCount;}private void createCOMInterfaces() {	iDispatch = new COMObject(new int[]{2, 0, 0, 1, 3, 4, 8}){		public int method0(int[] args) {return QueryInterface(args[0], args[1]);}		public int method1(int[] args) {return AddRef();}		public int method2(int[] args) {return Release();}		// method3 GetTypeInfoCount - not implemented		// method4 GetTypeInfo - not implemented		// method5 GetIDsOfNames - not implemented		public int method6(int[] args) {return Invoke(args[0], args[1], args[2], args[3], args[4], args[5], args[6], args[7]);}	};}void disconnect() {	// disconnect event sink	if (eventCookie != 0 && objIUnknown != null) {		int[] ppvObject = new int[1];		if (objIUnknown.QueryInterface(COM.IIDIConnectionPointContainer, ppvObject) == COM.S_OK) {			IConnectionPointContainer cpc = new IConnectionPointContainer(ppvObject[0]);			if (cpc.FindConnectionPoint(eventGuid, ppvObject) == COM.S_OK) {				IConnectionPoint cp = new IConnectionPoint(ppvObject[0]);				if (cp.Unadvise(eventCookie) == COM.S_OK) {					eventCookie = 0;				}				cp.Release();			}			cpc.Release();		}	}}private void disposeCOMInterfaces() {	if (iDispatch != null)		iDispatch.dispose();	iDispatch = null;	}private int Invoke(int dispIdMember, int riid, int lcid, int dwFlags, int pDispParams, int pVarResult, int pExcepInfo, int pArgErr){	if (eventTable == null || !eventTable.hooks(dispIdMember)) return COM.S_OK;		// Construct an array of the parameters that are passed in	// Note: parameters are passed in reverse order - here we will correct the order	Variant[] eventInfo = null;	if (pDispParams != 0) {			DISPPARAMS dispParams = new DISPPARAMS();		COM.MoveMemory(dispParams, pDispParams, DISPPARAMS.sizeof);		eventInfo = new Variant[dispParams.cArgs];		int size = Variant.sizeof;		int offset = (dispParams.cArgs - 1) * size;				for (int j = 0; j < dispParams.cArgs; j++){			eventInfo[j] = new Variant();			eventInfo[j].setData(dispParams.rgvarg + offset);			offset = offset - size;		}	}			OleEvent event = new OleEvent();	event.arguments = eventInfo;	try {		notifyListener(dispIdMember,event);	} catch (Throwable t) {	}	return COM.S_OK;}/*** Notify listeners of an event.* <p>*	This method notifies all listeners that an event* has occurred.** @param eventType the desired SWT event* @param event the event data** @exception SWTError <ul>*		<li>ERROR_THREAD_INVALID_ACCESS when called from the wrong thread</li>*		<li>ERROR_WIDGET_DISPOSED when the widget has been disposed</li>* 		<li>ERROR_NULL_ARGUMENT when handler is null</li>*	</ul>*/private void notifyListener (int eventType, OleEvent event) {	if (event == null) OLE.error (SWT.ERROR_NULL_ARGUMENT);	if (eventTable == null) return;	event.type = eventType;	event.widget = widget;	eventTable.sendEvent (event);}private int QueryInterface(int riid, int ppvObject) {	if (riid == 0 || ppvObject == 0)		return COM.E_INVALIDARG;	GUID guid = new GUID();	COM.MoveMemory(guid, riid, GUID.sizeof);	if ( COM.IsEqualGUID(guid, COM.IIDIUnknown) || COM.IsEqualGUID(guid, COM.IIDIDispatch) ||			COM.IsEqualGUID(guid, eventGuid)) {		COM.MoveMemory(ppvObject, new int[] {iDispatch.getAddress()}, 4);		AddRef();		return OLE.S_OK;	}	COM.MoveMemory(ppvObject, new int[] {0}, 4);	return COM.E_NOINTERFACE;}int Release() {	refCount--;	if (refCount == 0) {		disposeCOMInterfaces();	}		return refCount;}void removeListener(int eventID, OleListener listener) {	if (listener == null) OLE.error (SWT.ERROR_NULL_ARGUMENT);	if (eventTable == null) return;	eventTable.unhook (eventID, listener);}boolean hasListeners() {	return eventTable.hasEntries();}}