| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | SharedFlow.kt | 214 …val bufferCapacity = if (bufferCapacity0 < 0) Int.MAX_VALUE else bufferCapacity0 // coerce to MAX_… in tryEmit() constant
215 return SharedFlowImpl(replay, bufferCapacity, onBufferOverflow) in tryEmit()
244 private val bufferCapacity: Int, constant in kotlinx.coroutines.flow.SharedFlowImpl
347 if (bufferSize >= bufferCapacity && minCollectorIndex <= replayIndex) { in tryEmitLocked()
357 if (bufferSize > bufferCapacity) dropOldestLocked() in tryEmitLocked()
430 if (bufferCapacity == 0) resumes = findSlotsToResumeLocked(resumes) in emitSuspend()
461 if (bufferCapacity == 0 && queueSize > 0) newMinCollectorIndex++ in updateCollectorIndexLocked()
476 minOf(queueSize, bufferCapacity - newBufferSize0) in updateCollectorIndexLocked()
510 …if (bufferCapacity == 0 && newReplayIndex < newQueueEndIndex && buffer!!.getBufferAt(newReplayInde… in updateCollectorIndexLocked()
548 if (bufferCapacity == 0 && queueSize <= 1) return // return, don't clear it in cleanupTailLocked()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/ |
| D | ShareInConflationTest.kt | 19 bufferCapacity: Int, in <lambda>()
37 … val first = if (onBufferOverflow == BufferOverflow.DROP_LATEST) 0 else n - bufferCapacity in <lambda>()
38 val last = first + bufferCapacity - 1 in <lambda>()
46 finish(n + bufferCapacity + 2) in <lambda>()
|
| /external/icu/icu4c/source/i18n/ |
| D | number_capi.cpp | 150 unumf_resultToString(const UFormattedNumber* uresult, UChar* buffer, int32_t bufferCapacity, in unumf_resultToString() argument
155 if (buffer == nullptr ? bufferCapacity != 0 : bufferCapacity < 0) { in unumf_resultToString()
160 return result->fData.toTempString(*ec).extract(buffer, bufferCapacity, *ec); in unumf_resultToString()
|
| /external/icu/icu4c/source/common/ |
| D | uloc.cpp | 719 char* buffer, int32_t bufferCapacity, in uloc_getKeywordValue() argument
726 CheckedArrayByteSink sink(buffer, bufferCapacity); in uloc_getKeywordValue()
738 u_terminateChars(buffer, bufferCapacity, reslen, status); in uloc_getKeywordValue()
857 char* buffer, int32_t bufferCapacity, in uloc_setKeywordValue() argument
883 if (keywordName == NULL || keywordName[0] == 0 || bufferCapacity <= 1) { in uloc_setKeywordValue()
888 if(bufferCapacity<bufLen) { in uloc_setKeywordValue()
931 if(needLen >= bufferCapacity) { in uloc_setKeywordValue()
1068 if (appendLength >= bufferCapacity - needLen) { in uloc_setKeywordValue()
1073 startSearchHere, bufferCapacity - needLen, *status); in uloc_setKeywordValue()
|
| D | ucnvsel.cpp | 284 void* buffer, int32_t bufferCapacity, UErrorCode* status) { in ucnvsel_serialize() argument
291 if (bufferCapacity < 0 || in ucnvsel_serialize()
292 (bufferCapacity > 0 && (p == NULL || (U_POINTER_MASK_LSB(p, 3) != 0))) in ucnvsel_serialize()
325 if (totalSize > bufferCapacity) { in ucnvsel_serialize()
|
| D | uniset.cpp | 1436 bufferCapacity = 0; in compact()
1679 if (newLen <= bufferCapacity) { in ensureBufferCapacity()
1694 bufferCapacity = newCapacity; in ensureBufferCapacity()
1708 capacity = bufferCapacity; in swapBuffers()
1709 bufferCapacity = c; in swapBuffers()
|
| D | loclikely.cpp | 1187 int32_t bufferCapacity, in do_canonicalize() argument
1193 bufferCapacity, in do_canonicalize()
|
| /external/icu/icu4c/source/common/unicode/ |
| D | ucnvsel.h | 152 void* buffer, int32_t bufferCapacity, UErrorCode* status);
|
| D | uloc.h | 966 char* buffer, int32_t bufferCapacity,
1003 char* buffer, int32_t bufferCapacity,
|
| D | locid.h | 650 …int32_t getKeywordValue(const char* keywordName, char *buffer, int32_t bufferCapacity, UErrorCode …
|
| D | uniset.h | 298 int32_t bufferCapacity = 0; // capacity of buffer variable
|
| /external/icu/libandroidicu/include/unicode/ |
| D | ucnvsel.h | 152 void* buffer, int32_t bufferCapacity, UErrorCode* status);
|
| D | uloc.h | 966 char* buffer, int32_t bufferCapacity,
1003 char* buffer, int32_t bufferCapacity,
|
| D | unumberformatter.h | 595 unumf_resultToString(const UFormattedNumber* uresult, UChar* buffer, int32_t bufferCapacity,
|
| /external/icu/libicu/cts_headers/unicode/ |
| D | ucnvsel.h | 152 void* buffer, int32_t bufferCapacity, UErrorCode* status);
|
| D | uloc.h | 966 char* buffer, int32_t bufferCapacity,
1003 char* buffer, int32_t bufferCapacity,
|
| D | unumberformatter.h | 595 unumf_resultToString(const UFormattedNumber* uresult, UChar* buffer, int32_t bufferCapacity,
|
| D | locid.h | 650 …int32_t getKeywordValue(const char* keywordName, char *buffer, int32_t bufferCapacity, UErrorCode …
|
| /external/icu/libicu/ndk_headers/unicode/ |
| D | uloc.h | 953 char* buffer, int32_t bufferCapacity,
992 char* buffer, int32_t bufferCapacity,
|
| /external/icu/icu4c/source/tools/toolutil/ |
| D | udbgutil.h | 103 U_CAPI int32_t udbg_getSystemParameterValueByIndex(int32_t i, char *buffer, int32_t bufferCapacity,…
|
| D | udbgutil.cpp | 572 U_CAPI int32_t udbg_getSystemParameterValueByIndex(int32_t i, char *buffer, int32_t bufferCapacity,… in udbg_getSystemParameterValueByIndex() argument
574 return systemParams[i].paramFunction(&(systemParams[i]),buffer,bufferCapacity,status); in udbg_getSystemParameterValueByIndex()
|
| /external/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/ |
| D | AnalyzerActivity.java | 134 int bufferCapacity = outStream.getBufferCapacityInFrames(); in getCommonTestReport() local
135 report.append(String.format("out.buffer.capacity.frames = %d\n", bufferCapacity)); in getCommonTestReport()
|
| /external/icu/icu4c/source/i18n/unicode/ |
| D | unumberformatter.h | 595 unumf_resultToString(const UFormattedNumber* uresult, UChar* buffer, int32_t bufferCapacity,
|
| /external/oboe/tests/ |
| D | testStreamClosedMethods.cpp | 106 int32_t bufferCapacity = mStream->getBufferCapacityInFrames(); in TEST_F() local
108 ASSERT_EQ(mStream->getBufferCapacityInFrames(), bufferCapacity); in TEST_F()
|
| /external/icu/libicu/src/ |
| D | shim.cpp | 917 …st char * localeID, const char * keywordName, char * buffer, int32_t bufferCapacity, UErrorCode * … in uloc_getKeywordValue() argument
918 …CU_ENTRY_POINT_RENAME(uloc_getKeywordValue)(localeID, keywordName, buffer, bufferCapacity, status); in uloc_getKeywordValue()
944 …har * keywordName, const char * keywordValue, char * buffer, int32_t bufferCapacity, UErrorCode * … in uloc_setKeywordValue() argument
945 …NTRY_POINT_RENAME(uloc_setKeywordValue)(keywordName, keywordValue, buffer, bufferCapacity, status); in uloc_setKeywordValue()
|