| /freebsd/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/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/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 MultiplexConsumer() local
280 if (auto *mutationListener = Consumer->GetASTMutationListener()) in MultiplexConsumer()
282 if (auto *serializationListener = Consumer->GetASTDeserializationListener()) in MultiplexConsumer()
299 for (auto &Consumer : Consumers) in Initialize() local
300 Consumer->Initialize(Context); in Initialize()
305 for (auto &Consumer : Consumers) in HandleTopLevelDecl() local
306 Continue = Continue && Consumer->HandleTopLevelDecl(D); in HandleTopLevelDecl()
311 for (auto &Consumer : Consumers) in HandleInlineFunctionDefinition() local
312 Consumer->HandleInlineFunctionDefinition(D); in HandleInlineFunctionDefinition()
[all …]
|
| H A D | CompilerInvocation.cpp | 306 static void denormalizeSimpleFlag(ArgumentConsumer Consumer, in denormalizeSimpleFlag() argument
309 Consumer(Spelling); in denormalizeSimpleFlag()
346 return [Value](ArgumentConsumer Consumer, const Twine &Spelling, in makeBooleanOptionDenormalizer()
349 Consumer(Spelling); in makeBooleanOptionDenormalizer()
353 static void denormalizeStringImpl(ArgumentConsumer Consumer, in denormalizeStringImpl() argument
361 Consumer(Spelling); in denormalizeStringImpl()
362 Consumer(Value); in denormalizeStringImpl()
366 Consumer(Spelling + Value); in denormalizeStringImpl()
375 static void denormalizeString(ArgumentConsumer Consumer, const Twine &Spelling, in denormalizeString() argument
378 denormalizeStringImpl(Consumer, Spelling, OptClass, TableIndex, Twine(Value)); in denormalizeString()
[all …]
|
| /freebsd/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/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/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/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/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 …]
|
| /freebsd/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/contrib/llvm-project/llvm/tools/llvm-diff/lib/ |
| 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()
|
| 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;
|
| /freebsd/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 …]
|
| /freebsd/contrib/llvm-project/clang/lib/Interpreter/ |
| H A D | IncrementalParser.cpp | 36 std::unique_ptr<ASTConsumer> Consumer; member in clang::IncrementalASTConsumer
40 : Interp(InterpRef), Consumer(std::move(C)) {} in IncrementalASTConsumer()
45 if (!Consumer) in HandleTopLevelDecl()
53 return Consumer->HandleTopLevelDecl(DGR); in HandleTopLevelDecl()
56 Consumer->HandleTranslationUnit(Ctx); in HandleTranslationUnit()
59 Consumer->HandleInlineFunctionDefinition(D); in HandleInlineFunctionDefinition()
62 Consumer->HandleInterestingDecl(D); in HandleInterestingDecl()
65 Consumer->HandleTagDeclDefinition(D); in HandleTagDeclDefinition()
68 Consumer->HandleTagDeclRequiredDefinition(D); in HandleTagDeclRequiredDefinition()
71 Consumer->HandleCXXImplicitFunctionInstantiation(D); in HandleCXXImplicitFunctionInstantiation()
[all …]
|