1 /****************************************************************************
2 * Copyright (C) 2016 Intel Corporation. All Rights Reserved.
4 * Permission is hereby granted, free of charge, to any person obtaining a
5 * copy of this software and associated documentation files (the "Software"),
6 * to deal in the Software without restriction, including without limitation
7 * the rights to use, copy, modify, merge, publish, distribute, sublicense,
8 * and/or sell copies of the Software, and to permit persons to whom the
9 * Software is furnished to do so, subject to the following conditions:
11 * The above copyright notice and this permission notice (including the next
12 * paragraph) shall be included in all copies or substantial portions of the
15 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
18 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
25 * @brief Event handler interface. auto-generated file
29 * Generation Command Line:
30 * ${'\n* '.join(cmdline)}
32 ******************************************************************************/
35 #include "common/os.h"
36 #include "${event_header}"
42 //////////////////////////////////////////////////////////////////////////
43 /// EventHandlerFile - interface for handling events.
44 //////////////////////////////////////////////////////////////////////////
45 class EventHandlerFile : public EventHandler
48 EventHandlerFile(uint32_t id)
52 DWORD pid = GetCurrentProcessId();
53 TCHAR procname[MAX_PATH];
54 GetModuleFileName(NULL, procname, MAX_PATH);
55 const char* pBaseName = strrchr(procname, '\\');
56 std::stringstream outDir;
57 outDir << KNOB_DEBUG_OUTPUT_DIR << pBaseName << "_" << pid << std::ends;
58 CreateDirectory(outDir.str().c_str(), NULL);
61 // There could be multiple threads creating thread pools. We
62 // want to make sure they are uniquly identified by adding in
63 // the creator's thread id into the filename.
64 sprintf(buf, "%s\\ar_event%d_%d.bin", outDir.str().c_str(), GetCurrentThreadId(), id);
65 mFilename = std::string(buf);
68 // There could be multiple threads creating thread pools. We
69 // want to make sure they are uniquly identified by adding in
70 // the creator's thread (process) id into the filename.
71 // Assumes a 1:1 thread:LWP mapping as in linux.
72 sprintf(buf, "%s/ar_event%d_%d.bin", "/tmp", GetCurrentProcessId(), id);
73 mFilename = std::string(buf);
77 virtual ~EventHandlerFile()
82 //////////////////////////////////////////////////////////////////////////
83 /// @brief Flush buffer to file.
88 if (mBufOffset == mHeaderBufOffset)
90 // Nothing to flush. Only header has been generated.
95 file.open(mFilename, std::ios::out | std::ios::app | std::ios::binary);
99 SWR_INVALID("ArchRast: Could not open event file!");
103 file.write((char*)mBuffer, mBufOffset);
107 mHeaderBufOffset = 0; // Reset header offset so its no longer considered.
112 //////////////////////////////////////////////////////////////////////////
113 /// @brief Write event and its payload to the memory buffer.
114 void Write(uint32_t eventId, const char* pBlock, uint32_t size)
116 if ((mBufOffset + size + sizeof(eventId)) > mBufferSize)
120 // Don't corrupt what's already in the buffer?
121 /// @todo Maybe add corrupt marker to buffer here in case we can open file in future?
126 memcpy(&mBuffer[mBufOffset], (char*)&eventId, sizeof(eventId));
127 mBufOffset += sizeof(eventId);
128 memcpy(&mBuffer[mBufOffset], pBlock, size);
132 % for name in protos['event_names']:
133 //////////////////////////////////////////////////////////////////////////
134 /// @brief Handle ${name} event
135 virtual void Handle(const ${name}& event)
137 % if protos['events'][name]['num_fields'] == 0:
138 Write(${protos['events'][name]['event_id']}, (char*)&event.data, 0);
140 Write(${protos['events'][name]['event_id']}, (char*)&event.data, sizeof(event.data));
145 //////////////////////////////////////////////////////////////////////////
146 /// @brief Everything written to buffer this point is the header.
147 virtual void MarkHeader()
149 mHeaderBufOffset = mBufOffset;
152 std::string mFilename;
154 static const uint32_t mBufferSize = 1024;
155 uint8_t mBuffer[mBufferSize];
156 uint32_t mBufOffset{0};
157 uint32_t mHeaderBufOffset{0};