/* Minetest-c55 Copyright (C) 2010 celeron55, Perttu Ahola This program is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include "test.h" #include "irrlichttypes_extrabloated.h" #include "debug.h" #include "map.h" #include "player.h" #include "main.h" #include "socket.h" #include "connection.h" #include "serialization.h" #include "voxel.h" #include "collision.h" #include #include "porting.h" #include "content_mapnode.h" #include "nodedef.h" #include "mapsector.h" #include "settings.h" #include "log.h" #include "util/string.h" #include "voxelalgorithms.h" #include "inventory.h" #include "util/numeric.h" #include "util/serialize.h" #include "noise.h" // PseudoRandom used for random data for compression #include "clientserver.h" // LATEST_PROTOCOL_VERSION /* Asserts that the exception occurs */ #define EXCEPTION_CHECK(EType, code)\ {\ bool exception_thrown = false;\ try{ code; }\ catch(EType &e) { exception_thrown = true; }\ UASSERT(exception_thrown);\ } #define UTEST(x, fmt, ...)\ {\ if(!(x)){\ LOGLINEF(LMT_ERROR, "Test (%s) failed: " fmt, #x, ##__VA_ARGS__);\ test_failed = true;\ }\ } #define UASSERT(x) UTEST(x, "UASSERT") /* A few item and node definitions for those tests that need them */ #define CONTENT_STONE 0 #define CONTENT_GRASS 0x800 #define CONTENT_TORCH 100 void define_some_nodes(IWritableItemDefManager *idef, IWritableNodeDefManager *ndef) { content_t i; ItemDefinition itemdef; ContentFeatures f; /* Stone */ i = CONTENT_STONE; itemdef = ItemDefinition(); itemdef.type = ITEM_NODE; itemdef.name = "default:stone"; itemdef.description = "Stone"; itemdef.groups["cracky"] = 3; itemdef.inventory_image = "[inventorycube" "{default_stone.png" "{default_stone.png" "{default_stone.png"; f = ContentFeatures(); f.name = itemdef.name; for(int i = 0; i < 6; i++) f.tiledef[i].name = "default_stone.png"; f.is_ground_content = true; idef->registerItem(itemdef); ndef->set(i, f); /* Grass */ i = CONTENT_GRASS; itemdef = ItemDefinition(); itemdef.type = ITEM_NODE; itemdef.name = "default:dirt_with_grass"; itemdef.description = "Dirt with grass"; itemdef.groups["crumbly"] = 3; itemdef.inventory_image = "[inventorycube" "{default_grass.png" "{default_dirt.png&default_grass_side.png" "{default_dirt.png&default_grass_side.png"; f = ContentFeatures(); f.name = itemdef.name; f.tiledef[0].name = "default_grass.png"; f.tiledef[1].name = "default_dirt.png"; for(int i = 2; i < 6; i++) f.tiledef[i].name = "default_dirt.png^default_grass_side.png"; f.is_ground_content = true; idef->registerItem(itemdef); ndef->set(i, f); /* Torch (minimal definition for lighting tests) */ i = CONTENT_TORCH; itemdef = ItemDefinition(); itemdef.type = ITEM_NODE; itemdef.name = "default:torch"; f = ContentFeatures(); f.name = itemdef.name; f.param_type = CPT_LIGHT; f.light_propagates = true; f.sunlight_propagates = true; f.light_source = LIGHT_MAX-1; idef->registerItem(itemdef); ndef->set(i, f); } struct TestBase { bool test_failed; TestBase(): test_failed(false) {} }; struct TestUtilities: public TestBase { void Run() { /*infostream<<"wrapDegrees(100.0) = "< std::string mkstr(const char (&s)[N]) { return std::string(s, N - 1); } void Run() { // Tests some serialization primitives UASSERT(serializeString("") == mkstr("\0\0")); UASSERT(serializeWideString(L"") == mkstr("\0\0")); UASSERT(serializeLongString("") == mkstr("\0\0\0\0")); UASSERT(serializeJsonString("") == "\"\""); std::string teststring = "Hello world!"; UASSERT(serializeString(teststring) == mkstr("\0\14Hello world!")); UASSERT(serializeWideString(narrow_to_wide(teststring)) == mkstr("\0\14\0H\0e\0l\0l\0o\0 \0w\0o\0r\0l\0d\0!")); UASSERT(serializeLongString(teststring) == mkstr("\0\0\0\14Hello world!")); UASSERT(serializeJsonString(teststring) == "\"Hello world!\""); std::string teststring2; std::wstring teststring2_w; std::string teststring2_w_encoded; { std::ostringstream tmp_os; std::wostringstream tmp_os_w; std::ostringstream tmp_os_w_encoded; for(int i = 0; i < 256; i++) { tmp_os<<(char)i; tmp_os_w<<(wchar_t)i; tmp_os_w_encoded<<(char)0<<(char)i; } teststring2 = tmp_os.str(); teststring2_w = tmp_os_w.str(); teststring2_w_encoded = tmp_os_w_encoded.str(); } UASSERT(serializeString(teststring2) == mkstr("\1\0") + teststring2); UASSERT(serializeWideString(teststring2_w) == mkstr("\1\0") + teststring2_w_encoded); UASSERT(serializeLongString(teststring2) == mkstr("\0\0\1\0") + teststring2); // MSVC fails when directly using "\\\\" std::string backslash = "\\"; UASSERT(serializeJsonString(teststring2) == mkstr("\"") + "\\u0000\\u0001\\u0002\\u0003\\u0004\\u0005\\u0006\\u0007" + "\\b\\t\\n\\u000b\\f\\r\\u000e\\u000f" + "\\u0010\\u0011\\u0012\\u0013\\u0014\\u0015\\u0016\\u0017" + "\\u0018\\u0019\\u001a\\u001b\\u001c\\u001d\\u001e\\u001f" + " !\\\"" + teststring2.substr(0x23, 0x2f-0x23) + "\\/" + teststring2.substr(0x30, 0x5c-0x30) + backslash + backslash + teststring2.substr(0x5d, 0x7f-0x5d) + "\\u007f" + "\\u0080\\u0081\\u0082\\u0083\\u0084\\u0085\\u0086\\u0087" + "\\u0088\\u0089\\u008a\\u008b\\u008c\\u008d\\u008e\\u008f" + "\\u0090\\u0091\\u0092\\u0093\\u0094\\u0095\\u0096\\u0097" + "\\u0098\\u0099\\u009a\\u009b\\u009c\\u009d\\u009e\\u009f" + "\\u00a0\\u00a1\\u00a2\\u00a3\\u00a4\\u00a5\\u00a6\\u00a7" + "\\u00a8\\u00a9\\u00aa\\u00ab\\u00ac\\u00ad\\u00ae\\u00af" + "\\u00b0\\u00b1\\u00b2\\u00b3\\u00b4\\u00b5\\u00b6\\u00b7" + "\\u00b8\\u00b9\\u00ba\\u00bb\\u00bc\\u00bd\\u00be\\u00bf" + "\\u00c0\\u00c1\\u00c2\\u00c3\\u00c4\\u00c5\\u00c6\\u00c7" + "\\u00c8\\u00c9\\u00ca\\u00cb\\u00cc\\u00cd\\u00ce\\u00cf" + "\\u00d0\\u00d1\\u00d2\\u00d3\\u00d4\\u00d5\\u00d6\\u00d7" + "\\u00d8\\u00d9\\u00da\\u00db\\u00dc\\u00dd\\u00de\\u00df" + "\\u00e0\\u00e1\\u00e2\\u00e3\\u00e4\\u00e5\\u00e6\\u00e7" + "\\u00e8\\u00e9\\u00ea\\u00eb\\u00ec\\u00ed\\u00ee\\u00ef" + "\\u00f0\\u00f1\\u00f2\\u00f3\\u00f4\\u00f5\\u00f6\\u00f7" + "\\u00f8\\u00f9\\u00fa\\u00fb\\u00fc\\u00fd\\u00fe\\u00ff" + "\""); { std::istringstream is(serializeString(teststring2), std::ios::binary); UASSERT(deSerializeString(is) == teststring2); UASSERT(!is.eof()); is.get(); UASSERT(is.eof()); } { std::istringstream is(serializeWideString(teststring2_w), std::ios::binary); UASSERT(deSerializeWideString(is) == teststring2_w); UASSERT(!is.eof()); is.get(); UASSERT(is.eof()); } { std::istringstream is(serializeLongString(teststring2), std::ios::binary); UASSERT(deSerializeLongString(is) == teststring2); UASSERT(!is.eof()); is.get(); UASSERT(is.eof()); } { std::istringstream is(serializeJsonString(teststring2), std::ios::binary); //dstream< fromdata(4); fromdata[0]=1; fromdata[1]=5; fromdata[2]=5; fromdata[3]=1; std::ostringstream os(std::ios_base::binary); compress(fromdata, os, 0); std::string str_out = os.str(); infostr/* Minetest Copyright (C) 2013 celeron55, Perttu Ahola <celeron55@gmail.com> This program is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include "test.h" #include <sstream> #include "irrlichttypes_extrabloated.h" #include "log.h" #include "serialization.h" #include "nodedef.h" #include "noise.h" class TestCompression : public TestBase { public: TestCompression() { TestManager::registerTestModule(this); } const char *getName() { return "TestCompression"; } void runTests(IGameDef *gamedef); void testRLECompression(); void testZlibCompression(); void testZlibLargeData(); void testZlibLimit(); void _testZlibLimit(u32 size, u32 limit); }; static TestCompression g_test_instance; void TestCompression::runTests(IGameDef *gamedef) { TEST(testRLECompression); TEST(testZlibCompression); TEST(testZlibLargeData); TEST(testZlibLimit); } //////////////////////////////////////////////////////////////////////////////// void TestCompression::testRLECompression() { SharedBuffer<u8> fromdata(4); fromdata[0]=1; fromdata[1]=5; fromdata[2]=5; fromdata[3]=1; std::ostringstream os(std::ios_base::binary); compress(fromdata, os, 0); std::string str_out = os.str(); infostream << "str_out.size()="<<str_out.size()<<std::endl; infostream << "TestCompress: 1,5,5,1 -> "; for (char i : str_out) infostream << (u32) i << ","; infostream << std::endl; UASSERT(str_out.size() == 10); UASSERT(str_out[0] == 0); UASSERT(str_out[1] == 0); UASSERT(str_out[2] == 0); UASSERT(str_out[3] == 4); UASSERT(str_out[4] == 0); UASSERT(str_out[5] == 1); UASSERT(str_out[6] == 1); UASSERT(str_out[7] == 5); UASSERT(str_out[8] == 0); UASSERT(str_out[9] == 1); std::istringstream is(str_out, std::ios_base::binary); std::ostringstream os2(std::ios_base::binary); decompress(is, os2, 0); std::string str_out2 = os2.str(); infostream << "decompress: "; for (char i : str_out2) infostream << (u32) i << ","; infostream << std::endl; UASSERTEQ(size_t, str_out2.size(), fromdata.getSize()); for (u32 i = 0; i < str_out2.size(); i++) UASSERT(str_out2[i] == fromdata[i]); } void TestCompression::testZlibCompression() { SharedBuffer<u8> fromdata(4); fromdata[0]=1; fromdata[1]=5; fromdata[2]=5; fromdata[3]=1; std::ostringstream os(std::ios_base::binary); compress(fromdata, os, SER_FMT_VER_HIGHEST_READ); std::string str_out = os.str(); infostream << "str_out.size()=" << str_out.size() <<std::endl; infostream << "TestCompress: 1,5,5,1 -> "; for (char i : str_out) infostream << (u32) i << ","; infostream << std::endl; std::istringstream is(str_out, std::ios_base::binary); std::ostringstream os2(std::ios_base::binary); decompress(is, os2, SER_FMT_VER_HIGHEST_READ); std::string str_out2 = os2.str(); infostream << "decompress: "; for (char i : str_out2) infostream << (u32) i << ","; infostream << std::endl; UASSERTEQ(size_t, str_out2.size(), fromdata.getSize()); for (u32 i = 0; i < str_out2.size(); i++) UASSERT(str_out2[i] == fromdata[i]); } void TestCompression::testZlibLargeData() { infostream << "Test: Testing zlib wrappers with a large amount " "of pseudorandom data" << std::endl; u32 size = 50000; infostream << "Test: Input size of large compressZlib is " << size << std::endl; std::string data_in; data_in.resize(size); PseudoRandom pseudorandom(9420); for (u32 i = 0; i < size; i++) data_in[i] = pseudorandom.range(0, 255); std::ostringstream os_compressed(std::ios::binary); compressZlib(data_in, os_compressed); infostream << "Test: Output size of large compressZlib is " << os_compressed.str().size()<<std::endl; std::istringstream is_compressed(os_compressed.str(), std::ios::binary); std::ostringstream os_decompressed(std::ios::binary); decompressZlib(is_compressed, os_decompressed); infostream << "Test: Output size of large decompressZlib is " << os_decompressed.str().size() << std::endl; std::string str_decompressed = os_decompressed.str(); UASSERTEQ(size_t, str_decompressed.size(), data_in.size()); for (u32 i = 0; i < size && i < str_decompressed.size(); i++) { UTEST(str_decompressed[i] == data_in[i], "index out[%i]=%i differs from in[%i]=%i", i, str_decompressed[i], i, data_in[i]); } } void TestCompression::testZlibLimit() { // edge cases _testZlibLimit(1024, 1023); _testZlibLimit(1024, 1024); _testZlibLimit(1024, 1025); // test around buffer borders u32 bufsize = 16384; // as in implementation for (int s = -1; s <= 1; s++) { for (int l = -1; l <= 1; l++) { _testZlibLimit(bufsize + s, bufsize + l); } } // span multiple buffers _testZlibLimit(35000, 22000); _testZlibLimit(22000, 35000); } void TestCompression::_testZlibLimit(u32 size, u32 limit) { infostream << "Test: Testing zlib wrappers with a decompression " "memory limit of " << limit << std::endl; infostream << "Test: Input size of compressZlib for limit is " << size << std::endl; // how much data we expect to get u32 expected = size < limit ? size : limit; // create recognizable data std::string data_in; data_in.resize(size); for (u32 i = 0; i < size; i++) data_in[i] = (u8)(i % 256); std::ostringstream os_compressed(std::ios::binary); compressZlib(data_in, os_compressed); infostream << "Test: Output size of compressZlib for limit is " << os_compressed.str().size()<<std::endl; std::istringstream is_compressed(os_compressed.str(), std::ios::binary); std::ostringstream os_decompressed(std::ios::binary); decompressZlib(is_compressed, os_decompressed, limit); infostream << "Test: Output size of decompressZlib with limit is " << os_decompressed.str().size() << std::endl; std::string str_decompressed = os_decompressed.str(); UASSERTEQ(size_t, str_decompressed.size(), expected); for (u32 i = 0; i < size && i < str_decompressed.size(); i++) { UTEST(str_decompressed[i] == data_in[i], "index out[%i]=%i differs from in[%i]=%i", i, str_decompressed[i], i, data_in[i]); } } seqnum = sn; server.Send(peer_id_client, chn, data1, true); ch->next_outgoing_seqnum = sn+1; server.Send(peer_id_client, chn, data2, true); sleep_ms(50); infostream<<"*** Receiving the packets"< recvdata; u32 size; infostream<<"** running client.Receive()"<20) infostream<<"..."; infostream< recvdata; infostream<<"** running client.Receive()"< 5000 || received) break; try{ size = client.Receive(peer_id, recvdata); received = true; }catch(con::NoIncomingDataException &e){ } sleep_ms(10); } UASSERT(received); infostream<<"** Client received: peer_id="<20) infostream<<"..."; infostream<