|  | /* | 
|  | Copyright (c) 2014-2015 Intel Corporation.  All Rights Reserved. | 
|  |  | 
|  | Redistribution and use in source and binary forms, with or without | 
|  | modification, are permitted provided that the following conditions | 
|  | are met: | 
|  |  | 
|  | * Redistributions of source code must retain the above copyright | 
|  | notice, this list of conditions and the following disclaimer. | 
|  | * Redistributions in binary form must reproduce the above copyright | 
|  | notice, this list of conditions and the following disclaimer in the | 
|  | documentation and/or other materials provided with the distribution. | 
|  | * Neither the name of Intel Corporation nor the names of its | 
|  | contributors may be used to endorse or promote products derived | 
|  | from this software without specific prior written permission. | 
|  |  | 
|  | THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | 
|  | "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | 
|  | LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | 
|  | A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | 
|  | HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | 
|  | SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | 
|  | LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | 
|  | DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | 
|  | THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 
|  | (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | 
|  | OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 
|  | */ | 
|  |  | 
|  |  | 
|  | #include "offload_trace.h" | 
|  | #include <stdio.h> | 
|  | #include <stdlib.h> | 
|  | #include <stdint.h> | 
|  | #include <sstream> | 
|  | #include "liboffload_error_codes.h" | 
|  |  | 
|  | extern const char *prefix; | 
|  |  | 
|  | #if !HOST_LIBRARY | 
|  | extern int mic_index; | 
|  | #endif | 
|  |  | 
|  | // The debug routines | 
|  |  | 
|  | static const char * offload_stage(std::stringstream &ss, | 
|  | int offload_number, | 
|  | const char *tag, | 
|  | const char *text, | 
|  | bool print_tag) | 
|  | { | 
|  | ss << "[" << report_get_message_str(c_report_offload) << "]"; | 
|  | #if HOST_LIBRARY | 
|  | ss << " [" << prefix << "]"; | 
|  | if (print_tag) { | 
|  | ss << "  [" << report_get_message_str(c_report_tag); | 
|  | ss << " " << offload_number << "]"; | 
|  | } | 
|  | else { | 
|  | ss << "         "; | 
|  | } | 
|  | ss << " [" << tag << "]"; | 
|  | ss << "           " << text; | 
|  | #else | 
|  | ss << " [" << prefix << " " << mic_index << "]"; | 
|  | if (print_tag) { | 
|  | ss << " [" << report_get_message_str(c_report_tag); | 
|  | ss << " " << offload_number << "]"; | 
|  | } | 
|  | ss << " [" << tag << "]"; | 
|  | ss << "           " << text; | 
|  | #endif | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static const char * offload_message_2str(std::stringstream &ss, | 
|  | int offload_number, | 
|  | const char *tag, | 
|  | const char *text) | 
|  | { | 
|  | ss << "[" << report_get_message_str(c_report_offload) << "]"; | 
|  | ss << " [" << prefix << "]"; | 
|  | ss << "  [" << report_get_message_str(c_report_tag); | 
|  | ss << " " << offload_number << "]"; | 
|  | ss << " [" << tag << "]"; | 
|  | ss << "          " << text; | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | void offload_stage_print(int stage, int offload_number, ...) | 
|  | { | 
|  | std::string buf; | 
|  | std::stringstream ss; | 
|  | char const *str1; | 
|  | char const *str2; | 
|  | va_list va_args; | 
|  | va_start(va_args, offload_number); | 
|  | va_arg(va_args, char*); | 
|  |  | 
|  | switch (stage) { | 
|  | case c_offload_start: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_start); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_init: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_init); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | ss << " " << report_get_message_str(c_report_logical_card); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " = " << report_get_message_str(c_report_physical_card); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | break; | 
|  | case c_offload_register: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_register); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_init_func: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_init_func); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << ": " << va_arg(va_args, char*); | 
|  | break; | 
|  | case c_offload_create_buf_host: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_create_buf_host); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << ": base=0x" << std::hex << va_arg(va_args, uint64_t); | 
|  | ss << " length=" << std::dec << va_arg(va_args, uint64_t); | 
|  | break; | 
|  | case c_offload_create_buf_mic: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_create_buf_mic); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << ": size=" << va_arg(va_args, uint64_t); | 
|  | ss << " offset=" << va_arg(va_args, int); | 
|  | if (va_arg(va_args,int)) | 
|  | ss << " (2M page)"; | 
|  | break; | 
|  | case c_offload_send_pointer_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_send_pointer_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_sent_pointer_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_sent_pointer_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << " " << va_arg(va_args, uint64_t); | 
|  | break; | 
|  | case c_offload_gather_copyin_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_gather_copyin_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_copyin_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_copyin_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << " " << va_arg(va_args, uint64_t) << " "; | 
|  | break; | 
|  | case c_offload_compute: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_compute); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_receive_pointer_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_receive_pointer_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_received_pointer_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_received_pointer_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << " " << va_arg(va_args, uint64_t); | 
|  | break; | 
|  | case c_offload_start_target_func: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_start_target_func); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << ": " << va_arg(va_args, char*); | 
|  | break; | 
|  | case c_offload_var: | 
|  | str1 = report_get_message_str(c_report_var); | 
|  | offload_stage(ss, offload_number, str1, "  ", true); | 
|  | va_arg(va_args, int); | 
|  | ss << va_arg(va_args, char*); | 
|  | ss << " " << " " << va_arg(va_args, char*); | 
|  | break; | 
|  | case c_offload_scatter_copyin_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_scatter_copyin_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_gather_copyout_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_gather_copyout_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_scatter_copyout_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_scatter_copyout_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_copyout_data: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_copyout_data); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | ss << "   " << va_arg(va_args, uint64_t); | 
|  | break; | 
|  | case c_offload_signal: | 
|  | { | 
|  | uint64_t  *signal; | 
|  | str1 = report_get_message_str(c_report_state_signal); | 
|  | str2 = report_get_message_str(c_report_signal); | 
|  | offload_message_2str(ss, offload_number, str1, str2); | 
|  | signal = va_arg(va_args, uint64_t*); | 
|  | if (signal) | 
|  | ss << " 0x" << std::hex << *signal; | 
|  | else | 
|  | ss << " none"; | 
|  | } | 
|  | break; | 
|  | case c_offload_stream: | 
|  | { | 
|  | int64_t  stream; | 
|  | str1 = report_get_message_str(c_report_state_stream); | 
|  | str2 = report_get_message_str(c_report_stream); | 
|  | offload_message_2str(ss, offload_number, str1, str2); | 
|  | stream = va_arg(va_args, int64_t); | 
|  | if (stream) | 
|  | ss << " 0x" << std::hex << stream; | 
|  | else | 
|  | ss << " none"; | 
|  | } | 
|  | break; | 
|  | case c_offload_wait: | 
|  | { | 
|  | int count; | 
|  | OffloadWaitKind kind; | 
|  | uint64_t  **signal; | 
|  | kind = (enum OffloadWaitKind) va_arg(va_args, int); | 
|  | // kind ==  c_offload_wait_signal for signal; | 
|  | // other kinds are for stream | 
|  | if (kind == c_offload_wait_signal) { | 
|  | str1 = report_get_message_str(c_report_state_signal); | 
|  | } | 
|  | else { | 
|  | str1 = report_get_message_str(c_report_state_stream); | 
|  | } | 
|  | str2 = report_get_message_str(c_report_wait); | 
|  | offload_message_2str(ss, offload_number, str1, str2); | 
|  | count = va_arg(va_args, int); | 
|  | signal = va_arg(va_args, uint64_t**); | 
|  | if (count) { | 
|  | if (kind == c_offload_wait_signal) { | 
|  | while (count) { | 
|  | ss << " " << std::hex << signal[count-1]; | 
|  | count--; | 
|  | } | 
|  | } | 
|  | else if (kind == c_offload_wait_stream) { | 
|  | ss << signal; | 
|  | } | 
|  | else { | 
|  | ss << " all"; | 
|  | } | 
|  | } | 
|  | else | 
|  | ss << " none"; | 
|  | } | 
|  | break; | 
|  | case c_offload_unregister: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_unregister); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_destroy: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_destroy); | 
|  | offload_stage(ss, offload_number, str1, str2, true); | 
|  | break; | 
|  | case c_offload_myoinit: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myoinit); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_myoregister: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myoregister); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_myofini: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myofini); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_mic_myo_shared: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_mic_myo_shared); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | ss << " " << va_arg(va_args, char*); | 
|  | break; | 
|  | case c_offload_mic_myo_fptr: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_mic_myo_fptr); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | ss << " " << va_arg(va_args, char*); | 
|  | break; | 
|  | case c_offload_myosharedmalloc: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedmalloc); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | break; | 
|  | case c_offload_myosharedfree: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedfree); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_myosharedalignedmalloc: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedalignedmalloc); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | break; | 
|  | case c_offload_myosharedalignedfree: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedalignedfree); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | break; | 
|  | case c_offload_myoacquire: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myoacquire); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_myorelease: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myorelease); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | break; | 
|  | case c_offload_myosupportsfeature: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosupportsfeature); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | break; | 
|  | case c_offload_myosharedarenacreate: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedarenacreate); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, unsigned int); | 
|  | break; | 
|  | case c_offload_myosharedalignedarenamalloc: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedalignedarenamalloc); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | break; | 
|  | case c_offload_myosharedalignedarenafree: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myosharedalignedarenafree); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | ss << " " << va_arg(va_args, size_t); | 
|  | break; | 
|  | case c_offload_myoarenaacquire: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myoarenaacquire); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | break; | 
|  | case c_offload_myoarenarelease: | 
|  | str1 = report_get_message_str(c_report_state); | 
|  | str2 = report_get_message_str(c_report_myoarenarelease); | 
|  | offload_stage(ss, offload_number, str1, str2, false); | 
|  | va_arg(va_args, char*); | 
|  | ss << " " << va_arg(va_args, int); | 
|  | break; | 
|  | default: | 
|  | LIBOFFLOAD_ERROR(c_report_unknown_trace_node); | 
|  | abort(); | 
|  | } | 
|  | ss << "\n"; | 
|  | buf = ss.str(); | 
|  | fprintf(stdout, buf.data()); | 
|  | fflush(stdout); | 
|  |  | 
|  | va_end(va_args); | 
|  | return; | 
|  | } |