| /oneTBB/src/tbb/ |
| H A D | rml_tbb.cpp | 25 namespace rml { namespace 37 …::rml::factory::status_type __TBB_make_rml_server( rml::tbb_factory& f, rml::tbb_server*& server, … 38 void __TBB_call_with_my_server_info( ::rml::server_info_callback_t cb, void* arg ); 61 const ::rml::versioned_object::version_type CLIENT_VERSION = 2; 67 …::rml::factory::status_type __RML_open_factory ( ::rml::factory&, ::rml::versioned_object::version… 68 void __RML_close_factory( ::rml::factory& f ); 72 ::rml::factory::status_type FACTORY::open() { in open() 103 ::rml::factory::status_type FACTORY::make_server( SERVER*& s, CLIENT& c) { in make_server()
|
| H A D | rml_tbb.h | 28 namespace rml { 35 class tbb_server: public ::rml::server { 53 class tbb_client: public ::rml::client { 62 class tbb_factory: public ::rml::factory { 68 void (*my_call_with_server_info_routine)( ::rml::server_info_callback_t cb, void* arg ); 71 typedef ::rml::versioned_object::version_type version_type;
|
| H A D | governor.h | 58 static rml::tbb_factory theRMLServerFactory; 72 static rml::tbb_server* create_rml_server ( rml::tbb_client& ); 133 static bool does_client_join_workers (const rml::tbb_client &client);
|
| H A D | governor.cpp | 50 namespace rml { namespace 90 rml::tbb_server* governor::create_rml_server ( rml::tbb_client& client ) { in create_rml_server() 91 rml::tbb_server* server = nullptr; in create_rml_server() 93 ::rml::factory::status_type status = theRMLServerFactory.make_server( server, client ); in create_rml_server() 94 if( status != ::rml::factory::st_success ) { in create_rml_server() 101 server = rml::make_private_server( client ); in create_rml_server() 113 bool governor::does_client_join_workers(const rml::tbb_client &client) { in does_client_join_workers() 262 ::rml::factory::status_type res = theRMLServerFactory.open(); in initialize_rml_factory() 263 UsePrivateRML = res != ::rml::factory::st_success; in initialize_rml_factory()
|
| H A D | rml_base.h | 34 namespace rml { 64 typedef ::rml::job job; 99 typedef ::rml::job job;
|
| H A D | thread_dispatcher.h | 37 class thread_dispatcher : no_copy, rml::tbb_client { 62 ::rml::job* create_one_job() override; 99 rml::tbb_server* my_server{nullptr};
|
| H A D | private_server.cpp | 33 namespace rml { namespace 35 using rml::internal::thread_monitor; 201 void register_external_thread ( ::rml::server::execution_resource_t& ) override {} in register_external_thread() 202 void unregister_external_thread ( ::rml::server::execution_resource_t ) override {} in unregister_external_thread() 267 ::rml::job& j = *my_client.create_one_job(); in run()
|
| H A D | assert_impl.h | 34 namespace rml { namespace internal {
|
| H A D | main.cpp | 40 rml::tbb_factory governor::theRMLServerFactory;
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_pools.cpp | 98 rml::MemoryPool *pool; in TestPoolReset() 176 rml::MemoryPool *pool; in TestSharedPool() 298 rml::MemoryPool *pool; in TestTooSmallBuffer() 339 rml::MemoryPool *pool; 361 rml::MemoryPool *pool; 374 rml::MemoryPool *pool; 403 rml::MemoryPool *pool; in TestFixedBufferPool() 535 rml::MemoryPool *pool; in TestPoolKeepTillDestroy() 596 rml::MemoryPool *pool; in TestEntries() 729 rml::MemoryPool *act_pool = rml::pool_identify(objs[id]); in operator ()() [all …]
|
| H A D | test_malloc_whitebox.cpp | 422 rml::MemoryPool *my_mallocPool; 440 rml::MemoryPool *pool1; in TestPools() 441 rml::MemoryPool *pool2; in TestPools() 449 rml::MemoryPool *fixedPool; in TestPools() 455 rml::MemoryPool *mallocPool; in TestPools() 543 rml::internal::ExtMemoryPool *mPool = &((rml::internal::MemoryPool*)mallocPool)->extMemPool; in TestPools() 641 rml::internal::Backend *backend; 665 rml::MemoryPool *mPool; in TestBackend() 667 rml::internal::ExtMemoryPool *ePool = &((rml::internal::MemoryPool*)mPool)->extMemPool; in TestBackend() 1175 …size_t headersSize = sizeof(rml::internal::LargeMemoryBlock)+sizeof(rml::internal::LargeObjectHdr); in operator ()() [all …]
|
| H A D | test_scalable_allocator.cpp | 148 rml::MemPoolPolicy pol(fixedBufGetMem, nullptr, 0, /*fixedSizePool=*/true, in TestSmallFixedSizePool() 150 rml::MemoryPool *pool; in TestSmallFixedSizePool() 153 rml::MemPoolError ret = pool_create_v1((intptr_t)&fixedPool, &pol, &pool); in TestSmallFixedSizePool() 155 if (ret == rml::POOL_OK) { in TestSmallFixedSizePool() 159 …REQUIRE_MESSAGE(ret == rml::NO_MEMORY, "Expected that pool either valid or have no memory to be cr… in TestSmallFixedSizePool()
|
| /oneTBB/src/tbbmalloc/def/ |
| H A D | win32-tbbmalloc.def | 36 ?pool_create@rml@@YAPAVMemoryPool@1@HPBUMemPoolPolicy@1@@Z 37 ?pool_create_v1@rml@@YA?AW4MemPoolError@1@HPBUMemPoolPolicy@1@PAPAVMemoryPool@1@@Z 38 ?pool_destroy@rml@@YA_NPAVMemoryPool@1@@Z 39 ?pool_malloc@rml@@YAPAXPAVMemoryPool@1@I@Z 40 ?pool_free@rml@@YA_NPAVMemoryPool@1@PAX@Z 41 ?pool_reset@rml@@YA_NPAVMemoryPool@1@@Z 42 ?pool_realloc@rml@@YAPAXPAVMemoryPool@1@PAXI@Z 43 ?pool_aligned_realloc@rml@@YAPAXPAVMemoryPool@1@PAXII@Z 44 ?pool_aligned_malloc@rml@@YAPAXPAVMemoryPool@1@II@Z 45 ?pool_identify@rml@@YAPAVMemoryPool@1@PAX@Z [all …]
|
| H A D | win64-tbbmalloc.def | 36 ?pool_create@rml@@YAPEAVMemoryPool@1@_JPEBUMemPoolPolicy@1@@Z 37 ?pool_create_v1@rml@@YA?AW4MemPoolError@1@_JPEBUMemPoolPolicy@1@PEAPEAVMemoryPool@1@@Z 38 ?pool_destroy@rml@@YA_NPEAVMemoryPool@1@@Z 39 ?pool_malloc@rml@@YAPEAXPEAVMemoryPool@1@_K@Z 40 ?pool_free@rml@@YA_NPEAVMemoryPool@1@PEAX@Z 41 ?pool_reset@rml@@YA_NPEAVMemoryPool@1@@Z 42 ?pool_realloc@rml@@YAPEAXPEAVMemoryPool@1@PEAX_K@Z 43 ?pool_aligned_realloc@rml@@YAPEAXPEAVMemoryPool@1@PEAX_K2@Z 44 ?pool_aligned_malloc@rml@@YAPEAXPEAVMemoryPool@1@_K1@Z 45 ?pool_identify@rml@@YAPEAVMemoryPool@1@PEAX@Z [all …]
|
| H A D | lin32-tbbmalloc.def | 53 *3rml*;
|
| H A D | lin64-tbbmalloc.def | 53 *3rml*;
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | memory_pool.h | 48 void recycle() { rml::pool_reset(my_pool); } in recycle() 51 void *malloc(size_t size) { return rml::pool_malloc(my_pool, size); } in malloc() 54 void free(void* ptr) { rml::pool_free(my_pool, ptr); } in free() 59 return rml::pool_realloc(my_pool, ptr, size); in realloc() 64 void destroy() { rml::pool_destroy(my_pool); } in destroy() 66 rml::MemoryPool *my_pool; 204 rml::MemPoolPolicy args(allocate_request, deallocate_request, in memory_pool() 206 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in memory_pool() 207 if (res!=rml::POOL_OK) in memory_pool() 249 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in fixed_pool() [all …]
|
| H A D | scalable_allocator.h | 135 namespace rml { 183 rml::MemoryPool **pool);
|
| /oneTBB/python/rml/ |
| H A D | ipc_server.cpp | 33 namespace rml { namespace 41 if( !tbb::internal::rml::get_enable_flag( IPC_ENABLE_VAR_NAME ) ) { in __RML_open_factory() 65 class ipc_thread_monitor : public tbb::detail::r1::rml::internal::thread_monitor { 92 using rml::internal::ipc_thread_monitor; 93 using tbb::internal::rml::get_shared_name; 104 namespace rml { namespace 118 using tbb_client = tbb::detail::r1::rml::tbb_client; 119 using tbb_server = tbb::detail::r1::rml::tbb_server; 120 using tbb_factory = tbb::detail::r1::rml::tbb_factory; 564 ::rml::job& j = *my_client.create_one_job(); in run() [all …]
|
| H A D | ipc_utils.h | 22 namespace rml {
|
| H A D | ipc_utils.cpp | 27 namespace rml { namespace
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _assert.h | 23 namespace rml { namespace internal { 44 #define __TBB_ASSERT_RELEASE(predicate,message) ((predicate)?((void)0) : rml::internal::assertion_f…
|
| /oneTBB/src/tbbmalloc/ |
| H A D | frontend.cpp | 56 namespace rml { namespace 2686 using namespace rml::internal; 2692 rml::MemoryPool *pool; in pool_create() 2720 rml::internal::MemoryPool *memPool = in pool_create_v1() 2721 (rml::internal::MemoryPool*)internalMalloc((sizeof(rml::internal::MemoryPool))); in pool_create_v1() 2733 *pool = (rml::MemoryPool*)memPool; in pool_create_v1() 2746 bool pool_reset(rml::MemoryPool* memPool) in pool_reset() 2781 rml::internal::MemoryPool *mPool = (rml::internal::MemoryPool*)memPool; in pool_aligned_realloc() 2802 rml::internal::MemoryPool *pool; in pool_identify() 2813 return (rml::MemoryPool*)pool; in pool_identify() [all …]
|
| H A D | Customize.h | 85 namespace rml { 90 #define MALLOC_EXTRA_INITIALIZATION rml::internal::init_tbbmalloc()
|
| H A D | tbbmalloc.cpp | 32 namespace rml { namespace
|