Edge callback listeners execute asyncly #1466

This commit cotributes to executing the registered listeners of Edge
browser on Browser callbacks in a asynchronous fashion making sure no
WebView related task is executed while a WebView callback is
already executing making sure there's no deadlock.

contributes to
#1771 and
#1919

Author: amartya4256

bundles/org.eclipse.swt/Eclipse SWT Browser/win32/org/eclipse/swt/browser/Edge.java

@@ -814,7 +814,7 @@ void browserDispose(Event event) {
 			if (inCallback) {
 				ICoreWebView2Controller controller1 = controller;
 				controller.put_IsVisible(false);
-				browser.getDisplay().asyncExec(() -> {
+				executeAsynchronously(() -> {
 					controller1.Close();
 					controller1.Release();
 				});
@@ -960,7 +960,7 @@ private String getExposedUrl(String url) {
 }
 
 int handleCloseRequested(long pView, long pArgs) {
-	browser.getDisplay().asyncExec(() -> {
+	executeAsynchronously(() -> {
 		if (browser.isDisposed()) return;
 		WindowEvent event = new WindowEvent(browser);
 		event.display = browser.getDisplay();
@@ -978,7 +978,7 @@ int handleDocumentTitleChanged(long pView, long pArgs) {
 	long[] ppsz = new long[1];
 	webViewProvider.getWebView(false).get_DocumentTitle(ppsz);
 	String title = wstrToString(ppsz[0], true);
-	browser.getDisplay().asyncExec(() -> {
+	executeAsynchronously(() -> {
 		if (browser.isDisposed()) return;
 		TitleEvent event = new TitleEvent(browser);
 		event.display = browser.getDisplay();
@@ -1031,10 +1031,12 @@ int handleNavigationStarting(long pView, long pArgs, boolean top) {
 	event.location = url;
 	event.top = top;
 	event.doit = true;
-	for (LocationListener listener : locationListeners) {
-		listener.changing(event);
-		if (browser.isDisposed()) return COM.S_OK;
-	}
+	executeAsynchronously(() -> {
+		for (LocationListener listener : locationListeners) {
+			listener.changing(event);
+			if (browser.isDisposed()) return;
+		}
+	});
 	// Save location and top for all events that use navigationId.
 	// will be eventually cleared again in handleNavigationCompleted().
 	navigations.put(pNavId[0], event);
@@ -1043,11 +1045,13 @@ int handleNavigationStarting(long pView, long pArgs, boolean top) {
 		settings.put_IsScriptEnabled(jsEnabled);
 		// Register browser functions in the new document.
 		if (!functions.isEmpty()) {
-			StringBuilder sb = new StringBuilder();
-			for (BrowserFunction function : functions.values()) {
-				sb.append(function.functionString);
-			}
-			execute(sb.toString());
+			executeAsynchronously(() -> {
+				StringBuilder sb = new StringBuilder();
+				for (BrowserFunction function : functions.values()) {
+					sb.append(function.functionString);
+				}
+				execute(sb.toString());
+			});
 		}
 	} else {
 		args.put_Cancel(true);
@@ -1093,7 +1097,7 @@ int handleSourceChanged(long pView, long pArgs) {
 		} else {
 			location = url;
 		}
-		browser.getDisplay().asyncExec(() -> {
+		executeAsynchronously(() -> {
 			if (browser.isDisposed()) return;
 			LocationEvent event = new LocationEvent(browser);
 			event.display = browser.getDisplay();
@@ -1110,7 +1114,7 @@ int handleSourceChanged(long pView, long pArgs) {
 }
 
 void sendProgressCompleted() {
-	browser.getDisplay().asyncExec(() -> {
+	executeAsynchronously(() -> {
 		if (browser.isDisposed()) return;
 		ProgressEvent event = new ProgressEvent(browser);
 		event.display = browser.getDisplay();
@@ -1160,22 +1164,24 @@ int handleBasicAuthenticationRequested(long pView, long pArgs) {
 	args.get_Uri(ppv);
 	String uri = wstrToString(ppv[0], true);
 
-	for (AuthenticationListener authenticationListener : this.authenticationListeners) {
-		AuthenticationEvent event = new AuthenticationEvent (browser);
-		event.location = uri;
-		authenticationListener.authenticate (event);
-		if (!event.doit) {
-			args.put_Cancel(true);
-			return COM.S_OK;
-		}
-		if (event.user != null && event.password != null) {
-			args.get_Response(ppv);
-			ICoreWebView2BasicAuthenticationResponse response = new ICoreWebView2BasicAuthenticationResponse(ppv[0]);
-			response.put_UserName(stringToWstr(event.user));
-			response.put_Password(stringToWstr(event.password));
-			return COM.S_OK;
+	executeAsynchronously(() -> {
+		for (AuthenticationListener authenticationListener : this.authenticationListeners) {
+			AuthenticationEvent event = new AuthenticationEvent (browser);
+			event.location = uri;
+			authenticationListener.authenticate (event);
+			if (!event.doit) {
+				args.put_Cancel(true);
+				return;
+			}
+			if (event.user != null && event.password != null) {
+				args.get_Response(ppv);
+				ICoreWebView2BasicAuthenticationResponse response = new ICoreWebView2BasicAuthenticationResponse(ppv[0]);
+				response.put_UserName(stringToWstr(event.user));
+				response.put_Password(stringToWstr(event.password));
+				return;
+			}
 		}
-	}
+	});
 
 	return COM.S_OK;
 }
@@ -1236,9 +1242,11 @@ int handleStatusBarTextChanged(long pView, long pArgs) {
 	statusTextEvent.display = browser.getDisplay();
 	statusTextEvent.widget = browser;
 	statusTextEvent.text = text;
-	for (StatusTextListener statusTextListener : statusTextListeners) {
-		statusTextListener.changed(statusTextEvent);
-	}
+	executeAsynchronously(() -> {
+		for (StatusTextListener statusTextListener : statusTextListeners) {
+			statusTextListener.changed(statusTextEvent);
+		}
+	});
 	return COM.S_OK;
 }
 
@@ -1267,7 +1275,7 @@ int handleNavigationCompleted(long pView, long pArgs, boolean top) {
 	int[] pIsSuccess = new int[1];
 	args.get_IsSuccess(pIsSuccess);
 	if (pIsSuccess[0] != 0) {
-		browser.getDisplay().asyncExec(() -> {
+		executeAsynchronously(() -> {
 			if (browser.isDisposed()) return;
 			LocationEvent event = new LocationEvent(browser);
 			event.display = browser.getDisplay();
@@ -1319,17 +1327,18 @@ int handleNewWindowRequested(long pView, long pArgs) {
 	args.GetDeferral(ppv);
 	ICoreWebView2Deferral deferral = new ICoreWebView2Deferral(ppv[0]);
 	inNewWindow = true;
-	browser.getDisplay().asyncExec(() -> {
 		try {
-			if (browser.isDisposed()) return;
+			if (browser.isDisposed()) return COM.S_OK;
 			WindowEvent openEvent = new WindowEvent(browser);
 			openEvent.display = browser.getDisplay();
 			openEvent.widget = browser;
 			openEvent.required = false;
-			for (OpenWindowListener openListener : openWindowListeners) {
-				openListener.open(openEvent);
-				if (browser.isDisposed()) return;
-			}
+			executeAsynchronously(() -> {
+				for (OpenWindowListener openListener : openWindowListeners) {
+					openListener.open(openEvent);
+					if (browser.isDisposed()) return;
+				}
+			});
 			if (openEvent.browser != null && !openEvent.browser.isDisposed()) {
 				WebBrowser other = openEvent.browser.webBrowser;
 				args.put_Handled(true);
@@ -1341,10 +1350,12 @@ int handleNewWindowRequested(long pView, long pArgs) {
 					showEvent.display = browser.getDisplay();
 					showEvent.widget = other.browser;
 					updateWindowFeatures(args, showEvent);
-					for (VisibilityWindowListener showListener : other.visibilityWindowListeners) {
-						showListener.show(showEvent);
-						if (other.browser.isDisposed()) return;
-					}
+					executeAsynchronously(() -> {
+						for (VisibilityWindowListener showListener : other.visibilityWindowListeners) {
+							showListener.show(showEvent);
+							if (other.browser.isDisposed()) return;
+						}
+					});
 				}
 			} else if (openEvent.required) {
 				args.put_Handled(true);
@@ -1355,7 +1366,6 @@ int handleNewWindowRequested(long pView, long pArgs) {
 			args.Release();
 			inNewWindow = false;
 		}
-	});
 	return COM.S_OK;
 }
 
@@ -1426,7 +1436,8 @@ int handleAcceleratorKeyPressed(long pView, long pArgs) {
 		}
 	} else {
 		keyEvent.type = SWT.KeyUp;
-		browser.notifyListeners (keyEvent.type, keyEvent);
+		executeAsynchronously(() -> browser.notifyListeners (keyEvent.type, keyEvent));
+
 		if (!keyEvent.doit) {
 			args.put_Handled(true);
 		}
@@ -1500,6 +1511,10 @@ public boolean setText(String html, boolean trusted) {
 	return setWebpageData(URI_FOR_CUSTOM_TEXT_PAGE.toString(), null, null, html);
 }
 
+private void executeAsynchronously(Runnable runnable) {
+	browser.getDisplay().asyncExec(runnable);
+}
+
 private boolean setWebpageData(String url, String postData, String[] headers, String html) {
 	// Feature in WebView2. Partial URLs like "www.example.com" are not accepted.
 	// Prepend the protocol if it's missing.

tests/org.eclipse.swt.tests/JUnit Tests/org/eclipse/swt/tests/junit/Test_org_eclipse_swt_browser_Browser.java

@@ -739,7 +739,6 @@ public void changed(LocationEvent event) {
 
 @Test
 public void test_LocationListener_LocationListener_ordered_changing () {
-	assumeFalse("Currently broken for Edge", isEdge);
 	List<String> locations = Collections.synchronizedList(new ArrayList<>());
 	browser.addLocationListener(changingAdapter(event -> {
 		locations.add(event.location);
@@ -1572,7 +1571,6 @@ public void completed(ProgressEvent event) {
 */
 @Test
 public void test_LocationListener_evaluateInCallback() {
-	assumeFalse("behavior is not (yet) supported by Edge browser", isEdge);
 
 	AtomicBoolean changingFinished = new AtomicBoolean(false);
 	AtomicBoolean changedFinished = new AtomicBoolean(false);
@@ -1622,7 +1620,6 @@ public void changed(LocationEvent event) {
 /** Verify that evaluation works inside an OpenWindowListener */
 @Test
 public void test_OpenWindowListener_evaluateInCallback() {
-	assumeFalse("behavior is not (yet) supported by Edge browser", isEdge);
 
 	AtomicBoolean eventFired = new AtomicBoolean(false);
 	browser.addOpenWindowListener(event -> {
@@ -2183,7 +2180,6 @@ public void test_evaluate_array_mixedTypes () {
  */
 @Test
 public void test_BrowserFunction_callback () {
-	assumeFalse("Currently broken for Edge", isEdge);
 	AtomicBoolean javaCallbackExecuted = new AtomicBoolean(false);
 
 	class JavascriptCallback extends BrowserFunction { // Note: Local class defined inside method.