Home
last modified time | relevance | path

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

/oneTBB/src/tbb/
H A Dexception.cpp106 char buf[BUF_SIZE + 1] = { 0 }; in handle_perror() local
107 std::strncat(buf, what, BUF_SIZE); in handle_perror()
108 std::size_t buf_len = std::strlen(buf); in handle_perror()
110 std::strncat(buf, ": ", BUF_SIZE - buf_len); in handle_perror()
111 buf_len = std::strlen(buf); in handle_perror()
112 std::strncat(buf, std::strerror(error_code), BUF_SIZE - buf_len); in handle_perror()
113 buf_len = std::strlen(buf); in handle_perror()
115 __TBB_ASSERT(buf_len <= BUF_SIZE && buf[buf_len] == 0, nullptr); in handle_perror()
117 do_throw([&buf] { throw std::runtime_error(buf); }); in handle_perror()
119 PRINT_ERROR_AND_ABORT( "runtime_error", buf); in handle_perror()
/oneTBB/test/tbbmalloc/
H A Dtest_scalable_allocator.cpp104 void *buf; member
117 return bytes? ((FixedPool*)pool_id)->buf : nullptr; in fixedBufGetMem()
125 char *buf; in TestSmallFixedSizePool() local
129 buf = (char*)malloc(sz); in TestSmallFixedSizePool()
132 tbb::fixed_pool pool(buf, sz); in TestSmallFixedSizePool()
151 FixedPool fixedPool(buf, sz); in TestSmallFixedSizePool()
161 free(buf); in TestSmallFixedSizePool()
197 static char buf[1024*1024*4]; variable
198 tbb::fixed_pool pool(buf, sizeof(buf));
292 static char buf[1024*1024*4]; variable
[all …]
H A Dtest_malloc_regression.cpp99 char *buf = (char*)scalable_malloc(startSz); in TestReallocMsize() local
100 REQUIRE_MESSAGE(buf, ""); in TestReallocMsize()
101 size_t realSz = scalable_msize(buf); in TestReallocMsize()
103 memset(buf, 'a', realSz-1); in TestReallocMsize()
104 buf[realSz-1] = 0; in TestReallocMsize()
105 char *buf1 = (char*)scalable_realloc(buf, 2*realSz); in TestReallocMsize()
H A Dtest_malloc_compliance.cpp420 intptr_t *buf =(intptr_t*)ptr; in NonZero() local
421 char *bufTail =(char*)(buf+words); in NonZero()
424 if (buf[i]) { in NonZero()
426 if (((char*)(buf+i))[b]) in NonZero()
H A Dtest_malloc_pools.cpp578 static bool memEqual(char *buf, size_t size, int val) in memEqual() argument
582 if (buf[k] != val) in memEqual()
/oneTBB/test/common/
H A Dutils_env.h40 char* buf = new char[namelen+valuelen+2]; in SetEnv() local
41 strncpy(buf, envname, namelen); in SetEnv()
42 buf[namelen] = '='; in SetEnv()
43 strncpy(buf+namelen+1, envval, valuelen); in SetEnv()
44 buf[namelen+1+valuelen] = char(0); in SetEnv()
45 int status = _putenv(buf); in SetEnv()
46 delete[] buf; in SetEnv()
H A Dtest_follows_and_precedes_api.h113 …tbb::flow::buffer_node<typename multioutput::output_type> buf(tbb::flow::follows(tbb::flow::output…
120 …CHECK_MESSAGE((buf.try_get(storage) && ! buf.try_get(storage)), "Not exact edge quantity was made"…
H A Ddoctest.h694 return reinterpret_cast<char*>(buf); in c_str()
3653 buf[sz] = '\0';
3655 return buf;
3675 memcpy(buf, other.buf, len);
3682 buf[0] = '\0';
3766 memcpy(buf, other.buf, len);
3767 other.buf[0] = '\0';
3775 memcpy(buf, other.buf, len);
3776 other.buf[0] = '\0';
6830 char buf[1024];
[all …]
H A Dcustom_allocators.h33 ArenaData( T* buf, std::size_t sz ) noexcept in ArenaData()
34 : my_buffer(reinterpret_cast<char*>(buf)), in ArenaData()
/oneTBB/examples/parallel_for/tachyon/src/
H A Dtachyon_video.cpp61 char buf[8192]; in on_process() local
73 sprintf(buf, "%s: %.3f seconds", global_window_title, runtime); in on_process()
74 rt_ui_message(MSG_0, buf); in on_process()
75 title = buf; in on_process()
/oneTBB/examples/graph/fgbzip2/
H A Dbzlib.hpp172 BZ_EXTERN int BZ_API(BZ2_bzRead)(int* bzerror, BZFILE* b, void* buf, int len);
177 BZ_EXTERN void BZ_API(BZ2_bzWrite)(int* bzerror, BZFILE* b, void* buf, int len);
227 BZ_EXTERN int BZ_API(BZ2_bzread)(BZFILE* b, void* buf, int len);
229 BZ_EXTERN int BZ_API(BZ2_bzwrite)(BZFILE* b, void* buf, int len);
H A Dbzlib.cpp1017 Char buf[BZ_MAX_UNUSED]; member
1088 if (bzf == nullptr || buf == nullptr || len < 0) { in BZ_API()
1107 bzf->strm.next_in = (char*)buf; in BZ_API()
1111 bzf->strm.next_out = bzf->buf; in BZ_API()
1178 bzf->strm.next_out = bzf->buf; in BZ_API()
1258 bzf->buf[bzf->bufN] = *((UChar*)(unused)); in BZ_API()
1272 bzf->strm.next_in = bzf->buf; in BZ_API()
1321 bzf->strm.next_out = (char*)buf; in BZ_API()
1337 bzf->strm.next_in = bzf->buf; in BZ_API()
1614 nread = BZ2_bzRead(&bzerr, b, buf, len); in BZ_API()
[all …]
/oneTBB/src/tbbmalloc/
H A Dshared_utils.h111 char buf[BUF_LINE_SIZE];
114 while (numFound < N && fgets(buf, BUF_LINE_SIZE, f)) {
116 if (!found[i] && 1 == sscanf(buf, items[i].format, &items[i].value)) {
/oneTBB/test/conformance/
H A Dconformance_async_node.cpp155 buffer_node<std::size_t> buf(g);
158 make_edge(activity_submitter, buf);
164 CHECK(buf.try_get(result));
166 CHECK(!buf.try_get(result));
H A Dconformance_multifunction_node.cpp167 buffer_node<std::size_t> buf(g);
172 make_edge(output_port<0>(mf21), buf);
173 make_edge(output_port<0>(mf22), buf);
181 while(buf.try_get(tmp)) {
H A Dconformance_function_node.cpp91 buffer_node<OutputType2> buf(g); in test_fn_invoke_basic() local
94 make_edge(f2, buf); in test_fn_invoke_basic()
101 CHECK(buf.try_get(result)); in test_fn_invoke_basic()
103 CHECK(!buf.try_get(result)); in test_fn_invoke_basic()
H A Dconformance_join_node.cpp287 buffer_node<tuple_type> buf(g); in test_invoke_basic() local
291 make_edge(j, buf); in test_invoke_basic()
304 while(buf.try_get(tpl)) { in test_invoke_basic()
/oneTBB/include/oneapi/tbb/
H A Dmemory_pool.h195 inline fixed_pool(void *buf, size_t size);
244 inline fixed_pool::fixed_pool(void *buf, size_t size) : my_buffer(buf), my_size(size) { in fixed_pool() argument
245 if (!buf || !size) in fixed_pool()
/oneTBB/doc/main/reference/scalable_memory_pools/
H A Dfixed_pool_cls.rst72 char buf[1024*1024];
73 oneapi::tbb::fixed_pool my_pool(buf, 1024*1024);
/oneTBB/test/tbb/
H A Dtest_indexer_node.cpp561 tbb::flow::buffer_node<tagged_msg_t>& buf, in check_edge() argument
567 bool is_get_succeeded = buf.try_get(msg); in check_edge()
578 void check_edge(tbb::flow::graph& g, BN& bn, tbb::flow::buffer_node<indexer_output_t>& buf, Type, t… in check_edge() argument
579 …sink(check_edge<indexer_output_t>(g, std::get<Seq>(bn), buf, typename std::tuple_element<Seq, Type… in check_edge()
592 buffer_node<indexer_output_t> buf(g); in test_follows_impl() local
593 make_edge(my_indexer, buf); in test_follows_impl()
595 check_edge<indexer_output_t>(g, bn, buf, t, seq); in test_follows_impl()
H A Dtest_broadcast_node.cpp229 buffer_node<int> buf(g); in test_deduction_guides() local
231 broadcast_node b1(follows(buf)); in test_deduction_guides()
234 broadcast_node b2(precedes(buf)); in test_deduction_guides()
H A Dtest_continue_node.cpp343 buffer_node<continue_msg> buf(g); in test_successor_cache_specialization() local
345 make_edge(node, buf); in test_successor_cache_specialization()
353 CHECK_MESSAGE((buf.try_get(storage) && !buf.try_get(storage)), in test_successor_cache_specialization()
H A Dtest_async_node.cpp736 buffer_node<output_t> buf(g); in test_follows() local
737 make_edge(node, buf); in test_follows()
747 …CHECK_MESSAGE((buf.try_get(storage) && buf.try_get(storage) && buf.try_get(storage) && !buf.try_ge… in test_follows()
H A Dtest_semaphore.cpp168 unsigned* buf, in FilterBase() argument
172 next_sem(n_sem), myBuffer(buf), nextBuffer(n_buf) in FilterBase()
H A Dtest_parallel_pipeline.cpp67 void freeBuffer(void *buf) { in freeBuffer() argument
69 if(buffers[i] == buf) { in freeBuffer()