Home
last modified time | relevance | path

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

12345678910>>...52

/dports/lang/yorick/yorick-y_2_2_04/mpy/
H A Dmpool.i252 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 Dprelude-connection-pool.cxx38 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 Dchyves-dataset29 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 Dprefork.py128 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 DUnixConnectionPool.cs153 _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 DTcpConnectionPool.cs156 _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 DParser.cpp293 _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 Dredis_cache.py35 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 Dtest_prefork.py27 _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 Dconnection_pool.py145 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 Dconnection_pool.py145 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 Dpool.py113 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 Dpool.py61 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 DCoWork.h43 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 Dthread.hpp116 _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 Dsaved_condition.hpp58 _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 Dtest_chunkheaderpool.cpp41 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 Dtest_chunkheaderpool.cpp41 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.py72 _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 Dnc_stats.h135 #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 Dmultiplexed_io.hpp65 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 Dmultiplexed_io.hpp65 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 Dreallocpool.cc61 , _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 Dmempool.cpp11 _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 Dold_thread_pool.cpp64 : _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()

12345678910>>...52