Skip to content
Snippets Groups Projects
  1. Apr 14, 2020
  2. Apr 13, 2020
    • Chris Sosnin's avatar
      session: store output format in struct session · 9c0e40f9
      Chris Sosnin authored
      box.session.storage is a general-purpose table, which can be
      used by user. Therefore, we shouldn't store any internal details
      in it.
      
      Needed for #4686
      9c0e40f9
    • Chris Sosnin's avatar
      box: fix formatting in session.push · 568b16ce
      Chris Sosnin authored
      box.session.push() encodes data as a YAML document independent on
      the current console output format. This patch adds handling for Lua
      as well.
      
      Closes #4686
      568b16ce
    • Chris Sosnin's avatar
      sql: provide a user friendly frontend for accessing session settings · 6706f659
      Chris Sosnin authored
      Currently if a user wants to change session setting with SQL, one has
      to execute UPDATE query like:
      [[UPDATE "_session_settings" SET "value" = true WHERE "name" = 'name']]
      However, direct access to system spaces isn't considered to be a good practice.
      To avoid that and a bit simplify user's life, we introduce SQL shortcut command
      SET SESSION.
      
      Closes #4711
      
      @TarantoolBot document
      Title: API for accessing _session_settings space.
      There are two ways of updating values of session settings:
      via Lua and SQL.
      
      Lua:
      box.session.settings is a table, which is always accessible
      to user. The syntax is the following:
      `box.session.settings.<setting_name> = <new_value>`.
      
      Example of usage:
      ```
      tarantool> box.session.settings.sql_default_engine
      ---
      - memtx
      ...
      
      tarantool> box.session.settings.sql_default_engine = 'vinyl'
      ---
      ...
      
      ```
      
      The table itself represents the (unordered) result of select
      from _session_settings space.
      
      SQL:
      Instead of typing long UPDATE query one can use the SET SESSION command:
      `box.execute([[SET SESSION "<setting_name>" = <new_value>]])`.
      Note, that this query is case sensitive so the name must be quoted.
      Also, SET SESSION doesn't provide any implicit casts, so <new_value> must
      be of the type corresponding to the setting being updated.
      
      Example:
      ```
      tarantool> box.execute([[set session "sql_default_engine" = 'memtx']])
      ---
      - row_count: 1
      ...
      
      tarantool> box.execute([[set session "sql_defer_foreign_keys" = true]])
      ---
      - row_count: 1
      ...
      
      ```
      6706f659
    • Chris Sosnin's avatar
      box: provide a user friendly frontend for accessing session settings · 5ea94c51
      Chris Sosnin authored
      - space_object:update() is hard to use for configuring session settings,
      so we provide box.session.settings table, which can be used in a much more
      native way.
      
      - Prior to this patch sql settings were not accessible before box.cfg()
      call, even though these flags can be set right after session creation.
      
      Part of #4711
      5ea94c51
    • Chris Sosnin's avatar
      box: replace session_settings modules with a single array · a4919528
      Chris Sosnin authored
      Currently we have an array of modules and each module has
      its own array of session_settings. This patch merges these
      into one array, as long as it turned out, that we cannot
      represent every setting as a part of some module.
      
      Part of #4711
      a4919528
    • Serge Petrenko's avatar
      box: introduce indices by UUID · b238def8
      Serge Petrenko authored
      It is now possible to create an index over UUID values, returned by
      `uuid.new()`.
      
      Closes #4268
      Closes #2916
      
      @TarantoolBot document
      Title: Document uuid field type.
      
      There's a new field type -- UUID, it accepts values returned by
      `uuid.new()`.
      
      The index may be either unique or non-unique, nullable or non-nullable,
      and may be a primary key.
      
      The values in an index are ordered lexicographically by their string
      representation.
      
      To create an index over a uuid field for space `test`, say:
      ```
      box.space.test:create_index("pk", {parts={1, 'uuid'}})
      ```
      Now you may insert uuids into the space:
      ```
      tarantool> box.space.test:insert{uuid.new()}
      ---
      - [e631fdcc-0e8a-4d2f-83fd-b0ce6762b13f]
      ...
      
      tarantool> box.space.test:insert{uuid.fromstr('64d22e4d-ac92-4a23-899a-e59f34af5479')}
      ---
      - [64d22e4d-ac92-4a23-899a-e59f34af5479]
      ...
      
      tarantool> box.space.test:select{}
      ---
      - - [64d22e4d-ac92-4a23-899a-e59f34af5479]
        - [e631fdcc-0e8a-4d2f-83fd-b0ce6762b13f]
      ...
      
      ```
      b238def8
    • Serge Petrenko's avatar
      box: add MsgPack encoding/decoding for UUID · d68fc292
      Serge Petrenko authored
      A special format for encoding UUIDs to MsgPack is introduced.
      It is supported by both lua and C encoders/decoders, and it is now
      possible to insert UUIDs into spaces, but only into unindexed fields
      without format for now.
      
      Prerequisite #4268
      
      @TarantoolBot document
      Title: Internals: msgpack format for UUID
      
      UUID values share the MessagePack type with decimals:
      both use MP_EXT. A new subtype is introduced for UUIDs,
      MP_UUID = `0x02`
      UUID is encoded as follows:
      ```
          +--------+---------+-----------+
          | MP_EXT | MP_UUID | UuidValue |
          +--------+---------+-----------+
      ```
      Since UUID is 16 bytes in size, the header, MP_EXT, is always the same:
      `0xd8`. MP_UUID = `0x02` follows. The header is followed by the 16
      bytes of the UuidValue.
      
      UuidValue consists of 11 fields, which are encoded as big endian
      unsigned integers in the following order: `time_low` (4 bytes), `time_mid`
      (2 bytes), `time_hi_and_version` (2 bytes), `clock_seq_hi_and_reserved` (1
      byte), `clock_seq_low` (1 byte), `node[0], ..., node[5]` (1 byte each).
      
      The total size of such a representation is 18 bytes, whereas storing
      uuids as strings requires from 34 (when '-'s are ommitted) to 38 bytes
      per UUID, giving a 2x space usage improvement.
      d68fc292
    • Serge Petrenko's avatar
      uuid: expose tt_uuid_validate method · 9e6eae41
      Serge Petrenko authored
      Expose the code used to check UUID variant to a separate function:
      tt_uuid_validate(). The function will be used for msgpack uuid decoding
      when checking whether the buffer contains a valid uuid value.
      
      Prerequisite #4268
      9e6eae41
    • Serge Petrenko's avatar
      refactoring: extract mpstream into a separate library · fd27a75f
      Serge Petrenko authored
      mpstream is part of core library, which, since the introduction of
      messagepack extension types, leads to circular dependencies between core
      and any other library having extension type encoding/decoding methods
      (e.g. uuid library which will soon be expanded with such methods).
      
      Prerequisite #4268
      fd27a75f
  3. Apr 11, 2020
  4. Apr 10, 2020
    • Alexander Turenko's avatar
      popen: use of exception safe functions for IO · 7c923503
      Alexander Turenko authored
      
      popen read / write functions are written in C and intended to be used
      from C: the contract is to return -1 at failure and set an entry to the
      diagnostics area. However a C++ exception from coio read / write
      functions would pass over a popen function stack frame.
      
      The solution is to use the recently introduced coio exception safe
      functions.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      7c923503
    • Alexander Turenko's avatar
      coio: add *_noxc read / write functions · 85eea4a8
      Alexander Turenko authored
      
      The popen implementation is written in C and uses coio read / write
      functions. If an exception occurs, it'll pass through the C code. It
      should be catched to proceed correctly.
      
      We usually have foo() and foo_xc() (exception) functions when both
      variants are necessary. Here I added non-conventional *_noxc() functions
      as the temporary solution to postpone refactoring of the code and all
      its usages.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      85eea4a8
    • Alexander Turenko's avatar
      coio: fix obsoleted comment in coio_write_timeout · b4360fec
      Alexander Turenko authored
      
      The comment was added in 52765de6, but
      becomes non-actual since 1.6.6-21-gc74abc786 ('Implement special
      TimedOut exception type and use it in coio and latch.')
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      b4360fec
    • Alexander Turenko's avatar
      popen: add missed diag_set() in popen IO functions · 4498d4f2
      Alexander Turenko authored
      
      Our usual convention for C code is to return a negative value at failure
      and set an entry to the diagnostics area.
      
      When code uses this convention consistently, it is much easier to handle
      failures when using it: you always know where to find an error type and
      message and how to pass the error to a C or Lua caller.
      
      See also the previous commit ('popen: add missed diag_set in
      popen_signal/delete').
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      4498d4f2
    • Alexander Turenko's avatar
      popen: remove redundant fd check before perform IO · 1ef95b99
      Alexander Turenko authored
      
      The function already checks flags to find out whether the file
      descriptor should be available for reading / writing. When it is so, the
      corresponding fd is great or equal to zero.
      
      The further commits will add missed diagnostics for IO functions and it
      is hard to write a meaningful error message for a situation that is not
      possible. Moreover, we would obligated to document the error as one of
      possible failures in a function contract (while it can't occur).
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      1ef95b99
    • Alexander Turenko's avatar
      popen: unblock popen_read_timeout at a first byte · 631f5f37
      Alexander Turenko authored
      
      Before this change popen_read_timeout() waits until a passed buffer will
      be fully filled (or until EOF / timeout / IO error occurs). Now it waits
      for any amount of data (but at least one byte).
      
      It allows to communicate with an interactive child program: write, read,
      repeat.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      631f5f37
    • Alexander Turenko's avatar
      popen: add const qualifier to popen_write_timeout · 04b0432d
      Alexander Turenko authored
      
      The buffer is for reading, we're not intend to change it.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      04b0432d
    • Alexander Turenko's avatar
      popen: decouple logger fd from stderr · 07a07b3c
      Alexander Turenko authored
      
      The default logger configuration writes logs to stderr.
      
      Popen implementation holds a logger fd until execve() to be able to
      write debug entries or information about a failure from a child. However
      when popen flags requires to close stderr in the child, the logger fd
      becomes closed: logging will fail.
      
      Another problem appears when a user want to capture stderr and
      tarantool's log level is set to debug (7). Since the logger uses stderr
      and it is fed to the parent using a pipe, the logger output will not
      shown on the 'real' stderr, but will be captured together with child's
      program debugging output.
      
      This commit duplicates a logger file descriptor that allows to close or
      redirect child's stderr without described side effects.
      
      See also 86ec3a5c ('popen: add logging
      in child process').
      
      Areas for improvements:
      
      * Copy logger fd at module initialization time instead of copying of
        each popen call.
      
      Alternatives:
      
      * Extend logger to allow to accumulate log entries in a buffer. Flush
        the buffer from the parent process. (It is possible since vfork does
        not split a virtual memory space).
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      07a07b3c
    • Alexander Turenko's avatar
      say: allow to set a logger file descriptor · 67c6a6e6
      Alexander Turenko authored
      
      It is necessary to decouple stderr from a logger file descriptor in the
      popen implementation.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      67c6a6e6
    • Alexander Turenko's avatar
      popen: add logging of fds closed in a child · 16c83356
      Alexander Turenko authored
      
      It is useful for debugging popen behaviour around file descriptors.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      16c83356
    • Alexander Turenko's avatar
      popen: add missed diag_set in popen_signal/delete · 96a25ee0
      Alexander Turenko authored
      
      Lua API will use content of the diagnostics area to report an error to a
      caller, so it is critical to always have proper diagnostics at failure.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      96a25ee0
    • Alexander Turenko's avatar
      popen: remove retval from popen_state() · e1579978
      Alexander Turenko authored
      
      After the previous commit ('popen: require popen handle to be non-NULL')
      it turns out that popen_state() function always succeeds. There is no
      reason to return a success / failure value from it.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      e1579978
    • Alexander Turenko's avatar
      popen: require popen handle to be non-NULL · 922cef65
      Alexander Turenko authored
      
      Further commits will add proper entries into the diagnostics area for
      failures inside popen functions. We should either report handle == NULL
      case via the diagnostics area or ensure that the NULL handle case is not
      possible.
      
      The latter approach is implemented in this commit. There are two
      reasons for this:
      
      * This way simplifies function contracts (one less kind of failure).
      * The popen Lua module (that will be implemented in the further commits)
        will not construct any logic using NULL as a handle. When 'NULL
        handle' error is not possible in the C API, it will be easier to
        verify that this failure is not possible the Lua API.
      
      A user of the C API should take care to don't call those functions with
      NULL handle.
      
      Part of #4031
      
      Acked-by: default avatarCyrill Gorcunov <gorcunov@gmail.com>
      922cef65
  5. Apr 08, 2020
  6. Apr 07, 2020
    • Nikita Pettik's avatar
      sql: reset values to be bound after execution · df03a7e8
      Nikita Pettik authored
      Before this patch prepared statements didn't reset bound values after
      its execution. As a result, if during next execution cycle not all
      parameters were provided, cached values would appear. For instance:
      
      prep = box.prepare('select :a, :b, :c')
      prep:execute({{[':a'] = 1}, {[':b'] = 2}, {[':c'] = 3}}
      -- [1, 2, 3]
      prep:execute({{[':a'] = 1}, {[':b'] = 2}})
      -- [1, 2, 3]
      
      However, expected result for the last query should be [1, 2, NULL].
      Let's fix it and always reset all binding values before next execution.
      
      Closes #4825
      df03a7e8
    • Nikita Pettik's avatar
      iproto: support error stacked diagnostic area · 4c465312
      Nikita Pettik authored
      This patch introduces support of stacked errors in IProto protocol and
      in net.box module.
      
      Closes #1148
      
      @TarantoolBot document
      Title: Stacked error diagnostic area
      
      Starting from now errors can be organized into lists. To achieve this
      Lua table representing error object is extended with .prev field and
      e:set_prev(err) method. .prev field returns previous error if any exist.
      e:set_prev(err) method expects err to be error object or nil and sets
      err as previous error of e. For instance:
      ```
      e1 = box.error.new({code = 111, reason = "cause"})
      e2 = box.error.new({code = 111, reason = "cause of cause"})
      
      e1:set_prev(e2)
      assert(e1.prev == e2) -- true
      ```
      Cycles are not allowed for error lists:
      ```
      e2:set_prev(e1)
      - error: 'builtin/error.lua: Cycles are not allowed'
      ```
      Nil is valid input to :set_prev() method:
      ```
      e1:set_prev(nil)
      assert(e1.prev == nil) -- true
      ```
      Note that error can be 'previous' only to the one error at once:
      ```
      e1:set_prev(e2)
      e3:set_prev(e2)
      assert(e1.prev == nil) -- true
      assert(e3.prev == e2) -- true
      ```
      Setting previous error does not erase its own previous members:
      ```
      -- e1 -> e2 -> e3 -> e4
      e1:set_prev(e2)
      e2:set_prev(e3)
      e3:set_prev(e4)
      e2:set_prev(e5)
      -- Now there are two lists: e1->e2->e5 and e3->e4
      assert(e1.prev == e2) -- true
      assert(e2.prev == e5) -- true
      assert(e3.prev == e4) -- true
      ```
      Alternatively:
      ```
      e1:set_prev(e2)
      e2:set_prev(e3)
      e3:set_prev(e4)
      e5:set_prev(e3)
      -- Now there are two lists: e1->e2 and e5->e3->e4
      assert(e1.prev == e2) -- true
      assert(e2.prev == nil) -- true
      assert(e5.prev == e3) -- true
      assert(e3.prev == e4) -- true
      ``
      Stacked diagnostics is also supported by IProto protocol. Now responses
      containing errors always (even if there's only one error to be returned)
      include new IProto key: IPROTO_ERROR_STACK (0x51). So, body corresponding to
      error response now looks like:
      ```
      MAP{IPROTO_ERROR : string, IPROTO_ERROR_STACK : ARRAY[MAP{ERROR_CODE : uint, ERROR_MESSAGE : string}, MAP{...}, ...]}
      ```
      where IPROTO_ERROR is 0x31 key, IPROTO_ERROR_STACK is 0x52, ERROR_CODE
      is 0x01 and ERROR_MESSAGE is 0x02.
      Instances of older versions (without support of stacked errors in
      protocol) simply ignore unknown keys and still rely only on IPROTO_ERROR
      key.
      4c465312
    • Nikita Pettik's avatar
      box: always promote error created via box.error() to diag · 4bcaf15e
      Nikita Pettik authored
      This patch makes box.error() always promote error to the diagnostic
      area despite of passed arguments.
      
      Closes #4829
      
      @TarantoolBot document
      Title: always promote error created via box.error() to diag
      
      box.error() is able to accept two types of argument: either pair of code
      and reason (box.error{code = 555, reason = 'Arbitrary message'}) or error
      object (box.error(err)). In the first case error is promoted to
      diagnostic area, meanwhile in the latter - it is not:
      ```
      e1 = box.error.new({code = 111, reason = "cause"})
      box.error({code = 111, reason = "err"})
      - error: err
      box.error.last()
      - err
      box.error(e1)
      - error: cause
      box.error.last()
      - err
      ```
      From now box.error(e1) sets error to diagnostic area as well:
      ```
      box.error(e1)
      - error: cause
      box.error.last()
      - cause
      ```
      4bcaf15e
    • Kirill Shcherbatov's avatar
      iproto: refactor error encoding with mpstream · ba7304fb
      Kirill Shcherbatov authored
      Refactor iproto_reply_error and iproto_write_error with a new
      mpstream-based helper mpstream_iproto_encode_error that encodes
      error object for iproto protocol on a given stream object.
      Previously each routine implemented an own error encoding, but
      with the increasing complexity of encode operation with following
      patches we need a uniform way to do it.
      
      The iproto_write_error routine starts using region location
      to use region-based mpstream. It is not a problem itself, because
      errors reporting is not really performance-critical path.
      
      Needed for #1148
      ba7304fb
    • Nikita Pettik's avatar
    • Nikita Pettik's avatar
      box: use stacked diagnostic area for functional indexes · c15cef54
      Nikita Pettik authored
      Since we've introduced stacked diagnostic in previous commit, let's use
      it in the code implementing functional indexes.
      
      Part of #1148
      c15cef54
    • Nikita Pettik's avatar
      box: introduce stacked diagnostic area · 3b887d04
      Nikita Pettik authored
      In terms of implementation, now struct error objects can be organized
      into double-linked lists. To achieve this pointers to the next and
      previous elements (cause and effect correspondingly) have been added to
      struct error. It is worth mentioning that already existing rlist and
      stailq list implementations are not suitable: rlist is cycled list, as a
      result it is impossible to start iteration over the list from random
      list entry and finish it at the logical end of the list; stailq is
      single-linked list leaving no possibility to remove elements from the
      middle of the list.
      
      As a part of C interface, box_error_add() has been introduced. In
      contrast to box_error_set() it does not replace last raised error, but
      instead it adds error to the list of diagnostic errors having already
      been set. If error is to be deleted (its reference counter hits 0 value)
      it is unlinked from the list it belongs to and destroyed. Meanwhile,
      error destruction leads to decrement of reference counter of its
      previous error and so on.
      
      To organize errors into lists in Lua, table representing error object in
      Lua now has .prev field (corresponding to 'previous' error) and method
      :set_prev(e). The latter accepts error object (i.e. created via
      box.error.new() or box.error.last()) and nil value. Both field .prev and
      :set_prev() method are implemented as ffi functions. Also note that
      cycles are not allowed while organizing errors into lists:
      e1 -> e2 -> e3; e3:set_prev(e1) -- would lead to error.
      
      Part of #1148
      3b887d04
Loading