File: zello_world.cpp

package info (click to toggle)
level-zero 1.27.0-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 14,020 kB
  • sloc: cpp: 132,430; ansic: 16,654; python: 10,040; makefile: 4
file content (249 lines) | stat: -rw-r--r-- 9,314 bytes parent folder | download
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
/*
 *
 * Copyright (C) 2020-2025 Intel Corporation
 *
 * SPDX-License-Identifier: MIT
 *
 */
#include <stdlib.h>
#include <memory>

#include "zello_init.h"

void print_loader_versions(){

    zel_component_version_t *versions;
    size_t size = 0;
    zelLoaderGetVersions(&size, nullptr);
    std::cout << "zelLoaderGetVersions number of components found: " << size << std::endl;
    versions = new zel_component_version_t[size];
    zelLoaderGetVersions(&size, versions);

    for(size_t i = 0; i < size; i++){
        std::cout << "Version " << i << std::endl;
        std::cout << "Name: " << versions[i].component_name << std::endl;
        std::cout << "Major: " << versions[i].component_lib_version.major << std::endl;
        std::cout << "Minor: " << versions[i].component_lib_version.minor << std::endl;
        std::cout << "Patch: " << versions[i].component_lib_version.patch << std::endl;
    }

    delete[] versions;
}

#if defined(_WIN32)
    #define putenv_safe _putenv
#else
    #define putenv_safe putenv
#endif

