diff options
Diffstat (limited to 'core')
| -rw-r--r-- | core/SCsub | 2 | ||||
| -rw-r--r-- | core/globals.cpp | 7 | ||||
| -rw-r--r-- | core/globals.h | 3 | ||||
| -rw-r--r-- | core/io/compression.cpp | 183 | ||||
| -rw-r--r-- | core/io/file_access_compressed.cpp | 786 | ||||
| -rw-r--r-- | core/io/resource_format_xml.cpp | 16 | ||||
| -rw-r--r-- | core/io/xml_parser.cpp | 16 | ||||
| -rw-r--r-- | core/io/xml_parser.h | 2 | ||||
| -rw-r--r-- | core/io/zip_io.h | 2 | ||||
| -rw-r--r-- | core/map.h | 2 | ||||
| -rw-r--r-- | core/math/math_2d.cpp | 10 | ||||
| -rw-r--r-- | core/math/math_2d.h | 2 | ||||
| -rw-r--r-- | core/ustring.cpp | 2 | ||||
| -rw-r--r-- | core/variant_call.cpp | 4 |
14 files changed, 569 insertions, 468 deletions
diff --git a/core/SCsub b/core/SCsub index 3d7eef0700..9a86c2943d 100644 --- a/core/SCsub +++ b/core/SCsub @@ -32,7 +32,7 @@ SConscript('math/SCsub'); SConscript('io/SCsub'); SConscript('bind/SCsub'); -lib = env.Library("core",env.core_sources) +lib = env.Library("core",env.core_sources, LIBSUFFIX=env['platform_libsuffix']) env.Prepend(LIBS=[lib]) diff --git a/core/globals.cpp b/core/globals.cpp index 2eb26a7b19..997e2a2d85 100644 --- a/core/globals.cpp +++ b/core/globals.cpp @@ -240,6 +240,7 @@ bool Globals::_load_resource_pack(const String& p_pack) { //if data.pck is found, all directory access will be from here DirAccess::make_default<DirAccessPack>(DirAccess::ACCESS_RESOURCES); + using_datapack=true; return true; } @@ -1327,6 +1328,10 @@ void Globals::set_disable_platform_override(bool p_disable) { disable_platform_override=p_disable; } +bool Globals::is_using_datapack() const { + + return using_datapack; +} void Globals::_bind_methods() { @@ -1439,6 +1444,8 @@ Globals::Globals() { custom_prop_info["render/mipmap_policy"]=PropertyInfo(Variant::INT,"render/mipmap_policy",PROPERTY_HINT_ENUM,"Allow,Allow For Po2,Disallow"); custom_prop_info["render/thread_model"]=PropertyInfo(Variant::INT,"render/thread_model",PROPERTY_HINT_ENUM,"Single-Unsafe,Single-Safe,Multi-Threaded"); set("display/emulate_touchscreen",false); + + using_datapack=false; } diff --git a/core/globals.h b/core/globals.h index 375c59a25e..08d9f08088 100644 --- a/core/globals.h +++ b/core/globals.h @@ -69,6 +69,7 @@ protected: String resource_path; HashMap<String,PropertyInfo> custom_prop_info; bool disable_platform_override; + bool using_datapack; bool _set(const StringName& p_name, const Variant& p_value); @@ -127,6 +128,8 @@ public: void register_global_defaults(); + bool is_using_datapack() const; + Globals(); ~Globals(); diff --git a/core/io/compression.cpp b/core/io/compression.cpp index 156767d241..67ba5de0fa 100644 --- a/core/io/compression.cpp +++ b/core/io/compression.cpp @@ -26,66 +26,123 @@ /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /*************************************************************************/ -#include "compression.h"
-
-#include "fastlz.h"
-#include "os/copymem.h"
-
-int Compression::compress(uint8_t *p_dst, const uint8_t *p_src, int p_src_size,Mode p_mode) {
-
- switch(p_mode) {
- case MODE_FASTLZ: {
-
- if (p_src_size<16) {
- uint8_t src[16];
- zeromem(&src[p_src_size],16-p_src_size);
- copymem(src,p_src,p_src_size);
- return fastlz_compress(src,16,p_dst);
- } else {
- return fastlz_compress(p_src,p_src_size,p_dst);
- }
-
- } break;
- }
-
- ERR_FAIL_V(-1);
-}
-
-int Compression::get_max_compressed_buffer_size(int p_src_size,Mode p_mode){
-
- switch(p_mode) {
- case MODE_FASTLZ: {
-
-
- int ss = p_src_size+p_src_size*6/100;
- if (ss<66)
- ss=66;
- return ss;
-
- } break;
- }
-
- ERR_FAIL_V(-1);
-
-}
-
-
-
-void Compression::decompress(uint8_t *p_dst, int p_dst_max_size, const uint8_t *p_src, int p_src_size,Mode p_mode){
-
- switch(p_mode) {
- case MODE_FASTLZ: {
-
- if (p_dst_max_size<16) {
- uint8_t dst[16];
- fastlz_decompress(p_src,p_src_size,dst,16);
- copymem(p_dst,dst,p_dst_max_size);
- } else {
- fastlz_decompress(p_src,p_src_size,p_dst,p_dst_max_size);
- }
- return;
- } break;
- }
-
- ERR_FAIL();
-}
+#include "compression.h" + +#include "fastlz.h" +#include "zlib.h" +#include "zip_io.h" +#include "os/copymem.h" + +int Compression::compress(uint8_t *p_dst, const uint8_t *p_src, int p_src_size,Mode p_mode) { + + switch(p_mode) { + case MODE_FASTLZ: { + + if (p_src_size<16) { + uint8_t src[16]; + zeromem(&src[p_src_size],16-p_src_size); + copymem(src,p_src,p_src_size); + return fastlz_compress(src,16,p_dst); + } else { + return fastlz_compress(p_src,p_src_size,p_dst); + } + + } break; + case MODE_DEFLATE: { + + z_stream strm; + strm.zalloc = zipio_alloc; + strm.zfree = zipio_free; + strm.opaque = Z_NULL; + int err = deflateInit(&strm,Z_DEFAULT_COMPRESSION); + if (err==Z_OK) + return -1; + + strm.avail_in=p_src_size; + int aout = deflateBound(&strm,p_src_size);; + strm.avail_out=aout; + strm.next_in=(Bytef*)p_src; + strm.next_out=p_dst; + deflate(&strm,Z_FINISH); + aout = aout - strm.avail_out; + deflateEnd(&strm); + return aout; + + } break; + } + + ERR_FAIL_V(-1); +} + +int Compression::get_max_compressed_buffer_size(int p_src_size,Mode p_mode){ + + switch(p_mode) { + case MODE_FASTLZ: { + + + int ss = p_src_size+p_src_size*6/100; + if (ss<66) + ss=66; + return ss; + + } break; + case MODE_DEFLATE: { + + z_stream strm; + strm.zalloc = zipio_alloc; + strm.zfree = zipio_free; + strm.opaque = Z_NULL; + int err = deflateInit(&strm,Z_DEFAULT_COMPRESSION); + if (err==Z_OK) + return -1; + int aout = deflateBound(&strm,p_src_size); + deflateEnd(&strm); + return aout; + } break; + } + + ERR_FAIL_V(-1); + +} + + + +void Compression::decompress(uint8_t *p_dst, int p_dst_max_size, const uint8_t *p_src, int p_src_size,Mode p_mode){ + + switch(p_mode) { + case MODE_FASTLZ: { + + if (p_dst_max_size<16) { + uint8_t dst[16]; + fastlz_decompress(p_src,p_src_size,dst,16); + copymem(p_dst,dst,p_dst_max_size); + } else { + fastlz_decompress(p_src,p_src_size,p_dst,p_dst_max_size); + } + return; + } break; + case MODE_DEFLATE: { + + z_stream strm; + strm.zalloc = zipio_alloc; + strm.zfree = zipio_free; + strm.opaque = Z_NULL; + strm.avail_in= 0; + strm.next_in=Z_NULL; + int err = inflateInit(&strm); + ERR_FAIL_COND(err!=Z_OK); + + strm.avail_in=p_src_size; + strm.avail_out=p_dst_max_size; + strm.next_in=(Bytef*)p_src; + strm.next_out=p_dst; + + err = inflate(&strm,Z_FINISH); + inflateEnd(&strm); + ERR_FAIL_COND(err!=Z_STREAM_END); + return; + } break; + } + + ERR_FAIL(); +} diff --git a/core/io/file_access_compressed.cpp b/core/io/file_access_compressed.cpp index ec9dce28e2..b90a41df54 100644 --- a/core/io/file_access_compressed.cpp +++ b/core/io/file_access_compressed.cpp @@ -26,396 +26,396 @@ /* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */ /* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ /*************************************************************************/ -#include "file_access_compressed.h"
-#include "print_string.h"
-void FileAccessCompressed::configure(const String& p_magic, Compression::Mode p_mode, int p_block_size) {
-
- magic=p_magic.ascii().get_data();
- if (magic.length()>4)
- magic=magic.substr(0,4);
- else {
- while(magic.length()<4)
- magic+=" ";
- }
-
- cmode=p_mode;
- block_size=p_block_size;
-
-}
-
-
-#define WRITE_FIT(m_bytes) \
-{\
-if (write_pos+(m_bytes) > write_max) {\
- write_max=write_pos+(m_bytes);\
-}\
-if (write_max > write_buffer_size) {\
- write_buffer_size = nearest_power_of_2( write_max );\
- buffer.resize(write_buffer_size);\
- write_ptr=buffer.ptr();\
-}\
-}
-
-
-Error FileAccessCompressed::open_after_magic(FileAccess *p_base) {
-
-
- f=p_base;
- cmode=(Compression::Mode)f->get_32();
- block_size=f->get_32();
- read_total=f->get_32();
- int bc = (read_total/block_size)+1;
- int acc_ofs=f->get_pos()+bc*4;
- int max_bs=0;
- for(int i=0;i<bc;i++) {
-
- ReadBlock rb;
- rb.offset=acc_ofs;
- rb.csize=f->get_32();
- acc_ofs+=rb.csize;
- max_bs=MAX(max_bs,rb.csize);
- read_blocks.push_back(rb);
-
-
- }
-
- comp_buffer.resize(max_bs);
- buffer.resize(block_size);
- read_ptr=buffer.ptr();
- f->get_buffer(comp_buffer.ptr(),read_blocks[0].csize);
- at_end=false;
- read_eof=false;
- read_block_count=bc;
- read_block_size=read_blocks.size()==1?read_total:block_size;
-
- Compression::decompress(buffer.ptr(),read_block_size,comp_buffer.ptr(),read_blocks[0].csize,cmode);
- read_block=0;
- read_pos=0;
-
- return OK;
-
-}
-
-Error FileAccessCompressed::_open(const String& p_path, int p_mode_flags){
-
- ERR_FAIL_COND_V(p_mode_flags==READ_WRITE,ERR_UNAVAILABLE);
-
- if (f)
- close();
-
-
- Error err;
- f = FileAccess::open(p_path,p_mode_flags,&err);
- if (err!=OK) {
- //not openable
-
- f=NULL;
- return err;
- }
-
- if (p_mode_flags&WRITE) {
-
- buffer.clear();
- writing=true;
- write_pos=0;
- write_buffer_size=256;
- buffer.resize(256);
- write_max=0;
- write_ptr=buffer.ptr();
-
-
-
- //don't store anything else unless it's done saving!
- } else {
-
- char rmagic[5];
- f->get_buffer((uint8_t*)rmagic,4);
- rmagic[4]=0;
- if (magic!=rmagic) {
- memdelete(f);
- f=NULL;
- return ERR_FILE_UNRECOGNIZED;
- }
-
- open_after_magic(f);
-
- }
-
- return OK;
-
-}
-void FileAccessCompressed::close(){
-
- if (!f)
- return;
-
-
- if (writing) {
- //save block table and all compressed blocks
-
- CharString mgc = magic.utf8();
- f->store_buffer((const uint8_t*)mgc.get_data(),mgc.length()); //write header 4
- f->store_32(cmode); //write compression mode 4
- f->store_32(block_size); //write block size 4
- f->store_32(write_max); //max amount of data written 4
- int bc=(write_max/block_size)+1;
-
- for(int i=0;i<bc;i++) {
- f->store_32(0); //compressed sizes, will update later
- }
-
-
- Vector<int> block_sizes;
- for(int i=0;i<bc;i++) {
-
- int bl = i==(bc-1) ? write_max % block_size : block_size;
- uint8_t *bp = &write_ptr[i*block_size];
-
- Vector<uint8_t> cblock;
- cblock.resize(Compression::get_max_compressed_buffer_size(bl,cmode));
- int s = Compression::compress(cblock.ptr(),bp,bl,cmode);
-
- f->store_buffer(cblock.ptr(),s);
- block_sizes.push_back(s);
- }
-
- f->seek(16); //ok write block sizes
- for(int i=0;i<bc;i++)
- f->store_32(block_sizes[i]);
- f->seek_end();
- f->store_buffer((const uint8_t*)mgc.get_data(),mgc.length()); //magic at the end too
-
- buffer.clear();
-
- } else {
-
-
- comp_buffer.clear();
- buffer.clear();
- read_blocks.clear();
- }
-
- memdelete(f);
- f=NULL;
-
-}
-
-bool FileAccessCompressed::is_open() const{
-
- return f!=NULL;
-}
-
-void FileAccessCompressed::seek(size_t p_position){
-
- ERR_FAIL_COND(!f);
- if (writing) {
-
- ERR_FAIL_COND(p_position>write_max);
-
- write_pos=p_position;
-
- } else {
-
- ERR_FAIL_COND(p_position>read_total);
- if (p_position==read_total) {
- at_end=true;
- } else {
-
- int block_idx = p_position/block_size;
- if (block_idx!=read_block) {
-
- read_block=block_idx;
- f->seek(read_blocks[read_block].offset);
- f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize);
- Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode);
- read_block_size=read_block==read_block_count-1?read_total%block_size:block_size;
- }
-
- read_pos=p_position%block_size;
- }
- }
-}
-
-
-void FileAccessCompressed::seek_end(int64_t p_position){
-
- ERR_FAIL_COND(!f);
- if (writing) {
-
- seek(write_max+p_position);
- } else {
-
- seek(read_total+p_position);
-
- }
-
-
-}
-size_t FileAccessCompressed::get_pos() const{
-
- ERR_FAIL_COND_V(!f,0);
- if (writing) {
-
- return write_pos;
- } else {
-
- return read_block*block_size+read_pos;
- }
-
-}
-size_t FileAccessCompressed::get_len() const{
-
- ERR_FAIL_COND_V(!f,0);
- if (writing) {
-
- return write_max;
- } else {
- return read_total;
- }
-}
-
-bool FileAccessCompressed::eof_reached() const{
-
- ERR_FAIL_COND_V(!f,false);
- if (writing) {
- return false;
- } else {
- return read_eof;
- }
-}
-
-uint8_t FileAccessCompressed::get_8() const{
-
- ERR_FAIL_COND_V(writing,0);
- ERR_FAIL_COND_V(!f,0);
-
- if (at_end) {
- read_eof=true;
- return 0;
- }
-
- uint8_t ret = read_ptr[read_pos];
-
- read_pos++;
- if (read_pos>=read_block_size) {
- read_block++;
-
- if (read_block<read_block_count) {
- //read another block of compressed data
- f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize);
- Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode);
- read_block_size=read_block==read_block_count-1?read_total%block_size:block_size;
- read_pos=0;
-
- } else {
- read_block--;
- at_end=true;
- ret =0;
- }
- }
-
- return ret;
-
-}
-int FileAccessCompressed::get_buffer(uint8_t *p_dst, int p_length) const{
-
- ERR_FAIL_COND_V(writing,0);
- ERR_FAIL_COND_V(!f,0);
-
- if (at_end) {
- read_eof=true;
- return 0;
- }
-
-
- for(int i=0;i<p_length;i++) {
-
-
- p_dst[i]=read_ptr[read_pos];
- read_pos++;
- if (read_pos>=read_block_size) {
- read_block++;
-
- if (read_block<read_block_count) {
- //read another block of compressed data
- f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize);
- Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode);
- read_block_size=read_block==read_block_count-1?read_total%block_size:block_size;
- read_pos=0;
-
- } else {
- read_block--;
- at_end=true;
- if (i<p_length-1)
- read_eof=true;
- return i;
-
- }
- }
-
- }
-
- return p_length;
-
-}
-
-Error FileAccessCompressed::get_error() const{
-
- return read_eof?ERR_FILE_EOF:OK;
-}
-
-void FileAccessCompressed::store_8(uint8_t p_dest){
-
- ERR_FAIL_COND(!f);
- ERR_FAIL_COND(!writing);
-
- WRITE_FIT(1);
- write_ptr[write_pos++]=p_dest;
-
-}
-
-bool FileAccessCompressed::file_exists(const String& p_name){
-
- FileAccess *fa = FileAccess::open(p_name,FileAccess::READ);
- if (!fa)
- return false;
- memdelete(fa);
- return true;
-}
-
-uint64_t FileAccessCompressed::_get_modified_time(const String& p_file) {
-
- if (f)
- return f->get_modified_time(p_file);
- else
- return 0;
-}
-
-FileAccessCompressed::FileAccessCompressed() {
-
- f=NULL;
- magic="GCMP";
- block_size=4096;
- cmode=Compression::MODE_FASTLZ;
- writing=false;
- write_ptr=0;
- write_buffer_size=0;
- write_max=0;
- block_size=0;
- read_eof=false;
- at_end=false;
- read_total=0;
- read_ptr=NULL;
- read_block=0;
- read_block_count=0;
- read_block_size=0;
- read_pos=0;
-
-}
-
-FileAccessCompressed::~FileAccessCompressed(){
-
- if (f)
- close();
-
-}
+#include "file_access_compressed.h" +#include "print_string.h" +void FileAccessCompressed::configure(const String& p_magic, Compression::Mode p_mode, int p_block_size) { + + magic=p_magic.ascii().get_data(); + if (magic.length()>4) + magic=magic.substr(0,4); + else { + while(magic.length()<4) + magic+=" "; + } + + cmode=p_mode; + block_size=p_block_size; + +} + + +#define WRITE_FIT(m_bytes) \ +{\ +if (write_pos+(m_bytes) > write_max) {\ + write_max=write_pos+(m_bytes);\ +}\ +if (write_max > write_buffer_size) {\ + write_buffer_size = nearest_power_of_2( write_max );\ + buffer.resize(write_buffer_size);\ + write_ptr=buffer.ptr();\ +}\ +} + + +Error FileAccessCompressed::open_after_magic(FileAccess *p_base) { + + + f=p_base; + cmode=(Compression::Mode)f->get_32(); + block_size=f->get_32(); + read_total=f->get_32(); + int bc = (read_total/block_size)+1; + int acc_ofs=f->get_pos()+bc*4; + int max_bs=0; + for(int i=0;i<bc;i++) { + + ReadBlock rb; + rb.offset=acc_ofs; + rb.csize=f->get_32(); + acc_ofs+=rb.csize; + max_bs=MAX(max_bs,rb.csize); + read_blocks.push_back(rb); + + + } + + comp_buffer.resize(max_bs); + buffer.resize(block_size); + read_ptr=buffer.ptr(); + f->get_buffer(comp_buffer.ptr(),read_blocks[0].csize); + at_end=false; + read_eof=false; + read_block_count=bc; + read_block_size=read_blocks.size()==1?read_total:block_size; + + Compression::decompress(buffer.ptr(),read_block_size,comp_buffer.ptr(),read_blocks[0].csize,cmode); + read_block=0; + read_pos=0; + + return OK; + +} + +Error FileAccessCompressed::_open(const String& p_path, int p_mode_flags){ + + ERR_FAIL_COND_V(p_mode_flags==READ_WRITE,ERR_UNAVAILABLE); + + if (f) + close(); + + + Error err; + f = FileAccess::open(p_path,p_mode_flags,&err); + if (err!=OK) { + //not openable + + f=NULL; + return err; + } + + if (p_mode_flags&WRITE) { + + buffer.clear(); + writing=true; + write_pos=0; + write_buffer_size=256; + buffer.resize(256); + write_max=0; + write_ptr=buffer.ptr(); + + + + //don't store anything else unless it's done saving! + } else { + + char rmagic[5]; + f->get_buffer((uint8_t*)rmagic,4); + rmagic[4]=0; + if (magic!=rmagic) { + memdelete(f); + f=NULL; + return ERR_FILE_UNRECOGNIZED; + } + + open_after_magic(f); + + } + + return OK; + +} +void FileAccessCompressed::close(){ + + if (!f) + return; + + + if (writing) { + //save block table and all compressed blocks + + CharString mgc = magic.utf8(); + f->store_buffer((const uint8_t*)mgc.get_data(),mgc.length()); //write header 4 + f->store_32(cmode); //write compression mode 4 + f->store_32(block_size); //write block size 4 + f->store_32(write_max); //max amount of data written 4 + int bc=(write_max/block_size)+1; + + for(int i=0;i<bc;i++) { + f->store_32(0); //compressed sizes, will update later + } + + + Vector<int> block_sizes; + for(int i=0;i<bc;i++) { + + int bl = i==(bc-1) ? write_max % block_size : block_size; + uint8_t *bp = &write_ptr[i*block_size]; + + Vector<uint8_t> cblock; + cblock.resize(Compression::get_max_compressed_buffer_size(bl,cmode)); + int s = Compression::compress(cblock.ptr(),bp,bl,cmode); + + f->store_buffer(cblock.ptr(),s); + block_sizes.push_back(s); + } + + f->seek(16); //ok write block sizes + for(int i=0;i<bc;i++) + f->store_32(block_sizes[i]); + f->seek_end(); + f->store_buffer((const uint8_t*)mgc.get_data(),mgc.length()); //magic at the end too + + buffer.clear(); + + } else { + + + comp_buffer.clear(); + buffer.clear(); + read_blocks.clear(); + } + + memdelete(f); + f=NULL; + +} + +bool FileAccessCompressed::is_open() const{ + + return f!=NULL; +} + +void FileAccessCompressed::seek(size_t p_position){ + + ERR_FAIL_COND(!f); + if (writing) { + + ERR_FAIL_COND(p_position>write_max); + + write_pos=p_position; + + } else { + + ERR_FAIL_COND(p_position>read_total); + if (p_position==read_total) { + at_end=true; + } else { + + int block_idx = p_position/block_size; + if (block_idx!=read_block) { + + read_block=block_idx; + f->seek(read_blocks[read_block].offset); + f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize); + Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode); + read_block_size=read_block==read_block_count-1?read_total%block_size:block_size; + } + + read_pos=p_position%block_size; + } + } +} + + +void FileAccessCompressed::seek_end(int64_t p_position){ + + ERR_FAIL_COND(!f); + if (writing) { + + seek(write_max+p_position); + } else { + + seek(read_total+p_position); + + } + + +} +size_t FileAccessCompressed::get_pos() const{ + + ERR_FAIL_COND_V(!f,0); + if (writing) { + + return write_pos; + } else { + + return read_block*block_size+read_pos; + } + +} +size_t FileAccessCompressed::get_len() const{ + + ERR_FAIL_COND_V(!f,0); + if (writing) { + + return write_max; + } else { + return read_total; + } +} + +bool FileAccessCompressed::eof_reached() const{ + + ERR_FAIL_COND_V(!f,false); + if (writing) { + return false; + } else { + return read_eof; + } +} + +uint8_t FileAccessCompressed::get_8() const{ + + ERR_FAIL_COND_V(writing,0); + ERR_FAIL_COND_V(!f,0); + + if (at_end) { + read_eof=true; + return 0; + } + + uint8_t ret = read_ptr[read_pos]; + + read_pos++; + if (read_pos>=read_block_size) { + read_block++; + + if (read_block<read_block_count) { + //read another block of compressed data + f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize); + Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode); + read_block_size=read_block==read_block_count-1?read_total%block_size:block_size; + read_pos=0; + + } else { + read_block--; + at_end=true; + ret =0; + } + } + + return ret; + +} +int FileAccessCompressed::get_buffer(uint8_t *p_dst, int p_length) const{ + + ERR_FAIL_COND_V(writing,0); + ERR_FAIL_COND_V(!f,0); + + if (at_end) { + read_eof=true; + return 0; + } + + + for(int i=0;i<p_length;i++) { + + + p_dst[i]=read_ptr[read_pos]; + read_pos++; + if (read_pos>=read_block_size) { + read_block++; + + if (read_block<read_block_count) { + //read another block of compressed data + f->get_buffer(comp_buffer.ptr(),read_blocks[read_block].csize); + Compression::decompress(buffer.ptr(),read_blocks.size()==1?read_total:block_size,comp_buffer.ptr(),read_blocks[read_block].csize,cmode); + read_block_size=read_block==read_block_count-1?read_total%block_size:block_size; + read_pos=0; + + } else { + read_block--; + at_end=true; + if (i<p_length-1) + read_eof=true; + return i; + + } + } + + } + + return p_length; + +} + +Error FileAccessCompressed::get_error() const{ + + return read_eof?ERR_FILE_EOF:OK; +} + +void FileAccessCompressed::store_8(uint8_t p_dest){ + + ERR_FAIL_COND(!f); + ERR_FAIL_COND(!writing); + + WRITE_FIT(1); + write_ptr[write_pos++]=p_dest; + +} + +bool FileAccessCompressed::file_exists(const String& p_name){ + + FileAccess *fa = FileAccess::open(p_name,FileAccess::READ); + if (!fa) + return false; + memdelete(fa); + return true; +} + +uint64_t FileAccessCompressed::_get_modified_time(const String& p_file) { + + if (f) + return f->get_modified_time(p_file); + else + return 0; +} + +FileAccessCompressed::FileAccessCompressed() { + + f=NULL; + magic="GCMP"; + block_size=16384; + cmode=Compression::MODE_DEFLATE; + writing=false; + write_ptr=0; + write_buffer_size=0; + write_max=0; + block_size=0; + read_eof=false; + at_end=false; + read_total=0; + read_ptr=NULL; + read_block=0; + read_block_count=0; + read_block_size=0; + read_pos=0; + +} + +FileAccessCompressed::~FileAccessCompressed(){ + + if (f) + close(); + +} diff --git a/core/io/resource_format_xml.cpp b/core/io/resource_format_xml.cpp index f175c73e98..20a42f25df 100644 --- a/core/io/resource_format_xml.cpp +++ b/core/io/resource_format_xml.cpp @@ -97,16 +97,17 @@ ResourceInteractiveLoaderXML::Tag* ResourceInteractiveLoaderXML::parse_tag(bool if (!complete) { String name; - String value; + CharString r_value; bool reading_value=false; while(!f->eof_reached()) { CharType c=get_char(); if (c=='>') { - if (value.length()) { + if (r_value.size()) { - tag.args[name]=value; + r_value.push_back(0); + tag.args[name].parse_utf8(r_value.get_data()); } break; @@ -115,17 +116,18 @@ ResourceInteractiveLoaderXML::Tag* ResourceInteractiveLoaderXML::parse_tag(bool if (!reading_value && name.length()) { reading_value=true; - } else if (reading_value && value.length()) { + } else if (reading_value && r_value.size()) { - tag.args[name]=value; + r_value.push_back(0); + tag.args[name].parse_utf8(r_value.get_data()); name=""; - value=""; + r_value.clear(); reading_value=false; } } else if (reading_value) { - value+=c; + r_value.push_back(c); } else { name+=c; diff --git a/core/io/xml_parser.cpp b/core/io/xml_parser.cpp index 150643b2e1..5d3e4f61ad 100644 --- a/core/io/xml_parser.cpp +++ b/core/io/xml_parser.cpp @@ -392,7 +392,8 @@ void XMLParser::_bind_methods() { ObjectTypeDB::bind_method(_MD("get_current_line"),&XMLParser::get_current_line); ObjectTypeDB::bind_method(_MD("skip_section"),&XMLParser::skip_section); ObjectTypeDB::bind_method(_MD("seek"),&XMLParser::seek); - ObjectTypeDB::bind_method(_MD("open"),&XMLParser::open); + ObjectTypeDB::bind_method(_MD("open","file"),&XMLParser::open); + ObjectTypeDB::bind_method(_MD("open_buffer","buffer"),&XMLParser::open_buffer); BIND_CONSTANT( NODE_NONE ); BIND_CONSTANT( NODE_ELEMENT ); @@ -493,6 +494,19 @@ bool XMLParser::is_empty() const { return node_empty; } +Error XMLParser::open_buffer(const Vector<uint8_t>& p_buffer) { + + ERR_FAIL_COND_V(p_buffer.size()==0,ERR_INVALID_DATA); + + length = p_buffer.size(); + data = memnew_arr( char, length+1); + copymem(data,p_buffer.ptr(),length); + data[length]=0; + P=data; + return OK; + +} + Error XMLParser::open(const String& p_path) { Error err; diff --git a/core/io/xml_parser.h b/core/io/xml_parser.h index 3025c041b3..9debbf9e2f 100644 --- a/core/io/xml_parser.h +++ b/core/io/xml_parser.h @@ -113,6 +113,8 @@ public: Error seek(uint64_t p_pos); Error open(const String& p_path); + Error open_buffer(const Vector<uint8_t>& p_buffer); + void close(); XMLParser(); diff --git a/core/io/zip_io.h b/core/io/zip_io.h index 2f99113392..798265cc48 100644 --- a/core/io/zip_io.h +++ b/core/io/zip_io.h @@ -32,7 +32,7 @@ #include "io/zip.h" #include "io/unzip.h" #include "os/file_access.h" -//#include "copymem.h" +#include "os/copymem.h" static void* zipio_open(void* data, const char* p_fname, int mode) { diff --git a/core/map.h b/core/map.h index 959dc58661..05abdc510e 100644 --- a/core/map.h +++ b/core/map.h @@ -115,7 +115,7 @@ private: Element* _nil; int size_cache; - _Data() { + _FORCE_INLINE_ _Data() { #ifdef GLOBALNIL_DISABLED _nil = memnew_allocator( Element, A ); _nil->parent=_nil->left=_nil->right=_nil; diff --git a/core/math/math_2d.cpp b/core/math/math_2d.cpp index dbeaea6e75..acaaa327f3 100644 --- a/core/math/math_2d.cpp +++ b/core/math/math_2d.cpp @@ -255,6 +255,16 @@ Vector2 Vector2::cubic_interpolate(const Vector2& p_b,const Vector2& p_pre_a, co } +Vector2 Vector2::slide(const Vector2& p_vec) const { + + return p_vec - *this * this->dot(p_vec); +} +Vector2 Vector2::reflect(const Vector2& p_vec) const { + + return p_vec - *this * this->dot(p_vec) * 2.0; + +} + bool Rect2::intersects_segment(const Point2& p_from, const Point2& p_to, Point2* r_pos,Point2* r_normal) const { diff --git a/core/math/math_2d.h b/core/math/math_2d.h index 212d848bcb..1f45036409 100644 --- a/core/math/math_2d.h +++ b/core/math/math_2d.h @@ -105,6 +105,8 @@ struct Vector2 { Vector2 cubic_interpolate(const Vector2& p_b,const Vector2& p_pre_a, const Vector2& p_post_b,float p_t) const; Vector2 cubic_interpolate_soft(const Vector2& p_b,const Vector2& p_pre_a, const Vector2& p_post_b,float p_t) const; + Vector2 slide(const Vector2& p_vec) const; + Vector2 reflect(const Vector2& p_vec) const; Vector2 operator+(const Vector2& p_v) const; void operator+=(const Vector2& p_v); diff --git a/core/ustring.cpp b/core/ustring.cpp index 336d8eea0a..b0f06c6ab6 100644 --- a/core/ustring.cpp +++ b/core/ustring.cpp @@ -2518,7 +2518,7 @@ bool String::begins_with(const char* p_string) const { } - return true; + return *p_string == 0; } diff --git a/core/variant_call.cpp b/core/variant_call.cpp index 24c5c6bf95..846b924a42 100644 --- a/core/variant_call.cpp +++ b/core/variant_call.cpp @@ -298,6 +298,8 @@ static void _call_##m_type##_##m_method(Variant& r_ret,Variant& p_self,const Var VCALL_LOCALMEM1R(Vector2,snapped); VCALL_LOCALMEM0R(Vector2,get_aspect); VCALL_LOCALMEM1R(Vector2,dot); + VCALL_LOCALMEM1R(Vector2,slide); + VCALL_LOCALMEM1R(Vector2,reflect); // VCALL_LOCALMEM1R(Vector2,cross); VCALL_LOCALMEM0R(Rect2,get_area); @@ -1192,6 +1194,8 @@ _VariantCall::addfunc(Variant::m_vtype,Variant::m_ret,_SCS(#m_method),VCALL(m_cl ADDFUNC1(VECTOR2,VECTOR2,Vector2,snapped,VECTOR2,"by",varray()); ADDFUNC0(VECTOR2,REAL,Vector2,get_aspect,varray()); ADDFUNC1(VECTOR2,REAL,Vector2,dot,VECTOR2,"with",varray()); + ADDFUNC1(VECTOR2,REAL,Vector2,slide,VECTOR2,"vec",varray()); + ADDFUNC1(VECTOR2,REAL,Vector2,reflect,VECTOR2,"vec",varray()); //ADDFUNC1(VECTOR2,REAL,Vector2,cross,VECTOR2,"with",varray()); ADDFUNC0(RECT2,REAL,Rect2,get_area,varray()); |