1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
/*
* Copyright (C) 2017-2020 Intel Corporation
*
* SPDX-License-Identifier: MIT
*
*/
#include "opencl/test/unit_test/command_queue/command_queue_fixture.h"
#include "shared/source/device/device.h"
#include "shared/test/unit_test/mocks/mock_device.h"
#include "opencl/source/command_queue/command_queue_hw.h"
#include "opencl/source/context/context.h"
#include "opencl/test/unit_test/mocks/mock_cl_device.h"
#include "opencl/test/unit_test/mocks/mock_command_queue.h"
#include "gtest/gtest.h"
namespace NEO {
// Global table of create functions
extern CommandQueueCreateFunc commandQueueFactory[IGFX_MAX_CORE];
CommandQueue *CommandQueueHwFixture::createCommandQueue(
ClDevice *pDevice,
cl_command_queue_properties properties) {
const cl_queue_properties props[3] = {CL_QUEUE_PROPERTIES, properties, 0};
return createCommandQueue(pDevice, props);
}
CommandQueue *CommandQueueHwFixture::createCommandQueue(
ClDevice *pDevice,
const cl_command_queue_properties *properties) {
if (pDevice == nullptr) {
if (this->device == nullptr) {
this->device = new MockClDevice{MockDevice::createWithNewExecutionEnvironment<MockDevice>(nullptr)};
}
pDevice = this->device;
}
if (!context)
context = new MockContext(pDevice);
auto funcCreate = commandQueueFactory[pDevice->getRenderCoreFamily()];
assert(nullptr != funcCreate);
return funcCreate(context, pDevice, properties, false);
}
void CommandQueueHwFixture::SetUp() {
ASSERT_NE(nullptr, pCmdQ);
context = new MockContext();
}
void CommandQueueHwFixture::SetUp(
ClDevice *pDevice,
cl_command_queue_properties properties) {
ASSERT_NE(nullptr, pDevice);
context = new MockContext(pDevice);
pCmdQ = createCommandQueue(pDevice, properties);
ASSERT_NE(nullptr, pCmdQ);
}
void CommandQueueHwFixture::TearDown() {
//resolve event dependencies
if (pCmdQ) {
auto blocked = pCmdQ->isQueueBlocked();
UNRECOVERABLE_IF(blocked);
pCmdQ->release();
}
if (context) {
context->release();
}
if (device) {
delete device;
}
}
CommandQueue *CommandQueueFixture::createCommandQueue(
Context *context,
ClDevice *device,
cl_command_queue_properties properties) {
const cl_queue_properties props[3] = {CL_QUEUE_PROPERTIES, properties, 0};
return new MockCommandQueue(
context,
device,
props);
}
void CommandQueueFixture::SetUp(
Context *context,
ClDevice *device,
cl_command_queue_properties properties) {
pCmdQ = createCommandQueue(
context,
device,
properties);
}
void CommandQueueFixture::TearDown() {
delete pCmdQ;
pCmdQ = nullptr;
}
} // namespace NEO
|