//////////////////////////////////////////////////////////////////////////
int main( int argc, char *argv[] )
{
    bool tracing_runtime_enabled = false;
    bool legacy_init = false;
    bool tracing_enabled = false;
    bool npu_test = false;
    if( argparse( argc, argv, "-null", "--enable_null_driver" ) )
    {
        putenv_safe( const_cast<char *>( "ZE_ENABLE_NULL_DRIVER=1" ) );
    }
    if( argparse( argc, argv, "-ldr", "--force_loader_intercepts" ) )
    {
        putenv_safe( const_cast<char *>( "ZE_ENABLE_LOADER_INTERCEPT=1" ) );
    }
    if( argparse( argc, argv, "-val", "--enable_validation_layer" ) )
    {
        putenv_safe( const_cast<char *>( "ZE_ENABLE_VALIDATION_LAYER=1" ) );
        putenv_safe( const_cast<char *>( "ZE_ENABLE_PARAMETER_VALIDATION=1" ) );
    }
    if( argparse( argc, argv, "-trace", "--enable_tracing_layer" ) )
    {
        putenv_safe( const_cast<char *>( "ZE_ENABLE_TRACING_LAYER=1" ) );
        tracing_enabled = true;
    }
    if( argparse( argc, argv, "-tracerun", "--enable_tracing_layer_runtime" ) )
    {
        tracing_runtime_enabled = true;
        tracing_enabled = true;
    }
    if( argparse( argc, argv, "-legacy_init", "--enable_legacy_init" ) )
    {
        legacy_init = true;
    }
    if( argparse( argc, argv, "-npu", "--enable_npu" ) )
    {
        npu_test = true;
    }

    ze_result_t status;
    ze_device_type_t type = ZE_DEVICE_TYPE_GPU;
    if (npu_test) {
        std::cout << "NPU Test Enabled. Looking for NPU devices." << std::endl;
        type = ZE_DEVICE_TYPE_VPU;
    }

    ze_init_driver_type_desc_t driverTypeDesc = {};
    driverTypeDesc.stype = ZE_STRUCTURE_TYPE_INIT_DRIVER_TYPE_DESC;
    if (npu_test) {
        driverTypeDesc.flags = ZE_INIT_DRIVER_TYPE_FLAG_NPU;
    } else {
        driverTypeDesc.flags = ZE_INIT_DRIVER_TYPE_FLAG_GPU;
    }
    driverTypeDesc.pNext = nullptr;

    ze_driver_handle_t pDriver = nullptr;
    ze_device_handle_t pDevice = nullptr;
    uint32_t driverCount = 0;
    zel_tracer_handle_t tracer = nullptr;
    std::vector<ze_driver_handle_t> drivers;
    std::vector<ze_device_handle_t> devices_per_driver;
    if( init_ze(legacy_init, driverCount, driverTypeDesc) )
    {

        print_loader_versions();

        if (tracing_runtime_enabled) {
            std::cout << "Enabling Tracing Layer after init" << std::endl;
            status = zelEnableTracingLayer();
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zelEnableTracingLayer Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        }

        if (legacy_init) {
            status = zeDriverGet(&driverCount, nullptr);
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zeDriverGet Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }

            drivers.resize(driverCount);
            status = zeDriverGet( &driverCount, drivers.data() );
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zeDriverGet Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        } else {
            drivers.resize(driverCount);
            status = zeInitDrivers( &driverCount, drivers.data(), &driverTypeDesc);
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zeInitDrivers Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        }

        for( size_t driver = 0; driver < drivers.size(); ++driver )
        {
            std::cout << "Driver # " << driver << "\n";
            pDriver = drivers[driver];
            pDevice = findDevice( pDriver, type );
            if (pDevice) {
                devices_per_driver.push_back(pDevice);
            } else {
                devices_per_driver.push_back(nullptr);
            }
        }
    }

    if( devices_per_driver.empty() || drivers.empty() )
    {
        std::cout << "Did NOT find matching " << to_string(type) <<" device!" << "\n";
        return -1;
    }

    for (size_t driver_idx = 0; driver_idx < drivers.size(); ++driver_idx) {
        if (driver_idx >= devices_per_driver.size() || devices_per_driver[driver_idx] == nullptr) {
            std::cout << "No valid device found for Driver #" << driver_idx << std::endl;
            continue;
        }
        if (tracing_enabled) {
            zel_tracer_desc_t tracer_desc = {ZEL_STRUCTURE_TYPE_TRACER_EXP_DESC, nullptr,
                nullptr};
            status = zelTracerCreate(&tracer_desc, &tracer);
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zelTracerCreate Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        }
        pDriver = drivers[driver_idx];
        pDevice = devices_per_driver[driver_idx];
        std::cout << "Executing on Driver #" << driver_idx << ", Device #" << 0 << std::endl;
        // Create the context
        ze_context_handle_t context;
        ze_context_desc_t context_desc = {};
        context_desc.stype = ZE_STRUCTURE_TYPE_CONTEXT_DESC;
        status = zeContextCreate(pDriver, &context_desc, &context);
        if(status != ZE_RESULT_SUCCESS) {
            std::cout << "zeContextCreate Failed with return code: " << to_string(status) << std::endl;
            continue;
        }

        // Create an immediate command list for direct submission
        ze_command_queue_desc_t altdesc = {};
        altdesc.stype = ZE_STRUCTURE_TYPE_COMMAND_QUEUE_DESC;
        ze_command_list_handle_t command_list = {};
        status = zeCommandListCreateImmediate(context, pDevice, &altdesc, &command_list);
        if(status != ZE_RESULT_SUCCESS) {
            std::cout << "zeCommandListCreateImmediate Failed with return code: " << to_string(status) << std::endl;
            continue;
        }

        // Create an event to be signaled by the device
        ze_event_pool_desc_t ep_desc = {};
        ep_desc.stype = ZE_STRUCTURE_TYPE_EVENT_POOL_DESC;
        ep_desc.count = 1;
        ep_desc.flags = ZE_EVENT_POOL_FLAG_HOST_VISIBLE;
        ze_event_desc_t ev_desc = {};
        ev_desc.stype = ZE_STRUCTURE_TYPE_EVENT_DESC;
        ev_desc.signal = ZE_EVENT_SCOPE_FLAG_HOST;
        ev_desc.wait = ZE_EVENT_SCOPE_FLAG_HOST;
        ze_event_handle_t event;
        ze_event_pool_handle_t event_pool;

        status = zeEventPoolCreate(context, &ep_desc, 1, &pDevice, &event_pool);
        if(status != ZE_RESULT_SUCCESS) {
            std::cout << "zeEventPoolCreate Failed with return code: " << to_string(status) << std::endl;
            continue;
        }

        status = zeEventCreate(event_pool, &ev_desc, &event);
        if(status != ZE_RESULT_SUCCESS) {
            std::cout << "zeEventCreate Failed with return code: " << to_string(status) << std::endl;
            continue;
        }

        // signal the event from the device and wait for completion
        zeCommandListAppendSignalEvent(command_list, event);
        zeEventHostSynchronize(event, UINT64_MAX );
        std::cout << "Congratulations, Executing on Driver #" << driver_idx << ", Device #" << 0 << " completed execution!" << std::endl;

        if (!zelCheckIsLoaderInTearDown())
            zeContextDestroy(context);
        if (!zelCheckIsLoaderInTearDown())
            zeCommandListDestroy(command_list);
        if (!zelCheckIsLoaderInTearDown())
            zeEventDestroy(event);
        if (!zelCheckIsLoaderInTearDown())
            zeEventPoolDestroy(event_pool);

        if (tracing_enabled) {
            status = zelTracerDestroy(tracer);
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zelTracerDestroy Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        }

        if (tracing_runtime_enabled) {
            std::cout << "Disable Tracing Layer after init" << std::endl;
            status = zelDisableTracingLayer();
            if(status != ZE_RESULT_SUCCESS) {
                std::cout << "zelDisableTracingLayer Failed with return code: " << to_string(status) << std::endl;
                exit(1);
            }
        }
    }

    return 0;
}