git.m6w6.name Git - awesomized/libmemcached/blob - libmemcached/csl/parser.yy

   1 /*  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
   2  *
   3  *  Libmemcached library
   4  *
   5  *  Copyright (C) 2012 Data Differential, http://datadifferential.com/
   6  *
   7  *  Redistribution and use in source and binary forms, with or without
   8  *  modification, are permitted provided that the following conditions are
   9  *  met:
  10  *
  11  *      * Redistributions of source code must retain the above copyright
  12  *  notice, this list of conditions and the following disclaimer.
  13  *
  14  *      * Redistributions in binary form must reproduce the above
  15  *  copyright notice, this list of conditions and the following disclaimer
  16  *  in the documentation and/or other materials provided with the
  17  *  distribution.
  18  *
  19  *      * The names of its contributors may not be used to endorse or
  20  *  promote products derived from this software without specific prior
  21  *  written permission.
  22  *
  23  *  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  24  *  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  25  *  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  26  *  A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  27  *  OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  28  *  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  29  *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  30  *  DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  31  *  THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  32  *  (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  33  *  OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  34  *
  35  */
  36
  37 %error-verbose
  38 %debug
  39 %defines
  40 %expect 0
  41 %output "libmemcached/csl/parser.cc"
  42 %defines "libmemcached/csl/parser.h"
  43 %lex-param { yyscan_t *scanner }
  44 %name-prefix="config_"
  45 %parse-param { Context *context }
  46 %parse-param { yyscan_t *scanner }
  47 %pure-parser
  48 %require "2.4"
  49 %start begin
  50 %verbose
  51
  52 %{
  53
  54 #include <libmemcached/csl/common.h>
  55 #include <libmemcached/options.hpp>
  56
  57 #include <libmemcached/csl/context.h>
  58 #include <libmemcached/csl/symbol.h>
  59 #include <libmemcached/csl/scanner.h>
  60
  61 #ifndef __INTEL_COMPILER
  62 #pragma GCC diagnostic ignored "-Wold-style-cast"
  63 #endif
  64
  65 int conf_lex(YYSTYPE* lvalp, void* scanner);
  66
  67 #define select_yychar(__context) yychar == UNKNOWN ? ( (__context)->previous_token == END ? UNKNOWN : (__context)->previous_token ) : yychar
  68
  69 #define stryytname(__yytokentype) ((__yytokentype) <  YYNTOKENS ) ? yytname[(__yytokentype)] : ""
  70
  71 #define parser_abort(__context, __error_message) do { (__context)->abort((__error_message), yytokentype(select_yychar(__context)), stryytname(YYTRANSLATE(select_yychar(__context)))); YYABORT; } while (0)
  72
  73 // This is bison calling error.
  74 inline void __config_error(Context *context, yyscan_t *scanner, const char *error, int last_token, const char *last_token_str)
  75 {
  76   if (not context->end())
  77   {
  78     context->error(error, yytokentype(last_token), last_token_str);
  79   }
  80   else
  81   {
  82     context->error(error, yytokentype(last_token), last_token_str);
  83   }
  84 }
  85
  86 #define config_error(__context, __scanner, __error_msg) do { __config_error((__context), (__scanner), (__error_msg), select_yychar(__context), stryytname(YYTRANSLATE(select_yychar(__context)))); } while (0)
  87
  88
  89 %}
  90
  91 %token COMMENT
  92 %token END
  93 %token ERROR
  94 %token RESET
  95 %token PARSER_DEBUG
  96 %token INCLUDE
  97 %token CONFIGURE_FILE
  98 %token EMPTY_LINE
  99 %token SERVER
 100 %token SOCKET
 101 %token SERVERS
 102 %token SERVERS_OPTION
 103 %token UNKNOWN_OPTION
 104 %token UNKNOWN
 105
 106 /* All behavior options */
 107 %token BINARY_PROTOCOL
 108 %token BUFFER_REQUESTS
 109 %token CONNECT_TIMEOUT
 110 %token DISTRIBUTION
 111 %token HASH
 112 %token HASH_WITH_NAMESPACE
 113 %token IO_BYTES_WATERMARK
 114 %token IO_KEY_PREFETCH
 115 %token IO_MSG_WATERMARK
 116 %token KETAMA_HASH
 117 %token KETAMA_WEIGHTED
 118 %token NOREPLY
 119 %token NUMBER_OF_REPLICAS
 120 %token POLL_TIMEOUT
 121 %token RANDOMIZE_REPLICA_READ
 122 %token RCV_TIMEOUT
 123 %token REMOVE_FAILED_SERVERS
 124 %token RETRY_TIMEOUT
 125 %token SND_TIMEOUT
 126 %token SOCKET_RECV_SIZE
 127 %token SOCKET_SEND_SIZE
 128 %token SORT_HOSTS
 129 %token SUPPORT_CAS
 130 %token USER_DATA
 131 %token USE_UDP
 132 %token VERIFY_KEY
 133 %token _TCP_KEEPALIVE
 134 %token _TCP_KEEPIDLE
 135 %token _TCP_NODELAY
 136 %token FETCH_VERSION
 137
 138 /* Callbacks */
 139 %token NAMESPACE
 140
 141 /* Pool */
 142 %token POOL_MIN
 143 %token POOL_MAX
 144
 145 /* Hash types */
 146 %token MD5
 147 %token CRC
 148 %token FNV1_64
 149 %token FNV1A_64
 150 %token FNV1_32
 151 %token FNV1A_32
 152 %token HSIEH
 153 %token MURMUR
 154 %token JENKINS
 155
 156 /* Distributions */
 157 %token CONSISTENT
 158 %token MODULA
 159 %token RANDOM
 160
 161 /* Boolean values */
 162 %token <boolean> TRUE
 163 %token <boolean> FALSE
 164
 165 %nonassoc ','
 166 %nonassoc '='
 167
 168 %token <number> FLOAT
 169 %token <number> NUMBER
 170 %token <number> PORT
 171 %token <number> WEIGHT_START
 172 %token <server> IPADDRESS
 173 %token <server> HOSTNAME
 174 %token <string> STRING
 175 %token <string> QUOTED_STRING
 176 %token <string> FILE_PATH
 177
 178 %type <behavior> behavior_boolean
 179 %type <behavior> behavior_number
 180 %type <distribution> distribution
 181 %type <hash> hash
 182 %type <number> optional_port
 183 %type <number> optional_weight
 184 %type <string> string
 185
 186 %%
 187
 188 begin:
 189           statement
 190         | begin ' ' statement
 191         ;
 192
 193 statement:
 194          expression
 195           { }
 196         | COMMENT
 197           { }
 198         | EMPTY_LINE
 199           { }
 200         | END
 201           {
 202             context->set_end();
 203             YYACCEPT;
 204           }
 205         | ERROR
 206           {
 207             context->rc= MEMCACHED_PARSE_USER_ERROR;
 208             parser_abort(context, "ERROR called directly");
 209           }
 210         | RESET
 211           {
 212             memcached_reset(context->memc);
 213           }
 214         | PARSER_DEBUG
 215           {
 216             yydebug= 1;
 217           }
 218         | INCLUDE ' ' string
 219           {
 220             if ((context->rc= memcached_parse_configure_file(*context->memc, $3.c_str, $3.size)) != MEMCACHED_SUCCESS)
 221             {
 222               parser_abort(context, "Failed to parse configuration file");
 223             }
 224           }
 225         ;
 226
 227
 228 expression:
 229           SERVER HOSTNAME optional_port optional_weight
 230           {
 231             if (memcached_failed(context->rc= memcached_server_add_with_weight(context->memc, $2.c_str, $3, $4)))
 232             {
 233               char buffer[1024];
 234               snprintf(buffer, sizeof(buffer), "Failed to add server: %s:%u", $2.c_str, uint32_t($3));
 235               parser_abort(context, buffer);
 236             }
 237             context->unset_server();
 238           }
 239         | SERVER IPADDRESS optional_port optional_weight
 240           {
 241             if (memcached_failed(context->rc= memcached_server_add_with_weight(context->memc, $2.c_str, $3, $4)))
 242             {
 243               char buffer[1024];
 244               snprintf(buffer, sizeof(buffer), "Failed to add server: %s:%u", $2.c_str, uint32_t($3));
 245               parser_abort(context, buffer);
 246             }
 247             context->unset_server();
 248           }
 249         | SOCKET string optional_weight
 250           {
 251             if (memcached_failed(context->rc= memcached_server_add_unix_socket_with_weight(context->memc, $2.c_str, $3)))
 252             {
 253               char buffer[1024];
 254               snprintf(buffer, sizeof(buffer), "Failed to add socket: %s", $2.c_str);
 255               parser_abort(context, buffer);
 256             }
 257           }
 258         | CONFIGURE_FILE string
 259           {
 260             memcached_set_configuration_file(context->memc, $2.c_str, $2.size);
 261           }
 262         | POOL_MIN NUMBER
 263           {
 264             context->memc->configure.initial_pool_size= $2;
 265           }
 266         | POOL_MAX NUMBER
 267           {
 268             context->memc->configure.max_pool_size= $2;
 269           }
 270         | behaviors
 271         ;
 272
 273 behaviors:
 274           NAMESPACE string
 275           {
 276             if (memcached_callback_get(context->memc, MEMCACHED_CALLBACK_PREFIX_KEY, NULL))
 277             {
 278               parser_abort(context, "--NAMESPACE can only be called once");
 279             }
 280
 281             if ((context->rc= memcached_set_namespace(context->memc, $2.c_str, $2.size)) != MEMCACHED_SUCCESS)
 282             {
 283               parser_abort(context, memcached_last_error_message(context->memc));
 284             }
 285           }
 286         | FETCH_VERSION
 287           {
 288             memcached_flag(*context->memc, MEMCACHED_FLAG_IS_FETCHING_VERSION, true);
 289           }
 290         | DISTRIBUTION distribution
 291           {
 292             // Check to see if DISTRIBUTION has already been set
 293             if ((context->rc= memcached_behavior_set(context->memc, MEMCACHED_BEHAVIOR_DISTRIBUTION, $2)) != MEMCACHED_SUCCESS)
 294             {
 295               parser_abort(context, "--DISTRIBUTION can only be called once");
 296             }
 297
 298             if ((context->rc= memcached_behavior_set(context->memc, MEMCACHED_BEHAVIOR_DISTRIBUTION, $2)) != MEMCACHED_SUCCESS)
 299             {
 300               parser_abort(context, memcached_last_error_message(context->memc));;
 301             }
 302           }
 303         | DISTRIBUTION distribution ',' hash
 304           {
 305             // Check to see if DISTRIBUTION has already been set
 306             if ((context->rc= memcached_behavior_set(context->memc, MEMCACHED_BEHAVIOR_DISTRIBUTION, $2)) != MEMCACHED_SUCCESS)
 307             {
 308               parser_abort(context, "--DISTRIBUTION can only be called once");
 309             }
 310
 311             if ((context->rc= memcached_behavior_set_distribution_hash(context->memc, $4)) != MEMCACHED_SUCCESS)
 312             {
 313               parser_abort(context, "Unable to set the hash for the DISTRIBUTION requested");
 314             }
 315           }
 316         | HASH hash
 317           {
 318             if (context->set_hash($2) == false)
 319             {
 320               parser_abort(context, "--HASH can only be set once");
 321             }
 322           }
 323         | behavior_number NUMBER
 324           {
 325             if ((context->rc= memcached_behavior_set(context->memc, $1, $2)) != MEMCACHED_SUCCESS)
 326             {
 327               parser_abort(context, "Unable to set behavior");
 328             }
 329           }
 330         | behavior_boolean
 331           {
 332             if ((context->rc= memcached_behavior_set(context->memc, $1, true)) != MEMCACHED_SUCCESS)
 333             {
 334               char buffer[1024];
 335               snprintf(buffer, sizeof(buffer), "Could not set: %s", libmemcached_string_behavior($1));
 336               parser_abort(context, buffer);
 337             }
 338           }
 339         |  USER_DATA
 340           {
 341           }
 342         ;
 343
 344 behavior_number:
 345           REMOVE_FAILED_SERVERS
 346           {
 347             $$= MEMCACHED_BEHAVIOR_REMOVE_FAILED_SERVERS;
 348           }
 349         | CONNECT_TIMEOUT
 350           {
 351             $$= MEMCACHED_BEHAVIOR_CONNECT_TIMEOUT;
 352           }
 353         | IO_MSG_WATERMARK
 354           {
 355             $$= MEMCACHED_BEHAVIOR_IO_MSG_WATERMARK;
 356           }
 357         | IO_BYTES_WATERMARK
 358           {
 359             $$= MEMCACHED_BEHAVIOR_IO_BYTES_WATERMARK;
 360           }
 361         | IO_KEY_PREFETCH
 362           {
 363             $$= MEMCACHED_BEHAVIOR_IO_KEY_PREFETCH;
 364           }
 365         | NUMBER_OF_REPLICAS
 366           {
 367             $$= MEMCACHED_BEHAVIOR_NUMBER_OF_REPLICAS;
 368           }
 369         | POLL_TIMEOUT
 370           {
 371             $$= MEMCACHED_BEHAVIOR_POLL_TIMEOUT;
 372           }
 373         |  RCV_TIMEOUT
 374           {
 375             $$= MEMCACHED_BEHAVIOR_RCV_TIMEOUT;
 376           }
 377         |  RETRY_TIMEOUT
 378           {
 379             $$= MEMCACHED_BEHAVIOR_RETRY_TIMEOUT;
 380           }
 381         |  SND_TIMEOUT
 382           {
 383             $$= MEMCACHED_BEHAVIOR_SND_TIMEOUT;
 384           }
 385         |  SOCKET_RECV_SIZE
 386           {
 387             $$= MEMCACHED_BEHAVIOR_SOCKET_RECV_SIZE;
 388           }
 389         |  SOCKET_SEND_SIZE
 390           {
 391             $$= MEMCACHED_BEHAVIOR_SOCKET_SEND_SIZE;
 392           }
 393         ;
 394
 395 behavior_boolean:
 396           BINARY_PROTOCOL
 397           {
 398             $$= MEMCACHED_BEHAVIOR_BINARY_PROTOCOL;
 399           }
 400         | BUFFER_REQUESTS
 401           {
 402             $$= MEMCACHED_BEHAVIOR_BUFFER_REQUESTS;
 403           }
 404         | HASH_WITH_NAMESPACE
 405           {
 406             $$= MEMCACHED_BEHAVIOR_HASH_WITH_PREFIX_KEY;
 407           }
 408         | NOREPLY
 409           {
 410             $$= MEMCACHED_BEHAVIOR_NOREPLY;
 411           }
 412         |  RANDOMIZE_REPLICA_READ
 413           {
 414             $$= MEMCACHED_BEHAVIOR_RANDOMIZE_REPLICA_READ;
 415           }
 416         |  SORT_HOSTS
 417           {
 418             $$= MEMCACHED_BEHAVIOR_SORT_HOSTS;
 419           }
 420         |  SUPPORT_CAS
 421           {
 422             $$= MEMCACHED_BEHAVIOR_SUPPORT_CAS;
 423           }
 424         |  _TCP_NODELAY
 425           {
 426             $$= MEMCACHED_BEHAVIOR_TCP_NODELAY;
 427           }
 428         |  _TCP_KEEPALIVE
 429           {
 430             $$= MEMCACHED_BEHAVIOR_TCP_KEEPALIVE;
 431           }
 432         |  _TCP_KEEPIDLE
 433           {
 434             $$= MEMCACHED_BEHAVIOR_TCP_KEEPIDLE;
 435           }
 436         |  USE_UDP
 437           {
 438             $$= MEMCACHED_BEHAVIOR_USE_UDP;
 439           }
 440         |  VERIFY_KEY
 441           {
 442             $$= MEMCACHED_BEHAVIOR_VERIFY_KEY;
 443           }
 444
 445
 446 optional_port:
 447           { $$= MEMCACHED_DEFAULT_PORT;}
 448         | PORT
 449           { };
 450         ;
 451
 452 optional_weight:
 453           { $$= 1; }
 454         | WEIGHT_START
 455           { }
 456         ;
 457
 458 hash:
 459           MD5
 460           {
 461             $$= MEMCACHED_HASH_MD5;
 462           }
 463         | CRC
 464           {
 465             $$= MEMCACHED_HASH_CRC;
 466           }
 467         | FNV1_64
 468           {
 469             $$= MEMCACHED_HASH_FNV1_64;
 470           }
 471         | FNV1A_64
 472           {
 473             $$= MEMCACHED_HASH_FNV1A_64;
 474           }
 475         | FNV1_32
 476           {
 477             $$= MEMCACHED_HASH_FNV1_32;
 478           }
 479         | FNV1A_32
 480           {
 481             $$= MEMCACHED_HASH_FNV1A_32;
 482           }
 483         | HSIEH
 484           {
 485             $$= MEMCACHED_HASH_HSIEH;
 486           }
 487         | MURMUR
 488           {
 489             $$= MEMCACHED_HASH_MURMUR;
 490           }
 491         | JENKINS
 492           {
 493             $$= MEMCACHED_HASH_JENKINS;
 494           }
 495         ;
 496
 497 string:
 498           STRING
 499           {
 500             $$= $1;
 501           }
 502         | QUOTED_STRING
 503           {
 504             $$= $1;
 505           }
 506         ;
 507
 508 distribution:
 509           CONSISTENT
 510           {
 511             $$= MEMCACHED_DISTRIBUTION_CONSISTENT;
 512           }
 513         | MODULA
 514           {
 515             $$= MEMCACHED_DISTRIBUTION_MODULA;
 516           }
 517         | RANDOM
 518           {
 519             $$= MEMCACHED_DISTRIBUTION_RANDOM;
 520           }
 521         ;
 522
 523 %%
 524
 525 void Context::start()
 526 {
 527   config_parse(this, (void **)scanner);
 528 }
 529