|
|
| version 1.145, 2001/04/11 15:45:50 | version 1.169, 2001/06/28 07:44:17 |
|---|---|
| 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 49 char *opcode_name[]={ | Line 45 char *opcode_name[]={ |
| "CALL", | "CALL", |
| // expression ops: unary | // expression ops: unary |
| "NEG", "INV", "NOT", "DEF", "IN", "FEXISTS", | "NEG", "INV", "NOT", "DEF", "IN", "FEXISTS", "DEXISTS", |
| // expression ops: binary | // expression ops: binary |
| "SUB", "ADD", "MUL", "DIV", "MOD", | "SUB", "ADD", "MUL", "DIV", "MOD", |
| "BIN_AND", "BIN_OR", "BIN_XOR", | "BIN_AND", "BIN_OR", "BIN_XOR", |
| 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); | |
| // when called method of some object, specifying object literally, | #endif |
| // e.g ^t.menu, code of curly params must be executed | |
| // in r/w context of that object. | |
| // otherwise in current r/w context. | |
| // | |
| // 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 |
| // it must go into any expressions using that parameter | // it must go into any expressions using that parameter |
| // hence, zeroing junction.wcontext being created | // hence, we zero junction.wcontext here, and later |
| // later, in .process we would test that field | // in .process we would test that field |
| // in decision "which wwrapper to use" | // in decision "which wwrapper to use" |
| Junction& j=*NEW Junction(pool(), | Junction& j=*NEW Junction(pool(), |
| *self, 0, 0, | *self, 0, 0, |
| root, | root, |
| wcontext->somebody_entered_some_object()>1? | rcontext, |
| &frame->junction.self /*^t.menu{}*/:rcontext/*^if()*/, | op.code==OP_EXPR_CODE__STORE_PARAM?0:wcontext, |
| op.code==OP_EXPR_CODE__STORE_PARAM? | |
| 0:wcontext->somebody_entered_some_object()>1? | |
| frame/*^t.menu{}*/:wcontext/*^if()*/, | |
| local_ops); | local_ops); |
| Value *value=NEW VJunction(j); | Value *value=NEW VJunction(j); |
| Line 229 void Request::execute(const Array& ops) | Line 226 void Request::execute(const Array& ops) |
| { | { |
| Value *value=POP(); | Value *value=POP(); |
| write_assign_lang(*value); | write_assign_lang(*value); |
| // forget the fact they've entered some ^object.method[]. | |
| // see OP_GET_ELEMENT | |
| wcontext->clear_somebody_entered_some_object(); | |
| break; | break; |
| } | } |
| case OP_WRITE_EXPR_RESULT: | case OP_WRITE_EXPR_RESULT: |
| Line 240 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 284 void Request::execute(const Array& ops) | Line 287 void Request::execute(const Array& ops) |
| { | { |
| Value *ncontext=POP(); | Value *ncontext=POP(); |
| PUSH(rcontext); | PUSH(rcontext); |
| rcontext=ncontext; | |
| PUSH(wcontext); | PUSH(wcontext); |
| rcontext=ncontext; | |
| wcontext=NEW WWrapper(pool(), ncontext, false /*not constructing*/); | wcontext=NEW WWrapper(pool(), ncontext, false /*not constructing*/); |
| break; | break; |
| } | } |
| Line 296 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 317 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 344 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 359 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 368 void Request::execute(const Array& ops) | Line 372 void Request::execute(const Array& ops) |
| PUSH(wcontext); | PUSH(wcontext); |
| VStateless_class *called_class=frame->junction.self.get_class(); | VStateless_class *called_class=frame->junction.self.get_class(); |
| // is context object or class & is it my class or my parent's class? | // not ^name.method call and |
| // 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(read_class && read_class->is_or_derived_from(*called_class)) // yes | if(!wcontext->somebody_entered_some_object() && |
| 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 derivates with constructors | // some stateless_object creatable derivates |
| if(called_class==table_class) | if(Value *value=called_class->create_new_value(pool())) |
| self=NEW VTable(pool()); | self=value; |
| else if(called_class==file_class) | |
| self=NEW VFile(pool()); | |
| else if(called_class==image_class) | |
| self=NEW VImage(pool()); | |
| else // stateful object | else // stateful object |
| self=NEW VObject(pool(), *called_class); | self=NEW VObject(pool(), *called_class); |
| frame->write(*self, | frame->write(*self, |
| Line 404 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 427 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 442 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 464 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 476 void Request::execute(const Array& ops) | Line 495 void Request::execute(const Array& ops) |
| PUSH(value); | PUSH(value); |
| break; | break; |
| } | } |
| case OP_DEXISTS: | |
| { | |
| Value *operand=POP(); | |
| Value *value=NEW VBool(pool(), | |
| dir_readable(absolute(operand->as_string()))); | |
| PUSH(value); | |
| break; | |
| } | |
| // expression ops: binary | // expression ops: binary |
| case OP_SUB: | case OP_SUB: |
| Line 510 void Request::execute(const Array& ops) | Line 537 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 519 void Request::execute(const Array& ops) | Line 546 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 528 void Request::execute(const Array& ops) | Line 555 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 537 void Request::execute(const Array& ops) | Line 564 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 666 void Request::execute(const Array& ops) | Line 693 void Request::execute(const Array& ops) |
| Value *Request::get_element() { | Value *Request::get_element() { |
| const String& name=POP_NAME(); | const String& name=POP_NAME(); |
| Value *ncontext=POP(); | Value *ncontext=POP(); |
| Value *value=ncontext->get_element(name); | Value *value; |
| if(!value) | if(Method* method=OP.get_method(name)) { // operator? |
| if(Method* method=OP.get_method(name)) { // operator? | // as if that method were in self and we have normal dynamic method here |
| // as if that method were in self and we have normal dynamic method here | Junction& junction=*NEW Junction(pool(), |
| Junction& junction=*NEW Junction(pool(), | *self, self->get_class(), method, 0,0,0,0); |
| *self, self->get_class(), method, 0,0,0,0); | value=NEW VJunction(junction); |
| value=NEW VJunction(junction); | } else |
| } | value=ncontext->get_element(name); |
| 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 699 Value& Request::process(Value& value, co | Line 725 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 737 Value& Request::process(Value& value, co | Line 765 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; |