SWDEV-276625 - Add implicit glFinish() for cl_khr_gl_event

Modifies the behavior of clEnqueueAcquireGLObjects and
clEnqueueReleaseGLObjects to implicitly guarantee synchronization
with an OpenGL context bound in the same thread as
the OpenCL context.

Change-Id: I23eddee37a77f6c1c9d1a9ad3a3e1eb254a1ed82

opencl/amdocl/cl_gl.cpp

@@ -1963,11 +1963,18 @@ cl_int clEnqueueAcquireExtObjectsAMD(cl_command_queue command_queue, cl_uint num
   amd::HostQueue& hostQueue = *queue;
 
   if (cmd_type == CL_COMMAND_ACQUIRE_GL_OBJECTS) {
+    GLFunctions* gl_functions = hostQueue.context().glenv();
     // Verify context init'ed for interop
-    if (!hostQueue.context().glenv() || !hostQueue.context().glenv()->isAssociated()) {
+    if (!gl_functions || !gl_functions->isAssociated()) {
       LogWarning("\"amdContext\" is not created from GL context or share list");
       return CL_INVALID_CONTEXT;
     }
+    // If the cl_khr_gl_event extension is supported, then the OpenCL implementation will ensure
+    // that any such pending OpenGL operations are complete for an OpenGL context bound
+    // to the same thread as the OpenCL context.
+    if (hostQueue.device().settings().checkExtension(ClKhrGlEvent)) {
+      gl_functions->WaitCurrentGlContext(hostQueue.context().info());
+    }
   }
 
   std::vector<amd::Memory*> memObjects;
@@ -2082,6 +2089,21 @@ cl_int clEnqueueReleaseExtObjectsAMD(cl_command_queue command_queue, cl_uint num
     }
   }
 #endif  //_WIN32
+  // If the cl_khr_gl_event extension is supported, then the OpenCL implementation will ensure
+  // that any pending OpenCL operations are complete for an OpenGL context bound
+  // to the same thread as the OpenCL context.
+  if (cmd_type == CL_COMMAND_RELEASE_GL_OBJECTS) {
+    GLFunctions* gl_functions = hostQueue.context().glenv();
+    // Verify context init'ed for interop
+    if (!gl_functions || !gl_functions->isAssociated()) {
+      LogWarning("\"amdContext\" is not created from GL context or share list");
+      return CL_INVALID_CONTEXT;
+    }
+    if (hostQueue.device().settings().checkExtension(ClKhrGlEvent) &&
+        gl_functions->IsCurrentGlContext(hostQueue.context().info())) {
+      command->awaitCompletion();
+    }
+  }
 
   *not_null(event) = as_cl(&command->event());
 
@@ -2224,6 +2246,8 @@ GLFunctions::GLFunctions(HMODULE h, bool isEGL)
 
   if (isEGL_) {
     GetProcAddress_ = (PFN_xxxGetProcAddress)GETPROCADDRESS(h, "eglGetProcAddress");
+    eglGetCurrentContext_ = (PFN_eglGetCurrentContext)GETPROCADDRESS(h, "eglGetCurrentContext");
+    VERIFY_POINTER(eglGetCurrentContext_)
   } else {
     GetProcAddress_ = (PFN_xxxGetProcAddress)GETPROCADDRESS(h, API_GETPROCADDR);
   }
@@ -2299,6 +2323,12 @@ GLFunctions::~GLFunctions() {
 #endif  //!_WIN32
 }
 
+void GLFunctions::WaitCurrentGlContext(const amd::Context::Info& info) const {
+  if (IsCurrentGlContext(info)) {
+    glFinish_();
+  }
+}
+
 bool GLFunctions::init(intptr_t hdc, intptr_t hglrc) {
   if (isEGL_) {
     eglDisplay_ = (EGLDisplay)hdc;