[xpcom] Make Base64 compatible with ReadSegments() with small buffers.

master
Fedor 2020-08-12 09:54:08 +03:00
parent 865e277683
commit 63f4b4c30e
2 changed files with 26 additions and 7 deletions

View File

@ -5,6 +5,7 @@
# file, You can obtain one at http://mozilla.org/MPL/2.0/. # file, You can obtain one at http://mozilla.org/MPL/2.0/.
UNIFIED_SOURCES += [ UNIFIED_SOURCES += [
'TestBase64Stream.cpp',
'TestProtocolProxyService.cpp', 'TestProtocolProxyService.cpp',
'TestStandardURL.cpp', 'TestStandardURL.cpp',
] ]

View File

@ -108,30 +108,51 @@ EncodeInputStream_Encoder(nsIInputStream* aStream,
EncodeInputStream_State<T>* state = EncodeInputStream_State<T>* state =
static_cast<EncodeInputStream_State<T>*>(aClosure); static_cast<EncodeInputStream_State<T>*>(aClosure);
// We always consume all data.
*aWriteCount = aCount;
// If we have any data left from last time, encode it now. // If we have any data left from last time, encode it now.
uint32_t countRemaining = aCount; uint32_t countRemaining = aCount;
const unsigned char* src = (const unsigned char*)aFromSegment; const unsigned char* src = (const unsigned char*)aFromSegment;
if (state->charsOnStack) { if (state->charsOnStack) {
MOZ_ASSERT(state->charsOnStack == 1 || state->charsOnStack == 2);
// Not enough data to compose a triple.
if (state->charsOnStack == 1 && countRemaining == 1) {
state->charsOnStack = 2;
state->c[1] = src[0];
return NS_OK;
}
uint32_t consumed = 0;
unsigned char firstSet[4]; unsigned char firstSet[4];
if (state->charsOnStack == 1) { if (state->charsOnStack == 1) {
firstSet[0] = state->c[0]; firstSet[0] = state->c[0];
firstSet[1] = src[0]; firstSet[1] = src[0];
firstSet[2] = (countRemaining > 1) ? src[1] : '\0'; firstSet[2] = src[1];
firstSet[3] = '\0'; firstSet[3] = '\0';
consumed = 2;
} else /* state->charsOnStack == 2 */ { } else /* state->charsOnStack == 2 */ {
firstSet[0] = state->c[0]; firstSet[0] = state->c[0];
firstSet[1] = state->c[1]; firstSet[1] = state->c[1];
firstSet[2] = src[0]; firstSet[2] = src[0];
firstSet[3] = '\0'; firstSet[3] = '\0';
consumed = 1;
} }
Encode(firstSet, 3, state->buffer); Encode(firstSet, 3, state->buffer);
state->buffer += 4; state->buffer += 4;
countRemaining -= (3 - state->charsOnStack); countRemaining -= consumed;
src += (3 - state->charsOnStack); src += consumed;
state->charsOnStack = 0; state->charsOnStack = 0;
// Bail if there is nothing left.
if (!countRemaining) {
return NS_OK;
}
} }
// Encode the bulk of the // Encode as many full triplets as possible.
uint32_t encodeLength = countRemaining - countRemaining % 3; uint32_t encodeLength = countRemaining - countRemaining % 3;
MOZ_ASSERT(encodeLength % 3 == 0, MOZ_ASSERT(encodeLength % 3 == 0,
"Should have an exact number of triplets!"); "Should have an exact number of triplets!");
@ -140,9 +161,6 @@ EncodeInputStream_Encoder(nsIInputStream* aStream,
src += encodeLength; src += encodeLength;
countRemaining -= encodeLength; countRemaining -= encodeLength;
// We must consume all data, so if there's some data left stash it
*aWriteCount = aCount;
if (countRemaining) { if (countRemaining) {
// We should never have a full triplet left at this point. // We should never have a full triplet left at this point.
MOZ_ASSERT(countRemaining < 3, "We should have encoded more!"); MOZ_ASSERT(countRemaining < 3, "We should have encoded more!");