| /external/python/cpython2/Lib/multiprocessing/ |
| pool.py | 2 # Module providing the `Pool` class for managing a process pool
47 from multiprocessing import Process, cpu_count, TimeoutError
127 # Class representing a process pool
134 Process = Process
215 w = self.Process(target=worker,
221 w.name = w.name.replace('Process', 'PoolWorker')
724 from .dummy import Process
|
| /external/python/cpython3/Lib/multiprocessing/ |
| context.py | 5 from . import process
37 current_process = staticmethod(process.current_process)
38 active_children = staticmethod(process.active_children)
49 '''Returns a manager associated with a running server process
116 '''Returns a process pool object'''
144 '''Check whether this is a fake forked process in a frozen executable.
180 '''Set list of module names to try to load in forkserver process.
219 class Process(process.BaseProcess):
223 return _default_context.get_context().Process._Popen(process_obj
[all...] |
| pool.py | 2 # Module providing the `Pool` class for managing a process pool
135 # Class representing a process pool
144 def Process(self, *args, **kwds):
145 return self._ctx.Process(*args, **kwds)
224 w = self.Process(target=worker,
231 w.name = w.name.replace('Process', 'PoolWorker')
748 def Process(*args, **kwds):
749 from .dummy import Process
750 return Process(*args, **kwds)
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/ |
| Process.java | 36 public class Process {
56 public Process() {
111 throw new RuntimeException("Attempted to start process that is already running.");
135 Log.v("Process " + pid + " exited with result code " + result + ".");
164 android.os.Process.killProcess(mPid.get());
165 Log.v("Killed process " + mPid);
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| ApplicationManagerFacade.java | 134 android.os.Process.killProcess(info.pid);
135 android.os.Process.sendSignal(info.pid, android.os.Process.SIGNAL_KILL);
|
| /external/tensorflow/tensorflow/core/profiler/internal/ |
| tfprof_timeline.h | 63 // A process (time series of events) in the timeline.
64 class Process {
66 Process(const string& device, int64 pid) : device(device), pid(pid) {}
78 TimeNode(Process* process, GraphNode* node, int64 start_micros,
80 : process(process),
89 Process* process; member in class:tensorflow::tfprof::TimeNode
185 std::map<string, std::unique_ptr<Process>> process_
[all...] |
| /external/v8/src/crankshaft/ |
| hydrogen-load-elimination.cc | 48 HLoadEliminationTable* Process(HInstruction* instr, Zone* zone) {
52 TRACE((" process L%d field %d (o%d)\n",
66 TRACE((" process S%d field %d (o%d) = v%d\n",
200 // Process a load instruction, updating internal table state. If a previous
227 // Process a store instruction, updating internal table state. If a previous
445 // Process a possibly side-effecting instruction.
446 void Process(HInstruction* instr, Zone* zone) {
|
| /external/webrtc/webrtc/modules/audio_coding/neteq/ |
| merge.cc | 41 size_t Merge::Process(int16_t* input, size_t input_length,
183 expand_->Process(&expanded_temp);
|
| /external/webrtc/webrtc/modules/audio_processing/agc/ |
| agc_manager_direct.cc | 232 void AgcManagerDirect::Process(const int16_t* audio,
241 // We have to wait until the first process call to check the volume,
246 if (agc_->Process(audio, length, sample_rate_hz) != 0) {
247 LOG(LS_ERROR) << "Agc::Process failed";
|
| /external/webrtc/webrtc/modules/audio_processing/test/ |
| debug_dump_test.cc | 79 void Process(size_t num_blocks);
187 void DebugDumpGenerator::Process(size_t num_blocks) {
475 generator.Process(100);
484 generator.Process(100);
492 generator.Process(100);
501 generator.Process(100);
504 generator.Process(100);
513 generator.Process(100);
516 generator.Process(100);
525 generator.Process(100)
[all...] |
| /external/webrtc/webrtc/modules/media_file/ |
| media_file_impl.cc | 98 int32_t MediaFileImpl::Process()
101 "Process: This method is not used by MediaFile class.");
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/ |
| nada.cc | 240 int NadaBweSender::Process() {
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| receive_statistics_impl.cc | 309 incoming_bitrate_.Process();
457 int32_t ReceiveStatisticsImpl::Process() {
533 int32_t NullReceiveStatistics::Process() { return 0; }
|
| /external/webrtc/webrtc/modules/video_capture/ |
| video_capture_impl.cc | 86 // returns the number of milliseconds until the module want a worker thread to call Process
95 // Process any pending tasks such as timeouts
96 int32_t VideoCaptureImpl::Process()
|
| /external/webrtc/webrtc/modules/video_coding/ |
| video_receiver.cc | 65 int32_t VideoReceiver::Process() {
119 // TODO(holmer): Add API for changing Process interval and make sure it's
156 // We need a Process call more often if we are relying on
|
| /external/webrtc/webrtc/modules/video_render/ |
| video_render_impl.cc | 122 int32_t ModuleVideoRenderImpl::Process()
|
| video_render_internal_impl.cc | 302 int32_t ModuleVideoRenderImpl::Process()
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| data_log.cc | 419 static_cast<DataLogImpl*>(obj)->Process();
423 void DataLogImpl::Process() {
|
| /external/webrtc/webrtc/test/channel_transport/ |
| udp_socket2_manager_win.cc | 564 return pWorker->Process();
567 // Process should always return true. Stopping the worker threads is done in
569 bool UdpSocket2WorkerWindows::Process()
598 "UdpSocket2WorkerWindows(%d)::Process(), pSocket == 0, end thread",
|
| /external/webrtc/webrtc/video/ |
| overuse_frame_detector.cc | 148 // Old frames have been skipped by the capture process thread.
280 int32_t OveruseFrameDetector::Process() {
285 // Used to protect against Process() being called too often.
|
| /frameworks/base/core/java/android/ddm/ |
| DdmHandleHello.java | 110 * Process the request.
149 out.putInt(android.os.Process.myPid());
|
| /frameworks/base/core/java/android/net/ |
| NetworkRequest.java | 24 import android.os.Process;
149 mNetworkCapabilities.setSingleUid(Process.myUid());
|
| /frameworks/base/core/java/com/android/internal/os/ |
| WrapperInit.java | 19 import android.os.Process;
37 * Startup class for the wrapper process.
51 * wrapper process instead of by forking Zygote.
54 * the pid of this process, or 0 if none.
74 os.writeInt(Process.myPid());
78 Slog.d(TAG, "Could not write pid of wrapped process to Zygote pipe.", ex);
141 * wrapper process.
|
| /frameworks/base/services/core/java/com/android/server/content/ |
| SyncLogger.java | 57 // Special UID used for logging to denote the self process.
178 mStringBuilder.append(android.os.Process.myTid());
|
| /frameworks/opt/net/wifi/service/java/com/android/server/wifi/hotspot2/ |
| PasspointNetworkEvaluator.java | 20 import android.os.Process;
153 mWifiConfigManager.addOrUpdateNetwork(config, Process.WIFI_UID);
158 mWifiConfigManager.enableNetwork(result.getNetworkId(), false, Process.WIFI_UID);
|
