/* * Copyright (c) 2017, Intel Corporation * * Permission is hereby granted, free of charge, to any person obtaining a * copy of this software and associated documentation files (the "Software"), * to deal in the Software without restriction, including without limitation * the rights to use, copy, modify, merge, publish, distribute, sublicense, * and/or sell copies of the Software, and to permit persons to whom the * Software is furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included * in all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR * OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR * OTHER DEALINGS IN THE SOFTWARE. */ #include "runtime/command_queue/command_queue.h" #include "runtime/event/event.h" #include "unit_tests/fixtures/hello_world_fixture.h" #include "unit_tests/helpers/hw_parse.h" #include "test.h" using namespace OCLRT; struct TwoIOQsTwoDependentWalkers : public HelloWorldTest, public HardwareParse { typedef HelloWorldTest Parent; using Parent::createCommandQueue; using Parent::pCmdQ; using Parent::pDevice; using Parent::pKernel; TwoIOQsTwoDependentWalkers() { } void SetUp() override { Parent::SetUp(); HardwareParse::SetUp(); } void TearDown() override { delete pCmdQ2; HardwareParse::TearDown(); Parent::TearDown(); } template void parseWalkers() { cl_uint workDim = 1; size_t globalWorkOffset[3] = {0, 0, 0}; size_t globalWorkSize[3] = {1, 1, 1}; size_t localWorkSize[3] = {1, 1, 1}; cl_event event1 = nullptr; cl_event event2 = nullptr; auto retVal = pCmdQ->enqueueKernel( pKernel, workDim, globalWorkOffset, globalWorkSize, localWorkSize, 0, nullptr, &event1); ASSERT_EQ(CL_SUCCESS, retVal); HardwareParse::parseCommands(*pCmdQ); // Create a second command queue (beyond the default one) pCmdQ2 = createCommandQueue(pDevice, 0); ASSERT_NE(nullptr, pCmdQ2); retVal = pCmdQ2->enqueueKernel( pKernel, workDim, globalWorkOffset, globalWorkSize, localWorkSize, 1, &event1, &event2); ASSERT_EQ(CL_SUCCESS, retVal); HardwareParse::parseCommands(*pCmdQ2); Event *E1 = castToObject(event1); ASSERT_NE(nullptr, E1); Event *E2 = castToObject(event2); ASSERT_NE(nullptr, E2); delete E1; delete E2; typedef typename FamilyType::GPGPU_WALKER GPGPU_WALKER; itorWalker1 = find(cmdList.begin(), cmdList.end()); ASSERT_NE(cmdList.end(), itorWalker1); itorWalker2 = itorWalker1; ++itorWalker2; itorWalker2 = find(itorWalker2, cmdList.end()); ASSERT_NE(cmdList.end(), itorWalker2); } GenCmdList::iterator itorWalker1; GenCmdList::iterator itorWalker2; CommandQueue *pCmdQ2 = nullptr; }; HWTEST_F(TwoIOQsTwoDependentWalkers, shouldHaveTwoWalkers) { parseWalkers(); EXPECT_NE(itorWalker1, itorWalker2); } HWTEST_F(TwoIOQsTwoDependentWalkers, shouldHaveOnePS) { parseWalkers(); int numCommands = getNumberOfPipelineSelectsThatEnablePipelineSelect(); EXPECT_EQ(1, numCommands); } HWTEST_F(TwoIOQsTwoDependentWalkers, shouldHaveOneVFEState) { parseWalkers(); auto numCommands = getCommandsList().size(); EXPECT_EQ(1u, numCommands); } HWTEST_F(TwoIOQsTwoDependentWalkers, shouldHaveAPipecontrolBetweenWalkers) { typedef typename FamilyType::PIPE_CONTROL PIPE_CONTROL; parseWalkers(); auto itorCmd = find(itorWalker1, itorWalker2); // Should find a PC. EXPECT_NE(itorWalker2, itorCmd); }