consumer (full) in projects: freebsd-src

Project(s)

Full Search
Definition
Symbol
File Path
History
Type

Searched full:consumer (Results 1 – 25 of 798) sorted by relevance

12 3 4 5 6 7 8 9 10 >>...32

/freebsd-src/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
H A D	TestStateMachine.java	32 * Regression test for the LocalConsumer state machine. Calls Consumer 58 printState(Consumer consumer) in printState() argument 60 System.out.println("open: " + consumer.isOpen()); in printState() 61 System.out.println("enabled: " + consumer.isEnabled()); in printState() 62 System.out.println("closed: " + consumer.isClosed()); in printState() 66 beforeOpen(Consumer consumer) in beforeOpen() argument 69 printState(consumer); in beforeOpen() 73 consumer.compile("syscall:::entry"); in beforeOpen() 84 consumer.enable(); in beforeOpen() 95 consumer.getOption(Option.bufsize); in beforeOpen() [all …]
H A D	TestAbort.java	`42 Consumer consumer = new LocalConsumer(); in main() local 46 consumer.open(); in main() 47 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main() 49 consumer.enable(); in main() 50 consumer.go(); in main() 57 consumer.close(); in main() 63 consumer = new LocalConsumer(); in main() 65 // Should be able to abort an unopened consumer in main() 68 consumer.addConsumerListener(new ConsumerAdapter() { in main() 73 consumer.abort(); in main() [all …]`
H A D	TestEnable.java	`34 * consumer. 48 Consumer consumer = new LocalConsumer(); in main() local 51 consumer.open(); in main() 52 Program p0 = consumer.compile("dtrace:::BEGIN"); in main() 53 Program p1 = consumer.compile("syscall:::entry"); in main() 54 Program p2 = consumer.compile("dtrace:::END"); in main() 55 consumer.enable(p0); in main() 56 consumer.enable(p1); in main() 58 consumer.go(); in main() 69 consumer.enable(); in main() [all …]`
H A D	TestGetAggregate.java	47 testIncluded(Consumer consumer, String ... aggregationNames) in testIncluded() argument 63 aggregate = consumer.getAggregate(included, null); in testIncluded() 81 if (!consumer.isRunning()) { in testIncluded() 82 throw new IllegalStateException("consumer exited"); in testIncluded() 87 testCleared(Consumer consumer, String ... aggregationNames) in testCleared() argument 104 aggregate = consumer.getAggregate(null, cleared); in testCleared() 110 aggregate = consumer.getAggregate(null, cleared); in testCleared() 119 } while (consumer.isRunning() && n++ < INTERVALS); in testCleared() 146 if (!consumer.isRunning()) { in testCleared() 147 throw new IllegalStateException("consumer exited"); in testCleared() [all …]
H A D	TestFunctionLookup.java	`48 Consumer consumer = new LocalConsumer(); in main() local 50 consumer.open(); in main() 51 consumer.compile(kernelLookupProgram); in main() 52 consumer.enable(); in main() 53 consumer.go(); in main() 60 a = consumer.getAggregate(); in main() 66 f = consumer.lookupKernelFunction(addr); in main() 69 f = consumer.lookupKernelFunction(addr); in main() 78 consumer.close(); in main() 84 consumer = new LocalConsumer(); in main() [all …]`
H A D	TestClose.java	`32 * Regression for bug 6419880 close() hangs running consumer. 38 Consumer consumer = new LocalConsumer(); in main() local 41 consumer.open(); in main() 42 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main() 44 consumer.enable(); in main() 45 consumer.go(); in main() 52 consumer.close(); in main() 58 consumer = new LocalConsumer(); in main() 61 consumer.open(); in main() 62 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main() [all …]`
H A D	TestDrop.java	62 sampleAggregate(Consumer consumer) throws DTraceException in sampleAggregate() argument 64 while (consumer.isRunning() && !done.get()) { in sampleAggregate() 70 consumer.getAggregate(Collections. <String> emptySet()); in sampleAggregate() 75 startAggregateThread(final Consumer consumer) in startAggregateThread() argument 83 sampleAggregate(consumer); in startAggregateThread() 96 consumer.close(); // blocks if lock held in startAggregateThread() 125 final Consumer consumer = new LocalConsumer() { in main() local 139 consumer.addConsumerListener(new ConsumerAdapter() { in main() 141 startAggregateThread(consumer); in main() 155 consumer.open(); in main() [all …]
H A D	TestStopLock.java	`33 * synchronized Consumer method 39 final Consumer consumer = new LocalConsumer(); in main() local 40 consumer.addConsumerListener(new ConsumerAdapter() { in main() 43 consumer.isRunning(); in main() 48 consumer.open(); in main() 49 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main() 51 consumer.enable(); in main() 52 consumer.go(); in main() 59 consumer.stop(); in main() 60 consumer.close(); in main()`
/freebsd-src/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/
H A D	tst.StateMachine.ksh.out	5 java.lang.IllegalStateException: consumer not open 6 java.lang.IllegalStateException: consumer not open 7 java.lang.IllegalStateException: consumer not open 8 java.lang.IllegalStateException: consumer not open 9 java.lang.IllegalStateException: consumer not open 10 java.lang.IllegalStateException: consumer not open 11 java.lang.IllegalStateException: consumer not open 12 java.lang.IllegalStateException: consumer not open 13 java.lang.IllegalStateException: consumer not open 18 java.lang.IllegalStateException: consumer already open [all …]
/freebsd-src/contrib/llvm-project/clang/lib/Frontend/
H A D	MultiplexConsumer.cpp	1 //===- MultiplexConsumer.cpp - AST Consumer for PCH Generation --- C++ --===// 279 for (auto &Consumer : Consumers) { in HandleTopLevelDecl() 280 if (auto mutationListener = Consumer->GetASTMutationListener()) 282 if (auto serializationListener = Consumer->GetASTDeserializationListener()) in HandleInlineFunctionDefinition() local 299 for (auto &Consumer : Consumers) in HandleTranslationUnit() 300 Consumer->Initialize(Context); 305 for (auto &Consumer : Consumers) 306 Continue = Continue && Consumer->HandleTopLevelDecl(D); in HandleTagDeclRequiredDefinition() 311 for (auto &Consumer : Consumers) in HandleCXXImplicitFunctionInstantiation() 312 Consumer in HandleCXXImplicitFunctionInstantiation() local 250 for (auto &Consumer : Consumers) { MultiplexConsumer() local 270 for (auto &Consumer : Consumers) Initialize() local 276 for (auto &Consumer : Consumers) HandleTopLevelDecl() local 287 for (auto &Consumer : Consumers) HandleCXXStaticMemberVarInstantiation() local 292 for (auto &Consumer : Consumers) HandleInterestingDecl() local 297 for (auto &Consumer : Consumers) HandleTranslationUnit() local 302 for (auto &Consumer : Consumers) HandleTagDeclDefinition() local 307 for (auto &Consumer : Consumers) HandleTagDeclRequiredDefinition() local 317 for (auto &Consumer : Consumers) HandleTopLevelDeclInObjCContainer() local 322 for (auto &Consumer : Consumers) HandleImplicitImportDecl() local 327 for (auto &Consumer : Consumers) CompleteTentativeDefinition() local 332 for (auto &Consumer : Consumers) CompleteExternalDeclaration() local 337 for (auto &Consumer : Consumers) AssignInheritanceModel() local 342 for (auto &Consumer : Consumers) HandleVTable() local 355 for (auto &Consumer : Consumers) PrintStats() local 361 for (auto &Consumer : Consumers) shouldSkipFunctionBody() local 367 for (auto &Consumer : Consumers) InitializeSema() local 373 for (auto &Consumer : Consumers) ForgetSema() local [all...]
H A D	CompilerInvocation.cpp	306 static void denormalizeSimpleFlag(ArgumentConsumer Consumer, 309 Consumer(Spelling); in makeFlagToValueNormalizer() 346 return [Value](ArgumentConsumer Consumer, const Twine &Spelling, in denormalizeStringImpl() 349 Consumer(Spelling); in denormalizeStringImpl() 353 static void denormalizeStringImpl(ArgumentConsumer Consumer, in denormalizeStringImpl() 361 Consumer(Spelling); in denormalizeStringImpl() 362 Consumer(Value); 366 Consumer(Spelling + Value); in denormalizeString() 375 static void denormalizeString(ArgumentConsumer Consumer, const Twine &Spelling, in findValueTableByName() 378 denormalizeStringImpl(Consumer, Spellin in findValueTableByName() 295 denormalizeSimpleFlag(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass,unsigned,...) denormalizeSimpleFlag() argument 342 denormalizeStringImpl(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass OptClass,unsigned,const Twine & Value) denormalizeStringImpl() argument 364 denormalizeString(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass OptClass,unsigned TableIndex,T Value) denormalizeString() argument 408 denormalizeSimpleEnumImpl(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass OptClass,unsigned TableIndex,unsigned Value) denormalizeSimpleEnumImpl() argument 424 denormalizeSimpleEnum(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass OptClass,unsigned TableIndex,T Value) denormalizeSimpleEnum() argument 464 denormalizeStringVector(ArgumentConsumer Consumer,const Twine & Spelling,Option::OptionClass OptClass,unsigned TableIndex,const std::vector<std::string> & Values) denormalizeStringVector() argument 541 GENERATE_OPTION_WITH_MARSHALLING(CONSUMER,PREFIX_TYPE,SPELLING,ID,KIND,GROUP,ALIAS,ALIASARGS,FLAGS,VISIBILITY,PARAM,HELPTEXT,METAVAR,VALUES,SHOULD_PARSE,ALWAYS_EMIT,KEYPATH,DEFAULT_VALUE,IMPLIED_CHECK,IMPLIED_VALUE,NORMALIZER,DENORMALIZER,MERGER,EXTRACTOR,TABLE_INDEX) global() argument 716 GenerateArg(ArgumentConsumer Consumer,llvm::opt::OptSpecifier OptSpecifier) GenerateArg() argument 723 GenerateArg(ArgumentConsumer Consumer,llvm::opt::OptSpecifier OptSpecifier,const Twine & Value) GenerateArg() argument 943 GenerateAnalyzerArgs(const AnalyzerOptions & Opts,ArgumentConsumer Consumer) GenerateAnalyzerArgs() argument 1287 GenerateOptimizationRemark(ArgumentConsumer Consumer,OptSpecifier OptEQ,StringRef Name,const CodeGenOptions::OptRemark & Remark) GenerateOptimizationRemark() argument 1451 GenerateCodeGenArgs(const CodeGenOptions & Opts,ArgumentConsumer Consumer,const llvm::Triple & T,const std::string & OutputFile,const LangOptions * LangOpts) GenerateCodeGenArgs() argument 2162 GenerateDependencyOutputArgs(const DependencyOutputOptions & Opts,ArgumentConsumer Consumer) GenerateDependencyOutputArgs() argument 2312 GenerateFileSystemArgs(const FileSystemOptions & Opts,ArgumentConsumer Consumer) GenerateFileSystemArgs() argument 2336 GenerateMigratorArgs(const MigratorOptions & Opts,ArgumentConsumer Consumer) GenerateMigratorArgs() argument 2359 GenerateDiagnosticArgs(const DiagnosticOptions & Opts,ArgumentConsumer Consumer,bool DefaultDiagColor) GenerateDiagnosticArgs() argument 2600 GenerateFrontendArgs(const FrontendOptions & Opts,ArgumentConsumer Consumer,bool IsHeader) GenerateFrontendArgs() argument 3022 GenerateHeaderSearchArgs(const HeaderSearchOptions & Opts,ArgumentConsumer Consumer) GenerateHeaderSearchArgs() argument 3271 GenerateAPINotesArgs(const APINotesOptions & Opts,ArgumentConsumer Consumer) GenerateAPINotesArgs() argument 3373 GenerateLangArgs(const LangOptions & Opts,ArgumentConsumer Consumer,const llvm::Triple & T,InputKind IK) GenerateLangArgs() argument 4309 GeneratePreprocessorArgs(const PreprocessorOptions & Opts,ArgumentConsumer Consumer,const LangOptions & LangOpts,const FrontendOptions & FrontendOpts,const CodeGenOptions & CodeGenOpts) GeneratePreprocessorArgs() argument 4481 GeneratePreprocessorOutputArgs(const PreprocessorOutputOptions & Opts,ArgumentConsumer Consumer,frontend::ActionKind Action) GeneratePreprocessorOutputArgs() argument 4519 GenerateTargetArgs(const TargetOptions & Opts,ArgumentConsumer Consumer) GenerateTargetArgs() argument [all...]
/freebsd-src/sys/dev/acpica/
H A D	acpi_powerres.c	66 /* A relationship between a power resource and a consumer. / 71 TAILQ_ENTRY(acpi_powerreference) ar_clink; / link on consumer / 98 static ACPI_STATUS acpi_pwr_register_consumer(ACPI_HANDLE consumer); 100 static ACPI_STATUS acpi_pwr_deregister_consumer(ACPI_HANDLE consumer); 114 acpi_pwr_find_consumer(ACPI_HANDLE consumer); 225 * Register a power consumer. 227 * It's OK to call this if we already know about the consumer. 230 acpi_pwr_register_consumer(ACPI_HANDLE consumer) in acpi_pwr_register_consumer() argument 237 /* Check to see whether we know about this consumer already */ in acpi_pwr_register_consumer() 238 if (acpi_pwr_find_consumer(consumer) != NULL) in acpi_pwr_register_consumer() [all …]
/freebsd-src/sys/dev/cxgbe/
H A D	t4_mp_ring.c	47 * The thread that is writing the hardware descriptors is the consumer and it 48 * runs with the consumer lock held. A producer becomes the consumer if there 49 * isn't one already. The consumer runs with the flags sets to BUSY and 52 * TOO_BUSY consumer will become the new consumer by setting flags to 53 * TAKING_OVER. The original consumer stops and sets the flags back to BUSY for 54 * the new consumer. 75 BUSY, /* consumer is running already, or will be shortly. / 76 TOO_BUSY, / consumer is running and is beyond its budget / 77 TAKING_OVER, / new consumer taking over from a TOO_BUSY consumer / 78 STALLED, / consumer stopped due to lack of resources. */ [all …]
/freebsd-src/tools/regression/geom/ConfCmp/
H A D	a1.conf	`11 <consumer> 16 </consumer> 23 <consumer> 28 </consumer> 35 <consumer> 40 </consumer> 47 <consumer> 52 </consumer> 59 <consumer> 64 </consumer> [all …]`
H A D	a1a.conf	`11 <consumer> 16 </consumer> 23 <consumer> 28 </consumer> 35 <consumer> 40 </consumer> 47 <consumer> 52 </consumer> 59 <consumer> 64 </consumer> [all …]`
H A D	a1d.conf	`11 <consumer> 16 </consumer> 23 <consumer> 28 </consumer> 35 <consumer> 40 </consumer> 47 <consumer> 52 </consumer> 59 <consumer> 64 </consumer> [all …]`
H A D	a1b.conf	`11 <consumer> 16 </consumer> 23 <consumer> 28 </consumer> 35 <consumer> 40 </consumer> 47 <consumer> 52 </consumer> 59 <consumer> 64 </consumer> [all …]`
H A D	a1c.conf	`11 <consumer> 16 </consumer> 23 <consumer> 28 </consumer> 35 <consumer> 40 </consumer> 47 <consumer> 52 </consumer> 59 <consumer> 64 </consumer> [all …]`
/freebsd-src/share/man/man9/
H A D	g_consumer.9	39 A GEOM consumer is the backdoor through which a geom connects to 44 function creates a new consumer on geom 46 Before using the new consumer, it has to be attached to a provider with 53 function destroys the given consumer and cancels all related pending events. 54 This function is the last stage of killing an unwanted consumer. 71 The consumer must not be attached to a provider. 81 returns a pointer to the newly created consumer. 83 Create consumer, attach it to given provider, gain read access and clean up. 92 /* Create new consumer on 'mygeom' geom. / 94 / Attach newly created consumer to given provider. */ [all …]
H A D	g_attach.9	41 function attaches given consumer 45 thus establishing a communication channel between the consumer and the 50 function detaches given consumer 58 The consumer must not be attached to a provider. 68 The consumer has to be attached. 81 Create a consumer, attach it to a given provider, gain read access and clean up. 90 /* Create new consumer on 'mygeom' geom. / 92 / Attach newly created consumer to given provider. / 97 / Open provider for reading through our consumer. / 114 / Destroy consumer. */
/freebsd-src/lib/libdevdctl/
H A D	consumer.cc	34 * \file consumer.cc 59 #include "consumer.h" 69 /----------------------------- DevdCtl::Consumer ----------------------------/ 70 //- Consumer Static Private Data ----------------------------------------------- 71 const char Consumer::s_devdSockPath[] = "/var/run/devd.seqpacket.pipe"; 73 //- Consumer Public Methods ---------------------------------------------------- 74 Consumer::Consumer(Event::BuildMethod *defBuilder, in Consumer() function in DevdCtl::Consumer 84 Consumer::~Consumer() in ~Consumer() 90 Consumer::ConnectToDevd() in ConnectToDevd() 125 Consumer::DisconnectFromDevd() in DisconnectFromDevd() [all …]
/freebsd-src/contrib/llvm-project/llvm/tools/llvm-diff/lib/
H A D	DifferenceEngine.h	`38 Engine.consumer.enterContext(L, R); in Context() 42 Engine.consumer.exitContext(); in ~Context() 60 DifferenceEngine(Consumer &consumer) in DifferenceEngine() argument 61 : consumer(consumer), globalValueOracle(nullptr) {} in DifferenceEngine() 66 consumer.log(text); in log() 69 return LogBuilder(consumer, text); in logf() 71 Consumer& getConsumer() const { return consumer; } in getConsumer() 85 Consumer &consumer;`
H A D	DiffLog.h	`22 class Consumer; variable 29 Consumer *consumer; variable 40 LogBuilder(Consumer &c, StringRef Format) : consumer(&c), Format(Format) {} in LogBuilder() 42 : consumer(L.consumer), Format(L.Format), in LogBuilder() 44 L.consumer = nullptr; in LogBuilder() 64 Consumer &consumer; variable 67 DiffLogBuilder(Consumer &c) : consumer(c) {} in DiffLogBuilder()`
/freebsd-src/sys/contrib/ck/include/
H A D	ck_ring.h	108 /* The consumer counter must always be smaller than the producer. / in ck_ring_valid() 112 / The producer may only be up to size slots ahead of consumer. / in ck_ring_valid() 146 unsigned int consumer, producer, delta; in _ck_ring_enqueue_reserve_sp() local 148 consumer = ck_pr_load_uint(&ring->c_head); in _ck_ring_enqueue_reserve_sp() 152 size = (producer - consumer) & mask; in _ck_ring_enqueue_reserve_sp() 154 if (CK_CC_UNLIKELY((delta & mask) == (consumer & mask))) in _ck_ring_enqueue_reserve_sp() 181 unsigned int consumer, producer, delta; in _ck_ring_enqueue_sp() local 183 consumer = ck_pr_load_uint(&ring->c_head); in _ck_ring_enqueue_sp() 187 *size = (producer - consumer) & mask; in _ck_ring_enqueue_sp() 189 if (CK_CC_UNLIKELY((delta & mask) == (consumer & mask))) in _ck_ring_enqueue_sp() [all …]
/freebsd-src/contrib/llvm-project/clang/include/clang/Tooling/Transformer/
H A D	Transformer.h	65 /// Provides the set of changes to the consumer. The callback is free to move 74 /// \param Consumer receives all rewrites for a single match, or an error. 80 ChangeSetConsumer Consumer) 82 [Consumer = std::move(Consumer)]( 85 Consumer(Result->Changes); 87 Consumer(Result.takeError()); 90 /// \param Consumer receives all rewrites and the associated metadata for a 100 Consumer); 142 std::function<void(llvm::Expected<TransformerResult<T>>)> Consumer; 147 std::function<void(llvm::Expected<TransformerResult<T>>)> Consumer) [all …]

12 3 4 5 6 7 8 9 10 >>...32