| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #include <string> |
| #include <iostream> |
| #include <iomanip> |
| |
| #include <geode/DataOutput.hpp> |
| #include <geode/DataInput.hpp> |
| #include "SerializationRegistry.hpp" |
| #include "DataInputInternal.hpp" |
| #include "DataOutputInternal.hpp" |
| |
| #include "fw_helper.hpp" |
| |
| using apache::geode::client::DataInputInternal; |
| using apache::geode::client::DataOutputInternal; |
| |
| void dumpnbytes(const uint8_t *buf, size_t length) { |
| for (size_t i = 0; i < length; i++) { |
| std::cout << "buf[" << i << "] = " << std::setfill('0') << std::setw(2) |
| << std::hex << (static_cast<int16_t>(buf[i]) & 0xff) << std::dec |
| << " " << static_cast<char>(buf[i]) << std::endl; |
| } |
| } |
| void dumpnshorts(const uint16_t *buf, size_t length) { |
| for (size_t i = 0; i < length; i++) { |
| std::cout << "buf[" << i << "] = " << std::hex |
| << static_cast<uint16_t>(buf[i]) << std::dec << std::endl; |
| } |
| } |
| void dumpnwords(const uint32_t *buf, size_t length) { |
| for (size_t i = 0; i < length; i++) { |
| std::cout << "buf[" << i << "] = " << std::hex |
| << static_cast<uint32_t>(buf[i]) << std::dec << std::endl; |
| } |
| } |
| |
| BEGIN_TEST(Byte) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.write(static_cast<uint8_t>(0x11)); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x11), "expected 0x11."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| const auto result = dataInput.read(); |
| ASSERT(result == static_cast<uint8_t>(0x11), "expected 0x11"); |
| } |
| END_TEST(Byte) |
| |
| BEGIN_TEST(Boolean) |
| { |
| DataOutputInternal dataOutput(nullptr); |
| |
| dataOutput.writeBoolean(true); |
| dataOutput.writeBoolean(false); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x1), "expected 0x1."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0x0), "expected 0x0."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| auto result = dataInput.readBoolean(); |
| ASSERT(result, "expected true"); |
| result = dataInput.readBoolean(); |
| ASSERT(result == false, "expected false"); |
| } |
| END_TEST(Boolean) |
| |
| BEGIN_TEST(Short) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.writeInt(static_cast<int16_t>(0x1122)); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x11), "expected 0x11."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0x22), "expected 0x22."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| int16_t result = dataInput.readInt16(); |
| ASSERT(result == 0x1122, "expected 0x1122"); |
| } |
| END_TEST(Short) |
| |
| BEGIN_TEST(int_t) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.writeInt(static_cast<int32_t>(0x11223344)); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| dumpnbytes(buffer, 4); |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x11), "expected 0x11."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0x22), "expected 0x22."); |
| ASSERT(buffer[2] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[3] == static_cast<uint8_t>(0x44), "expected 0x44."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| int32_t result = dataInput.readInt32(); |
| ASSERT(result == 0x11223344, "expected 0x11223344"); |
| } |
| END_TEST(int_t) |
| |
| BEGIN_TEST(Long) |
| { |
| DataOutputInternal dataOutput; |
| |
| int64_t value = ((static_cast<int64_t>(0x11223344)) << 32) | 0x55667788; |
| dataOutput.writeInt(value); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x11), "expected 0x11."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0x22), "expected 0x22."); |
| ASSERT(buffer[2] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[3] == static_cast<uint8_t>(0x44), "expected 0x44."); |
| ASSERT(buffer[4] == static_cast<uint8_t>(0x55), "expected 0x55."); |
| ASSERT(buffer[5] == static_cast<uint8_t>(0x66), "expected 0x66."); |
| ASSERT(buffer[6] == static_cast<uint8_t>(0x77), "expected 0x77."); |
| ASSERT(buffer[7] == static_cast<uint8_t>(0x88), "expected 0x88."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| int64_t result = dataInput.readInt64(); |
| ASSERT(result == value, "expected 0x1122334455667788"); |
| } |
| END_TEST(Long) |
| |
| BEGIN_TEST(Float) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.writeFloat(1.2f); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x3f), "expected 0x3f."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0x99), "expected 0x99."); |
| ASSERT(buffer[2] == static_cast<uint8_t>(0x99), "expected 0x99."); |
| ASSERT(buffer[3] == static_cast<uint8_t>(0x9a), "expected 0x9a."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| float result = dataInput.readFloat(); |
| ASSERT(result == 1.2f, "expected 1.2f"); |
| } |
| END_TEST(Float) |
| |
| BEGIN_TEST(Double) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.writeDouble(1.2); |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| ASSERT(buffer[0] == static_cast<uint8_t>(0x3f), "expected 0x3f."); |
| ASSERT(buffer[1] == static_cast<uint8_t>(0xf3), "expected 0xf3."); |
| ASSERT(buffer[2] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[3] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[4] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[5] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[6] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| ASSERT(buffer[7] == static_cast<uint8_t>(0x33), "expected 0x33."); |
| |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| double result = dataInput.readDouble(); |
| ASSERT(result == 1.2, "expected 1.2"); |
| } |
| END_TEST(Double) |
| |
| // Test data output numbers. |
| BEGIN_TEST(Numbers) |
| { |
| DataOutputInternal dataOutput; |
| |
| dataOutput.write(static_cast<uint8_t>(0x11)); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| dataOutput.writeInt(static_cast<int16_t>(0x1122)); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| dataOutput.writeInt(0x11223344); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| dataOutput.writeInt(((static_cast<int64_t>(0x11223344)) << 32) | |
| 0x55667788); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| dataOutput.writeFloat(1.2f); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| dataOutput.writeDouble(1.2); |
| dataOutput.write(static_cast<uint8_t>(0xAA)); |
| |
| // test data |
| } |
| END_TEST(Numbers) |
| |
| BEGIN_TEST(WideStrings) |
| { |
| DataOutputInternal dataOutput; |
| |
| wchar_t *strOrig = new wchar_t[40]; |
| strOrig[0] = 0; |
| strOrig[1] = 0x7f; |
| strOrig[2] = 0x80; |
| strOrig[3] = 0x81; |
| strOrig[4] = 0xfffd; |
| |
| dumpnshorts(reinterpret_cast<uint16_t *>(strOrig), 5); |
| dataOutput.writeUTF(std::wstring(strOrig, 5)); |
| |
| const uint8_t *buffer = dataOutput.getBuffer(); |
| std::cout << "Wrote to buffer..." << std::endl; |
| dumpnbytes(buffer, dataOutput.getBufferLength()); |
| |
| ASSERT(buffer[0] == 0x00, "wrong utf encoding."); |
| ASSERT(buffer[1] == 0x0a, "wrong utf encoding."); |
| ASSERT(buffer[2] == 0xc0, "wrong utf encoding."); |
| ASSERT(buffer[3] == 0x80, "wrong utf encoding."); |
| ASSERT(buffer[4] == 0x7f, "wrong utf encoding."); |
| ASSERT(buffer[5] == 0xc2, "wrong utf encoding."); |
| ASSERT(buffer[6] == 0x80, "wrong utf encoding."); |
| ASSERT(buffer[7] == 0xc2, "wrong utf encoding."); |
| ASSERT(buffer[8] == 0x81, "wrong utf encoding."); |
| ASSERT(buffer[9] == 0xef, "wrong utf encoding."); |
| ASSERT(buffer[10] == 0xbf, "wrong utf encoding."); |
| ASSERT(buffer[11] == 0xbd, "wrong utf encoding."); |
| std::cout << "sizeof wchar_t " << sizeof(wchar_t) << std::endl; |
| DataInputInternal dataInput(buffer, dataOutput.getBufferLength(), nullptr); |
| auto str = dataInput.readUTF<wchar_t>(); |
| ASSERT(str.length() == 5, "expected length 5."); |
| std::cout << "Read from buffer..." << std::endl; |
| dumpnshorts(reinterpret_cast<const uint16_t *>(str.data()), 5); |
| |
| ASSERT(str[0] == 0x00, "wrong decoded value"); |
| ASSERT(str[1] == 0x7f, "wrong decoded value"); |
| ASSERT(str[2] == 0x80, "wrong decoded value"); |
| ASSERT(str[3] == 0x81, "wrong decoded value"); |
| ASSERT(str[4] == 0xfffd, "wrong decoded value"); |
| |
| delete[] strOrig; |
| } |
| END_TEST(WideStrings) |