/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...] |
/external/chromium_org/third_party/WebKit/Source/core/css/resolver/ |
StyleResolver.cpp | 377 void StyleResolver::matchAuthorRulesForShadowHost(Element* element, ElementRuleCollector& collector, bool includeEmptyRules, WillBeHeapVector<RawPtrWillBeMember<ScopedStyleResolver>, 8>& resolvers, WillBeHeapVector<RawPtrWillBeMember<ScopedStyleResolver>, 8>& resolversInShadowTree) 379 collector.clearMatchedRules(); 380 collector.matchedResult().ranges.lastAuthorRule = collector.matchedResult().matchedProperties.size() - 1; 386 resolversInShadowTree.at(j)->collectMatchingAuthorRules(collector, includeEmptyRules, cascadeScope, cascadeOrder++); 392 resolvers.at(i)->collectMatchingAuthorRules(collector, includeEmptyRules, cascadeScope++, --cascadeOrder); 394 m_treeBoundaryCrossingRules.collectTreeBoundaryCrossingRules(element, collector, includeEmptyRules); 395 collector.sortAndTransferMatchedRules(); 398 void StyleResolver::matchAuthorRules(Element* element, ElementRuleCollector& collector, bool includeEmptyRules) 400 collector.clearMatchedRules() [all...] |
ScopedStyleResolver.cpp | 124 void ScopedStyleResolver::collectMatchingAuthorRules(ElementRuleCollector& collector, bool includeEmptyRules, CascadeScope cascadeScope, CascadeOrder cascadeOrder) 131 RuleRange ruleRange = collector.matchedResult().ranges.authorRuleRange(); 134 collector.collectMatchingRules(matchRequest, ruleRange, static_cast<SelectorChecker::ContextFlags>(contextFlags), cascadeScope, cascadeOrder); 138 void ScopedStyleResolver::matchPageRules(PageRuleCollector& collector) 143 collector.matchPageRules(&m_authorStyleSheets[i]->contents()->ruleSet());
|
/external/chromium_org/components/domain_reliability/ |
scheduler.cc | 103 VLOG(1) << "Starting upload to collector " << collector_index_ << "."; 116 VLOG(1) << "Upload to collector " << collector_index_ 119 CollectorState* collector = &collectors_[collector_index_]; local 123 collector->failures = 0; 130 ++collector->failures; 134 base::TimeDelta retry_interval = GetUploadRetryInterval(collector->failures); 135 collector->next_upload = now + retry_interval; 141 VLOG(1) << "Next upload to collector at least " 231 CollectorState* collector = &collectors_[i]; local 232 // If a collector is usable, use the first one in the list [all...] |
/art/runtime/gc/collector/ |
mark_sweep-inl.h | 20 #include "gc/collector/mark_sweep.h" 30 namespace collector { namespace in namespace:art::gc 49 } // namespace collector
|
partial_mark_sweep.cc | 26 namespace collector { namespace in namespace:art::gc 47 } // namespace collector
|
sticky_mark_sweep.h | 25 namespace collector { namespace in namespace:art::gc 53 } // namespace collector
|
immune_region.h | 32 namespace collector { namespace in namespace:art::gc 73 } // namespace collector
|
sticky_mark_sweep.cc | 25 namespace collector { namespace in namespace:art::gc 62 } // namespace collector
|
/external/smack/src/org/jivesoftware/smackx/search/ |
UserSearch.java | 73 PacketCollector collector = con.createPacketCollector(new PacketIDFilter(search.getPacketID())); local 76 IQ response = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 78 // Cancel the collector. 79 collector.cancel(); 105 PacketCollector collector = con.createPacketCollector(new PacketIDFilter(search.getPacketID())); local 109 IQ response = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 111 // Cancel the collector. 112 collector.cancel(); 140 PacketCollector collector = con.createPacketCollector(new PacketIDFilter(search.getPacketID())); local 144 IQ response = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()) [all...] |
/external/chromium_org/base/files/ |
file_path_watcher_browsertest.cc | 110 explicit TestDelegate(NotificationCollector* collector) 111 : collector_(collector) { 190 NotificationCollector* collector() { return collector_.get(); } function in class:base::__anon6875::FilePathWatcherTest 217 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector())); 230 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector())); 245 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector())); 258 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector())); 310 scoped_ptr<TestDelegate> delegate(new TestDelegate(collector())); 320 scoped_ptr<TestDelegate> delegate1(new TestDelegate(collector())); 321 scoped_ptr<TestDelegate> delegate2(new TestDelegate(collector())); [all...] |
/art/runtime/gc/ |
heap.h | 30 #include "gc/collector/garbage_collector.h" 31 #include "gc/collector/gc_type.h" 67 namespace collector { namespace in namespace:art::gc 73 } // namespace collector 150 // How long we wait after a transition request to perform a collector transition (nanoseconds). 221 // Transition the garbage collector during runtime, may copy objects from one space to another. 224 // Change the collector to be one of the possible options (MS, CMS, SS). 319 // Blocks the caller until the garbage collector becomes idle and returns the type of GC we 321 collector::GcType WaitForGcToComplete(GcCause cause, Thread* self) 335 const collector::Iteration* GetCurrentGcIteration() const [all...] |
heap.cc | 39 #include "gc/collector/concurrent_copying.h" 40 #include "gc/collector/mark_compact.h" 41 #include "gc/collector/mark_sweep-inl.h" 42 #include "gc/collector/partial_mark_sweep.h" 43 #include "gc/collector/semi_space.h" 44 #include "gc/collector/sticky_mark_sweep.h" 150 last_gc_type_(collector::kGcTypeNone), 151 next_gc_type_(collector::kGcTypePartial), 261 // collector type. 318 // We only to create the bump pointer if the foreground collector is a compacting GC 1883 ZygoteCompactingCollector* collector = context->collector_; local 2179 collector::GarbageCollector* collector = nullptr; local [all...] |
/external/chromium_org/third_party/protobuf/src/google/protobuf/io/ |
tokenizer.cc | 745 CommentCollector collector(prev_trailing_comments, detached_comments, 749 collector.DetachFromPrev(); 756 ConsumeLineComment(collector.GetBufferForLineComment()); 760 collector.Flush(); 763 ConsumeBlockComment(collector.GetBufferForBlockComment()); 769 collector.ClearBuffer(); 775 collector.Flush(); 794 ConsumeLineComment(collector.GetBufferForLineComment()); 797 ConsumeBlockComment(collector.GetBufferForBlockComment()); 809 collector.Flush() [all...] |
/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/commands/ |
RemoteCommand.java | 154 PacketCollector collector = connection.createPacketCollector( local 159 Packet response = collector.nextResult(timeout); 161 // Cancel the collector. 162 collector.cancel();
|
/external/smack/src/org/jivesoftware/smackx/filetransfer/ |
StreamNegotiator.java | 88 // establish collector to await response
89 PacketCollector collector = connection
local 93 Packet streamMethodInitiation = collector
95 collector.cancel();
|
/external/smack/src/org/jivesoftware/smackx/packet/ |
LastActivity.java | 149 PacketCollector collector = con.createPacketCollector(new PacketIDFilter(activity.getPacketID())); local 152 LastActivity response = (LastActivity) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 154 // Cancel the collector. 155 collector.cancel();
|
/art/runtime/gc/accounting/ |
remembered_set.h | 31 namespace collector { namespace in namespace:art::gc 33 } // namespace collector
|
/external/chromium_org/chrome/browser/extensions/api/file_handlers/ |
mime_util_unittest.cc | 105 MimeTypeCollector collector(&profile_); 118 collector.CollectForURLs(urls, base::Bind(&OnMimeTypesCollected, &result)); 128 MimeTypeCollector collector(&profile_); 137 collector.CollectForLocalPaths(local_paths,
|
/external/chromium_org/tools/gn/ |
parser_unittest.cc | 34 std::ostringstream collector; local 35 result->Print(collector, 0); 37 EXPECT_EQ(expected, collector.str()); 50 std::ostringstream collector; local 51 result->Print(collector, 0); 53 EXPECT_EQ(expected, collector.str());
|
/external/smack/src/org/jivesoftware/smack/ |
SASLAuthentication.java | 444 PacketCollector collector = connection
local 449 Bind response = (Bind) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
450 collector.cancel();
462 collector = connection.createPacketCollector(new PacketIDFilter(session.getPacketID()));
466 IQ ack = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
467 collector.cancel();
|
/external/smack/src/org/jivesoftware/smackx/ |
PrivateDataManager.java | 199 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(packetID)); local 205 IQ response = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 207 collector.cancel(); 245 PacketCollector collector = connection.createPacketCollector(new PacketIDFilter(packetID)); local 251 IQ response = (IQ)collector.nextResult(5000); 253 collector.cancel();
|
ServiceDiscoveryManager.java | 543 // Create a packet collector to listen for a response. 544 PacketCollector collector = local 550 IQ result = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 552 collector.cancel(); 590 // Create a packet collector to listen for a response. 591 PacketCollector collector = local 597 IQ result = (IQ) collector.nextResult(SmackConfiguration.getPacketReplyTimeout()); 599 collector.cancel(); 669 // Create a packet collector to listen for a response. 670 PacketCollector collector local [all...] |
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/coverage/ |
data.py | 14 * collector: a string identifying the collecting software 25 def __init__(self, basename=None, collector=None): 30 `collector` is a string describing the coverage measurement software. 33 self.collector = collector or 'unknown' 124 if self.collector: 125 data['collector'] = self.collector
|