| /external/grpc-grpc/doc/ |
| D | fork_support.md | 7 etc, to work around the GIL. These modules call ```fork()``` underneath the hood. Various issues ha…
9 gRPC core, which uses multithreading for performance, and hence doesn't support ```fork()```.
20 RPCs prior to the fork. Attempting to fork with an active channel that
24 A regression was noted in cases where users are doing fork/exec. This
31 immediately following fork. It will disable the fork handlers.
35 the background c-threads when fork was called. This does not shut down the
42 The workaround when using fork/exec by setting
44 [this PR](https://github.com/grpc/grpc/pull/14647), fork
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_signal/ |
| D | 1-2.c | 69 if (td->fork) \
78 if (td->fork) \
118 int fork; /* 0: Test between threads. ~ !0: Test across processes, if supported (mmap) */ member
203 char fork; /* the children are processes */ member
400 td->fork = 0; in main()
455 if ((pshared > 0) && (scenarii[scenar].fork != 0)) { in main()
456 td->fork = 1; in main()
490 if (td->fork == 0) { in main()
499 p_child[ch] = fork(); in main()
575 if (td->fork == 0) { in main()
|
| /external/linux-kselftest/tools/testing/selftests/ftrace/test.d/ftrace/ |
| D | func-filter-pid.tc | 25 if [ ! -f options/function-fork ]; then
34 orig_value=`grep function-fork trace_options`
62 echo nofunction-fork > trace_options
84 echo function-fork > trace_options
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_broadcast/ |
| D | 2-3.c | 46 if (td->fork) { \
54 if (td->fork) { \
87 int fork; member
149 char fork; member
354 td->fork = 0; in main()
403 if ((pshared > 0) && (scenarii[scenar].fork != 0)) in main()
404 td->fork = 1; in main()
432 if (td->fork == 0) { in main()
441 children.ch[children.nb].p = fork(); in main()
504 if (td->fork == 0) { in main()
|
| D | 1-2.c | 51 if (td->fork) { \
63 if (td->fork) { \
102 int fork; member
163 char fork; /* the children are processes */ member
425 td->fork = 0; in main()
472 if ((pshared > 0) && (scenarii[scenar].fork != 0)) in main()
473 td->fork = 1; in main()
513 if (td->fork == 0) { in main()
542 tmp->data.p = fork(); in main()
623 if (td->fork == 0) { in main()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_cond_destroy/ |
| D | 2-1.c | 70 if (td->fork) \
79 if (td->fork) \
119 int fork; /* 0: Test between threads. ~ !0: Test across processes, if supported (mmap) */ member
206 char fork; /* the children are processes */ member
442 td->fork = 0; in main()
497 if ((pshared > 0) && (scenarii[scenar].fork != 0)) { in main()
498 td->fork = 1; in main()
535 if (td->fork == 0) { in main()
544 p_child[ch] = fork(); in main()
729 if (td->fork == 0) { in main()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | fork_posix.pyx.pxi | 27 # that will fork() without exec(). When enabled, gRPC Python will attempt to
28 # pause all of its internally created threads before the fork syscall proceeds.
31 # its own calling into gRPC when fork is invoked. Any callbacks from gRPC
47 'Failed to shutdown gRPC Python threads prior to fork. '
48 'Behavior after fork will be undefined.')
61 # block_if_fork_in_progress() when fork occurs. Reset the lock here.
64 # when fork occurs.
76 _LOGGER.error('Failed to shutdown gRPC Core after fork()')
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 121 Context fork = Context.ROOT.fork(); in rootCanBeAttached() local
122 Context toRestore1 = fork.attach(); in rootCanBeAttached()
126 Context toRestore3 = fork.attach(); in rootCanBeAttached()
127 assertTrue(fork.isCurrent()); in rootCanBeAttached()
129 fork.detach(toRestore3); in rootCanBeAttached()
131 fork.detach(toRestore1); in rootCanBeAttached()
442 Context fork = base.fork(); in nonCascadingCancellationDoesNotNotifyForked() local
443 fork.addListener(cancellationListener, MoreExecutors.directExecutor()); in nonCascadingCancellationDoesNotNotifyForked()
445 assertEquals(0, fork.listenerCount()); in nonCascadingCancellationDoesNotNotifyForked()
448 assertFalse(fork.isCancelled()); in nonCascadingCancellationDoesNotNotifyForked()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/ftrace/test.d/event/ |
| D | event-pid.tc | 9 echo 0 > options/event-fork
29 echo 0 > options/event-fork
58 echo 1 > options/event-fork
|
| /external/ltp/testcases/kernel/syscalls/getrusage/ |
| D | getrusage03.c | 103 switch (pid = fork()) { in inherit_fork()
133 switch (pid = fork()) { in inherit_fork2()
158 switch (pid = fork()) { in fork_malloc()
186 switch (pid = fork()) { in grandchild_maxrss()
220 switch (pid = fork()) { in zombie()
263 switch (pid = fork()) { in sig_ign()
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_wait/ |
| D | stress1.c | 129 int fork; /* 0: Test between threads. ~ !0: Test across processes, if supported (mmap) */ member
212 int fork; member
280 if (cd->fork == 0) { in threaded_A()
287 child_p = fork(); in threaded_A()
319 if (cd->fork == 0) { in threaded_A()
565 if ((pshared > 0) && (scenarii[i].fork != 0)) { in main()
581 CD.fork = do_fork; in main()
|
| /external/ltp/testcases/open_posix_testsuite/stress/threads/pthread_cond_timedwait/ |
| D | stress1.c | 119 int fork; /* 0: Test between threads. ~ !0: Test across processes, if supported (mmap) */ member
203 int fork; member
283 if (cd->fork == 0) { in threaded_A()
290 child_p = fork(); in threaded_A()
331 if (cd->fork == 0) { in threaded_A()
571 if ((pshared > 0) && (scenarii[i].fork != 0)) { in main()
587 CD.fork = do_fork; in main()
|
| /external/google-breakpad/src/client/linux/handler/ |
| D | exception_handler_unittest.cc | 225 const pid_t child = fork(); in ChildCrash()
322 const pid_t child = fork(); in TEST()
334 const pid_t child = fork(); in TEST()
346 const pid_t child = fork(); in TEST()
358 const pid_t child = fork(); in TEST()
370 const pid_t child = fork(); in TEST()
386 const pid_t child = fork(); in TEST()
416 const pid_t child = fork(); in TEST()
432 const pid_t child = fork(); in TEST()
448 const pid_t child = fork(); in TEST()
[all …]
|
| /external/jemalloc_new/test/unit/ |
| D | fork.c | 52 pid = fork(); in TEST_BEGIN()
79 int pid = fork(); in do_fork_thd()
118 int pid = fork(); in TEST_BEGIN()
|
| /external/libnetfilter_conntrack/qa/ |
| D | test_api.c | 506 ret = fork(); in main()
536 ret = fork(); in main()
547 ret = fork(); in main()
588 ret = fork(); in main()
598 ret = fork(); in main()
619 ret = fork(); in main()
633 ret = fork(); in main()
644 ret = fork(); in main()
662 ret = fork(); in main()
678 ret = fork(); in main()
[all …]
|
| /external/perf_data_converter/src/ |
| D | perf_data_handler.cc | 86 void UpdateMapsWithForkEvent(const quipper::PerfDataProto_ForkEvent& fork);
153 const quipper::PerfDataProto_ForkEvent& fork) { in UpdateMapsWithForkEvent() argument
154 if (fork.pid() == fork.ppid()) { in UpdateMapsWithForkEvent()
158 const auto& it = pid_to_mmaps_.find(fork.ppid()); in UpdateMapsWithForkEvent()
160 pid_to_mmaps_[fork.pid()] = std::unique_ptr<MMapIntervalMap>( in UpdateMapsWithForkEvent()
163 auto comm_it = pid_to_comm_event_.find(fork.ppid()); in UpdateMapsWithForkEvent()
165 pid_to_comm_event_[fork.pid()] = comm_it->second; in UpdateMapsWithForkEvent()
167 auto exec_mmap_it = pid_to_executable_mmap_.find(fork.ppid()); in UpdateMapsWithForkEvent()
169 pid_to_executable_mmap_[fork.pid()] = exec_mmap_it->second; in UpdateMapsWithForkEvent()
|
| /external/ltp/testcases/kernel/syscalls/waitid/ |
| D | waitid01.c | 71 TEST(fork()); in main()
88 TEST(fork()); in main()
106 TEST(pid = fork()); in main()
|
| /external/ltp/testcases/kernel/syscalls/unshare/ |
| D | unshare01.c | 170 pid1 = fork(); //call to fork() in main()
206 pid1 = fork(); in main()
242 pid1 = fork(); in main()
|
| /external/ltp/tools/genload/ |
| D | stress.c | 203 switch (pid = fork()) { in main()
221 switch (pid = fork()) { in main()
241 switch (pid = fork()) { in main()
260 switch (pid = fork()) { in main()
480 switch (pid = fork()) { in hogcpu()
556 switch (pid = fork()) { in hogio()
637 switch (pid = fork()) { in hogvm()
766 switch (pid = fork()) { in hoghdd()
|
| D | genload.c | 203 switch (pid = fork()) { in main()
221 switch (pid = fork()) { in main()
241 switch (pid = fork()) { in main()
260 switch (pid = fork()) { in main()
480 switch (pid = fork()) { in hogcpu()
556 switch (pid = fork()) { in hogio()
637 switch (pid = fork()) { in hogvm()
766 switch (pid = fork()) { in hoghdd()
|
| /external/ltp/testcases/kernel/fs/doio/ |
| D | forker.c | 132 switch (fork()) { in background()
171 if ((pid = fork()) == -1) { in forker()
198 if ((pid = fork()) == -1) { in forker()
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sem_unlink/ |
| D | 2-2.c | 150 p1 = fork(); in main()
167 p2 = fork(); in main()
178 p3 = fork(); in main()
|
| /external/ltp/testcases/kernel/mem/mtest01/ |
| D | mtest01.c | 193 pid = fork(); in main()
207 pid = fork(); in main()
226 pid = fork(); in main()
245 pid = fork(); in main()
|
| /external/ltp/testcases/kernel/syscalls/mmap/ |
| D | mmap10.c | 144 switch (n = fork()) { in mmapzero()
155 switch (n = fork()) { in mmapzero()
164 switch (n = fork()) { in mmapzero()
|
| /external/strace/tests-m32/ |
| D | siginfo.c | 54 pid_t pid = fork(); in main()
98 pid = fork(); in main()
128 pid = fork(); in main()
|