• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1/*
2 * Copyright 2018 Google LLC
3 * SPDX-License-Identifier: MIT
4 */
5(void)doLock;
6
7auto stream = mImpl->stream();
8auto pool = mImpl->pool();
9VkQueue local_queue;
10VkCommandBuffer local_commandBuffer;
11VkDeviceSize local_dataSize;
12void* local_pData;
13local_queue = queue;
14local_commandBuffer = commandBuffer;
15local_dataSize = dataSize;
16// Avoiding deepcopy for pData
17local_pData = (void*)pData;
18size_t count = 0;
19size_t* countPtr = &count;
20{
21    uint64_t cgen_var_1405;
22    *countPtr += 1 * 8;
23    uint64_t cgen_var_1406;
24    *countPtr += 1 * 8;
25    *countPtr += sizeof(VkDeviceSize);
26    *countPtr += ((dataSize)) * sizeof(uint8_t);
27}
28bool queueSubmitWithCommandsEnabled = sFeatureBits & VULKAN_STREAM_FEATURE_QUEUE_SUBMIT_WITH_COMMANDS_BIT;
29uint32_t packetSize_vkQueueFlushCommandsGOOGLE = 4 + 4 + (queueSubmitWithCommandsEnabled ? 4 : 0) + count;
30uint8_t* streamPtr = stream->reserve(packetSize_vkQueueFlushCommandsGOOGLE - local_dataSize);
31uint8_t* packetBeginPtr = streamPtr;
32uint8_t** streamPtrPtr = &streamPtr;
33uint32_t opcode_vkQueueFlushCommandsGOOGLE = OP_vkQueueFlushCommandsGOOGLE;
34uint32_t seqno = ResourceTracker::nextSeqno();
35memcpy(streamPtr, &opcode_vkQueueFlushCommandsGOOGLE, sizeof(uint32_t)); streamPtr += sizeof(uint32_t);
36memcpy(streamPtr, &packetSize_vkQueueFlushCommandsGOOGLE, sizeof(uint32_t)); streamPtr += sizeof(uint32_t);
37memcpy(streamPtr, &seqno, sizeof(uint32_t)); streamPtr += sizeof(uint32_t);
38uint64_t cgen_var_1407;
39*&cgen_var_1407 = get_host_u64_VkQueue((*&local_queue));
40memcpy(*streamPtrPtr, (uint64_t*)&cgen_var_1407, 1 * 8);
41*streamPtrPtr += 1 * 8;
42uint64_t cgen_var_1408;
43*&cgen_var_1408 = get_host_u64_VkCommandBuffer((*&local_commandBuffer));
44memcpy(*streamPtrPtr, (uint64_t*)&cgen_var_1408, 1 * 8);
45*streamPtrPtr += 1 * 8;
46memcpy(*streamPtrPtr, (VkDeviceSize*)&local_dataSize, sizeof(VkDeviceSize));
47*streamPtrPtr += sizeof(VkDeviceSize);
48
49MESA_TRACE_SCOPE("vkQueueFlush large xfer");
50stream->flush();
51stream->writeLarge(local_pData, dataSize);
52
53++encodeCount;;
54if (0 == encodeCount % POOL_CLEAR_INTERVAL)
55{
56    pool->freeAll();
57    stream->clearPool();
58}
59