Home
last modified time | relevance | path

Searched +refs:thread +refs:alive +refs:p (Results 1 – 25 of 2325) sorted by relevance

12345678910>>...93

/dports/devel/log4cxx/apache-log4cxx-0.11.0/src/main/cpp/
H A Dthreadcxx.cpp50 return p.palloc(sz); in operator new()
70 return thread; in getThread()
109 LaunchStatus(volatile unsigned int* p) : alive(p) in LaunchStatus() argument
111 apr_atomic_set32(alive, 0xFFFFFFFF); in LaunchStatus()
118 apr_atomic_set32(alive, 0); in ~LaunchStatus()
124 volatile unsigned int* alive; member in __anon00805dac0111::LaunchStatus
153 Thread::Thread() : thread(NULL), alive(0), interruptedStatus(0), in Thread()
201 p.getAPRPool()); in run()
220 apr_atomic_set32(&alive, 0xFFFFFFFF); in run()
303 return apr_atomic_read32(&alive) != 0; in isAlive()
[all …]
/dports/graphics/vips/vips-8.12.0/libvips/iofuncs/
H A Dbuffer.c124 *alive += buffer->bsize; in vips_buffer_dump()
135 *alive += buffer->bsize; in vips_buffer_dump()
160 printf( "\tthread %p\n", cache->thread ); in vips_buffer_cache_dump()
175 size_t alive; in vips_buffer_dump_all() local
180 alive = 0; in vips_buffer_dump_all()
249 for( p = cache->buffers; p; p = p->next ) { in buffer_cache_free()
260 for( p = cache->reserve; p; p = p->next ) { in buffer_cache_free()
277 cache->thread = g_thread_self(); in buffer_cache_new()
307 buffer_thread->thread = g_thread_self(); in buffer_thread_new()
402 g_assert( cache->buffer_thread->thread == cache->thread ); in vips_buffer_undone()
[all …]
H A Dregion.c390 if( region->thread != g_thread_self() ) { in vips__region_take_ownership()
391 g_assert( region->thread == NULL ); in vips__region_take_ownership()
401 region->thread = g_thread_self(); in vips__region_take_ownership()
410 if( region->thread ) { in vips__region_check_ownership()
413 g_assert( region->thread == in vips__region_check_ownership()
414 region->buffer->cache->thread ); in vips__region_check_ownership()
432 region->thread = NULL; in vips__region_no_ownership()
2022 *alive += region->buffer->bsize; in vips_region_dump_all_cb()
2030 size_t alive; in vips_region_dump_all() local
2033 alive = 0; in vips_region_dump_all()
[all …]
/dports/lang/swi-pl/swipl-8.2.3/packages/http/
H A Dthread_httpd.pl161 % Time to keep `Keep alive' connections alive. Default is
166 % from the `main` thread.
687 debug(http(keep_alive), 'Waiting for keep-alive ...', []),
692 debug(http(keep_alive), '\tre-using keep-alive connection', [])
694 -> debug(http(keep_alive), '\tRemote closed keep-alive connection', [])
695 ; debug(http(keep_alive), '\tTimeout on keep-alive connection', [])
813 debug(http(server), 'Running server goal ~p on ~p -> ~p',
840 debug(http(spawn), 'Handler spawned to thread ~w', [ThreadId]).
842 downcase_atom(Connection, 'keep-alive'),
1006 [ 'Stopped worker ~p: ~p'-[Self, Status] ].
[all …]
/dports/lang/racket/racket-8.3/share/pkgs/readline-lib/readline/
H A Drktrl.rkt62 (define alive-values (box null))
63 (void (malloc-immobile-cell alive-values))
64 (define (keep-alive! v)
65 (set-box! alive-values (cons v (unbox alive-values))))
102 (vm-eval '(lambda (p)
280 (lambda (p) (p)))
294 [p (malloc (add1 len) 'raw)])
295 (memcpy p cur len)
296 (ptr-set! p _byte len 0)
297 p))))
[all …]
/dports/lang/python-legacy/Python-2.7.18/Demo/threads/
H A Dsync.py271 import thread
277 self.mutex = thread.allocate_lock()
287 self.checkout = thread.allocate_lock()
291 self.idlock = thread.allocate_lock()
410 def p(self): member in semaphore
429 self.rwOK = thread.allocate_lock()
498 io.acquire(); alive.append(id); \
501 thread.start_new_thread( func, (id,) + args )
523 alive.remove(tid); io.release()
568 global TID, tid, io, wh, randint, alive
[all …]
/dports/lang/python27/Python-2.7.18/Demo/threads/
H A Dsync.py271 import thread
277 self.mutex = thread.allocate_lock()
287 self.checkout = thread.allocate_lock()
291 self.idlock = thread.allocate_lock()
410 def p(self): member in semaphore
429 self.rwOK = thread.allocate_lock()
498 io.acquire(); alive.append(id); \
501 thread.start_new_thread( func, (id,) + args )
523 alive.remove(tid); io.release()
568 global TID, tid, io, wh, randint, alive
[all …]
/dports/devel/log4cxx/apache-log4cxx-0.11.0/src/main/include/log4cxx/helpers/
H A Dthread.h50 typedef void* (LOG4CXX_THREAD_FUNC* Runnable)(apr_thread_t* thread, void* data);
53 extern "C" void* LOG4CXX_THREAD_FUNC launcher(apr_thread_t* thread, void* data);
79 return thread != 0; in isActive()
109 Pool p;
110 apr_thread_t* thread; variable
111 volatile unsigned int alive; variable
117 friend void* LOG4CXX_THREAD_FUNC ThreadLaunch::launcher(apr_thread_t* thread, void* data);
/dports/devel/pybind11/pybind11-2.8.1/tests/
H A Dtest_callbacks.cpp85 Payload p; in TEST_SUBMODULE() local
89 return [p]() { in TEST_SUBMODULE()
91 (void) p; in TEST_SUBMODULE()
109 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
112 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
119 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
121 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
125 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
127 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
129 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
[all …]
/dports/science/smoldyn/smoldyn-2.67/source/pybind11/tests/
H A Dtest_callbacks.cpp85 Payload p; in TEST_SUBMODULE() local
89 return [p]() { in TEST_SUBMODULE()
91 (void) p; in TEST_SUBMODULE()
109 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
112 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
119 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
121 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
125 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
127 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
129 alive_counts.append(stat.alive()); in TEST_SUBMODULE()
[all …]
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/test/
H A Dharness.h255 #define ASSERT(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
256 #define ASSERT_WARNING(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
491 Movable() : alive(true) {}
492 void Reset() { alive = true; }
495 alive = true;
496 other.alive = false;
501 other.alive = false;
511 alive = true;
513 ~Movable() { alive = false; }
514 volatile bool alive; variable
[all …]
/dports/devel/tbb/oneTBB-2020.3/src/test/
H A Dharness.h255 #define ASSERT(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
256 #define ASSERT_WARNING(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
491 Movable() : alive(true) {}
492 void Reset() { alive = true; }
495 alive = true;
496 other.alive = false;
501 other.alive = false;
511 alive = true;
513 ~Movable() { alive = false; }
514 volatile bool alive; variable
[all …]
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/test/
H A Dharness.h255 #define ASSERT(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
256 #define ASSERT_WARNING(p,msg) (Harness::suppress_unused_warning(p), (void)0) argument
491 Movable() : alive(true) {}
492 void Reset() { alive = true; }
495 alive = true;
496 other.alive = false;
501 other.alive = false;
511 alive = true;
513 ~Movable() { alive = false; }
514 volatile bool alive; variable
[all …]
/dports/net/asterisk-chan_sccp/chan-sccp-4.3.3/src/
H A Dsccp_refcount.c213 uint16_t alive; member
355 obj->alive = SCCP_LIVE_MARKER; in sccp_refcount_object_alloc()
432 if (obj->alive != SCCP_LIVE_MARKER) { in __sccp_refcount_debug()
472 if (SCCP_LIVE_MARKER != obj->alive) { in sccp_refcount_find_obj()
681 CLI_AMI_TABLE_FIELD(Ptr, "-15", p, 15, obj) \ in sccp_show_refcount()
866 int alive = ATOMIC_DECR(&obj->alive, SCCP_LIVE_MARKER, &obj->lock); in sccp_refcount_release() local
998 int thread = 0; in AST_TEST_DEFINE() local
1032 for (thread = 0; thread < NUM_THREADS; thread++) { in AST_TEST_DEFINE()
1033 pbx_pthread_create(&t[thread], NULL, refcount_test_thread, &test_result[thread]); in AST_TEST_DEFINE()
1035 for (thread = 0; thread < NUM_THREADS; thread++) { in AST_TEST_DEFINE()
[all …]
/dports/lang/yap/yap-6.2.2/packages/http/
H A Dthread_httpd.pl234 -> debug(http(connection), 'New HTTP connection from ~p', [Peer]),
350 debug(http(worker), 'Got job ~p', [Message]),
392 debug(http(connection), 'Opened connection from ~p', [Peer]).
475 debug(http(error), 'Re-queue failed: ~p', [Header]),
495 debug(http(server), 'Running server goal ~p on ~p -> ~p',
506 debug(http(spawn), 'Handler spawned to thread ~w', [ThreadId]).
508 downcase_atom(Connection, 'keep-alive'),
529 debug(http(connection), 'Closing connection from ~p', [Peer]),
593 [ 'Stopped worker ~p: ~p'-[Self, Status] ].
/dports/www/firefox-legacy/firefox-52.8.0esr/python/psutil/test/
H A Dtest_psutil.py305 for p in alive:
597 for p in alive:
616 for p in alive:
1492 thread = ThreadTask()
1493 thread.start()
1497 thread.stop()
1500 thread.stop()
1512 thread = ThreadTask()
1513 thread.start()
1527 thread.stop()
[all …]
/dports/lang/abcl/abcl-src-1.8.0/doc/manual/
H A Dthreads.tex4 --- Function: \textbf{current-thread} [\textbf{threads}] \textit{}
7 Returns a reference to invoking thread.
13 --- Function: \textbf{destroy-thread} [\textbf{threads}] \textit{}
31 --- Function: \textbf{interrupt-thread} [\textbf{threads}] \textit{thread function \&rest args}
41 --- Function: \textbf{mailbox-empty-p} [\textbf{threads}] \textit{mailbox}
58 calling thread.
132 Wakes up a single thread that is waiting on OBJECT's monitor.
182 --- Class: \textbf{thread} [\textbf{threads}] \textit{}
191 --- Function: \textbf{thread-alive-p} [\textbf{threads}] \textit{thread}
194 Boolean predicate whether THREAD is alive.
[all …]
/dports/www/trafficserver/trafficserver-9.1.1/src/tscore/unit_tests/
H A Dtest_Extendible.cc43 std::thread jobs[32];
47 jobs[i] = std::thread(job_set, i);
56 jobs[i] = std::thread(job_clear, i);
110 memDelta(void *p, void *q) in memDelta() argument
112 return uintptr_t(q) - uintptr_t(p); in memDelta()
292 static int alive; member
300 alive++; in testField()
307 alive--; in ~testField()
310 int testField::alive = 0; member in testField
/dports/lang/nim/nim-1.6.2/compiler/
H A Dcgendata.nim109 usesThreadVars, # true if the module uses a thread var
115 useAliveDataFromDce # use the `alive: IntSet` field instead of
116 # computing alive data on our own.
131 nimtv*: Rope # Nim thread vars; the struct body
136 # effort is to store all thread vars in a ROD
158 alive*: IntSet # symbol IDs of alive data as computed by `dce.nim`
178 template config*(p: BProc): ConfigRef = p.module.g.config
184 proc s*(p: BProc, s: TCProcSection): var Rope {.inline.} =
186 result = p.blocks[^1].sections[s]
188 proc procSec*(p: BProc, s: TCProcSection): var Rope {.inline.} =
[all …]
/dports/editors/emacs/emacs-27.2/src/
H A Dprocess.h120 Lisp_Object thread; member
167 bool_bf alive : 1; member
235 pset_childp (struct Lisp_Process *p, Lisp_Object val) in pset_childp() argument
237 p->childp = val; in pset_childp()
241 pset_status (struct Lisp_Process *p, Lisp_Object val) in pset_status() argument
243 p->status = val; in pset_status()
248 pset_gnutls_cred_type (struct Lisp_Process *p, Lisp_Object val) in pset_gnutls_cred_type() argument
250 p->gnutls_cred_type = val; in pset_gnutls_cred_type()
/dports/textproc/kibana6/kibana-6.8.16-darwin-x86_64/node_modules/thread-loader/
H A DREADME.md11 <h1>thread-loader</h1>
12 <p>Runs the following loaders in a worker pool.</p>
18 npm install --save-dev thread-loader
47 "thread-loader",
61 loader: "thread-loader",
82 // can be set to Infinity for watching builds to keep workers alive
106 const threadLoader = require('thread-loader');
138 [npm]: https://img.shields.io/npm/v/thread-loader.svg
139 [npm-url]: https://npmjs.com/package/thread-loader
141 [deps]: https://david-dm.org/webpack-contrib/thread-loader.svg
[all …]
/dports/editors/emacs-devel/emacs-4d1968b/src/
H A Dprocess.h120 Lisp_Object thread; member
167 bool_bf alive : 1; member
235 pset_childp (struct Lisp_Process *p, Lisp_Object val) in pset_childp() argument
237 p->childp = val; in pset_childp()
241 pset_status (struct Lisp_Process *p, Lisp_Object val) in pset_status() argument
243 p->status = val; in pset_status()
248 pset_gnutls_cred_type (struct Lisp_Process *p, Lisp_Object val) in pset_gnutls_cred_type() argument
250 p->gnutls_cred_type = val; in pset_gnutls_cred_type()
/dports/misc/gnome-devel-docs/gnome-devel-docs-40.3/platform-demos/C/
H A Dcustom-gsource.c.page28 <p>
33 </p>
39 <p>
46 <p>
52 <p>
63 <p>
66 source (potentially from another thread).
69 <p>
137 <code>GSource</code> and <code>TRUE</code> to keep it alive, just as for
182 object alive while the source is still alive:
[all …]
/dports/www/resin3/resin-3.1.16/webapps/resin-doc/examples/jca-work/
H A Dindex.xtp8 <p>Resources using threads will want to use JCA's work management API.
13 implementation.</p>
37 <p>A <code>Work</code> task implements the
40 public <code>run()</code> method as the main thread method.
44 <p>The example task increments a counter and sleeps.
45 The <code>run</code> method has the main loop.</p>
49 server is still alive. It is important that <code>_isActive</code> is
53 <code>release()</code> before the run thread started.</p>
55 <p>The task uses <code>wait(long)</code> for sleeping.
108 to simplify the example.</p>
[all …]
/dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/libpijul-1.0.0-alpha.49/src/
H A Drecord.rs311 workers.push(std::thread::spawn(move || { in record()
396 t.thread().unpark() in record()
434 t.thread().unpark() in record()
517 |p| txn.get_external(&p).unwrap().map(From::from), in delete_obsolete_children()
803 |p| txn_.get_external(&p).unwrap().map(From::from), in record_existing_file()
1053 alive: Vec::new(), in collect_moved_edges()
1088 let v = alive in collect_moved_edges()
1093 let v = alive in collect_moved_edges()
1107 |p| txn.get_external(&p).unwrap().map(From::from), in collect_moved_edges()
1205 let v = alive in collect_moved_edges()
[all …]

12345678910>>...93