| /external/smack/src/org/jivesoftware/smackx/ |
| SharedGroupManager.java | 54 // Create a packet collector to listen for a response.
55 PacketCollector collector =
local
61 IQ result = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
63 collector.cancel();
|
| /external/smack/src/org/jivesoftware/smackx/filetransfer/ |
| FaultTolerantNegotiator.java | 77 PacketCollector collector = connection.createPacketCollector( local
89 futures.add(service.submit(new NegotiatorService(collector)));
90 futures.add(service.submit(new NegotiatorService(collector)));
122 collector.cancel();
170 private PacketCollector collector; field in class:FaultTolerantNegotiator.NegotiatorService
172 NegotiatorService(PacketCollector collector) {
173 this.collector = collector;
177 Packet streamInitiation = collector.nextResult(
|
| /external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
| AgentSession.java | 264 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class), new FromContainsFilter(workgroupJID)));
local
268 presence = (Presence)collector.nextResult(5000);
269 collector.cancel();
369 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class), new FromContainsFilter(workgroupJID)));
local
373 presence = (Presence)collector.nextResult(5000);
374 collector.cancel();
419 PacketCollector collector = this.connection.createPacketCollector(new AndFilter(new PacketTypeFilter(Presence.class),
local
424 presence = (Presence)collector.nextResult(5000);
425 collector.cancel();
515 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
807 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(notes.getPacketID())); local
836 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
874 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
901 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
931 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
961 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
990 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
1046 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(iq.getPacketID())); local
1098 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(iq.getPacketID())); local
1126 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(setting.getPacketID())); local
1147 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
1171 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
[all...] |
| /external/chromium/base/files/ |
| file_path_watcher_browsertest.cc | 96 explicit TestDelegate(NotificationCollector* collector)
97 : collector_(collector) {
196 NotificationCollector* collector() { return collector_.get(); } function in class:base::files::__anon4077::FilePathWatcherTest
207 scoped_refptr<TestDelegate> delegate(new TestDelegate(collector()));
219 scoped_refptr<TestDelegate> delegate(new TestDelegate(collector()));
233 scoped_refptr<TestDelegate> delegate(new TestDelegate(collector()));
245 scoped_refptr<TestDelegate> delegate(new TestDelegate(collector()));
289 scoped_refptr<TestDelegate> delegate(new TestDelegate(collector()));
298 scoped_refptr<TestDelegate> delegate1(new TestDelegate(collector()));
299 scoped_refptr<TestDelegate> delegate2(new TestDelegate(collector()));
[all...] |
| /external/chromium_org/third_party/WebKit/Source/core/css/resolver/ |
| ScopedStyleResolver.cpp | 348 void ScopedStyleResolver::matchHostRules(ElementRuleCollector& collector, bool includeEmptyRules)
360 collector.clearMatchedRules();
361 collector.matchedResult().ranges.lastAuthorRule = collector.matchedResult().matchedProperties.size() - 1;
375 RuleRange ruleRange = collector.matchedResult().ranges.authorRuleRange();
376 collector.setBehaviorAtBoundary(static_cast<SelectorChecker::BehaviorAtBoundary>(SelectorChecker::DoesNotCrossBoundary | SelectorChecker::ScopeContainsLastMatchedElement));
379 collector.collectMatchingRules(MatchRequest(ruleSet, includeEmptyRules, m_scopingNode), ruleRange, cascadeScope);
382 collector.sortAndTransferMatchedRules();
385 void ScopedStyleResolver::matchAuthorRules(ElementRuleCollector& collector, bool includeEmptyRules, bool applyAuthorStyles)
387 collector.clearMatchedRules()
[all...] |
| /art/runtime/gc/collector/ |
| gc_type.h | 24 namespace collector { namespace in namespace:art::gc
42 } // namespace collector
|
| partial_mark_sweep.cc | 26 namespace collector { namespace in namespace:art::gc
47 } // namespace collector
|
| partial_mark_sweep.h | 25 namespace collector { namespace in namespace:art::gc
45 } // namespace collector
|
| sticky_mark_sweep.h | 26 namespace collector { namespace in namespace:art::gc
56 } // namespace collector
|
| /external/chromium_org/build/android/ |
| surface_stats.py | 101 collector = surface_stats_collector.SurfaceStatsCollector(adb)
102 collector.DisableWarningAboutEmptyData()
108 collector.Start()
111 results = collector.SampleResults()
128 collector.Stop()
|
| /external/chromium_org/base/files/ |
| file_path_watcher_browsertest.cc | 110 explicit TestDelegate(NotificationCollector* collector)
111 : collector_(collector) {
204 NotificationCollector* collector() { return collector_.get(); } function in class:base::__anon6138::FilePathWatcherTest
232 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
245 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
260 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
273 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
325 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector()));
335 scoped_ptr<TestDelegate> delegate1(new TestDelegate(collector()));
336 scoped_ptr<TestDelegate> delegate2(new TestDelegate(collector()));
[all...] |
| /external/smack/src/org/jivesoftware/smack/ |
| RosterGroup.java | 167 PacketCollector collector = null; local
177 collector = connection
182 if (collector != null) {
183 IQ response = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
184 collector.cancel();
206 PacketCollector collector = null; local
219 collector = connection
224 if (collector != null) {
225 IQ response = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
226 collector.cancel()
[all...] |
| AccountManager.java | 234 PacketCollector collector = connection.createPacketCollector(filter); local
236 IQ result = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
238 collector.cancel();
265 PacketCollector collector = connection.createPacketCollector(filter); local
267 IQ result = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
269 collector.cancel();
299 PacketCollector collector = connection.createPacketCollector(filter); local
301 IQ result = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
303 collector.cancel();
322 PacketCollector collector = connection.createPacketCollector(filter) local
[all...] |
| /dalvik/vm/alloc/ |
| Heap.h | 68 * Stops any threads internal to the garbage collector. Called before
85 * Run the garbage collector without doing any locking.
90 * Blocks the calling thread until the garbage collector is inactive.
|
| /external/smack/src/org/jivesoftware/smackx/workgroup/user/ |
| Workgroup.java | 162 PacketCollector collector = connection.createPacketCollector(new AndFilter(fromFilter,
local
167 Presence response = (Presence)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
169 // Cancel the collector.
170 collector.cancel();
327 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(joinPacket.getPacketID()));
local
331 IQ response = (IQ)collector.nextResult(10000);
333 // Cancel the collector.
334 collector.cancel();
421 PacketCollector collector = this.connection.createPacketCollector(new PacketIDFilter(departPacket.getPacketID()));
local
425 IQ response = (IQ)collector.nextResult(5000);
673 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
720 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
748 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
776 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
806 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(request.getPacketID())); local
837 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(workgroupForm.getPacketID())); local
[all...] |
| /frameworks/base/core/java/android/database/sqlite/ |
| DatabaseObjectNotClosedException.java | 20 * An exception that indicates that garbage-collector is finalizing a database object
|
| /external/chromium_org/tools/perf/measurements/ |
| rasterize_and_record.py | 172 collector = StatsCollector(timeline)
173 collector.GatherRenderingStats()
178 collector.total_best_rasterize_time / 1.e3,
181 collector.total_best_record_time / 1.e3,
184 collector.total_pixels_rasterized,
187 collector.total_pixels_recorded,
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/coverage/ |
| collector.py | 1 """Raw data collector for Coverage."""
124 class Collector(object):
131 When the Collector is started, it creates a Tracer for the current thread,
133 When the Collector is stopped, all active Tracers are stopped.
135 Threads started while the Collector is stopped will never have Tracers
146 """Create a collector.
179 return "<Collector at 0x%x>" % id(self)
267 # Remove this Collector from the stack, and resume the one underneath
314 Note that no data is collected or returned if the Collector wasn't
|
| /art/runtime/gc/accounting/ |
| mod_union_table.h | 34 namespace collector { namespace in namespace:art::gc
36 } // namespace collector
69 virtual void MarkReferences(collector::MarkSweep* mark_sweep) = 0;
102 void MarkReferences(collector::MarkSweep* mark_sweep)
137 void MarkReferences(collector::MarkSweep* mark_sweep)
|
| /external/llvm/docs/ |
| Lexicon.rst | 66 A pointer to the interior of an object, such that a garbage collector is
69 the collector might free the referenced object. With copying collectors,
142 A pointer to an object such that the garbage collector is able to trace
174 which the collector begins its reachability analysis. In the context of code
190 calculated only at designated safe points. With a copying collector,
|
| /external/llvm/include/llvm/Support/ |
| Registry.h | 126 /// class CollectorPrinter : public Registry<Collector>::listener {
128 /// void registered(const Registry<Collector>::entry &e) {
129 /// cerr << "collector now available: " << e->getName() << "\n";
179 /// Registry<Collector>::Add<FancyGC>
180 /// X("fancy-gc", "Newfangled garbage collector.");
|
| /art/runtime/gc/ |
| heap.cc | 35 #include "gc/collector/mark_sweep-inl.h"
36 #include "gc/collector/partial_mark_sweep.h"
37 #include "gc/collector/sticky_mark_sweep.h"
89 last_gc_type_(collector::kGcTypeNone),
90 next_gc_type_(collector::kGcTypePartial),
235 mark_sweep_collectors_.push_back(new collector::MarkSweep(this, concurrent));
236 mark_sweep_collectors_.push_back(new collector::PartialMarkSweep(this, concurrent));
237 mark_sweep_collectors_.push_back(new collector::StickyMarkSweep(this, concurrent));
438 for (const auto& collector : mark_sweep_collectors_) {
439 CumulativeLogger& logger = collector->GetCumulativeTimings()
1251 collector::MarkSweep* collector = NULL; local
[all...] |
| /external/chromium_org/chrome_frame/test/ |
| run_all_unittests.cc | 40 const char kNoLogCollector[] = "no-log-collector";
72 // Install the log collector before anything else that adds a Google Test
75 // the collector to emit logs if other listeners ADD_FAILURE or EXPECT_*.
|
| /external/guava/guava-tests/test/com/google/common/io/ |
| ResourcesTest.java | 80 List<String> collector = new ArrayList<String>();
83 collector.add(WHITESPACE.trimFrom(line));
89 return collector;
|
| /external/smack/src/org/jivesoftware/smackx/packet/ |
| Version.java | 36 * // Create a packet collector to listen for a response.
37 * PacketCollector collector = con.createPacketCollector(
43 * IQ result = (IQ)collector.nextResult(5000);
|
