src/ftacmp/parse_partn.cc

   1 /* ------------------------------------------------\r
   2 Copyright 2014 AT&T Intellectual Property\r
   3    Licensed under the Apache License, Version 2.0 (the "License");\r
   4    you may not use this file except in compliance with the License.\r
   5    You may obtain a copy of the License at\r
   6 \r
   7      http://www.apache.org/licenses/LICENSE-2.0\r
   8 \r
   9    Unless required by applicable law or agreed to in writing, software\r
  10    distributed under the License is distributed on an "AS IS" BASIS,\r
  11    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  12    See the License for the specific language governing permissions and\r
  13    limitations under the License.\r
  14  ------------------------------------------- */\r
  15 #include"parse_partn.h"\r
  16 #include "parse_schema.h"\r
  17 #include"analyze_fta.h"\r
  18 \r
  19 \r
  20 using namespace std;\r
  21 \r
  22 \r
  23 int find_field(scalarexp_t *se, string &fld){\r
  24         vector<scalarexp_t *> operands;\r
  25         int o,ret=0;\r
  26 \r
  27         switch(se->get_operator_type()){\r
  28         case SE_LITERAL:\r
  29                 return 0;\r
  30         case SE_PARAM:\r
  31         case SE_IFACE_PARAM:\r
  32                 return 100;             // force failure, but no error message.\r
  33         case SE_UNARY_OP:\r
  34                 return find_field(se->get_left_se(), fld);\r
  35         case SE_BINARY_OP:\r
  36                 return find_field(se->get_left_se(), fld)+find_field(se->get_right_se(), fld);\r
  37         case SE_COLREF:\r
  38                 fld = se->get_colref()->get_field();\r
  39                 return 1;\r
  40         case SE_AGGR_STAR:\r
  41         case SE_AGGR_SE:\r
  42 //                      Should be no aggregates\r
  43                 return 0;\r
  44         case SE_FUNC:\r
  45                 return 100;             // force failure, but no error message.\r
  46         default:\r
  47                 fprintf(stderr,"INTERNAL ERROR in find_field, unknown operator type %d\n", se->get_operator_type());\r
  48                 return(-100);\r
  49         }\r
  50         return(-100);\r
  51 }\r
  52 \r
  53 \r
  54 int partn_def_t::verify(table_list *schema, string &err_msg){\r
  55         if(schema->find_tbl(protocol) < 0){\r
  56                 err_msg += "ERROR, partition definition "+name+" uses source "+protocol+", but its not in the schema.\n";\r
  57                 return 1;\r
  58         }\r
  59         if(schema->get_schema_type(schema->find_tbl(protocol)) != PROTOCOL_SCHEMA){\r
  60                 err_msg += "ERROR, partition definition "+name+" uses source "+protocol+", but its not a PROTOCOL.\n";\r
  61                 return 1;\r
  62         }\r
  63 \r
  64         tablevar_t *fme = new tablevar_t(protocol.c_str());\r
  65         tablevar_list_t fm(fme);\r
  66 \r
  67 //              Validate the SE and assign data types.\r
  68         int i;\r
  69         int retval = 0;\r
  70         for(i=0;i<se_list.size();++i){\r
  71                 int ret = verify_colref(se_list[i],&fm,schema,NULL);\r
  72                 if(ret){\r
  73                         err_msg += "ERROR validating entry "+int_to_string(i)+" of partition definition "+name+".\n";\r
  74                         retval=1;\r
  75                 }\r
  76         }\r
  77         if(retval)\r
  78                 return 1;\r
  79 \r
  80 //              Ensure that the data type is an integer type.\r
  81         for(i=0;i<se_list.size();++i){\r
  82                 data_type *dt = se_list[i]->get_data_type();\r
  83                 string type_s = dt->get_type_str();\r
  84                 if(! ( type_s=="UINT" || type_s=="INT" || type_s=="ULLONG" || type_s=="LLONG") ){\r
  85                         err_msg += "ERROR, entry "+int_to_string(i)+" of partition definition "+name+" has type "+type_s+", but it must be one of UINT, INT, ULLONG, LLONG.\n";\r
  86                         retval=1;\r
  87                 }\r
  88         }\r
  89         if(retval)\r
  90                 return 1;\r
  91 \r
  92 //              Ensure that each SE ref's a field only once.\r
  93         for(i=0;i<se_list.size();++i){\r
  94                 string fld;\r
  95                 int ret = find_field(se_list[i],fld);\r
  96                 if(ret<0){\r
  97                         err_msg += "ERROR validating entry "+int_to_string(i)+" of partition definition "+name+".\n";\r
  98                         retval=1;\r
  99                 }\r
 100                 if(ret!=1){\r
 101                         err_msg += "ERROR validating entry "+int_to_string(i)+" of partition definition "+name+": the expression references a field "+int_to_string(ret)+" times, but it should reference a field exactly once.\n";\r
 102                         retval=1;\r
 103                         field_list.push_back("");\r
 104                 }else{\r
 105                         field_list.push_back(fld);\r
 106                 }\r
 107         }\r
 108         if(retval)\r
 109                 return 1;\r
 110 \r
 111         return 0;\r
 112 \r
 113 }\r
 114 \r
 115 void find_colref_path(scalarexp_t *se, vector<scalarexp_t *> &se_stack){\r
 116         vector<scalarexp_t *> operands;\r
 117         int o,ret=0;\r
 118 \r
 119         switch(se->get_operator_type()){\r
 120         case SE_LITERAL:\r
 121         case SE_PARAM:\r
 122         case SE_IFACE_PARAM:\r
 123                 return ;\r
 124         case SE_UNARY_OP:\r
 125                 find_colref_path(se->get_left_se(), se_stack);\r
 126                 if(se_stack.size()>0)\r
 127                         se_stack.push_back(se);\r
 128                 return;\r
 129         case SE_BINARY_OP:\r
 130                 find_colref_path(se->get_left_se(), se_stack);\r
 131                 if(se_stack.size()>0){\r
 132                         se_stack.push_back(se);\r
 133                         return;\r
 134                 }\r
 135                 find_colref_path(se->get_right_se(), se_stack);\r
 136                 if(se_stack.size()>0)\r
 137                         se_stack.push_back(se);\r
 138                 return;\r
 139         case SE_COLREF:\r
 140                 se_stack.push_back(se);\r
 141                 return;\r
 142         case SE_AGGR_STAR:\r
 143         case SE_AGGR_SE:\r
 144 //                      Should be no aggregates\r
 145                 return;\r
 146         case SE_FUNC:\r
 147                 operands = se->get_operands();\r
 148                 for(o=0;o<operands.size();o++){\r
 149                         find_colref_path(operands[o], se_stack);\r
 150                         if(se_stack.size()>0){\r
 151                                 se_stack.push_back(se);\r
 152                                 return;\r
 153                         }\r
 154                 }\r
 155                 return;\r
 156         default:\r
 157                 fprintf(stderr,"INTERNAL ERROR in find_colref_path, unknown operator type %d\n", se->get_operator_type());\r
 158                 return;\r
 159         }\r
 160         return;\r
 161 }\r
 162 \r
 163 struct param_int{\r
 164         union{\r
 165                 long int li;\r
 166                 unsigned long int uli;\r
 167                 long long int lli;\r
 168                 unsigned long long int ulli;\r
 169         } v;\r
 170     dtype d;\r
 171 \r
 172         void convert_to_final() {};\r
 173 \r
 174         void load_val(dtype dt, const char *val){\r
 175                 d=dt;\r
 176                 switch(dt){\r
 177                 case u_int_t:\r
 178                         sscanf(val,"%llu",&(v.ulli));\r
 179                         break;\r
 180                 case int_t:\r
 181                         sscanf(val,"%lld",&(v.lli));\r
 182                         break;\r
 183                 case u_llong_t:\r
 184                         sscanf(val,"%llu",&(v.ulli));\r
 185                         break;\r
 186                 case llong_t:\r
 187                         sscanf(val,"%lld",&(v.lli));\r
 188                         break;\r
 189                 default:\r
 190                         fprintf(stderr,"INTERNAL ERROR, data type %d passed to param_int::load_val.\n",dt);\r
 191                         exit(1);\r
 192                 }\r
 193         }\r
 194 \r
 195         void add(dtype dt, param_int &l, param_int &r){\r
 196                 d=dt;\r
 197                 if(dt==int_t || dt==llong_t)\r
 198                         if(l.d==int_t || l.d==llong_t)\r
 199                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli+r.v.lli; else v.lli = l.v.lli+r.v.ulli;\r
 200                         else\r
 201                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli+r.v.lli; else v.lli = l.v.ulli+r.v.ulli;\r
 202                 else\r
 203                         if(l.d==int_t || l.d==llong_t)\r
 204                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli+r.v.lli; else v.ulli = l.v.lli+r.v.ulli;\r
 205                         else\r
 206                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli+r.v.lli; else v.ulli = l.v.ulli+r.v.ulli;\r
 207         }\r
 208         void subtract(dtype dt, param_int &l, param_int &r){\r
 209                 d=dt;\r
 210                 if(dt==int_t || dt==llong_t)\r
 211                         if(l.d==int_t || l.d==llong_t)\r
 212                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli-r.v.lli; else v.lli = l.v.lli-r.v.ulli;\r
 213                         else\r
 214                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli-r.v.lli; else v.lli = l.v.ulli-r.v.ulli;\r
 215                 else\r
 216                         if(l.d==int_t || l.d==llong_t)\r
 217                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli-r.v.lli; else v.ulli = l.v.lli-r.v.ulli;\r
 218                         else\r
 219                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli-r.v.lli; else v.ulli = l.v.ulli-r.v.ulli;\r
 220         }\r
 221         void mult(dtype dt, param_int &l, param_int &r){\r
 222                 d=dt;\r
 223                 if(dt==int_t || dt==llong_t)\r
 224                         if(l.d==int_t || l.d==llong_t)\r
 225                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli*r.v.lli; else v.lli = l.v.lli*r.v.ulli;\r
 226                         else\r
 227                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli*r.v.lli; else v.lli = l.v.ulli*r.v.ulli;\r
 228                 else\r
 229                         if(l.d==int_t || l.d==llong_t)\r
 230                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli*r.v.lli; else v.ulli = l.v.lli*r.v.ulli;\r
 231                         else\r
 232                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli*r.v.lli; else v.ulli = l.v.ulli*r.v.ulli;\r
 233         }\r
 234         void div(dtype dt, param_int &l, param_int &r){\r
 235                 d=dt;\r
 236                 if(dt==int_t || dt==llong_t)\r
 237                         if(l.d==int_t || l.d==llong_t)\r
 238                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli/r.v.lli; else v.lli = l.v.lli/r.v.ulli;\r
 239                         else\r
 240                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli/r.v.lli; else v.lli = l.v.ulli/r.v.ulli;\r
 241                 else\r
 242                         if(l.d==int_t || l.d==llong_t)\r
 243                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli/r.v.lli; else v.ulli = l.v.lli/r.v.ulli;\r
 244                         else\r
 245                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli/r.v.lli; else v.ulli = l.v.ulli/r.v.ulli;\r
 246         }\r
 247         void bit_and(dtype dt, param_int &l, param_int &r){\r
 248                 d=dt;\r
 249                 if(dt==int_t || dt==llong_t)\r
 250                         if(l.d==int_t || l.d==llong_t)\r
 251                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli&r.v.lli; else v.lli = l.v.lli&r.v.ulli;\r
 252                         else\r
 253                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli&r.v.lli; else v.lli = l.v.ulli&r.v.ulli;\r
 254                 else\r
 255                         if(l.d==int_t || l.d==llong_t)\r
 256                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli&r.v.lli; else v.ulli = l.v.lli&r.v.ulli;\r
 257                         else\r
 258                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli&r.v.lli; else v.ulli = l.v.ulli&r.v.ulli;\r
 259         }\r
 260         void bit_or(dtype dt, param_int &l, param_int &r){\r
 261                 d=dt;\r
 262                 if(dt==int_t || dt==llong_t)\r
 263                         if(l.d==int_t || l.d==llong_t)\r
 264                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli|r.v.lli; else v.lli = l.v.lli|r.v.ulli;\r
 265                         else\r
 266                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli|r.v.lli; else v.lli = l.v.ulli|r.v.ulli;\r
 267                 else\r
 268                         if(l.d==int_t || l.d==llong_t)\r
 269                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli|r.v.lli; else v.ulli = l.v.lli|r.v.ulli;\r
 270                         else\r
 271                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli|r.v.lli; else v.ulli = l.v.ulli|r.v.ulli;\r
 272         }\r
 273         void modulo(dtype dt, param_int &l, param_int &r){\r
 274                 d=dt;\r
 275                 if(dt==int_t || dt==llong_t)\r
 276                         if(l.d==int_t || l.d==llong_t)\r
 277                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli%r.v.lli; else v.lli = l.v.lli%r.v.ulli;\r
 278                         else\r
 279                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli%r.v.lli; else v.lli = l.v.ulli%r.v.ulli;\r
 280                 else\r
 281                         if(l.d==int_t || l.d==llong_t)\r
 282                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli%r.v.lli; else v.ulli = l.v.lli%r.v.ulli;\r
 283                         else\r
 284                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli%r.v.lli; else v.ulli = l.v.ulli%r.v.ulli;\r
 285         }\r
 286         void shift_left(dtype dt, param_int &l, param_int &r){\r
 287                 d=dt;\r
 288                 if(dt==int_t || dt==llong_t)\r
 289                         if(l.d==int_t || l.d==llong_t)\r
 290                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli<<r.v.lli; else v.lli = l.v.lli<<r.v.ulli;\r
 291                         else\r
 292                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli<<r.v.lli; else v.lli = l.v.ulli<<r.v.ulli;\r
 293                 else\r
 294                         if(l.d==int_t || l.d==llong_t)\r
 295                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli<<r.v.lli; else v.ulli = l.v.lli<<r.v.ulli;\r
 296                         else\r
 297                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli<<r.v.lli; else v.ulli = l.v.ulli<<r.v.ulli;\r
 298         }\r
 299         void shift_right(dtype dt, param_int &l, param_int &r){\r
 300                 d=dt;\r
 301                 if(dt==int_t || dt==llong_t)\r
 302                         if(l.d==int_t || l.d==llong_t)\r
 303                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.lli>>r.v.lli; else v.lli = l.v.lli>>r.v.ulli;\r
 304                         else\r
 305                                 if(r.d==int_t || r.d==llong_t) v.lli = l.v.ulli>>r.v.lli; else v.lli = l.v.ulli>>r.v.ulli;\r
 306                 else\r
 307                         if(l.d==int_t || l.d==llong_t)\r
 308                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.lli>>r.v.lli; else v.ulli = l.v.lli>>r.v.ulli;\r
 309                         else\r
 310                                 if(r.d==int_t || r.d==llong_t) v.ulli = l.v.ulli>>r.v.lli; else v.ulli = l.v.ulli>>r.v.ulli;\r
 311         }\r
 312 \r
 313         void plus(dtype dt, param_int &l){\r
 314                 d=dt;\r
 315                 if(dt==int_t || dt==llong_t)\r
 316                         if(l.d==int_t || l.d==llong_t)\r
 317                                 v.lli = l.v.ulli;\r
 318                         else\r
 319                                 v.lli = l.v.lli;\r
 320                 else\r
 321                         if(l.d==int_t || l.d==llong_t)\r
 322                                 v.ulli = l.v.ulli;\r
 323                         else\r
 324                                 v.ulli = l.v.lli;\r
 325         }\r
 326         void minus(dtype dt, param_int &l){\r
 327                 d=dt;\r
 328                 if(dt==int_t || dt==llong_t)\r
 329                         if(l.d==int_t || l.d==llong_t)\r
 330                                 v.lli = -l.v.ulli;\r
 331                         else\r
 332                                 v.lli = -l.v.lli;\r
 333                 else\r
 334                         if(l.d==int_t || l.d==llong_t)\r
 335                                 v.ulli = -l.v.ulli;\r
 336                         else\r
 337                                 v.ulli = -l.v.lli;\r
 338         }\r
 339         void abs_not(dtype dt, param_int &l){\r
 340                 d=dt;\r
 341                 if(dt==int_t || dt==llong_t)\r
 342                         if(l.d==int_t || l.d==llong_t)\r
 343                                 v.lli = !l.v.ulli;\r
 344                         else\r
 345                                 v.lli = !l.v.lli;\r
 346                 else\r
 347                         if(l.d==int_t || l.d==llong_t)\r
 348                                 v.ulli = !l.v.ulli;\r
 349                         else\r
 350                                 v.ulli = !l.v.lli;\r
 351         }\r
 352         void bit_not(dtype dt, param_int &l){\r
 353                 d=dt;\r
 354                 if(dt==int_t || dt==llong_t)\r
 355                         if(l.d==int_t || l.d==llong_t)\r
 356                                 v.lli = ~l.v.ulli;\r
 357                         else\r
 358                                 v.lli = ~l.v.lli;\r
 359                 else\r
 360                         if(l.d==int_t || l.d==llong_t)\r
 361                                 v.ulli = ~l.v.ulli;\r
 362                         else\r
 363                                 v.ulli = ~l.v.lli;\r
 364         }\r
 365 };\r
 366 \r
 367 \r
 368 bool int_operand_divides(param_int &lp, param_int &rp){\r
 369         if( (lp.d==int_t || lp.d==llong_t)){\r
 370                 if(lp.v.lli < 0)\r
 371                         lp.v.ulli = -lp.v.lli;\r
 372                 else\r
 373                         lp.v.ulli = lp.v.lli;\r
 374         }\r
 375         if( (rp.d==int_t || rp.d==llong_t)){\r
 376                 if(rp.v.lli < 0)\r
 377                         rp.v.ulli = -rp.v.lli;\r
 378                 else\r
 379                         rp.v.ulli = rp.v.lli;\r
 380         }\r
 381     unsigned long long int d = rp.v.ulli / lp.v.ulli;\r
 382     unsigned long long int r = rp.v.ulli - d * lp.v.ulli;\r
 383         return d==0;\r
 384 }\r
 385 \r
 386 bool int_operand_implies(param_int &lp, param_int &rp){\r
 387         unsigned long long int d = (lp.v.ulli & rp.v.ulli) | (!lp.v.ulli);\r
 388         return (~d)==0;\r
 389 }\r
 390 \r
 391 \r
 392 \r
 393 \r
 394 void extract_param_int(scalarexp_t *se, param_int &p_int) {\r
 395 param_int lp, rp;\r
 396 string op_str;\r
 397 dtype dt = se->get_data_type()->get_type();\r
 398         switch(se->get_operator_type()){\r
 399         case SE_LITERAL:\r
 400                 p_int.load_val(se->get_data_type()->get_type(),se->to_string().c_str());\r
 401                 return;\r
 402         case SE_UNARY_OP:\r
 403                 extract_param_int(se->get_left_se(), lp);\r
 404                 op_str = se->get_op();\r
 405                 if(op_str=="+") p_int.plus(dt,lp);\r
 406                 if(op_str=="-") p_int.minus(dt,lp);\r
 407                 if(op_str=="!") p_int.abs_not(dt,lp);\r
 408                 if(op_str=="~") p_int.bit_not(dt,lp);\r
 409                 return;\r
 410         case SE_BINARY_OP:\r
 411                 extract_param_int(se->get_left_se(), lp);\r
 412                 extract_param_int(se->get_right_se(), rp);\r
 413                 op_str = se->get_op();\r
 414                 if(op_str=="+") p_int.add(dt,lp,rp);\r
 415                 if(op_str=="-") p_int.subtract(dt,lp,rp);\r
 416                 if(op_str=="*") p_int.mult(dt,lp,rp);\r
 417                 if(op_str=="/") p_int.div(dt,lp,rp);\r
 418                 if(op_str=="&") p_int.bit_and(dt,lp,rp);\r
 419                 if(op_str=="|") p_int.bit_or(dt,lp,rp);\r
 420                 if(op_str=="%") p_int.modulo(dt,lp,rp);\r
 421                 if(op_str=="<<") p_int.shift_left(dt,lp,rp);\r
 422                 if(op_str==">>") p_int.shift_right(dt,lp,rp);\r
 423                 return;\r
 424         default:\r
 425                 fprintf(stderr,"INTERNAL ERROR in find_field, invalid operator type %d\n", se->get_operator_type());\r
 426                 exit(1);\r
 427         }\r
 428         return;\r
 429 \r
 430 }\r
 431 \r
 432 \r
 433 void get_int_operand(scalarexp_t *parent, scalarexp_t *child, param_int &p_int){\r
 434         if(parent->get_operator_type() != SE_BINARY_OP){\r
 435                 fprintf(stderr,"INTERNAL ERROR, operator type %d in get_int_operand.\n",\r
 436 parent->get_operator_type());\r
 437                 exit(1);\r
 438         }\r
 439         if(parent->get_right_se() == child){\r
 440                 extract_param_int(parent->get_left_se(), p_int);\r
 441                 p_int.convert_to_final();\r
 442         }else{\r
 443                 extract_param_int(parent->get_right_se(), p_int);\r
 444                 p_int.convert_to_final();\r
 445         }\r
 446 }\r
 447 \r
 448 \r
 449 bool partition_compatible(scalarexp_t *pse, scalarexp_t *gse){\r
 450         vector<scalarexp_t *> pstack, gstack;\r
 451 \r
 452         find_colref_path(pse, pstack);\r
 453         find_colref_path(gse, gstack);\r
 454 \r
 455         int ppos=0, gpos=0;\r
 456         string p_op, g_op;\r
 457         param_int p_int, g_int;\r
 458 \r
 459         while(ppos<pstack.size()-1 && gpos<gstack.size()-1){\r
 460 \r
 461 //              first, try to raise both stack pointers.\r
 462                 if(ppos<pstack.size()-1 && gpos<gstack.size()-1){\r
 463                         p_op = pstack[ppos+1]->get_op();\r
 464                         g_op = gstack[gpos+1]->get_op();\r
 465                         if(p_op==g_op){\r
 466                                 if(p_op=="/"){\r
 467                                         get_int_operand(pstack[ppos+1],pstack[ppos],p_int);\r
 468                                         get_int_operand(gstack[gpos+1],gstack[gpos],g_int);\r
 469                                         if(int_operand_divides(g_int, p_int)){\r
 470                                                 ppos++;\r
 471                                                 gpos++;\r
 472                                                 continue;\r
 473                                         }else{\r
 474                                                 return false;\r
 475                                         }\r
 476                                 }\r
 477                                 if(p_op=="&"){\r
 478                                         get_int_operand(pstack[ppos+1],pstack[ppos],p_int);\r
 479                                         get_int_operand(gstack[gpos+1],gstack[gpos],g_int);\r
 480                                         if(int_operand_implies(p_int, g_int)){\r
 481                                                 ppos++;\r
 482                                                 gpos++;\r
 483                                                 continue;\r
 484                                         }else{\r
 485                                                 return false;\r
 486                                         }\r
 487                                 }\r
 488                                 if(p_op=="|"){\r
 489                                         get_int_operand(pstack[ppos+1],pstack[ppos],p_int);\r
 490                                         get_int_operand(gstack[gpos+1],gstack[gpos],g_int);\r
 491                                         if(int_operand_implies(g_int, p_int)){\r
 492                                                 ppos++;\r
 493                                                 gpos++;\r
 494                                                 continue;\r
 495                                         }else{\r
 496                                                 return false;\r
 497                                         }\r
 498                                 }\r
 499                         }\r
 500                 }\r
 501                 if(ppos<pstack.size()-1){\r
 502                         p_op = pstack[ppos+1]->get_op();\r
 503                         if(p_op=="+" || p_op=="-" || p_op=="*" || p_op=="/" || p_op=="&" || p_op=="|"){\r
 504                                 ppos++;\r
 505                                 continue;\r
 506                         }\r
 507                 }\r
 508                 if(gpos<gstack.size()-1){\r
 509                         g_op = gstack[gpos+1]->get_op();\r
 510                         if(g_op=="+" || g_op=="-" || g_op=="*" || g_op=="/" || g_op=="&" || g_op=="|"){\r
 511                                 gpos++;\r
 512                                 continue;\r
 513                         }\r
 514                 }\r
 515 \r
 516                 return false;   // no reduction rule applies\r
 517         }\r
 518 \r
 519         return true;            // reduced both stacks.\r
 520 }\r
 521 \r
 522 \r
 523 bool partn_def_t::is_compatible(gb_table *gb_tbl){\r
 524         vector<string> gb_flds;\r
 525         int i,p,g;\r
 526 \r
 527         for(i=0;i<gb_tbl->size();++i){\r
 528                 string gfld;\r
 529                 if(find_field(gb_tbl->get_def(i),gfld)==1){\r
 530                         gb_flds.push_back(gfld);\r
 531                 }else{\r
 532                         gb_flds.push_back("");\r
 533                 }\r
 534         }\r
 535 \r
 536         for(p=p;p<se_list.size();++p){\r
 537                 for(g=0;g<gb_tbl->size();++g){\r
 538                         if(partition_compatible(se_list[p], gb_tbl->get_def(g)))\r
 539                                 break;\r
 540                 }\r
 541                 if(g==gb_tbl->size()){\r
 542                         return false;\r
 543                 }\r
 544         }\r
 545         return true;\r
 546 }\r