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.cc445 // Need to pump messages on our main thread on Windows.
455 buzz::XmppPump pump; local
456 CallClient *client = new CallClient(pump.client(), caps_node, caps_ver);
485 pump.client()->SignalLogInput.connect(&debug_log_, &DebugLog::Input);
486 pump.client()->SignalLogOutput.connect(&debug_log_, &DebugLog::Output);
490 pump.DoLogin(xcs, new buzz::XmppSocket(buzz::TLS_REQUIRED), new XmppAuth());
492 pump.DoDisconnect();
/external/chromium_org/base/message_loop/
H A Dmessage_pump_libevent_unittest.cc45 MessagePumpLibevent* pump,
47 pump->OnLibeventNotification(0, EV_WRITE | EV_READ, controller);
125 scoped_ptr<MessagePumpLibevent> pump(new MessagePumpLibevent);
129 pump->WatchFileDescriptor(pipefds_[1],
133 OnLibeventNotification(pump.get(), watcher);
150 scoped_ptr<MessagePumpLibevent> pump(new MessagePumpLibevent);
153 pump->WatchFileDescriptor(pipefds_[1],
157 OnLibeventNotification(pump.get(), &watcher);
44 OnLibeventNotification( MessagePumpLibevent* pump, MessagePumpLibevent::FileDescriptorWatcher* controller) argument
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
347 MessagePumpLibevent* pump = controller->pump(); local
[all...]
H A Dmessage_pump_glib.cc38 // On each iteration of the GLib pump, it calls each source's Prepare function.
78 // For the GLib pump we try to follow the Windows UI pump model:
86 MessagePumpGlib* pump; member in struct:base::__anon3814::WorkSource
91 *timeout_ms = static_cast<WorkSource*>(source)->pump->HandlePrepare();
100 return static_cast<WorkSource*>(source)->pump->HandleCheck();
107 static_cast<WorkSource*>(source)->pump->HandleDispatch();
132 // This keeps the state of whether the pump got signaled that there was new
154 static_cast<WorkSource*>(work_source_)->pump = this;
173 // Make sure we only run this on one thread. X/GTK only has one message pump
[all...]
H A Dmessage_pump_aurax11.cc34 MessagePumpAuraX11* pump = static_cast<MessagePumpAuraX11*>(data); local
35 return pump->DispatchXEvents();
/external/chromium/base/
H A Dmessage_pump_libevent.h73 void set_pump(MessagePumpLibevent* pump) { pump_ = pump; } argument
74 MessagePumpLibevent* pump() { return pump_; } function in class:base::MessagePumpLibevent::FileDescriptorWatcher
78 void OnFileCanReadWithoutBlocking(int fd, MessagePumpLibevent* pump);
79 void OnFileCanWriteWithoutBlocking(int fd, MessagePumpLibevent* pump);
H A Dmessage_pump_libevent.cc25 // struct event_base (of which there is one per message pump), and
94 int fd, MessagePumpLibevent* pump) {
95 pump->WillProcessIOEvent();
97 pump->DidProcessIOEvent();
101 int fd, MessagePumpLibevent* pump) {
102 pump->WillProcessIOEvent();
104 pump->DidProcessIOEvent();
174 // Set current interest mask and message pump for this event.
177 // Tell libevent which message pump this socket will belong to when we add it.
330 MessagePumpLibevent* pump local
93 OnFileCanReadWithoutBlocking( int fd, MessagePumpLibevent* pump) argument
100 OnFileCanWriteWithoutBlocking( int fd, MessagePumpLibevent* pump) 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 base::MessagePumpForUI* pump; member in struct:__anon1724::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();
137 // This keeps the state of whether the pump got signaled that there was new
156 static_cast<WorkSource*>(work_source_)->pump = this;
178 // Make sure we only run this on one thread. GTK only has one message pump
[all...]
H A Dmessage_loop.cc278 // Start the native pump if we are not already pumping.
516 scoped_refptr<base::MessagePump> pump;
523 return; // Someone else should have started the sub-pump.
525 pump = pump_;
529 // We use a stack-based reference to the message pump so that we can call
532 pump->ScheduleWork();
/external/chromium_org/third_party/libjingle/source/talk/examples/chat/
H A Dchat_main.cc137 // Need to pump messages on our main thread on Windows.
147 buzz::XmppPump* pump = new buzz::XmppPump(); local
148 ChatApp *client = new ChatApp(pump->client(), main_thread);
151 pump->DoLogin(xcs, new buzz::XmppSocket(buzz::TLS_REQUIRED), new XmppAuth());
154 pump->DoDisconnect();
/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/third_party/libjingle/source/talk/examples/pcp/
H A Dpcp_main.cc632 CustomXmppPump pump; local
633 pump.client()->SignalLogInput.connect(&debug_log_, &DebugLog::Input);
634 pump.client()->SignalLogOutput.connect(&debug_log_, &DebugLog::Output);
635 pump.DoLogin(LoginSettings(), new buzz::XmppSocket(gXmppUseTls), 0);
650 pump.SendStanza(presence.get());
653 std::string user_jid_str = pump.client()->jid().Str();
662 allocator.SetXmppClient(pump.client());
665 cricket::SecureTunnelSessionClient session_client(pump.client()->jid(),
670 cricket::TunnelSessionClient session_client(pump.client()->jid(),
674 new cricket::SessionManagerTask(pump
[all...]
/external/chromium/third_party/libjingle/source/talk/examples/call/
H A Dcall_main.cc347 // Need to pump messages on our main thread on Windows.
353 XmppPump pump; local
354 CallClient *client = new CallClient(pump.client());
378 pump.client()->SignalLogInput.connect(&debug_log_, &DebugLog::Input);
379 pump.client()->SignalLogOutput.connect(&debug_log_, &DebugLog::Output);
382 pump.DoLogin(xcs, new XmppSocket(true), NULL);
384 pump.DoDisconnect();
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/thread/
H A Dmessagepump_unittest.py55 pump = MessagePump(delegate, queue)
/external/proguard/src/proguard/obfuscate/
H A DMappingReader.java47 public void pump(MappingProcessor mappingProcessor) throws IOException method in class:MappingReader
H A DObfuscator.java135 reader.pump(keeper);
/external/chromium_org/content/browser/devtools/
H A Dtethering_handler.cc232 SocketPump* pump = new SocketPump(delegate_, accept_socket_.release());
233 std::string name = pump->Init();
/external/chromium_org/ipc/
H A Dipc_sync_channel_unittest.cc99 bool SendAnswerToLife(bool pump, int timeout, bool succeed) { argument
102 if (pump)
109 bool SendDouble(bool pump, bool succeed) { argument
112 if (pump)
/external/proguard/src/proguard/retrace/
H A DReTrace.java116 mappingReader.pump(this);
/external/proguard/lib/
H A Dproguard.jarMETA-INF/ META-INF/MANIFEST.MF proguard/evaluation/Stack.class Stack.java package proguard ...

Completed in 578 milliseconds

12