fix unit test to call pipe read/write directly

Author: zibaiwan

sycl/include/sycl/handler.hpp

@@ -86,7 +86,6 @@ class __copyAcc2Acc;
 
 // For unit testing purposes
 class MockHandler;
-class PipeTest_Basic_Test;
 
 namespace sycl {
 __SYCL_INLINE_VER_NAMESPACE(_V1) {
@@ -2901,7 +2900,6 @@ class __SYCL_EXPORT handler {
   template <class _name, class _dataT, int32_t _min_capacity,
           class _propertiesT, class> 
   friend class ext::intel::experimental::pipe;
-  friend class ::PipeTest_Basic_Test;
 
   /// Read from a host pipe given a host address and
   /// \param Name name of the host pipe to be passed into lower level runtime

sycl/unittests/pipes/host_pipe_registration.cpp

@@ -91,6 +91,26 @@ pi_result redefinedEnqueueWriteHostPipe(pi_queue, pi_program, const char *,
   return PI_SUCCESS;
 }
 
+pi_result after_piDeviceGetInfo(pi_device device, pi_device_info param_name,
+                                size_t param_value_size, void *param_value,
+                                size_t *param_value_size_ret) {
+  constexpr char MockSupportedExtensions[] =
+      "cl_khr_fp64 cl_khr_fp16 cl_khr_il_program cl_intel_program_scope_host_pipe";
+  switch (param_name) {
+  case PI_DEVICE_INFO_EXTENSIONS: {
+    if (param_value) {
+      assert(param_value_size >= sizeof(MockSupportedExtensions));
+      std::memcpy(param_value, MockSupportedExtensions,
+                  sizeof(MockSupportedExtensions));
+    }
+    if (param_value_size_ret)
+      *param_value_size_ret = sizeof(MockSupportedExtensions);
+    return PI_SUCCESS;
+  }
+  }
+  return PI_SUCCESS;
+}
+
 void preparePiMock(unittest::PiMock &Mock) {
   Mock.redefine<detail::PiApiKind::piextEnqueueReadHostPipe>(
       redefinedEnqueueReadHostPipe);
@@ -120,32 +140,20 @@ class PipeTest : public ::testing::Test {
 };
 
 TEST_F(PipeTest, Basic) {
+  // Fake extension
+  Mock.redefineAfter<sycl::detail::PiApiKind::piDeviceGetInfo>(after_piDeviceGetInfo);
 
   // Device registration
   static sycl::unittest::PiImage Img = generateDefaultImage();
   static sycl::unittest::PiImageArray<1> ImgArray{&Img};
 
-  // Get the hostpipe
-  const void *HostPipePtr = Pipe::get_host_ptr();
-  detail::HostPipeMapEntry *HostPipeEntry =
-      detail::ProgramManager::getInstance().getHostPipeEntry(HostPipePtr);
-  const std::string PipeName = HostPipeEntry->MUniqueId;
-
-  // Testing read
+  //Testing read
   int HostPipeReadData;
-  void *DataPtrRead = &HostPipeReadData;
-  event ERead = q.submit([=](handler &CGH) {
-    CGH.ext_intel_read_host_pipe(PipeName, DataPtrRead, sizeof(int), true /* blocking */);
-  });
-  ERead.wait();
+  HostPipeReadData = Pipe::read(q);
   assert(HostPipeReadData == PipeReadVal);
 
   // Testing write
   int HostPipeWriteData = 9;
-  void *DataPtrWrite = &HostPipeWriteData;
-  event EWrite = q.submit([=](handler &CGH) {
-    CGH.ext_intel_write_host_pipe(PipeName, DataPtrWrite, sizeof(int), true/* blocking */);
-  });
-  EWrite.wait();
+  Pipe::write(q,HostPipeWriteData);
   assert(PipeWriteVal == 9);
 }