Skip to content

Commit 169ec04

Browse files
philippeVerneyphilippeVerney
committed
Fix some numerical datatype conversion warnings
1 parent b1f0b13 commit 169ec04

6 files changed

Lines changed: 208 additions & 209 deletions

File tree

‎src/etp/ClientSessionLaunchers.cpp‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,11 @@ namespace
3232
{
3333
std::size_t getNegotiatedMaxWebSocketFramePayloadSize(const std::string& responseBody, std::size_t preferredMaxFrameSize) {
3434
const auto maxWebSocketFramePayloadSizePos = responseBody.find("MaxWebSocketFramePayloadSize");
35-
if (maxWebSocketFramePayloadSizePos == std::string::npos) return preferredMaxFrameSize;
35+
if (maxWebSocketFramePayloadSizePos == std::string::npos ||
36+
maxWebSocketFramePayloadSizePos > static_cast<size_t>(std::numeric_limits<std::streamoff>::max())) return preferredMaxFrameSize;
3637

3738
std::istringstream iss(responseBody);
38-
iss.seekg(maxWebSocketFramePayloadSizePos);
39+
iss.seekg(static_cast<std::streamoff>(maxWebSocketFramePayloadSizePos));
3940

4041
std::string temp;
4142
std::size_t serverMaxWebSocketFramePayloadSize;

‎src/etp/InitializationParameters.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ std::map<std::string, Energistics::Etp::v12::Datatypes::DataValue> Initializatio
8282
Energistics::Etp::v12::Datatypes::DataValue value;
8383

8484
if (maxWebSocketMessagePayloadSize > 0) {
85-
value.item.set_long(maxWebSocketMessagePayloadSize);
85+
value.item.set_long(static_cast<int64_t>(maxWebSocketMessagePayloadSize));
8686
result["MaxWebSocketFramePayloadSize"] = value;
8787
result["MaxWebSocketMessagePayloadSize"] = value;
8888
}

‎src/etp/fesapi/FesapiHdfProxy.cpp‎

Lines changed: 110 additions & 138 deletions
Original file line numberDiff line numberDiff line change
@@ -178,68 +178,54 @@ namespace {
178178
}
179179
}
180180

181-
void FesapiHdfProxy::writeArrayNd(const std::string & groupName,
182-
const std::string & name,
181+
void FesapiHdfProxy::writeArrayNd(const std::string& groupName,
182+
const std::string& name,
183183
COMMON_NS::AbstractObject::numericalDatatypeEnum datatype,
184-
const void * values,
185-
const uint64_t * numValuesInEachDimension,
184+
const void* values,
185+
const uint64_t* numValuesInEachDimension,
186186
unsigned int numDimensions)
187187
{
188-
if (!isOpened())
189-
open();
190-
191-
// URI AND PATH
192-
std::string uri{ buildEtp12Uri() };
193-
194-
std::string pathInResource{ (groupName.back() == '/' ?
195-
groupName : groupName + '/') + name };
196-
197-
// Create Dimensions and Total Count
198-
size_t totalCount{ 1 };
199-
std::vector<int64_t> dimensions{};
200-
201-
for (size_t i = 0; i < numDimensions; ++i) {
202-
dimensions.push_back(numValuesInEachDimension[i]);
203-
totalCount *= numValuesInEachDimension[i];
204-
}
205-
206-
// Determine Value Size (bytes) and Any Array Type
207-
size_t valueSize{ 1 };
208-
209-
switch (datatype) {
210-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
211-
valueSize = sizeof(double);
212-
break;
213-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
214-
valueSize = sizeof(float);
215-
break;
216-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
217-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
218-
valueSize = sizeof(int64_t);
219-
break;
220-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
221-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
222-
valueSize = sizeof(int32_t);
223-
break;
224-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
225-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
226-
valueSize = sizeof(short);
227-
break;
228-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
229-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
230-
valueSize = sizeof(char);
231-
break;
232-
default:
233-
throw std::logic_error(
234-
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
235-
}
188+
if (!isOpened()) open();
189+
190+
const size_t totalCount = std::accumulate(numValuesInEachDimension, numValuesInEachDimension + numDimensions, size_t{ 1 }, std::multiplies<uint64_t>());
191+
const size_t valueSize = [&datatype] {
192+
switch (datatype) {
193+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
194+
return sizeof(double);
195+
break;
196+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
197+
return sizeof(float);
198+
break;
199+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
200+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
201+
return sizeof(int64_t);
202+
break;
203+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
204+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
205+
return sizeof(int32_t);
206+
break;
207+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
208+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
209+
return sizeof(short);
210+
break;
211+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
212+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
213+
return sizeof(char);
214+
break;
215+
default:
216+
throw std::logic_error(
217+
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
218+
}
219+
}();
236220

237221
if (totalCount * valueSize <= maxArraySize_) {
238222
// PUT DATA ARRAYS
239223
auto pda = std::make_shared<Energistics::Etp::v12::Protocol::DataArray::PutDataArrays>();
240-
pda->dataArrays["0"].uid.uri = uri;
241-
pda->dataArrays["0"].uid.pathInResource = pathInResource;
242-
pda->dataArrays["0"].array.dimensions = dimensions;
224+
pda->dataArrays["0"].uid.uri = buildEtp12Uri();
225+
pda->dataArrays["0"].uid.pathInResource = (groupName.back() == '/' ? groupName : groupName + '/') + name;
226+
pda->dataArrays["0"].array.dimensions.resize(numDimensions);
227+
std::transform(numValuesInEachDimension, numValuesInEachDimension + numDimensions, pda->dataArrays["0"].array.dimensions.begin(),
228+
[](uint64_t val) { return static_cast<int64_t>(val); });
243229

244230
// Create AVRO Array
245231
pda->dataArrays["0"].array.data = convertVoidArrayIntoAvroAnyArray(datatype, values, totalCount);
@@ -270,48 +256,43 @@ void FesapiHdfProxy::createArrayNd(
270256
const uint64_t* numValuesInEachDimension,
271257
unsigned int numDimensions)
272258
{
273-
std::string pathInResource{ (groupName.back() == '/' ?
274-
groupName : groupName + '/') + datasetName };
275-
276-
std::vector<int64_t> dimensions{};
277-
for (size_t i = 0; i < numDimensions; ++i) {
278-
dimensions.push_back(numValuesInEachDimension[i]);
279-
}
280-
Energistics::Etp::v12::Datatypes::AnyArrayType anyArrayType;
281-
282-
switch (datatype) {
283-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
284-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfDouble;
285-
break;
286-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
287-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfFloat;
288-
break;
289-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
290-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
291-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfLong;
292-
break;
293-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
294-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
295-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt;
296-
break;
297-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
298-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
299-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt;
300-
break;
301-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
302-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
303-
anyArrayType = Energistics::Etp::v12::Datatypes::AnyArrayType::bytes;
304-
break;
305-
default:
306-
throw std::logic_error(
307-
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
308-
}
259+
const Energistics::Etp::v12::Datatypes::AnyArrayType anyArrayType = [&datatype] {
260+
switch (datatype) {
261+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
262+
return Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfDouble;
263+
break;
264+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
265+
return Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfFloat;
266+
break;
267+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
268+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
269+
return Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfLong;
270+
break;
271+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
272+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
273+
return Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt;
274+
break;
275+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
276+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
277+
return Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt;
278+
break;
279+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
280+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
281+
return Energistics::Etp::v12::Datatypes::AnyArrayType::bytes;
282+
break;
283+
default:
284+
throw std::logic_error(
285+
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
286+
}
287+
}();
309288

310289
// PUT UNINITIALIZED DATA ARRAYS
311290
auto puda = std::make_shared<Energistics::Etp::v12::Protocol::DataArray::PutUninitializedDataArrays>();
312291
puda->dataArrays["0"].uid.uri = buildEtp12Uri();
313-
puda->dataArrays["0"].uid.pathInResource = pathInResource;
314-
puda->dataArrays["0"].metadata.dimensions = dimensions;
292+
puda->dataArrays["0"].uid.pathInResource = (groupName.back() == '/' ? groupName : groupName + '/') + datasetName;
293+
puda->dataArrays["0"].metadata.dimensions.resize(numDimensions);
294+
std::transform(numValuesInEachDimension, numValuesInEachDimension + numDimensions, puda->dataArrays["0"].metadata.dimensions.begin(),
295+
[](uint64_t val) { return static_cast<int64_t>(val); });
315296
puda->dataArrays["0"].metadata.transportArrayType = anyArrayType;
316297

317298
// Send Uninitialized Data Arrays
@@ -358,62 +339,53 @@ std::set<int64_t> FesapiHdfProxy::async_writeArrayNdSlab(
358339
const uint64_t* offsetInEachDimension,
359340
unsigned int numDimensions)
360341
{
361-
if (!isOpened())
362-
open();
363-
364-
// URI AND PATH
365-
const std::string uri{ buildEtp12Uri() };
366-
367-
const std::string pathInResource{ (groupName.back() == '/' ?
368-
groupName : groupName + '/') + datasetName };
342+
if (!isOpened()) open();
369343

370344
// Create Total Count
371-
const size_t totalCount = std::accumulate(numValuesInEachDimension, numValuesInEachDimension + numDimensions, 1, std::multiplies<size_t>());
372-
373-
// Determine Value Size (bytes) and Any Array Type
374-
size_t valueSize{ 1 };
375-
376-
switch (datatype) {
377-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
378-
valueSize = sizeof(double);
379-
break;
380-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
381-
valueSize = sizeof(float);
382-
break;
383-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
384-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
385-
valueSize = sizeof(int64_t);
386-
break;
387-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
388-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
389-
valueSize = sizeof(int32_t);
390-
break;
391-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
392-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
393-
valueSize = sizeof(int16_t);
394-
break;
395-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
396-
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
397-
valueSize = sizeof(int8_t);
398-
break;
399-
default:
400-
throw std::logic_error(
401-
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
402-
}
345+
const size_t totalCount = std::accumulate(numValuesInEachDimension, numValuesInEachDimension + numDimensions, 1ull, std::multiplies<size_t>());
346+
const size_t valueSize = [&datatype] {
347+
switch (datatype) {
348+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::DOUBLE:
349+
return sizeof(double);
350+
break;
351+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::FLOAT:
352+
return sizeof(float);
353+
break;
354+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT64:
355+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT64:
356+
return sizeof(int64_t);
357+
break;
358+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT32:
359+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT32:
360+
return sizeof(int32_t);
361+
break;
362+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT16:
363+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT16:
364+
return sizeof(short);
365+
break;
366+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::INT8:
367+
case COMMON_NS::AbstractObject::numericalDatatypeEnum::UINT8:
368+
return sizeof(char);
369+
break;
370+
default:
371+
throw std::logic_error(
372+
"You need to give a COMMON_NS::AbstractObject::numericalDatatypeEnum as the datatype");
373+
}
374+
}();
403375

404376
std::set<int64_t> sentMessageIds;
405377
if (totalCount * valueSize <= maxArraySize_) {
406378
std::vector<int64_t> counts;
407379
std::vector<int64_t> starts;
408380
for (size_t i = 0; i < numDimensions; ++i) {
409-
counts.push_back(numValuesInEachDimension[i]);
410-
starts.push_back(offsetInEachDimension[i]);
381+
counts.push_back(static_cast<int64_t>(numValuesInEachDimension[i]));
382+
starts.push_back(static_cast<int64_t>(offsetInEachDimension[i]));
411383
}
412384

413385
// PUT DATA SUBARRAYS
414386
auto pdsa = std::make_shared<Energistics::Etp::v12::Protocol::DataArray::PutDataSubarrays>();
415-
pdsa->dataSubarrays["0"].uid.uri = uri;
416-
pdsa->dataSubarrays["0"].uid.pathInResource = pathInResource;
387+
pdsa->dataSubarrays["0"].uid.uri = buildEtp12Uri();
388+
pdsa->dataSubarrays["0"].uid.pathInResource = (groupName.back() == '/' ? groupName : groupName + '/') + datasetName;
417389
pdsa->dataSubarrays["0"].starts = starts;
418390
pdsa->dataSubarrays["0"].counts = counts;
419391

@@ -443,7 +415,7 @@ std::set<int64_t> FesapiHdfProxy::async_writeArrayNdSlab(
443415
starts.get(), numDimensions);
444416
sentMessageIds.insert(intermediateResult.begin(), intermediateResult.end());
445417

446-
writtenTotalCount = std::accumulate(counts.get(), counts.get() + numDimensions, 1, std::multiplies<size_t>());
418+
writtenTotalCount = std::accumulate(counts.get(), counts.get() + numDimensions, 1ull, std::multiplies<size_t>());
447419

448420
starts[dimIdx] += counts[dimIdx];
449421
counts[dimIdx] = previousCount - counts[dimIdx];

‎src/etp/fesapi/FesapiHdfProxy.h‎

Lines changed: 16 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -509,16 +509,17 @@ namespace ETP_NS
509509
{
510510
// First get metadata about the data array
511511
const Energistics::Etp::v12::Datatypes::DataArrayTypes::DataArrayMetadata daMetadata = getDataArrayMetadata(datasetName);
512-
const size_t valueCount = std::accumulate(daMetadata.dimensions.begin(), daMetadata.dimensions.end(), 1, std::multiplies<int64_t>());
512+
const size_t valueCount = std::accumulate(daMetadata.dimensions.begin(), daMetadata.dimensions.end(),
513+
size_t{1}, [](size_t a, int64_t b) { return a * static_cast<size_t>(b); });
513514

514515
size_t valueSize = 1;
515516
switch (daMetadata.transportArrayType) {
516517
case Energistics::Etp::v12::Datatypes::AnyArrayType::bytes:
517518
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfBoolean: break;
518-
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt: valueSize = 6; break; // 25% more because of zig zag encoding worst case scenario
519-
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfFloat: valueSize = 4; break;
520-
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfLong: valueSize = 10; break; // 25% more because of zig zag encoding worst case scenario
521-
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfDouble: valueSize = 8; break;
519+
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfInt: valueSize = 6ull; break; // 25% more because of zig zag encoding worst case scenario
520+
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfFloat: valueSize = 4ull; break;
521+
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfLong: valueSize = 10ull; break; // 25% more because of zig zag encoding worst case scenario
522+
case Energistics::Etp::v12::Datatypes::AnyArrayType::arrayOfDouble: valueSize = 8ull; break;
522523
default: throw std::logic_error("Array of strings are not implemented yet");
523524
}
524525
const size_t wholeSize = valueCount * valueSize;
@@ -543,18 +544,17 @@ namespace ETP_NS
543544

544545
// Compute the dimensions of the subArrays to get
545546
size_t subArrayValueCount = 1;
546-
for (int64_t dimIndex = daMetadata.dimensions.size() - 1; dimIndex >= 0; --dimIndex) {
547-
int64_t maxCountOnDim = daMetadata.preferredSubarrayDimensions.empty()
548-
? daMetadata.dimensions[dimIndex]
549-
: daMetadata.preferredSubarrayDimensions[dimIndex];
547+
for (auto it = daMetadata.dimensions.rbegin(); it != daMetadata.dimensions.rend(); ++it) {
548+
const size_t dimIndex = static_cast<size_t>(std::distance(daMetadata.dimensions.begin(), it.base()) - 1);
549+
const size_t maxCountOnDim = static_cast<size_t>(daMetadata.preferredSubarrayDimensions.empty() ? *it : daMetadata.preferredSubarrayDimensions[dimIndex]);
550550
subArrayValueCount *= maxCountOnDim;
551-
int64_t allowedCountOnDim = maxCountOnDim;
551+
size_t allowedCountOnDim = maxCountOnDim;
552552
while (subArrayValueCount * valueSize + (subArrayValueCount + 1) * 8 > maxAllowedDataArraySize) {
553553
subArrayValueCount /= allowedCountOnDim;
554554
allowedCountOnDim /= 2;
555555
subArrayValueCount *= allowedCountOnDim;
556556
}
557-
counts[dimIndex] = allowedCountOnDim;
557+
counts[dimIndex] = static_cast<int64_t>(allowedCountOnDim);
558558
if (allowedCountOnDim != maxCountOnDim) {
559559
break;
560560
}
@@ -575,11 +575,12 @@ namespace ETP_NS
575575
// next sub array to get
576576
++subArrayIndex;
577577
hasParsedAllArray = true;
578-
for (int64_t dimIndex = daMetadata.dimensions.size() - 1; dimIndex >= 0; --dimIndex) {
579-
if (starts[dimIndex] + currentCounts[dimIndex] < daMetadata.dimensions[dimIndex]) {
578+
for (auto it = daMetadata.dimensions.rbegin(); it != daMetadata.dimensions.rend(); ++it) {
579+
const size_t dimIndex = static_cast<size_t>(std::distance(daMetadata.dimensions.begin(), it.base()) - 1);
580+
if (starts[dimIndex] + currentCounts[dimIndex] < *it) {
580581
starts[dimIndex] += currentCounts[dimIndex];
581-
if (starts[dimIndex] + currentCounts[dimIndex] > daMetadata.dimensions[dimIndex]) {
582-
currentCounts[dimIndex] = daMetadata.dimensions[dimIndex] - starts[dimIndex];
582+
if (starts[dimIndex] + currentCounts[dimIndex] > *it) {
583+
currentCounts[dimIndex] = *it - starts[dimIndex];
583584
}
584585

585586
for (size_t dimIndex2 = dimIndex + 1; dimIndex2 < daMetadata.dimensions.size(); ++dimIndex2) {

‎src/etp/protocolHandlers/CoreHandlers.cpp‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ void CoreHandlers::decodeMessageBody(const Energistics::Etp::v12::Datatypes::Mes
4646
auto search = os.endpointCapabilities.find("MaxWebSocketMessagePayloadSize");
4747
if (search != os.endpointCapabilities.end() &&
4848
search->second.item.idx() == 3) {
49-
const uint64_t maxWebSocketMessagePayloadSize = search->second.item.get_long();
49+
const uint64_t maxWebSocketMessagePayloadSize = static_cast<uint64_t>(search->second.item.get_long());
5050
if (maxWebSocketMessagePayloadSize > 0 &&
5151
maxWebSocketMessagePayloadSize < session->getMaxWebSocketMessagePayloadSize()) {
5252
session->setMaxWebSocketMessagePayloadSize(maxWebSocketMessagePayloadSize);

0 commit comments

Comments
 (0)