Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 1 | // |
| 2 | // Copyright © 2019 Arm Ltd. All rights reserved. |
| 3 | // SPDX-License-Identifier: MIT |
| 4 | // |
| 5 | |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 6 | #include "../../../src/profiling/PacketVersionResolver.hpp" |
| 7 | #include "../../../src/profiling/PeriodicCounterSelectionCommandHandler.hpp" |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 8 | #include "CommandFileParser.hpp" |
| 9 | #include "CommandLineProcessor.hpp" |
| 10 | #include "GatordMockService.hpp" |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 11 | #include "PeriodicCounterCaptureCommandHandler.hpp" |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 12 | #include "PeriodicCounterSelectionResponseHandler.hpp" |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 13 | |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 14 | #include <iostream> |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 15 | #include <string> |
| 16 | |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 17 | int main(int argc, char* argv[]) |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 18 | { |
| 19 | // Process command line arguments |
| 20 | armnn::gatordmock::CommandLineProcessor cmdLine; |
| 21 | if (!cmdLine.ProcessCommandLine(argc, argv)) |
| 22 | { |
| 23 | return EXIT_FAILURE; |
| 24 | } |
| 25 | |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 26 | armnn::profiling::PacketVersionResolver packetVersionResolver; |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 27 | // Create the Command Handler Registry |
| 28 | armnn::profiling::CommandHandlerRegistry registry; |
| 29 | |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 30 | // This functor will receive back the selection response packet. |
| 31 | armnn::gatordmock::PeriodicCounterSelectionResponseHandler periodicCounterSelectionResponseHandler( |
| 32 | 4, packetVersionResolver.ResolvePacketVersion(4).GetEncodedValue()); |
| 33 | // This functor will receive the counter data. |
| 34 | armnn::gatordmock::PeriodicCounterCaptureCommandHandler counterCaptureCommandHandler( |
| 35 | 0, packetVersionResolver.ResolvePacketVersion(0).GetEncodedValue()); |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 36 | |
| 37 | // Register different derived functors |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 38 | registry.RegisterFunctor(&periodicCounterSelectionResponseHandler); |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 39 | registry.RegisterFunctor(&counterCaptureCommandHandler); |
| 40 | |
| 41 | armnn::gatordmock::GatordMockService mockService(registry, cmdLine.IsEchoEnabled()); |
| 42 | |
| 43 | if (!mockService.OpenListeningSocket(cmdLine.GetUdsNamespace())) |
| 44 | { |
| 45 | return EXIT_FAILURE; |
| 46 | } |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 47 | std::cout << "Bound to UDS namespace: \\0" << cmdLine.GetUdsNamespace() << std::endl; |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 48 | |
| 49 | // Wait for a single connection. |
| 50 | if (-1 == mockService.BlockForOneClient()) |
| 51 | { |
| 52 | return EXIT_FAILURE; |
| 53 | } |
Colm Donelan | b682d84 | 2019-10-16 12:24:20 +0100 | [diff] [blame] | 54 | std::cout << "Client connection established." << std::endl; |
Colm Donelan | a21620d | 2019-10-11 13:09:49 +0100 | [diff] [blame] | 55 | |
| 56 | // Send receive the strweam metadata and send connection ack. |
| 57 | if (!mockService.WaitForStreamMetaData()) |
| 58 | { |
| 59 | return EXIT_FAILURE; |
| 60 | } |
| 61 | mockService.SendConnectionAck(); |
| 62 | |
| 63 | // Prepare to receive data. |
| 64 | mockService.LaunchReceivingThread(); |
| 65 | |
| 66 | // Process the SET and WAIT command from the file. |
| 67 | armnn::gatordmock::CommandFileParser commandLineParser; |
| 68 | commandLineParser.ParseFile(cmdLine.GetCommandFile(), mockService); |
| 69 | |
| 70 | // Once we've finished processing the file wait for the receiving thread to close. |
| 71 | mockService.WaitForReceivingThread(); |
| 72 | |
| 73 | return EXIT_SUCCESS; |
| 74 | } |