| /external/libxcam/xcore/ |
| thread_pool.cpp | 34 , _pool (pool)
43 SmartPtr<ThreadPool> _pool; member in class:XCam::UserThread
49 XCAM_ASSERT (_pool.ptr ());
50 SmartLock lock (_pool->_mutex);
63 XCAM_ASSERT (_pool.ptr ());
65 SmartLock lock (_pool->_mutex);
66 if (!_pool->_running)
70 SmartPtr<ThreadPool::UserData> data = _pool->_data_queue.pop ();
72 XCAM_LOG_DEBUG ("user thread(%s) get null data, need stop", XCAM_STR (_pool->get_name ()));
77 SmartLock lock (_pool->_mutex)
[all...] |
| buffer_pool.h | 58 _pool = pool;
76 SmartPtr<BufferPool> _pool; member in class:XCam::BufferProxy
|
| buffer_pool.cpp | 40 if (_pool.ptr ()) {
41 _pool->release (_data);
|
| /external/autotest/site_utils/lxc/container_pool/ |
| service.py | 70 self._pool = pool
83 if self._pool is None:
87 self._pool = pool.Pool(factory=factory, size=pool_size)
114 self._pool.cleanup()
140 status['pool capacity'] = self._pool.capacity
141 status['pool size'] = self._pool.size
142 status['pool worker count'] = self._pool.worker_count
143 status['pool errors'] = self._pool.errors.qsize()
153 thread = _ClientThread(self, self._pool, connection)
183 self._pool = poo
[all...] |
| pool.py | 75 self._pool = Queue.Queue(size)
76 self._monitor = _Monitor(factory, self._pool)
97 return self._pool.get(block=(timeout != 0),
122 container = self._pool.get(block=False)
142 return self._pool.qsize()
148 return self._pool.maxsize
191 self._pool = pool
253 if self._pool.full():
271 qsize = self._pool.qsize()
272 shortfall = self._pool.maxsize - qsiz
[all...] |
| /external/javassist/sample/evolve/ |
| Evolution.java | 37 public void start(ClassPool _pool) throws NotFoundException {
38 pool = _pool;
42 trapMethod = _pool.getMethod("sample.evolve.Sample", "make");
45 public void onLoad(ClassPool _pool, String classname)
53 CtClass clazz = _pool.get(classname);
|
| /external/autotest/server/cros/dynamic_suite/ |
| tools_unittest.py | 28 _POOL = 'bvt'
35 host_spec_list = [HostSpec([self._BOARD, self._POOL])]
38 HostSpec([self._BOARD, self._POOL], dep_list))
|
| /external/webrtc/webrtc/modules/video_capture/linux/ |
| video_capture_linux.cc | 59 _pool(NULL)
348 _pool = new Buffer[rbuffer.count];
363 _pool[i].start = mmap(NULL, buffer.length, PROT_READ | PROT_WRITE, MAP_SHARED,
366 if (MAP_FAILED == _pool[i].start)
369 munmap(_pool[j].start, _pool[j].length);
373 _pool[i].length = buffer.length;
387 munmap(_pool[i].start, _pool[i].length);
389 delete[] _pool;
[all...] |
| video_capture_linux.h | 60 Buffer *_pool; member in class:webrtc::videocapturemodule::VideoCaptureModuleV4L2
|
| /external/autotest/server/hosts/ |
| ssh_multiplex.py | 136 self._pool = {}
156 conn = self._pool.get(key)
159 self._pool[key] = conn
164 for ssh in self._pool.itervalues():
|
| /external/nanopb-c/generator/google/protobuf/ |
| message_factory.py | 74 _POOL = descriptor_pool.DescriptorPool(_DB)
111 yield _POOL.FindMessageTypeByName(name)
|
| /external/python/cpython2/Doc/includes/ |
| mp_pool.py | 246 for worker in pool._pool:
255 for worker in pool._pool:
273 for worker in pool._pool:
286 processes = pool._pool
|
| /external/python/cpython2/Lib/multiprocessing/ |
| pool.py | 158 self._pool = []
173 self._pool, self._cache)
189 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
200 for i in reversed(range(len(self._pool))):
201 worker = self._pool[i]
207 del self._pool[i]
214 for i in range(self._processes - len(self._pool)):
220 self._pool.append(w)
307 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
473 for p in self._pool
[all...] |
| /external/python/cpython3/Lib/multiprocessing/ |
| pool.py | 167 self._pool = []
182 self._pool, self._cache)
198 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
209 for i in reversed(range(len(self._pool))):
210 worker = self._pool[i]
216 del self._pool[i]
223 for i in range(self._processes - len(self._pool)):
230 self._pool.append(w)
346 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
513 for p in self._pool
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| pool.py | 158 self._pool = []
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
199 for i in reversed(range(len(self._pool))):
200 worker = self._pool[i]
206 del self._pool[i]
213 for i in range(self._processes - len(self._pool)):
219 self._pool.append(w)
306 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
460 for p in self._pool
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| pool.py | 158 self._pool = []
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
199 for i in reversed(range(len(self._pool))):
200 worker = self._pool[i]
206 del self._pool[i]
213 for i in range(self._processes - len(self._pool)):
219 self._pool.append(w)
306 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
460 for p in self._pool
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 158 self._pool = []
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
199 for i in reversed(range(len(self._pool))):
200 worker = self._pool[i]
206 del self._pool[i]
213 for i in range(self._processes - len(self._pool)):
219 self._pool.append(w)
306 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
460 for p in self._pool
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 158 self._pool = []
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
199 for i in reversed(range(len(self._pool))):
200 worker = self._pool[i]
206 del self._pool[i]
213 for i in range(self._processes - len(self._pool)):
219 self._pool.append(w)
306 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
460 for p in self._pool
[all...] |
| /external/mesa3d/src/intel/vulkan/ |
| anv_query.c | 84 VkQueryPool _pool,
88 ANV_FROM_HANDLE(anv_query_pool, pool, _pool);
|
| /external/valgrind/memcheck/tests/ |
| mempool.c | 22 typedef struct _pool { struct
|
| mempool2.c | 25 typedef struct _pool { struct
|
| /external/libxcam/tests/ |
| test-soft-image.cpp | 127 SmartPtr<BufferPool> _pool; member in class:SoftElement
185 _pool = new SoftVideoBufAllocator ();
186 _pool->set_video_info (info);
187 if (!_pool->reserve (count)) {
198 _buf = _pool->get_buffer (_pool);
|
| /external/mesa3d/src/amd/vulkan/ |
| radv_query.c | 111 VkQueryPool _pool,
115 RADV_FROM_HANDLE(radv_query_pool, pool, _pool);
|
| radv_descriptor_set.c | 467 VkDescriptorPool _pool,
471 RADV_FROM_HANDLE(radv_descriptor_pool, pool, _pool);
|
| /external/autotest/scheduler/ |
| drone_utility.py | 454 self._pool = None
479 self._pool = multiprocessing.Pool(pool_size)
513 contents = self._pool.map(_read_pidfile, pidfile_paths)
545 dark_marks = self._pool.map(
|
