Searched refs:pump (Results 1 - 25 of 26) sorted by relevance

12

/external/chromium_org/third_party/libjingle/source/talk/examples/call/
H A Dcallclient_unittest.cc37 buzz::XmppPump pump; local
38 CallClient *client = new CallClient(pump.client(), "app", "version");
43 buzz::XmppPump pump; local
44 CallClient *client = new CallClient(pump.client(), "app", "version");
H A Dcall_main.cc443 // Need to pump messages on our main thread on Windows.
453 buzz::XmppPump pump; local
454 CallClient *client = new CallClient(pump.client(), caps_node, caps_ver);
483 pump.client()->SignalLogInput.connect(&debug_log_, &DebugLog::Input);
484 pump.client()->SignalLogOutput.connect(&debug_log_, &DebugLog::Output);
488 pump.DoLogin(xcs, new buzz::XmppSocket(buzz::TLS_REQUIRED), new XmppAuth());
490 pump.DoDisconnect();
/external/chromium_org/base/message_loop/
H A Dmessage_pump_libevent_unittest.cc47 MessagePumpLibevent* pump,
49 pump->OnLibeventNotification(0, EV_WRITE | EV_READ, controller);
87 scoped_ptr<MessagePumpLibevent> pump(new MessagePumpLibevent);
88 ASSERT_DEATH(pump->Quit(), "Check failed: in_run_. "
133 scoped_ptr<MessagePumpLibevent> pump(new MessagePumpLibevent);
137 pump->WatchFileDescriptor(pipefds_[1],
141 OnLibeventNotification(pump.get(), watcher);
158 scoped_ptr<MessagePumpLibevent> pump(new MessagePumpLibevent);
161 pump->WatchFileDescriptor(pipefds_[1],
165 OnLibeventNotification(pump
46 OnLibeventNotification( MessagePumpLibevent* pump, MessagePumpLibevent::FileDescriptorWatcher* controller) argument
[all...]
H A Dmessage_pump_glib.cc40 // On each iteration of the GLib pump, it calls each source's Prepare function.
80 // For the GLib pump we try to follow the Windows UI pump model:
88 MessagePumpGlib* pump; member in struct:base::__anon2370::WorkSource
93 *timeout_ms = static_cast<WorkSource*>(source)->pump->HandlePrepare();
102 return static_cast<WorkSource*>(source)->pump->HandleCheck();
109 static_cast<WorkSource*>(source)->pump->HandleDispatch();
123 // thread. X only has one message pump so we can only have one UI loop per
127 // Tracks the pump the most recent pump tha
130 MessagePumpGlib* pump; member in struct:base::__anon2370::ThreadInfo
143 CheckThread(MessagePumpGlib* pump) argument
155 PumpDestroyed(MessagePumpGlib* pump) argument
[all...]
H A Dmessage_pump_io_ios.cc52 MessagePumpIOSForIO* pump) {
54 pump->WillProcessIOEvent();
56 pump->DidProcessIOEvent();
61 MessagePumpIOSForIO* pump) {
63 pump->WillProcessIOEvent();
65 pump->DidProcessIOEvent();
85 // WatchFileDescriptor should be called on the pump thread. It is not
186 MessagePumpIOSForIO* pump = controller->pump().get(); local
187 DCHECK(pump);
50 OnFileCanReadWithoutBlocking( int fd, MessagePumpIOSForIO* pump) argument
59 OnFileCanWriteWithoutBlocking( int fd, MessagePumpIOSForIO* pump) argument
[all...]
H A Dmessage_pump_io_ios_unittest.cc129 scoped_ptr<MessagePumpIOSForIO> pump(new MessagePumpIOSForIO);
133 pump->WatchFileDescriptor(pipefds_[1],
143 MessagePumpIOSForIO* pump,
146 pump_(pump),
165 scoped_ptr<MessagePumpIOSForIO> pump(new MessagePumpIOSForIO);
167 StopWatcher delegate(&watcher, pump.get());
168 pump->WatchFileDescriptor(pipefds_[1],
176 scoped_ptr<MessagePumpIOSForIO> pump(new MessagePumpIOSForIO);
178 StopWatcher delegate(&watcher, pump.get(), alternate_pipefds_[1]);
179 pump
142 StopWatcher(MessagePumpIOSForIO::FileDescriptorWatcher* controller, MessagePumpIOSForIO* pump, int fd_to_start_watching = -1) argument
[all...]
H A Dmessage_pump_io_ios.h75 void set_pump(base::WeakPtr<MessagePumpIOSForIO> pump) { pump_ = pump; } argument
76 const base::WeakPtr<MessagePumpIOSForIO>& pump() const { return pump_; } function in class:base::MessagePumpIOSForIO::FileDescriptorWatcher
80 void OnFileCanReadWithoutBlocking(int fd, MessagePumpIOSForIO* pump);
81 void OnFileCanWriteWithoutBlocking(int fd, MessagePumpIOSForIO* pump);
H A Dmessage_pump_libevent.h78 void set_pump(MessagePumpLibevent* pump) { pump_ = pump; } argument
79 MessagePumpLibevent* pump() const { return pump_; } function in class:base::MessagePumpLibevent::FileDescriptorWatcher
83 void OnFileCanReadWithoutBlocking(int fd, MessagePumpLibevent* pump);
84 void OnFileCanWriteWithoutBlocking(int fd, MessagePumpLibevent* pump);
H A Dmessage_pump_libevent.cc26 // struct event_base (of which there is one per message pump), and
93 int fd, MessagePumpLibevent* pump) {
98 pump->WillProcessIOEvent();
100 pump->DidProcessIOEvent();
104 int fd, MessagePumpLibevent* pump) {
106 pump->WillProcessIOEvent();
108 pump->DidProcessIOEvent();
147 // WatchFileDescriptor should be called on the pump thread. It is not
182 // Set current interest mask and message pump for this event.
185 // Tell libevent which message pump thi
92 OnFileCanReadWithoutBlocking( int fd, MessagePumpLibevent* pump) argument
103 OnFileCanWriteWithoutBlocking( int fd, MessagePumpLibevent* pump) argument
345 MessagePumpLibevent* pump = controller->pump(); local
[all...]
H A Dmessage_loop_test.cc89 scoped_ptr<MessagePump> pump(factory());
90 MessageLoop loop(pump.Pass());
118 scoped_ptr<MessagePump> pump(factory());
119 MessageLoop loop(pump.Pass());
141 scoped_ptr<MessagePump> pump(factory());
142 MessageLoop loop(pump.Pass());
166 scoped_ptr<MessagePump> pump(factory());
167 MessageLoop loop(pump.Pass());
196 scoped_ptr<MessagePump> pump(factory());
197 MessageLoop loop(pump
[all...]
H A Dmessage_loop.cc109 MessagePumpForIO* ToPumpIO(MessagePump* pump) { argument
110 return static_cast<MessagePumpForIO*>(pump);
143 MessageLoop::MessageLoop(scoped_ptr<MessagePump> pump) argument
144 : pump_(pump.Pass()),
349 // Kick the native pump just in case we enter a OS-driven nested message
H A Dmessage_loop.h50 // variants. Depending on the type of message pump used by the MessageLoop
61 // message pump is created. That inner pump then processes native messages
97 // where it does not use the main thread specific pump factory.
117 explicit MessageLoop(scoped_ptr<base::MessagePump> pump);
405 // Invokes the actual run loop using the message pump.
434 // Wakes up the message pump. Can be called on any thread. The caller is
480 // insider a (accidentally induced?) nested message pump.
/external/chromium_org/tools/measure_page_load_time/ff_ext/content/
H A Dmeasure_page_load_time.js53 MPLT.pump = Components.classes['@mozilla.org/network/input-stream-pump;1']
55 MPLT.pump.init(MPLT.streamInput, -1, -1, 0, 0, false);
56 MPLT.pump.asyncRead(MPLT.dataListener,null);
/external/chromium_org/chrome/browser/chromeos/attestation/
H A Dattestation_policy_browsertest.cc97 base::RunLoop pump; local
98 pump.RunUntilIdle();
/external/chromium_org/content/renderer/
H A Drenderer_main.cc148 // As long as scrollbars on Mac are painted with Cocoa, the message pump
151 scoped_ptr<base::MessagePump> pump(new base::MessagePumpNSRunLoop());
152 base::MessageLoop main_message_loop(pump.Pass());
/external/proguard/src/proguard/obfuscate/
H A DMappingReader.java47 public void pump(MappingProcessor mappingProcessor) throws IOException method in class:MappingReader
H A DObfuscator.java146 reader.pump(keeper);
/external/chromium_org/components/devtools_bridge/android/java/src/org/chromium/components/devtools_bridge/
H A DSocketTunnelBase.java317 open = pump();
326 private boolean pump() throws IOException { method in class:SocketTunnelBase.ConnectionBase
/external/chromium_org/jingle/notifier/base/
H A Dxmpp_connection_unittest.cc79 scoped_ptr<base::MessagePump> pump(new base::MessagePumpDefault());
80 message_loop_.reset(new base::MessageLoop(pump.Pass()));
235 // We don't destroy XmppConnection's task pump on destruction, but it
/external/chromium_org/content/browser/devtools/
H A Dtethering_handler.cc224 SocketPump* pump = new SocketPump(delegate_, accept_socket_.release());
225 std::string name = pump->Init();
/external/chromium_org/content/gpu/
H A Dgpu_main.cc175 scoped_ptr<base::MessagePump> pump(new base::MessagePumpCFRunLoop());
176 base::MessageLoop main_message_loop(pump.Pass());
/external/chromium_org/ipc/
H A Dipc_sync_channel_unittest.cc96 bool SendAnswerToLife(bool pump, bool succeed) { argument
99 if (pump)
106 bool SendDouble(bool pump, bool succeed) { argument
109 if (pump)
/external/proguard/src/proguard/retrace/
H A DReTrace.java113 mappingReader.pump(this);
/external/chromium_org/jingle/glue/
H A Dchrome_async_socket_unittest.cc153 scoped_ptr<base::MessagePump> pump(new base::MessagePumpDefault());
154 message_loop_.reset(new base::MessageLoop(pump.Pass()));
193 // Run any tasks that we forgot to pump.
/external/proguard/lib/
H A Dproguard.jarMETA-INF/ META-INF/MANIFEST.MF proguard/DataEntryWriterFactory.class DataEntryWriterFactory.java package proguard public ...

Completed in 2426 milliseconds

12