/external/chromium_org/third_party/libjingle/source/talk/examples/call/ |
H A D | callclient_unittest.cc | 37 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 D | call_main.cc | 445 // 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 D | message_pump_libevent_unittest.cc | 45 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 D | message_pump_io_ios.cc | 52 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 D | message_pump_io_ios_unittest.cc | 129 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 D | message_pump_io_ios.h | 75 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 D | message_pump_libevent.h | 78 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 D | message_pump_libevent.cc | 26 // 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 D | message_pump_glib.cc | 38 // 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 D | message_pump_aurax11.cc | 34 MessagePumpAuraX11* pump = static_cast<MessagePumpAuraX11*>(data); local 35 return pump->DispatchXEvents();
|
/external/chromium/base/ |
H A D | message_pump_libevent.h | 73 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 D | message_pump_libevent.cc | 25 // 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 D | message_pump_glib.cc | 40 // 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 D | message_loop.cc | 278 // 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 D | chat_main.cc | 137 // 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 D | measure_page_load_time.js | 53 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 D | pcp_main.cc | 632 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 D | call_main.cc | 347 // 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 D | messagepump_unittest.py | 55 pump = MessagePump(delegate, queue)
|
/external/proguard/src/proguard/obfuscate/ |
H A D | MappingReader.java | 47 public void pump(MappingProcessor mappingProcessor) throws IOException method in class:MappingReader
|
H A D | Obfuscator.java | 135 reader.pump(keeper);
|
/external/chromium_org/content/browser/devtools/ |
H A D | tethering_handler.cc | 232 SocketPump* pump = new SocketPump(delegate_, accept_socket_.release()); 233 std::string name = pump->Init();
|
/external/chromium_org/ipc/ |
H A D | ipc_sync_channel_unittest.cc | 99 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 D | ReTrace.java | 116 mappingReader.pump(this);
|
/external/proguard/lib/ |
H A D | proguard.jar | META-INF/ META-INF/MANIFEST.MF proguard/evaluation/Stack.class Stack.java package proguard ... |