Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 30) sorted by relevance

12

/oneTBB/test/common/
H A Dutils_report.h78 void Report ( const char* msg ) { in Report()
79 printf( "%s", msg ); in Report()
82 OutputDebugStringA(msg); in Report()
113 char msg[MAX_TRACE_SIZE]; in trace() local
122 int len = vsnprintf(msg, MAX_TRACE_SIZE, msg_fmt, argptr); in trace()
125 msg[len] = '\n'; in trace()
126 msg[len + 1] = 0; in trace()
128 m_reporter.Report(msg); in trace()
H A Dtest_join_node_multiple_predecessors.h83 std::tuple<continue_msg, continue_msg, continue_msg> msg; in run_and_check() local
91 (qn.try_get(msg) == expected), in run_and_check()
/oneTBB/include/oneapi/tbb/detail/
H A D_config.h413 #define __TBB_DEPRECATED_MSG(msg) [[deprecated(msg)]] argument
416 #define __TBB_DEPRECATED_MSG(msg) __declspec(deprecated(msg)) argument
419 #define __TBB_DEPRECATED_MSG(msg) __attribute__((deprecated(msg))) argument
425 #define __TBB_DEPRECATED_MSG(msg) argument
433 #define __TBB_DEPRECATED_VERBOSE_MSG(msg) __TBB_DEPRECATED_MSG(msg) argument
436 #define __TBB_DEPRECATED_VERBOSE_MSG(msg) argument
H A D_flow_graph_cache_impl.h103 bool msg = false; in get_item() local
116 msg = src->try_get( v ); in get_item()
118 if (msg == false) { in get_item()
125 } while ( msg == false ); in get_item()
126 return msg; in get_item()
161 bool msg = false; in try_reserve() local
175 msg = pred->try_reserve( v ); in try_reserve()
177 if (msg == false) { in try_reserve()
186 } while ( msg == false ); in try_reserve()
188 return msg; in try_reserve()
H A D_exception.h71 unsafe_wait(const char* msg) : std::runtime_error(msg) {} in unsafe_wait() argument
/oneTBB/test/conformance/
H A Dconformance_sequencer_node.cpp143 function_node<message, message> process(g, unlimited, [] (message msg) { in __anona3025c380302() argument
144 msg.data++; in __anona3025c380302()
145 return msg; in __anona3025c380302()
151 function_node<message> writer(g, tbb::flow::serial, [&] (const message& msg) { in __anona3025c380402() argument
152 …CHECK_MESSAGE((msg.id == counter++), "The data is passed to the successor node in the exact same o… in __anona3025c380402()
159 message msg = {i, 0}; variable
160 process.try_put(msg);
H A Dconformance_flowgraph.h54 message(const message& msg) : data(msg.data) {}; in message()
57 message& operator=(const message& msg) {
58 this->data = msg.data;
66 bool operator==(const message& msg) const {
67 return data == msg.data;
137 std::size_t operator()(seq_message msg) { in operator()
138 return msg.id; in operator()
764 [&](const int& msg) { in test_with_reserving_join_node_class()
766 int result = int((msg >> 2) / 4); in test_with_reserving_join_node_class()
/oneTBB/examples/parallel_for/tachyon/src/
H A Dutil.cpp158 void rtbomb(const char* msg) { in rtbomb() argument
159 rt_ui_message(MSG_ERR, msg); in rtbomb()
166 void rtmesg(const char* msg) { in rtmesg() argument
167 rt_ui_message(MSG_0, msg); in rtmesg()
H A Dui.cpp70 void rt_ui_message(int level, const char *msg) { in rt_ui_message() argument
73 fprintf(stderr, "%s\n", msg); in rt_ui_message()
78 rt_static_ui_message(level, msg); in rt_ui_message()
H A Dapi.cpp102 rpcmsg msg; in rt_initialize() local
111 msg.type = 1; /* setup a ping message */ in rt_initialize()
/oneTBB/examples/common/gui/
H A Dwinvideo.hpp231 MSG msg; in loop_once() local
232 if (PeekMessage(&msg, nullptr, 0, 0, PM_REMOVE)) { in loop_once()
233 if (msg.message == WM_QUIT) { in loop_once()
237 if (!hAccelTable || !TranslateAccelerator(msg.hwnd, hAccelTable, &msg)) { in loop_once()
238 TranslateMessage(&msg); in loop_once()
239 DispatchMessage(&msg); in loop_once()
/oneTBB/test/tbb/
H A Dtest_limiter_node.cpp99 bool msg = my_lim.try_put( T(i) ); in operator ()() local
100 if ( msg == true ) in operator ()()
118 bool msg = my_lim.try_put( T(local_accept_count) ); in operator ()() local
119 if ( msg == true ) { in operator ()()
198 bool msg = lim.try_put( T(j) ); in test_serial() local
199 CHECK_MESSAGE( (( j < i && msg == true ) || ( j >= i && msg == false )), "" ); in test_serial()
213 bool msg = lim.try_put( T(j) ); in test_serial() local
214 CHECK_MESSAGE( (( j < i && msg == true ) || ( j >= i && msg == false )), "" ); in test_serial()
215 if ( msg == false ) { in test_serial()
217 msg = lim.try_put( T(j) ); in test_serial()
[all …]
H A Dtest_sequencer_node.cpp65 bool msg = my_q.try_put( T(j) ); in operator ()() local
66 CHECK_MESSAGE( msg == true, "" ); in operator ()()
173 bool msg = my_s1.try_put( T(i) ); in operator ()() local
284 bool msg = s.try_put( T(i) ); in test_serial() local
285 CHECK_MESSAGE( msg == true, "" ); in test_serial()
306 bool msg = s2.try_put( T(i) ); in test_serial() local
307 CHECK_MESSAGE( msg == true, "" ); in test_serial()
331 bool msg = s3.try_put( T(i) ); in test_serial() local
332 CHECK_MESSAGE( msg == true, "" ); in test_serial()
367 bool msg = s6.try_put( T(i) ); in test_serial() local
[all …]
H A Dtest_buffer_node.cpp54 bool msg = my_b.try_put( T(N*i + j) ); in operator ()() local
55 CHECK_MESSAGE( msg == true, "" ); in operator ()()
337 bool msg = b.try_put( T(i) ); in test_serial() local
338 CHECK_MESSAGE( msg == true, "" ); in test_serial()
357 bool msg = b.try_put( T(i) ); in test_serial() local
358 CHECK_MESSAGE( msg == true, "" ); in test_serial()
389 bool msg = b.try_put( T(i) ); in test_serial() local
390 CHECK_MESSAGE( msg == true, "" ); in test_serial()
H A Dtest_queue_node.cpp74 bool msg = my_q.try_put( T(N*i + j) ); in operator ()() local
75 CHECK_MESSAGE( msg == true, "" ); in operator ()()
381 bool msg = q.try_put( T(i) ); in test_serial() local
382 CHECK_MESSAGE( msg == true, "" ); in test_serial()
399 bool msg = q.try_put( T(i) ); in test_serial() local
400 CHECK_MESSAGE( msg == true, "" ); in test_serial()
430 bool msg = q.try_put( T(i) ); in test_serial() local
431 CHECK_MESSAGE( msg == true, "" ); in test_serial()
H A Dtest_split_node.cpp303 function_node<msg_t, msg_t> f1(g, unlimited, [](msg_t msg) { return msg; } ); in test_follows_and_precedes_api() argument
324 msg_t msg(1, 2.2f, 3.3); in test_follows_and_precedes_api() local
325 f1.try_put(msg); in test_follows_and_precedes_api()
326 f2.try_put(msg); in test_follows_and_precedes_api()
327 f3.try_put(msg); in test_follows_and_precedes_api()
H A Dtest_global_control.cpp135 const char* msg = e.what(); in TestException() local
136 REQUIRE((msg && std::strlen(msg) != 0)); in TestException()
H A Dtest_flow_graph_priorities.cpp90 T operator()( const T& msg ) const { in operator ()()
92 return msg; in operator ()()
94 void operator()( int msg, multi_node::output_ports_type& op ) const { in operator ()()
96 std::get<0>(op).try_put( msg ); in operator ()()
433 continue_msg operator()( const continue_msg& msg ) const { in operator ()()
435 return msg; in operator ()()
H A Dtest_priority_queue_node.cpp60 bool msg = my_q.try_put( T(N*i + j) ); in operator ()() local
61 CHECK_MESSAGE( msg == true, "" ); in operator ()()
H A Dtest_indexer_node.cpp566 tagged_msg_t msg; in check_edge() local
567 bool is_get_succeeded = buf.try_get(msg); in check_edge()
570 CHECK_MESSAGE( ((tbb::flow::cast_to<input_t>(msg) == input_value)), "Wrong item value"); in check_edge()
H A Dtest_continue_node.cpp304 auto pass_through = [](const msg_t& msg) { return msg; }; in test_follows_and_precedes_api() argument
/oneTBB/examples/graph/fgbzip2/
H A Dbzlib_private.hpp111 #define AssertD(cond, msg) \ argument
114 fprintf(stderr, "\n\nlibbzip2(debug build): internal error\n\t%s\n", msg); \
119 #define AssertD(cond, msg) /* */ argument
137 #define AssertD(cond, msg) \ argument
/oneTBB/src/tbb/
H A Dexception.cpp71 #define PRINT_ERROR_AND_ABORT(exc_name, msg) \ argument
73 "if exception handling had not been disabled. Aborting.\n", exc_name, msg); \
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DGUI_Thread.rst101 LRESULT CALLBACK WndProc(HWND hWnd, UINT msg, WPARAM wParam, LPARAM lParam) {
102 switch(msg) {
113 return DefWindowProc(hWnd, msg, wParam, lParam);
129 return DefWindowProc( hWnd, msg, wParam, lParam );
/oneTBB/src/tbbmalloc/
H A Dfrontend.cpp388 const char *msg = "Possible double free or heap corruption."; in checkFreePrecond() local
395 MALLOC_ASSERT(allocatedCount>0, msg); in checkFreePrecond()
398 MALLOC_ASSERT((uintptr_t)object - (uintptr_t)this >= sizeof(Block), msg); in checkFreePrecond()
400 MALLOC_ASSERT(object<=bumpPtr, msg); in checkFreePrecond()
407 && (!bumpPtr || object>bumpPtr), msg); in checkFreePrecond()
410 MALLOC_ASSERT(toFree != freeList, msg); in checkFreePrecond()
414 MALLOC_ASSERT(toFree != publicFreeList.load(std::memory_order_relaxed), msg); in checkFreePrecond()

12