| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/gofmt/ |
| D | gofmt.go | 98 type sequencer struct { struct
99 maxWeight int64
100 …m *semaphore.Weighted // weighted by input bytes (an approximate proxy for memory overhead)
101 prev <-chan *reporterState // 1-buffered
137 func (s *sequencer) Add(weight int64, f func(*reporter) error) {
164 func (s *sequencer) AddReport(err error) {
170 func (s *sequencer) GetExitCode() int {
376 func gofmtMain(s *sequencer) {
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/net/textproto/ |
| D | pipeline.go | 72 type sequencer struct { struct
73 mu sync.Mutex
74 id uint
75 wait map[uint]chan struct{}
81 func (s *sequencer) Start(id uint) {
99 func (s *sequencer) End(id uint) {
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| H A D | quic_stream_sequencer_peer.cc | 15 QuicStreamSequencer* sequencer) { in GetNumBufferedBytes()
21 QuicStreamSequencer* sequencer) { in GetCloseOffset()
27 QuicStreamSequencer* sequencer) { in IsUnderlyingBufferAllocated()
34 QuicStreamSequencer* sequencer, QuicStreamOffset total_bytes_read) { in SetFrameBufferTotalBytesRead()
|
| H A D | quic_stream_peer.cc | 94 QuicStreamSequencer* QuicStreamPeer::sequencer(QuicStream* stream) { in sequencer() function in quic::test::QuicStreamPeer
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/encryption/ |
| D | BackgroundKeyFetchWorker.java | 191 ExecutionSequencer sequencer = ExecutionSequencer.create(); in fetchNewKeys() local
312 ExecutionSequencer sequencer, in fetchAndPersistAuctionKeys()
330 ExecutionSequencer sequencer, in fetchAndPersistJoinKey()
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| H A D | quic_stream.h | 96 const QuicStreamSequencer* sequencer() const { return &sequencer_; } in sequencer() function
478 const QuicStreamSequencer* sequencer() const { return &sequencer_; } in sequencer() function
479 QuicStreamSequencer* sequencer() { return &sequencer_; } in sequencer() function
|
| H A D | quic_crypto_stream.h | 265 QuicStreamSequencer sequencer; member
|
| H A D | quic_stream_sequencer_test.cc | 87 bool VerifyReadableRegion(const QuicStreamSequencer& sequencer, in VerifyReadableRegion()
99 bool VerifyReadableRegions(const QuicStreamSequencer& sequencer, in VerifyReadableRegions()
|
| H A D | quic_crypto_client_stream_test.cc | 270 QuicStreamSequencer* sequencer = QuicStreamPeer::sequencer(stream()); in TEST_F() local
|
| H A D | quic_crypto_stream.cc | 112 QuicStreamSequencer* sequencer, EncryptionLevel level) { in OnDataAvailableInSequencer()
|
| H A D | quic_stream.cc | 336 QuicStreamSequencer sequencer, bool is_static, in QuicStream()
|
| /aosp_15_r20/external/libbrillo/brillo/dbus/ |
| H A D | dbus_object.cc | 66 scoped_refptr<AsyncEventSequencer> sequencer(new AsyncEventSequencer()); in ExportAsync() local
134 scoped_refptr<AsyncEventSequencer> sequencer(new AsyncEventSequencer()); in UnexportAsync() local
309 scoped_refptr<AsyncEventSequencer> sequencer(new AsyncEventSequencer()); in RegisterAsync() local
|
| /aosp_15_r20/frameworks/av/services/camera/libcameraservice/api1/client2/ |
| H A D | JpegProcessor.cpp | 48 wp<CaptureSequencer> sequencer): in JpegProcessor()
294 sp<CaptureSequencer> sequencer = mSequencer.promote(); in processNewCapture() local
|
| H A D | ZslProcessor.cpp | 132 wp<CaptureSequencer> sequencer): in ZslProcessor()
|
| /aosp_15_r20/external/libbrillo/brillo/daemons/ |
| H A D | dbus_daemon.cc | 53 scoped_refptr<AsyncEventSequencer> sequencer(new AsyncEventSequencer()); in OnInit() local
|
| /aosp_15_r20/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/policy/ |
| D | FinalizationStateDispatchQueue.java | 54 FinalizationStateDispatchQueue(ExecutionSequencer sequencer) { in FinalizationStateDispatchQueue()
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/customaudience/ |
| D | AdditionalScheduleRequestsEnabledStrategy.java | 101 ExecutionSequencer sequencer = ExecutionSequencer.create(); in scheduleRequests() local
|
| D | BackgroundFetchWorker.java | 221 ExecutionSequencer sequencer = ExecutionSequencer.create(); in updateData() local
|
| D | ScheduledUpdatesHandler.java | 309 ExecutionSequencer sequencer = ExecutionSequencer.create(); in handleUpdates() local
|
| /aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/ |
| H A D | web_transport_stream_adapter.cc | 32 QuicSession* session, QuicStream* stream, QuicStreamSequencer* sequencer) in WebTransportStreamAdapter()
|
| /aosp_15_r20/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/adselection/ |
| D | PerBuyerBiddingRunner.java | 126 ExecutionSequencer sequencer = ExecutionSequencer.create(); in runBidPerCAWorkPartition() local
|
| /aosp_15_r20/packages/modules/Permission/PermissionController/tests/mocking/src/com/android/permissioncontroller/tests/mocking/safetycenter/ui/ |
| D | SafetyStatusAnimationSequencerTest.kt | 33 private val sequencer: SafetyStatusAnimationSequencer = SafetyStatusAnimationSequencer() constant in com.android.permissioncontroller.tests.mocking.safetycenter.ui.SafetyStatusAnimationSequencerTest
|
| /aosp_15_r20/external/webrtc/modules/rtp_rtcp/source/ |
| H A D | rtp_sender_egress.cc | 35 PacketSequencer* sequencer) in NonPacedPacketSender()
|
| /aosp_15_r20/prebuilts/jdk/jdk8/linux-x86/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/ |
| D | ScanManager.java | 167 private final Semaphore sequencer = new Semaphore(1); field in ScanManager
|
| /aosp_15_r20/prebuilts/jdk/jdk8/darwin-x86/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/ |
| D | ScanManager.java | 167 private final Semaphore sequencer = new Semaphore(1); field in ScanManager
|