/dports/lang/yorick/yorick-y_2_2_04/mpy/ |
H A D | mpool.i | 252 if (_pool.list) _pool.nmax = min(_pool.nmax, numberof(*_pool.list)-1); 269 _pool.slave = _pool.list? (*_pool.list)(1+n) : n; 315 _pool.navg = _mpool_navg(_pool.tsow, _pool.twork, _pool.treap); 407 _pool.nself = _pool.njobs; 408 _pool.navg = _mpool_navg(_pool.tsow, _pool.twork, _pool.treap); 418 t=_pool.t0; u=_pool.tsow; timer,t,u; _pool.t0=t; _pool.tsow=u; 420 t=_pool.t0; u=_pool.twork; timer,t,u; _pool.t0=t; _pool.twork=u; 422 t=_pool.t0; u=_pool.treap; timer,t,u; _pool.t0=t; _pool.treap=u; 442 write, format=f4, _pool.tsow(1), _pool.tsow(2), _pool.tsow(3); 443 write, format=f5, _pool.twork(1), _pool.twork(2), _pool.twork(3); [all …]
|
/dports/security/libprelude/libprelude-1.2.6/bindings/c++/ |
H A D | prelude-connection-pool.cxx | 38 if ( _pool ) in ~ConnectionPool() 39 prelude_connection_pool_destroy(_pool); in ~ConnectionPool() 45 _pool = NULL; in ConnectionPool() 51 _pool = pool; in ConnectionPool() 57 _pool = (con._pool) ? prelude_connection_pool_ref(con._pool) : NULL; in ConnectionPool() 76 ret = prelude_connection_pool_init(_pool); in init() 159 prelude_connection_pool_set_data(_pool, data); in setData() 171 if ( this != &pool && _pool != pool._pool ) { in operator =() 172 if ( _pool ) in operator =() 175 _pool = (pool._pool) ? prelude_connection_pool_ref(pool._pool) : NULL; in operator =() [all …]
|
/dports/sysutils/chyves/chyves-0.2.0/lib/ |
H A D | chyves-dataset | 29 local _pool="$1" 31 echo "Setting up chyves on $_pool..." 32 zfs create -o mountpoint=/chyves/$_pool $_pool/chyves 33 zfs create $_pool/chyves/.config 35 touch /chyves/$_pool/.config/pool.cfg 38 zfs create $_pool/chyves/guests 43 …__write_property_value_to_config_file "manual" "dataset_role" "secondary" "/chyves/$_pool/.config/… 47 _PRIMARY_POOL=$_pool 131 __log 2 "Done setting up primary pool: $_pool" 137 local _pool="$1" [all …]
|
/dports/devel/py-celery/celery-4.4.7/celery/concurrency/ |
H A D | prefork.py | 128 self._pool.restart() 143 if self._pool is not None and self._pool._state in (RUN, CLOSE): 144 self._pool.close() 145 self._pool.join() 146 self._pool = None 150 if self._pool is not None: 151 self._pool.terminate() 152 self._pool = None 155 if self._pool is not None and self._pool._state == RUN: 156 self._pool.close() [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/Mono.Posix/Mono.Remoting.Channels.Unix/ |
H A D | UnixConnectionPool.cs | 153 _pool = pool; in UnixConnection() 212 lock (_pool) in GetConnection() 216 if (_pool.Count > 0) in GetConnection() 220 connection = (UnixConnection)_pool[_pool.Count - 1]; in GetConnection() 221 _pool.RemoveAt(_pool.Count - 1); in GetConnection() 242 Monitor.Wait(_pool); in GetConnection() 271 lock (_pool) in ReleaseConnection() 274 _pool.Add (entry); in ReleaseConnection() 275 Monitor.Pulse (_pool); in ReleaseConnection() 293 lock (_pool) in PurgeConnections() [all …]
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/System.Runtime.Remoting/System.Runtime.Remoting.Channels.Tcp/ |
H A D | TcpConnectionPool.cs | 156 _pool = pool; in TcpConnection() 217 lock (_pool) in GetConnection() 221 if (_pool.Count > 0) in GetConnection() 225 connection = (TcpConnection)_pool[_pool.Count - 1]; in GetConnection() 226 _pool.RemoveAt(_pool.Count - 1); in GetConnection() 247 Monitor.Wait(_pool); in GetConnection() 276 lock (_pool) in ReleaseConnection() 279 _pool.Add (entry); in ReleaseConnection() 280 Monitor.Pulse (_pool); in ReleaseConnection() 298 lock (_pool) in PurgeConnections() [all …]
|
/dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/libs/3rdparty/cplusplus/ |
H A D | Parser.cpp | 293 _pool(unit->memoryPool()), in Parser() 967 UsingAST *ast = new (_pool) UsingAST; in parseUsing() 2444 *iter = new (_pool) NameListAST; in parseQtEnumDeclaration() 2477 *iter = new (_pool) NameListAST; in parseQtFlags() 3236 MemoryPool *previousPool = _pool; in parseExpressionStatement() 3237 _pool = &_expressionStatementTempPool; in parseExpressionStatement() 3262 _pool = previousPool; in parseExpressionStatement() 5955 *nextId = new (_pool) NameListAST; in parseObjCClassForwardDeclaration() 5956 name = new (_pool) SimpleNameAST; in parseObjCClassForwardDeclaration() 6351 name = new (_pool) SimpleNameAST; in parseObjCProtocolRefs() [all …]
|
/dports/mail/py-postfix-mta-sts-resolver/postfix-mta-sts-resolver-1.1.1/postfix_mta_sts_resolver/ |
H A D | redis_cache.py | 35 self._pool = None 40 self._pool = aioredis.from_url(url, **opts) 43 assert self._pool is not None 45 res = await self._pool.zrevrange(key, 0, 0, withscores=True) 53 assert self._pool is not None 59 async with self._pool.pipeline(transaction=True) as pipe: 65 assert self._pool is not None 81 assert self._pool is not None 86 assert self._pool is not None 91 assert self._pool is not None [all …]
|
/dports/devel/py-celery/celery-4.4.7/t/unit/concurrency/ |
H A D | test_prefork.py | 27 _pool = Mock() variable in _mp.TaskPool 369 assert pool._pool.started 372 _pool = pool._pool 374 assert _pool.closed 375 assert _pool.joined 379 _pool = pool._pool 382 assert _pool.terminated 406 pool._pool._state = mp.RUN 413 pool._pool._state = mp.CLOSE 436 _pool = procs variable in test_TaskPool.test_info._Pool [all …]
|
/dports/www/py-httpcore/httpcore-0.14.3/httpcore/_sync/ |
H A D | connection_pool.py | 145 return list(self._pool) 162 self._pool.pop(idx) 172 self._pool.pop(idx) 181 self._pool.insert(0, connection) 193 self._pool.pop(idx) 197 pool_size = len(self._pool) 201 self._pool.pop(idx) 277 self._pool.remove(connection) 298 for connection in self._pool: 300 self._pool = [] [all …]
|
/dports/www/py-httpcore/httpcore-0.14.3/httpcore/_async/ |
H A D | connection_pool.py | 145 return list(self._pool) 162 self._pool.pop(idx) 172 self._pool.pop(idx) 181 self._pool.insert(0, connection) 193 self._pool.pop(idx) 197 pool_size = len(self._pool) 201 self._pool.pop(idx) 277 self._pool.remove(connection) 298 for connection in self._pool: 300 self._pool = [] [all …]
|
/dports/databases/py-aioredis/aioredis-1.3.1/aioredis/ |
H A D | pool.py | 113 return self._pool.maxlen 123 return len(self._pool) 139 while self._pool: 149 while self._pool: 235 conn = self._pool[0] 236 self._pool.rotate(1) 370 conn = self._pool[0] 448 self._pool = pool 458 self._pool = None 467 self._pool = pool [all …]
|
/dports/net/py-mpi4py/mpi4py-3.1.3/src/mpi4py/futures/ |
H A D | pool.py | 61 self._pool = None 66 if self._pool is None: 77 self._pool.wait() 78 return self._pool.size 93 self._pool.wait() 115 self._pool.push((future, task)) 197 if self._pool is not None: 198 self._pool.done() 201 self._pool.cancel() 204 pool = self._pool [all …]
|
/dports/devel/upp/upp/bazaar/CoWork/ |
H A D | CoWork.h | 43 Pool & _pool; //this ref is actually used, set depending on threadnr variable 52 int GetThreadCount() const { return _pool.threads.GetCount(); } in GetThreadCount() 53 …int GetThreadCount() { _pool.lock.Enter(); int c = _pool.threads.GetCount(); _pool.lock.Leave(); r… in GetThreadCount() 54 void AddThread(int count = 1) { ASSERT(&_pool != &pool()); _pool.AddThread(count); } 55 …void KillThread(int count = 1, bool waitone = false) { ASSERT(&_pool != &pool()); _pool.KillThread…
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/src/mod/endpoints/mod_khomp/commons/base/system/freeswitch/ |
H A D | thread.hpp | 116 _pool(pool), in Thread() 119 if(!_pool) in Thread() 121 switch_core_new_memory_pool(&_pool); in Thread() 130 (switch_threadattr_t **)&_thread_info->_attribute, _pool) != 0) in Thread() 150 _pool(pool), in Thread() 153 if(!_pool) in Thread() 155 switch_core_new_memory_pool(&_pool); in Thread() 187 switch_core_destroy_memory_pool(&_pool); in ~Thread() 202 if(!_pool || !_thread_info->_attribute) in start() 209 _pool); in start() [all …]
|
H A D | saved_condition.hpp | 58 _pool(pool), in SavedCondition() 61 if(!_pool) in SavedCondition() 63 switch_core_new_memory_pool(&_pool); in SavedCondition() 67 switch_thread_cond_create(&_condition, _pool); in SavedCondition() 68 switch_mutex_init(&_mutex, SWITCH_MUTEX_DEFAULT, _pool); in SavedCondition() 78 switch_core_destroy_memory_pool(&_pool); in ~SavedCondition() 131 switch_memory_pool_t *_pool; member
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/hotspot/gtest/metaspace/ |
H A D | test_chunkheaderpool.cpp | 41 ChunkHeaderPool _pool; member in ChunkHeaderPoolTest 55 _pool.return_chunk_header(_elems[index]); in attempt_free_at() 59 DEBUG_ONLY(_num_allocated.check(_pool.used());) in attempt_free_at() 61 DEBUG_ONLY(_pool.verify();) in attempt_free_at() 73 Metachunk* c = _pool.allocate_chunk_header(); in attempt_allocate_at() 79 DEBUG_ONLY(_num_allocated.check(_pool.used());) in attempt_allocate_at() 81 DEBUG_ONLY(_pool.verify();) in attempt_allocate_at() 100 DEBUG_ONLY(_pool.verify();) in test_random_alloc_free() 111 ChunkHeaderPoolTest() : _pool() { in ChunkHeaderPoolTest()
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/hotspot/gtest/metaspace/ |
H A D | test_chunkheaderpool.cpp | 41 ChunkHeaderPool _pool; member in ChunkHeaderPoolTest 55 _pool.return_chunk_header(_elems[index]); in attempt_free_at() 59 DEBUG_ONLY(_num_allocated.check(_pool.used());) in attempt_free_at() 61 DEBUG_ONLY(_pool.verify();) in attempt_free_at() 73 Metachunk* c = _pool.allocate_chunk_header(); in attempt_allocate_at() 79 DEBUG_ONLY(_num_allocated.check(_pool.used());) in attempt_allocate_at() 81 DEBUG_ONLY(_pool.verify();) in attempt_allocate_at() 100 DEBUG_ONLY(_pool.verify();) in test_random_alloc_free() 111 ChunkHeaderPoolTest() : _pool() { in ChunkHeaderPoolTest()
|
/dports/science/py-pygmo2/pygmo2-2.18.0/pygmo/ |
H A D | _py_bfes.py | 72 _pool = None variable in mp_bfe 164 ret = mp_bfe._pool.map_async( 208 if mp_bfe._pool is None: 209 mp_bfe._pool, mp_bfe._pool_size = _make_pool(processes) 294 mp_bfe._pool.close() 295 mp_bfe._pool.join() 297 mp_bfe._pool = new_pool 314 if mp_bfe._pool is not None: 315 mp_bfe._pool.close() 316 mp_bfe._pool.join() [all …]
|
/dports/databases/twemproxy/twemproxy-0.5.0/src/ |
H A D | nc_stats.h | 135 #define stats_pool_incr(_ctx, _pool, _name) do { \ argument 136 _stats_pool_incr(_ctx, _pool, STATS_POOL_##_name); \ 139 #define stats_pool_decr(_ctx, _pool, _name) do { \ argument 140 _stats_pool_decr(_ctx, _pool, STATS_POOL_##_name); \ 143 #define stats_pool_incr_by(_ctx, _pool, _name, _val) do { \ argument 144 _stats_pool_incr_by(_ctx, _pool, STATS_POOL_##_name, _val); \ 147 #define stats_pool_decr_by(_ctx, _pool, _name, _val) do { \ argument 177 #define stats_pool_incr(_ctx, _pool, _name) argument 179 #define stats_pool_decr(_ctx, _pool, _name) argument 181 #define stats_pool_incr_by(_ctx, _pool, _name, _val) argument [all …]
|
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/SuperReadsR/include/jflib/ |
H A D | multiplexed_io.hpp | 65 writer_info(std::ostream *_os, buffer_pool *_pool) : os(_os), pool(_pool) { } in writer_info() 82 : _os(os), _pool(nb_buffers), _info(_os, &_pool), _writer_started(false) in o_multiplexer() 84 for(buffer_pool::iterator it = _pool.begin(); it != _pool.end(); in o_multiplexer() 111 _pool.close_A_to_B(); in close() 191 multiplexedbuf(buffer_pool *pool) : _pool(pool), _closed(false) in multiplexedbuf() 275 _closed = _pool->is_closed_B_to_A(); in update_buffer() 281 _elt = _pool->get_A(); in update_buffer() 289 buffer_pool *_pool; member in jflib::o_multiplexer::multiplexedbuf 297 multiplexedbuf *new_multiplexedbuf() { return new multiplexedbuf(&_pool); } in new_multiplexedbuf() 300 buffer_pool _pool; member in jflib::o_multiplexer
|
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/quorum/include/jflib/ |
H A D | multiplexed_io.hpp | 65 writer_info(std::ostream *_os, buffer_pool *_pool) : os(_os), pool(_pool) { } in writer_info() 82 : _os(os), _pool(nb_buffers), _info(_os, &_pool), _writer_started(false) in o_multiplexer() 84 for(buffer_pool::iterator it = _pool.begin(); it != _pool.end(); in o_multiplexer() 111 _pool.close_A_to_B(); in close() 191 multiplexedbuf(buffer_pool *pool) : _pool(pool), _closed(false) in multiplexedbuf() 275 _closed = _pool->is_closed_B_to_A(); in update_buffer() 281 _elt = _pool->get_A(); in update_buffer() 289 buffer_pool *_pool; member in jflib::o_multiplexer::multiplexedbuf 297 multiplexedbuf *new_multiplexedbuf() { return new multiplexedbuf(&_pool); } in new_multiplexedbuf() 300 buffer_pool _pool; member in jflib::o_multiplexer
|
/dports/audio/ardour6/Ardour-6.8.0/libs/pbd/ |
H A D | reallocpool.cc | 61 , _pool (0) in ReallocPool() 86 mlock (_pool, bytes); in ReallocPool() 91 _mru = _pool; in ReallocPool() 104 ::free (_pool); in ~ReallocPool() 105 _pool = NULL; in ~ReallocPool() 225 p = _pool; in _malloc() 263 p = _pool; in _malloc() 343 char *p = _pool; in dumpsegments() 369 if (p == _pool + _poolsize) { in dumpsegments() 373 if (p > _pool + _poolsize) { in dumpsegments() [all …]
|
/dports/math/yacas/yacas-1.9.1/cyacas/libyacas/src/ |
H A D | mempool.cpp | 11 _pool(new std::uint8_t[_block_size * _no_blocks]), in MemPool() 12 _next_free_block(_pool), in MemPool() 22 delete[] _pool; in ~MemPool() 29 std::uint8_t* p = _pool + _no_initialized_blocks * _block_size; in alloc() 53 if (p >= _pool && p < _pool + _block_size * _no_blocks) { in free() 58 *reinterpret_cast<std::uint8_t**>(p) = _pool + _no_blocks; in free()
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/util/concurrency/ |
H A D | old_thread_pool.cpp | 64 : _pool(makeOptions(nThreads, threadNamePrefix)) {} in OldThreadPool() 66 OldThreadPool::OldThreadPool(ThreadPool::Options options) : _pool(std::move(options)) {} in OldThreadPool() 69 return _pool.getStats().numThreads; in getNumThreads() 73 return _pool.getStats(); in getStats() 77 _pool.startup(); in startThreads() 81 _pool.waitForIdle(); in join() 85 fassert(28705, _pool.schedule(std::move(task))); in schedule()
|