Showing the changes to src/vm/channel.cpp (1 of 16 files). Show all
Unified · Split
| @@ -44,13 +44,13 @@ vm_channel_t::vm_channel_t( · 43 unmodified lines | |||
| 44 | if (buffer_len > 0) | 44 | if (buffer_len > 0) |
| 45 | _data_buffer = new vm_array_t{ td, buffer_len }; | 45 | _data_buffer = new vm_array_t{ td, buffer_len }; |
| 46 | 46 | ||
| 47 | debug::log_msg(debug::component_trace_t::memory, debug::log_level_t::debug, "init: vm channel\n"); | 47 | debug::log_msg(debug::component_trace_t::memory, debug::log_level_t::debug, "init: vm channel"); |
| 48 | } | 48 | } |
| 49 | 49 | ||
| 50 | vm_channel_t::~vm_channel_t() | 50 | vm_channel_t::~vm_channel_t() |
| 51 | { | 51 | { |
| 52 | dec_ref_count_and_free(_data_buffer); | 52 | dec_ref_count_and_free(_data_buffer); |
| 53 | debug::log_msg(debug::component_trace_t::memory, debug::log_level_t::debug, "destroy: vm channel\n"); | 53 | debug::log_msg(debug::component_trace_t::memory, debug::log_level_t::debug, "destroy: vm channel"); |
| 54 | } | 54 | } |
| 55 | 55 | ||
| 56 | std::shared_ptr<const type_descriptor_t> vm_channel_t::get_data_type() const | 56 | std::shared_ptr<const type_descriptor_t> vm_channel_t::get_data_type() const |
| @@ -88,7 +88,7 @@ bool vm_channel_t::send_data(vm_channel_request_t &send_request) · 31 unmodified lines | |||
| 88 | } | 88 | } |
| 89 | 89 | ||
| 90 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 90 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 91 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: queue: %d\n", send_request.thread_id); | 91 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: queue: %d", send_request.thread_id); |
| 92 | 92 | ||
| 93 | _data_senders.emplace_back(std::move(send_request)); | 93 | _data_senders.emplace_back(std::move(send_request)); |
| 94 | return false; | 94 | return false; |
| @@ -122,7 +122,7 @@ bool vm_channel_t::send_data(vm_channel_request_t &send_request) · 27 unmodified lines | |||
| 122 | data_lock.unlock(); | 122 | data_lock.unlock(); |
| 123 | 123 | ||
| 124 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 124 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 125 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: %d %d\n", send_request.thread_id, receiver.thread_id); | 125 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: %d %d", send_request.thread_id, receiver.thread_id); |
| 126 | 126 | ||
| 127 | receiver.request_handled_callback(*this); | 127 | receiver.request_handled_callback(*this); |
| 128 | 128 | ||
| @@ -159,7 +159,7 @@ bool vm_channel_t::receive_data(vm_channel_request_t &receive_request) · 30 unmodified lines | |||
| 159 | } | 159 | } |
| 160 | 160 | ||
| 161 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 161 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 162 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: queue: %d\n", receive_request.thread_id); | 162 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: queue: %d", receive_request.thread_id); |
| 163 | 163 | ||
| 164 | _data_receivers.emplace_back(std::move(receive_request)); | 164 | _data_receivers.emplace_back(std::move(receive_request)); |
| 165 | return false; | 165 | return false; |
| @@ -201,7 +201,7 @@ bool vm_channel_t::receive_data(vm_channel_request_t &receive_request) · 35 unmodified lines | |||
| 201 | _data_transfer(receive_request.data, sender.data, _data_type.get()); | 201 | _data_transfer(receive_request.data, sender.data, _data_type.get()); |
| 202 | 202 | ||
| 203 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 203 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 204 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: %d %d\n", receive_request.thread_id, sender.thread_id); | 204 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: %d %d", receive_request.thread_id, sender.thread_id); |
| 205 | } | 205 | } |
| 206 | 206 | ||
| 207 | // Release channel and pending request lock after data transfer | 207 | // Release channel and pending request lock after data transfer |
| @@ -235,7 +235,7 @@ void vm_channel_t::cancel_request(uint32_t thread_id) · 27 unmodified lines | |||
| 235 | } | 235 | } |
| 236 | 236 | ||
| 237 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 237 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 238 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: cancel: request: %d\n", thread_id); | 238 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: cancel: request: %d", thread_id); |
| 239 | } | 239 | } |
| 240 | 240 | ||
| 241 | word_t vm_channel_t::get_buffer_size() const | 241 | word_t vm_channel_t::get_buffer_size() const |
| @@ -267,7 +267,7 @@ bool vm_channel_t::try_send_to_buffer(vm_channel_request_t &send_request) · 25 unmodified lines | |||
| 267 | send_request.request_mutex.get().pending_request = false; | 267 | send_request.request_mutex.get().pending_request = false; |
| 268 | 268 | ||
| 269 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 269 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 270 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: buffer: %d\n", send_request.thread_id); | 270 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: send: buffer: %d", send_request.thread_id); |
| 271 | 271 | ||
| 272 | return true; | 272 | return true; |
| 273 | } | 273 | } |
| @@ -294,7 +294,7 @@ bool vm_channel_t::try_receive_from_buffer(vm_channel_request_t &receive_request · 20 unmodified lines | |||
| 294 | receive_request.request_mutex.get().pending_request = false; | 294 | receive_request.request_mutex.get().pending_request = false; |
| 295 | 295 | ||
| 296 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) | 296 | if (debug::is_component_tracing_enabled<debug::component_trace_t::channel>()) |
| 297 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: buffer: %d\n", receive_request.thread_id); | 297 | debug::log_msg(debug::component_trace_t::channel, debug::log_level_t::debug, "channel: receive: buffer: %d", receive_request.thread_id); |
| 298 | 298 | ||
| 299 | return true; | 299 | return true; |
| 300 | } | 300 | } |