| /external/chromium_org/third_party/libjingle/source/talk/examples/call/ |
| 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");
|
| 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/base/ |
| message_pump_libevent.h | 73 void set_pump(MessagePumpLibevent* pump) { pump_ = pump; }
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);
|
| 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 = controller->pump() local
[all...] |
| 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:__anon4130::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...] |
| 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/base/message_loop/ |
| message_pump_io_ios.h | 75 void set_pump(base::WeakPtr<MessagePumpIOSForIO> pump) { pump_ = pump; }
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);
|
| message_pump_libevent.h | 78 void set_pump(MessagePumpLibevent* pump) { pump_ = pump; }
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);
|
| 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);
|
| 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);
[all...] |
| 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->WatchFileDescriptor(pipefds_[1]
[all...] |
| 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 this socket will belong to when we add it
347 MessagePumpLibevent* pump = controller->pump(); local
[all...] |
| 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::__anon6220::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...] |
| message_pump_aurax11.cc | 34 MessagePumpAuraX11* pump = static_cast<MessagePumpAuraX11*>(data); local
35 return pump->DispatchXEvents();
|
| /external/chromium_org/third_party/libjingle/source/talk/examples/chat/ |
| 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/third_party/libjingle/source/talk/examples/pcp/ |
| 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.client(), &session_manager)
[all...] |
| /external/chromium/third_party/libjingle/source/talk/examples/call/ |
| 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/ |
| messagepump_unittest.py | 55 pump = MessagePump(delegate, queue)
|
| /external/proguard/src/proguard/obfuscate/ |
| MappingReader.java | 47 public void pump(MappingProcessor mappingProcessor) throws IOException method in class:MappingReader
|
| Obfuscator.java | 135 reader.pump(keeper);
|
| /external/chromium_org/content/browser/devtools/ |
| tethering_handler.cc | 232 SocketPump* pump = new SocketPump(delegate_, accept_socket_.release());
233 std::string name = pump->Init();
|
| /external/chromium_org/tools/measure_page_load_time/ff_ext/content/ |
| 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/ipc/ |
| ipc_sync_channel_unittest.cc | 99 bool SendAnswerToLife(bool pump, int timeout, bool succeed) {
102 if (pump)
109 bool SendDouble(bool pump, bool succeed) {
112 if (pump)
[all...] |
| /external/proguard/src/proguard/retrace/ |
| ReTrace.java | 116 mappingReader.pump(this);
|
| /external/proguard/lib/ |
| proguard.jar | |
