Calling alloy first when deserializing
[satune.git] / src / Serialize / deserializer.cc
index fc4cd7bab1faa3f30191d05c9ebe8385830b57f4..8b1e3fd00cf1a81745763b8f0236dafea783a249 100644 (file)
@@ -1,8 +1,8 @@
 
-/* 
+/*
  * File:   deserializer.cc
  * Author: hamed
- * 
+ *
  * Created on September 7, 2017, 6:08 PM
  */
 
 #include "element.h"
 #include "mutableset.h"
 
-Deserializer::Deserializer(const char* file):
+#define READBUFFERSIZE 16384
+
+Deserializer::Deserializer(const char *file, bool alloy) :
+       buffer((char *) ourmalloc(READBUFFERSIZE)),
+       bufferindex(0),
+       bufferbytes(0),
+       buffercap(READBUFFERSIZE),
        solver(new CSolver())
 {
        filedesc = open(file, O_RDONLY);
+
        if (filedesc < 0) {
                exit(-1);
        }
+       if(alloy){
+               solver->setAlloyEncoder();
+       }
 }
 
 Deserializer::~Deserializer() {
-       delete solver;
-       
-       if (-1 == close(filedesc)){
+       if (-1 == close(filedesc)) {
                exit(-1);
        }
+       ourfree(buffer);
 }
 
-ssize_t Deserializer::myread(void* __buf, size_t __nbytes){
-       return read (filedesc, __buf, __nbytes);
+ssize_t Deserializer::myread(void *__buf, size_t bytestoread) {
+       char *out = (char * ) __buf;
+       size_t totalbytesread = 0;
+       while (bytestoread) {
+               if (bufferbytes != 0) {
+                       uint bytestocopy = (bufferbytes > bytestoread) ? bytestoread : bufferbytes;
+                       memcpy(out, &buffer[bufferindex], bytestocopy);
+                       //update local buffer
+                       bufferbytes -= bytestocopy;
+                       bufferindex += bytestocopy;
+                       totalbytesread += bytestocopy;
+                       //update request pointers
+                       out += bytestocopy;
+                       bytestoread -= bytestocopy;
+               } else {
+                       ssize_t bytesread = read (filedesc, buffer, buffercap);
+                       bufferindex = 0;
+                       bufferbytes = bytesread;
+                       if (bytesread == 0) {
+                               break;
+                       } else if (bytesread < 0) {
+                               exit(-1);
+                       }
+               }
+       }
+       return totalbytesread;
 }
 
-CSolver * Deserializer::deserialize(){
+CSolver *Deserializer::deserialize() {
        ASTNodeType nodeType;
-       while(myread(&nodeType, sizeof(ASTNodeType) ) >0){
-               switch(nodeType){
-                       case BOOLEANEDGE:
-                               deserializeBooleanEdge();
-                               break;
-                       case BOOLEANVAR:
-                               deserializeBooleanVar();
-                               break;
-                       case ORDERCONST:
-                               deserializeBooleanOrder();
-                               break;
-                       case ORDERTYPE:
-                               deserializeOrder();
-                               break;
-                       case SETTYPE:
-                               deserializeSet();
-                               break;
-                       case LOGICOP:
-                               deserializeBooleanLogic();
-                               break;
-                       case PREDICATEOP:
-                               deserializeBooleanPredicate();
-                               break;
-                       case PREDTABLETYPE:
-                               deserializePredicateTable();
-                               break;
-                       case PREDOPERTYPE:
-                               deserializePredicateOperator();
-                               break;
-                       case TABLETYPE:
-                               deserializeTable();
-                               break;
-                       case ELEMSET:
-                               deserializeElementSet();
-                               break;
-                       case ELEMCONST:
-                               deserializeElementConst();
-                               break;
-                       case ELEMFUNCRETURN:
-                               deserializeElementFunction();
-                               break;
-                       case FUNCOPTYPE:
-                               deserializeFunctionOperator();
-                               break;
-                       case FUNCTABLETYPE:
-                               deserializeFunctionTable();
-                               break;
-                       default:
-                               ASSERT(0);
+       while (myread(&nodeType, sizeof(ASTNodeType) ) > 0) {
+               switch (nodeType) {
+               case BOOLEANEDGE:
+                       deserializeBooleanEdge();
+                       break;
+               case BOOLEANVAR:
+                       deserializeBooleanVar();
+                       break;
+               case BOOLCONST:
+                       deserializeBooleanConst();
+                       break;
+               case ORDERCONST:
+                       deserializeBooleanOrder();
+                       break;
+               case ORDERTYPE:
+                       deserializeOrder();
+                       break;
+               case SETTYPE:
+                       deserializeSet();
+                       break;
+               case LOGICOP:
+                       deserializeBooleanLogic();
+                       break;
+               case PREDICATEOP:
+                       deserializeBooleanPredicate();
+                       break;
+               case PREDTABLETYPE:
+                       deserializePredicateTable();
+                       break;
+               case PREDOPERTYPE:
+                       deserializePredicateOperator();
+                       break;
+               case TABLETYPE:
+                       deserializeTable();
+                       break;
+               case ELEMSET:
+                       deserializeElementSet();
+                       break;
+               case ELEMCONST:
+                       deserializeElementConst();
+                       break;
+               case ELEMFUNCRETURN:
+                       deserializeElementFunction();
+                       break;
+               case FUNCOPTYPE:
+                       deserializeFunctionOperator();
+                       break;
+               case FUNCTABLETYPE:
+                       deserializeFunctionTable();
+                       break;
+               default:
+                       ASSERT(0);
                }
        }
        return solver;
 }
 
-void Deserializer::deserializeBooleanEdge(){
-       Boolean *b;
-       myread(&b, sizeof(Boolean*));
-       BooleanEdge tmp(b);
+void Deserializer::deserializeBooleanEdge() {
+       Boolean *b_ptr;
+       myread(&b_ptr, sizeof(Boolean *));
+       BooleanEdge tmp(b_ptr);
        bool isNegated = tmp.isNegated();
        ASSERT(map.contains(tmp.getBoolean()));
-       b = (Boolean*) map.get(tmp.getBoolean());
-       BooleanEdge res(b);
-       solver->addConstraint(isNegated?res.negate():res);
+       b_ptr = (Boolean *) map.get(tmp.getBoolean());
+       BooleanEdge res(b_ptr);
+       bool isTopLevel;
+       myread(&isTopLevel, sizeof(bool));
+       if (isTopLevel) {
+               solver->addConstraint(isNegated ? res.negate() : res);
+       }
 }
 
-void Deserializer::deserializeBooleanVar(){
+void Deserializer::deserializeBooleanVar() {
        BooleanVar *b;
-       myread(&b, sizeof(BooleanVar*));
+       myread(&b, sizeof(BooleanVar *));
        VarType vtype;
        myread(&vtype, sizeof(VarType));
        map.put(b, solver->getBooleanVar(vtype).getBoolean());
 }
 
-void Deserializer::deserializeBooleanOrder(){
-       BooleanOrder* bo_ptr;
-       myread(&bo_ptr, sizeof(BooleanOrder*));
-       Order* order;
-       myread(&order, sizeof(Order*));
+void Deserializer::deserializeBooleanConst() {
+       BooleanVar *b;
+       myread(&b, sizeof(BooleanVar *));
+       bool istrue;
+       myread(&istrue, sizeof(bool));
+       map.put(b, istrue ? solver->getBooleanTrue().getBoolean() :
+                                       solver->getBooleanFalse().getBoolean());
+}
+
+void Deserializer::deserializeBooleanOrder() {
+       BooleanOrder *bo_ptr;
+       myread(&bo_ptr, sizeof(BooleanOrder *));
+       Order *order;
+       myread(&order, sizeof(Order *));
        ASSERT(map.contains(order));
-       order  = (Order*) map.get(order);
+       order  = (Order *) map.get(order);
        uint64_t first;
        myread(&first, sizeof(uint64_t));
        uint64_t second;
@@ -126,55 +174,58 @@ void Deserializer::deserializeBooleanOrder(){
        map.put(bo_ptr, solver->orderConstraint(order, first, second).getBoolean());
 }
 
-void Deserializer::deserializeOrder(){
-       Ordero_ptr;
-       myread(&o_ptr, sizeof(Order*));
+void Deserializer::deserializeOrder() {
+       Order *o_ptr;
+       myread(&o_ptr, sizeof(Order *));
        OrderType type;
        myread(&type, sizeof(OrderType));
-       Set * set_ptr;
+       Set *set_ptr;
        myread(&set_ptr, sizeof(Set *));
        ASSERT(map.contains(set_ptr));
-       Set* set  = (Set*) map.get(set_ptr);
+       Set *set  = (Set *) map.get(set_ptr);
        map.put(o_ptr, solver->createOrder(type, set));
 }
 
-void Deserializer::deserializeSet(){
+void Deserializer::deserializeSet() {
        Set *s_ptr;
-       myread(&s_ptr, sizeof(Set*));
+       myread(&s_ptr, sizeof(Set *));
        VarType type;
        myread(&type, sizeof(VarType));
        bool isRange;
        myread(&isRange, sizeof(bool));
-       uint64_t low;
-       myread(&low, sizeof(uint64_t));
-       uint64_t high;
-       myread(&high, sizeof(uint64_t));
        bool isMutable;
        myread(&isMutable, sizeof(bool));
-       Set *set;
-       if(isMutable){
-               set = new MutableSet(type);
-       }
-       uint size;
-       myread(&size, sizeof(uint));
-       Vector<uint64_t> members;
-       for(uint i=0; i<size; i++){
-               uint64_t mem;
-               myread(&mem, sizeof(uint64_t));
-               if(isMutable) {
-                       ((MutableSet*) set)->addElementMSet(mem);
-               }else {
-                       members.push(mem);
+       if (isRange) {
+               uint64_t low;
+               myread(&low, sizeof(uint64_t));
+               uint64_t high;
+               myread(&high, sizeof(uint64_t));
+               map.put(s_ptr, new Set(type, low, high));
+       } else {
+               Set *set = NULL;
+               if (isMutable) {
+                       set = new MutableSet(type);
                }
+               uint size;
+               myread(&size, sizeof(uint));
+               Vector<uint64_t> members;
+               for (uint i = 0; i < size; i++) {
+                       uint64_t mem;
+                       myread(&mem, sizeof(uint64_t));
+                       if (isMutable) {
+                               ((MutableSet *) set)->addElementMSet(mem);
+                       } else {
+                               members.push(mem);
+                       }
+               }
+               if (!isMutable) {
+                       set = solver->createSet(type, members.expose(), size);
+               }
+               map.put(s_ptr, set);
        }
-       if(!isMutable){
-               set = isRange? solver->createRangeSet(type, low, high):
-                       solver->createSet(type, members.expose(), size);
-       }
-       map.put(s_ptr, set);
 }
 
-void Deserializer::deserializeBooleanLogic(){
+void Deserializer::deserializeBooleanLogic() {
        BooleanLogic *bl_ptr;
        myread(&bl_ptr, sizeof(BooleanLogic *));
        LogicOp op;
@@ -182,205 +233,187 @@ void Deserializer::deserializeBooleanLogic(){
        uint size;
        myread(&size, sizeof(uint));
        Vector<BooleanEdge> members;
-       for(uint i=0; i<size; i++){
-               Booleanmember;
+       for (uint i = 0; i < size; i++) {
+               Boolean *member;
                myread(&member, sizeof(Boolean *));
                BooleanEdge tmp(member);
                bool isNegated = tmp.isNegated();
                ASSERT(map.contains(tmp.getBoolean()));
-               member = (Boolean*) map.get(tmp.getBoolean());
+               member = (Boolean *) map.get(tmp.getBoolean());
                BooleanEdge res(member);
-               members.push( isNegated?res.negate():res );
+               members.push( isNegated ? res.negate() : res );
        }
        map.put(bl_ptr, solver->applyLogicalOperation(op, members.expose(), size).getBoolean());
 }
 
-void Deserializer::deserializeBooleanPredicate(){
+void Deserializer::deserializeBooleanPredicate() {
        BooleanPredicate *bp_ptr;
        myread(&bp_ptr, sizeof(BooleanPredicate *));
-       Predicatepredicate;
-       myread(&predicate, sizeof(Predicate*));
+       Predicate *predicate;
+       myread(&predicate, sizeof(Predicate *));
        ASSERT(map.contains(predicate));
-       predicate = (Predicate*) map.get(predicate);
+       predicate = (Predicate *) map.get(predicate);
        uint size;
        myread(&size, sizeof(uint));
-       Vector<Element*> members;
-       for(uint i=0; i<size; i++){
-               Elementinput;
+       Vector<Element *> members;
+       for (uint i = 0; i < size; i++) {
+               Element *input;
                myread(&input, sizeof(Element *));
                ASSERT(map.contains(input));
-               input = (Element*) map.get(input);
+               input = (Element *) map.get(input);
                members.push(input);
        }
-       
-       Booleanstat_ptr;
+
+       Boolean *stat_ptr;
        myread(&stat_ptr, sizeof(Boolean *));
        BooleanEdge undefStatus;
-       if(stat_ptr != NULL){
+       if (stat_ptr != NULL) {
                BooleanEdge tmp(stat_ptr);
                bool isNegated = tmp.isNegated();
                ASSERT(map.contains(tmp.getBoolean()));
-               stat_ptr = (Boolean*) map.get(tmp.getBoolean());
+               stat_ptr = (Boolean *) map.get(tmp.getBoolean());
                BooleanEdge res(stat_ptr);
-               undefStatus = isNegated?res.negate():res;
+               undefStatus = isNegated ? res.negate() : res;
        } else {
                undefStatus = NULL;
        }
        map.put(bp_ptr, solver->applyPredicateTable(predicate, members.expose(), size, undefStatus).getBoolean());
 }
 
-void Deserializer::deserializePredicateTable(){
+void Deserializer::deserializePredicateTable() {
        PredicateTable *pt_ptr;
        myread(&pt_ptr, sizeof(PredicateTable *));
-       Tabletable;
-       myread(&table, sizeof(Table*));
+       Table *table;
+       myread(&table, sizeof(Table *));
        ASSERT(map.contains(table));
-       table = (Table*) map.get(table);
+       table = (Table *) map.get(table);
        UndefinedBehavior undefinedbehavior;
        myread(&undefinedbehavior, sizeof(UndefinedBehavior));
-       
+
        map.put(pt_ptr, solver->createPredicateTable(table, undefinedbehavior));
 }
 
-void Deserializer::deserializePredicateOperator(){
+void Deserializer::deserializePredicateOperator() {
        PredicateOperator *po_ptr;
        myread(&po_ptr, sizeof(PredicateOperator *));
        CompOp op;
        myread(&op, sizeof(CompOp));
-       uint size;
-       myread(&size, sizeof(uint));
-       Vector<Set*> domains;
-       for(uint i=0; i<size; i++){
-               Set* domain;
-               myread(&domain, sizeof(Set*));
-               ASSERT(map.contains(domain));
-               domain = (Set*) map.get(domain);
-               domains.push(domain);
-       }
 
-       map.put(po_ptr, solver->createPredicateOperator(op, domains.expose(), size));
+       map.put(po_ptr, solver->createPredicateOperator(op));
 }
 
-void Deserializer::deserializeTable(){
+void Deserializer::deserializeTable() {
        Table *t_ptr;
        myread(&t_ptr, sizeof(Table *));
-       uint size;
-       myread(&size, sizeof(uint));
-       Vector<Set*> domains;
-       for(uint i=0; i<size; i++){
-               Set* domain;
-               myread(&domain, sizeof(Set*));
-               ASSERT(map.contains(domain));
-               domain = (Set*) map.get(domain);
-               domains.push(domain);
-       }
-       Set* range;
-       myread(&range, sizeof(Set*));
-       if(range != NULL){
+       Set *range;
+       myread(&range, sizeof(Set *));
+       if (range != NULL) {
                ASSERT(map.contains(range));
-               range = (Set*) map.get(range);
+               range = (Set *) map.get(range);
        }
-       Table* table = solver->createTable(domains.expose(), size, range);
+       Table *table = solver->createTable(range);
+       uint size;
        myread(&size, sizeof(uint));
-       for(uint i=0; i<size; i++){
+       for (uint i = 0; i < size; i++) {
                uint64_t output;
                myread(&output, sizeof(uint64_t));
                uint inputSize;
                myread(&inputSize, sizeof(uint));
                Vector<uint64_t> inputs;
                inputs.setSize(inputSize);
-               myread(inputs.expose(), sizeof(uint64_t)*inputSize);
+               myread(inputs.expose(), sizeof(uint64_t) * inputSize);
                table->addNewTableEntry(inputs.expose(), inputSize, output);
        }
-       
+
        map.put(t_ptr, table);
 }
 
 
-void Deserializer::deserializeElementSet(){
-       ElementSet* es_ptr;
-       myread(&es_ptr, sizeof(ElementSet*));
-       Set * set;
+void Deserializer::deserializeElementSet() {
+       bool anyValue = false;
+       myread(&anyValue, sizeof(bool));
+       ElementSet *es_ptr;
+       myread(&es_ptr, sizeof(ElementSet *));
+       Set *set;
        myread(&set, sizeof(Set *));
        ASSERT(map.contains(set));
-       set  = (Set*) map.get(set);
-       map.put(es_ptr, solver->getElementVar(set));
+       set  = (Set *) map.get(set);
+       Element *newEl = solver->getElementVar(set);
+       newEl->anyValue = anyValue;
+       map.put(es_ptr, newEl);
 }
 
-void Deserializer::deserializeElementConst(){
-       ElementSet* es_ptr;
-       myread(&es_ptr, sizeof(ElementSet*));
+void Deserializer::deserializeElementConst() {
+       bool anyValue = false;
+       myread(&anyValue, sizeof(bool));
+       ElementSet *es_ptr;
+       myread(&es_ptr, sizeof(ElementSet *));
        VarType type;
        myread(&type, sizeof(VarType));
        uint64_t value;
        myread(&value, sizeof(uint64_t));
-       map.put(es_ptr, solver->getElementConst(type, value));
+       Element *newEl = solver->getElementConst(type, value);
+       newEl->anyValue = anyValue;
+       map.put(es_ptr, newEl);
 }
 
-void Deserializer::deserializeElementFunction(){
+void Deserializer::deserializeElementFunction() {
+       bool anyValue = false;
+       myread(&anyValue, sizeof(bool));
        ElementFunction *ef_ptr;
        myread(&ef_ptr, sizeof(ElementFunction *));
        Function *function;
-       myread(&function, sizeof(Function*));
+       myread(&function, sizeof(Function *));
        ASSERT(map.contains(function));
-       function = (Function*) map.get(function);
+       function = (Function *) map.get(function);
        uint size;
        myread(&size, sizeof(uint));
-       Vector<Element*> members;
-       for(uint i=0; i<size; i++){
-               Elementinput;
+       Vector<Element *> members;
+       for (uint i = 0; i < size; i++) {
+               Element *input;
                myread(&input, sizeof(Element *));
                ASSERT(map.contains(input));
-               input = (Element*) map.get(input);
+               input = (Element *) map.get(input);
                members.push(input);
        }
-       
-       Booleanoverflowstatus;
+
+       Boolean *overflowstatus;
        myread(&overflowstatus, sizeof(Boolean *));
        BooleanEdge tmp(overflowstatus);
        bool isNegated = tmp.isNegated();
        ASSERT(map.contains(tmp.getBoolean()));
-       overflowstatus = (Boolean*) map.get(tmp.getBoolean());
+       overflowstatus = (Boolean *) map.get(tmp.getBoolean());
        BooleanEdge res(overflowstatus);
-       BooleanEdge undefStatus = isNegated?res.negate():res;
-       
-       map.put(ef_ptr, solver->applyFunction(function, members.expose(), size, undefStatus));
+       BooleanEdge undefStatus = isNegated ? res.negate() : res;
+       Element *newEl = solver->applyFunction(function, members.expose(), size, undefStatus);
+       newEl->anyValue = anyValue;
+       map.put(ef_ptr, newEl);
 }
 
 
-void Deserializer::deserializeFunctionOperator(){
+void Deserializer::deserializeFunctionOperator() {
        FunctionOperator *fo_ptr;
        myread(&fo_ptr, sizeof(FunctionOperator *));
        ArithOp op;
        myread(&op, sizeof(ArithOp));
-       uint size;
-       myread(&size, sizeof(uint));
-       Vector<Set*> domains;
-       for(uint i=0; i<size; i++){
-               Set* domain;
-               myread(&domain, sizeof(Set*));
-               ASSERT(map.contains(domain));
-               domain = (Set*) map.get(domain);
-               domains.push(domain);
-       }
-       Set* range;
-       myread(&range, sizeof(Set*));
+       Set *range;
+       myread(&range, sizeof(Set *));
        ASSERT(map.contains(range));
-       range = (Set*) map.get(range);
+       range = (Set *) map.get(range);
        OverFlowBehavior overflowbehavior;
        myread(&overflowbehavior, sizeof(OverFlowBehavior));
-       map.put(fo_ptr, solver->createFunctionOperator(op, domains.expose(), size, range, overflowbehavior));
+       map.put(fo_ptr, solver->createFunctionOperator(op, range, overflowbehavior));
 }
 
-void Deserializer::deserializeFunctionTable(){
+void Deserializer::deserializeFunctionTable() {
        FunctionTable *ft_ptr;
        myread(&ft_ptr, sizeof(FunctionTable *));
-       Tabletable;
-       myread(&table, sizeof(Table*));
+       Table *table;
+       myread(&table, sizeof(Table *));
        ASSERT(map.contains(table));
-       table = (Table*) map.get(table);
+       table = (Table *) map.get(table);
        UndefinedBehavior undefinedbehavior;
        myread(&undefinedbehavior, sizeof(UndefinedBehavior));
-       
+
        map.put(ft_ptr, solver->completeTable(table, undefinedbehavior));
-}
\ No newline at end of file
+}