|
|
| version 1.150, 2001/04/28 09:14:49 | version 1.170, 2001/06/29 13:53:23 |
|---|---|
| Line 4 | Line 4 |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) |
| $Id$ | |
| */ | */ |
| static const char *RCSId="$Id$"; | |
| #include "pa_config_includes.h" | #include "pa_opcode.h" |
| #include "code.h" | |
| #include "pa_array.h" | #include "pa_array.h" |
| #include "pa_request.h" | #include "pa_request.h" |
| #include "pa_vstring.h" | #include "pa_vstring.h" |
| #include "pa_vhash.h" | #include "pa_vhash.h" |
| #include "pa_vunknown.h" | #include "pa_vvoid.h" |
| #include "pa_vcode_frame.h" | #include "pa_vcode_frame.h" |
| #include "pa_vmethod_frame.h" | #include "pa_vmethod_frame.h" |
| #include "pa_vobject.h" | #include "pa_vobject.h" |
| Line 24 | Line 22 |
| #include "pa_vfile.h" | #include "pa_vfile.h" |
| #include "pa_vimage.h" | #include "pa_vimage.h" |
| #include <stdio.h> | //#define DEBUG_EXECUTE |
| #define PUSH(value) stack.push(value) | |
| #define POP() static_cast<Value *>(stack.pop()) | |
| #define POP_NAME() static_cast<Value *>(stack.pop())->as_string() | |
| const uint ANTI_ENDLESS_EXECUTE_RECOURSION=500; | |
| #ifdef DEBUG_EXECUTE | |
| char *opcode_name[]={ | char *opcode_name[]={ |
| // literals | // literals |
| "VALUE", "CURLY_CODE__STORE_PARAM", "EXPR_CODE__STORE_PARAM", | "VALUE", "CURLY_CODE__STORE_PARAM", "EXPR_CODE__STORE_PARAM", |
| Line 59 char *opcode_name[]={ | Line 55 char *opcode_name[]={ |
| "IS" | "IS" |
| }; | }; |
| void va_log_printf(Pool& pool, const char *fmt,va_list args) { | void va_debug_printf(Pool& pool, const char *fmt,va_list args) { |
| return; | |
| char buf[MAX_STRING]; | char buf[MAX_STRING]; |
| vsnprintf(buf, MAX_STRING, fmt, args); | vsnprintf(buf, MAX_STRING, fmt, args); |
| SAPI::log(pool, "%s", buf); | SAPI::log(pool, "%s", buf); |
| } | } |
| void log_printf(Pool& pool, const char *fmt, ...) { | void debug_printf(Pool& pool, const char *fmt, ...) { |
| va_list args; | va_list args; |
| va_start(args,fmt); | va_start(args,fmt); |
| va_log_printf(pool,fmt,args); | va_debug_printf(pool,fmt,args); |
| va_end(args); | va_end(args); |
| } | } |
| void dump(Pool& pool, int level, const Array& ops) { | void debug_dump(Pool& pool, int level, const Array& ops) { |
| if(0){ | { |
| int size=ops.quick_size(); | int size=ops.quick_size(); |
| //log_printf(pool, "size=%d\n", size); | //debug_printf(pool, "size=%d\n", size); |
| for(int i=0; i<size; i++) { | for(int i=0; i<size; i++) { |
| Operation op; | Operation op; |
| op.cast=ops.quick_get(i); | op.cast=ops.quick_get(i); |
| log_printf(pool, "%8X\n", op.cast); | debug_printf(pool, "%8X\n", op.cast); |
| } | } |
| } | } |
| int size=ops.quick_size(); | int size=ops.quick_size(); |
| //log_printf(pool, "size=%d\n", size); | //debug_printf(pool, "size=%d\n", size); |
| for(int i=0; i<size; i++) { | for(int i=0; i<size; i++) { |
| Operation op; | Operation op; |
| op.cast=ops.quick_get(i); | op.cast=ops.quick_get(i); |
| if(op.code==OP_VALUE || op.code==OP_STRING__WRITE) { | if(op.code==OP_VALUE || op.code==OP_STRING__WRITE) { |
| Value *value=static_cast<Value *>(ops.quick_get(++i)); | Value *value=static_cast<Value *>(ops.quick_get(++i)); |
| log_printf(pool, | debug_printf(pool, |
| "%*s%s" | "%*s%s" |
| " \"%s\" %s", | " \"%s\" %s", |
| level*4, "", opcode_name[op.code], | level*4, "", opcode_name[op.code], |
| value->get_string()->cstr(), value->type()); | value->get_string()->cstr(), value->type()); |
| continue; | continue; |
| } | } |
| log_printf(pool, "%*s%s", level*4, "", opcode_name[op.code]); | debug_printf(pool, "%*s%s", level*4, "", opcode_name[op.code]); |
| if(op.code==OP_CURLY_CODE__STORE_PARAM || op.code==OP_EXPR_CODE__STORE_PARAM) { | if(op.code==OP_CURLY_CODE__STORE_PARAM || op.code==OP_EXPR_CODE__STORE_PARAM) { |
| const Array *local_ops=reinterpret_cast<const Array *>(ops.quick_get(++i)); | const Array *local_ops=reinterpret_cast<const Array *>(ops.quick_get(++i)); |
| dump(pool, level+1, *local_ops); | debug_dump(pool, level+1, *local_ops); |
| } | } |
| } | } |
| } | } |
| #endif | |
| #define PUSH(value) stack.push(value) | |
| #define POP() static_cast<Value *>(stack.pop()) | |
| #define POP_NAME() static_cast<Value *>(stack.pop())->as_string() | |
| void Request::execute(const Array& ops) { | void Request::execute(const Array& ops) { |
| if(1) { | #ifdef DEBUG_EXECUTE |
| log_printf(pool(), "source----------------------------\n"); | debug_printf(pool(), "source----------------------------\n"); |
| dump(pool(), 0, ops); | debug_dump(pool(), 0, ops); |
| log_printf(pool(), "execution-------------------------\n"); | debug_printf(pool(), "execution-------------------------\n"); |
| } | #endif |
| int size=ops.quick_size(); | int size=ops.quick_size(); |
| //log_printf(pool(), "size=%d\n", size); | //debug_printf(pool(), "size=%d\n", size); |
| for(int i=0; i<size; i++) { | for(int i=0; i<size; i++) { |
| Operation op; | Operation op; |
| op.cast=ops.quick_get(i); | op.cast=ops.quick_get(i); |
| log_printf(pool(), "%d:%s", stack.top_index()+1, opcode_name[op.code]); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), "%d:%s", stack.top_index()+1, opcode_name[op.code]); | |
| #endif | |
| switch(op.code) { | switch(op.code) { |
| // param in next instruction | // param in next instruction |
| case OP_VALUE: | case OP_VALUE: |
| { | { |
| Value *value=static_cast<Value *>(ops.quick_get(++i)); | Value *value=static_cast<Value *>(ops.quick_get(++i)); |
| log_printf(pool(), " \"%s\" %s", value->get_string()->cstr(), value->type()); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), " \"%s\" %s", value->get_string()->cstr(), value->type()); | |
| #endif | |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 137 void Request::execute(const Array& ops) | Line 141 void Request::execute(const Array& ops) |
| VMethodFrame *frame=static_cast<VMethodFrame *>(stack.top_value()); | VMethodFrame *frame=static_cast<VMethodFrame *>(stack.top_value()); |
| // code | // code |
| const Array *local_ops=reinterpret_cast<const Array *>(ops.quick_get(++i)); | const Array *local_ops=reinterpret_cast<const Array *>(ops.quick_get(++i)); |
| log_printf(pool(), " (%d)\n", local_ops->size()); | #ifdef DEBUG_EXECUTE |
| dump(pool(), 1, *local_ops); | debug_printf(pool(), " (%d)\n", local_ops->size()); |
| debug_dump(pool(), 1, *local_ops); | |
| #endif | |
| // when they evaluate expression parameter, | // when they evaluate expression parameter, |
| // the object expression result | // the object expression result |
| // does not need to be written into calling frame | // does not need to be written into calling frame |
| Line 236 void Request::execute(const Array& ops) | Line 241 void Request::execute(const Array& ops) |
| case OP_STRING__WRITE: | case OP_STRING__WRITE: |
| { | { |
| VString *vstring=static_cast<VString *>(ops.quick_get(++i)); | VString *vstring=static_cast<VString *>(ops.quick_get(++i)); |
| log_printf(pool(), " \"%s\"", vstring->string().cstr()); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), " \"%s\"", vstring->string().cstr()); | |
| #endif | |
| write_no_lang(vstring->string()); | write_no_lang(vstring->string()); |
| break; | break; |
| } | } |
| Line 292 void Request::execute(const Array& ops) | Line 299 void Request::execute(const Array& ops) |
| if(string) | if(string) |
| value=NEW VString(*string); | value=NEW VString(*string); |
| else | else |
| value=NEW VUnknown(pool()); | value=NEW VVoid(pool()); |
| wcontext=static_cast<WContext *>(POP()); | wcontext=static_cast<WContext *>(POP()); |
| rcontext=POP(); | rcontext=POP(); |
| PUSH(value); | PUSH(value); |
| Line 313 void Request::execute(const Array& ops) | Line 320 void Request::execute(const Array& ops) |
| if(string) | if(string) |
| value=NEW VString(*string); | value=NEW VString(*string); |
| else | else |
| NEW VUnknown(pool()); | NEW VVoid(pool()); |
| wcontext=static_cast<WContext *>(POP()); | wcontext=static_cast<WContext *>(POP()); |
| PUSH(value); | PUSH(value); |
| break; | break; |
| Line 340 void Request::execute(const Array& ops) | Line 347 void Request::execute(const Array& ops) |
| if(is_constructor) | if(is_constructor) |
| wcontext->constructing(false); | wcontext->constructing(false); |
| VMethodFrame *frame=NEW VMethodFrame(pool(), *junction, is_constructor); | VMethodFrame *frame=NEW VMethodFrame(pool(), value->name(), *junction, is_constructor); |
| frame->set_name(value->name()); | |
| PUSH(frame); | PUSH(frame); |
| break; | break; |
| } | } |
| Line 355 void Request::execute(const Array& ops) | Line 361 void Request::execute(const Array& ops) |
| case OP_CALL: | case OP_CALL: |
| { | { |
| log_printf(pool(), "->\n"); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), "->\n"); | |
| #endif | |
| VMethodFrame *frame=static_cast<VMethodFrame *>(POP()); | VMethodFrame *frame=static_cast<VMethodFrame *>(POP()); |
| frame->fill_unspecified_params(); | frame->fill_unspecified_params(); |
| PUSH(self); | PUSH(self); |
| Line 365 void Request::execute(const Array& ops) | Line 373 void Request::execute(const Array& ops) |
| VStateless_class *called_class=frame->junction.self.get_class(); | VStateless_class *called_class=frame->junction.self.get_class(); |
| // not ^name.method call and | // not ^name.method call and |
| // is context object or class & is it my class or my parent's class? | // is context object or class & is it my class or my parent's class and? |
| VStateless_class *read_class=rcontext->get_class(); | VStateless_class *read_class=rcontext->get_class(); |
| if( | if(!wcontext->somebody_entered_some_object() && |
| !wcontext->somebody_entered_some_object() && | |
| read_class && read_class->is_or_derived_from(*called_class)) // yes | read_class && read_class->is_or_derived_from(*called_class)) // yes |
| self=rcontext; // class dynamic call | self=rcontext; // class dynamic call |
| else // no, not me or relative of mine (total stranger) | else // no, not me or relative of mine (total stranger) |
| if(frame->is_constructor) { | // were are constructing something and |
| // our constructor is just method call and | |
| // not static-only-method call | |
| if(frame->is_constructor && | |
| wcontext->somebody_entered_some_object()==1 && | |
| frame->junction.method->call_type!=Method::CT_STATIC) { | |
| // this is a constructor call | // this is a constructor call |
| // some stateless_object creatable derivates | // some stateless_object creatable derivates |
| if(Value *value=called_class->create_new_value(pool())) | if(Value *value=called_class->create_new_value(pool())) |
| Line 399 void Request::execute(const Array& ops) | Line 411 void Request::execute(const Array& ops) |
| method.call_type==Method::CT_ANY || | method.call_type==Method::CT_ANY || |
| method.call_type==call_type) // allowed call type? | method.call_type==call_type) // allowed call type? |
| if(method.native_code) { // native code? | if(method.native_code) { // native code? |
| method.check_actual_numbered_params( | method.check_actual_numbered_params(pool(), |
| frame->junction.self, | frame->junction.self, |
| frame->name(), frame->numbered_params()); | frame->name(), frame->numbered_params()); |
| (*method.native_code)( | method.native_code( |
| *this, | *this, |
| frame->name(), frame->numbered_params()); // execute it | frame->name(), frame->numbered_params()); // execute it |
| } else // parser code | } else { // parser code |
| if(++anti_endless_execute_recoursion==ANTI_ENDLESS_EXECUTE_RECOURSION) { | |
| anti_endless_execute_recoursion=0; // give @exception a chance | |
| THROW(0, 0, | |
| &frame->name(), | |
| "endless recursion detected"); | |
| } | |
| execute(*method.parser_code); // execute it | execute(*method.parser_code); // execute it |
| anti_endless_execute_recoursion--; | |
| } | |
| else | else |
| THROW(0, 0, | THROW(0, 0, |
| &frame->name(), | &frame->name(), |
| Line 422 void Request::execute(const Array& ops) | Line 443 void Request::execute(const Array& ops) |
| self=static_cast<VAliased *>(POP()); | self=static_cast<VAliased *>(POP()); |
| PUSH(value); | PUSH(value); |
| log_printf(pool(), "<-returned"); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), "<-returned"); | |
| #endif | |
| break; | break; |
| } | } |
| Line 437 void Request::execute(const Array& ops) | Line 460 void Request::execute(const Array& ops) |
| case OP_INV: | case OP_INV: |
| { | { |
| Value *operand=POP(); | Value *operand=POP(); |
| Value *value=NEW VDouble(pool(), ~(int)operand->as_double()); | Value *value=NEW VDouble(pool(), ~operand->as_int()); |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 459 void Request::execute(const Array& ops) | Line 482 void Request::execute(const Array& ops) |
| { | { |
| Value *operand=POP(); | Value *operand=POP(); |
| const char *path=operand->as_string().cstr(); | const char *path=operand->as_string().cstr(); |
| Value *value=NEW VBool(pool(), info.uri && strcmp(path, info.uri)<=0); | Value *value=NEW VBool(pool(), |
| info.uri && strncmp(path, info.uri, strlen(path))==0); | |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 505 void Request::execute(const Array& ops) | Line 529 void Request::execute(const Array& ops) |
| case OP_DIV: | case OP_DIV: |
| { | { |
| Value *b=POP(); Value *a=POP(); | Value *b=POP(); Value *a=POP(); |
| Value *value=NEW VDouble(pool(), a->as_double() / b->as_double()); | |
| double a_double=a->as_double(); | |
| double b_double=b->as_double(); | |
| if(b_double == 0) | |
| THROW(0, 0, | |
| &b->name(), | |
| "Division by zero"); | |
| Value *value=NEW VDouble(pool(), a_double/b_double); | |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| case OP_MOD: | case OP_MOD: |
| { | { |
| Value *b=POP(); Value *a=POP(); | Value *b=POP(); Value *a=POP(); |
| Value *value=NEW VDouble(pool(), | |
| (int)a->as_double() % | int a_int=a->as_int(); |
| (int)b->as_double()); | int b_int=b->as_int(); |
| if(b_int == 0) | |
| THROW(0, 0, | |
| &b->name(), | |
| "Modulus by zero"); | |
| Value *value=NEW VDouble(pool(), a_int % b_int); | |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 522 void Request::execute(const Array& ops) | Line 562 void Request::execute(const Array& ops) |
| { | { |
| Value *b=POP(); Value *a=POP(); | Value *b=POP(); Value *a=POP(); |
| Value *value=NEW VDouble(pool(), | Value *value=NEW VDouble(pool(), |
| (int)a->as_double() & | a->as_int() & |
| (int)b->as_double()); | b->as_int()); |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 531 void Request::execute(const Array& ops) | Line 571 void Request::execute(const Array& ops) |
| { | { |
| Value *b=POP(); Value *a=POP(); | Value *b=POP(); Value *a=POP(); |
| Value *value=NEW VDouble(pool(), | Value *value=NEW VDouble(pool(), |
| (int)a->as_double() | | a->as_int() | |
| (int)b->as_double()); | b->as_int()); |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 540 void Request::execute(const Array& ops) | Line 580 void Request::execute(const Array& ops) |
| { | { |
| Value *b=POP(); Value *a=POP(); | Value *b=POP(); Value *a=POP(); |
| Value *value=NEW VDouble(pool(), | Value *value=NEW VDouble(pool(), |
| (int)a->as_double() ^ | a->as_int() ^ |
| (int)b->as_double()); | b->as_int()); |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| Line 680 Value *Request::get_element() { | Line 720 Value *Request::get_element() { |
| if(value) | if(value) |
| value=&process(*value, &name); // process possible code-junction | value=&process(*value, &name); // process possible code-junction |
| else { | else { |
| value=NEW VUnknown(pool()); | value=NEW VVoid(pool()); |
| value->set_name(name); | value->set_name(name); |
| } | } |
| return value; | return value; |
| } | } |
| /** | /** @param intercept_string |
| intercept_string: | |
| - true: | - true: |
| they want result=string value, | they want result=string value, |
| possible object result goes to wcontext | possible object result goes to wcontext |
| Line 702 Value& Request::process(Value& value, co | Line 741 Value& Request::process(Value& value, co |
| Junction *junction=value.get_junction(); | Junction *junction=value.get_junction(); |
| if(junction && junction->code) { // is it a code-junction? | if(junction && junction->code) { // is it a code-junction? |
| // process it | // process it |
| log_printf(pool(), "ja->\n"); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), "ja->\n"); | |
| #endif | |
| PUSH(self); | PUSH(self); |
| PUSH(root); | PUSH(root); |
| PUSH(rcontext); | PUSH(rcontext); |
| Line 740 Value& Request::process(Value& value, co | Line 781 Value& Request::process(Value& value, co |
| root=POP(); | root=POP(); |
| self=static_cast<VAliased *>(POP()); | self=static_cast<VAliased *>(POP()); |
| log_printf(pool(), "<-ja returned"); | #ifdef DEBUG_EXECUTE |
| debug_printf(pool(), "<-ja returned"); | |
| #endif | |
| } else | } else |
| result=&value; | result=&value; |