Na}{

Path: ~//usr/include/mysql/server/private/

File Content: `sql_lifo_buffer.h`

/*
   Copyright (c) 2010, 2011, Monty Program Ab

   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.

   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 */

/**
  @defgroup Bi-directional LIFO buffers used by DS-MRR implementation
  @{
*/

class Forward_lifo_buffer;
class Backward_lifo_buffer;


/*
  A base class for in-memory buffer used by DS-MRR implementation. Common
  properties:
  - The buffer is last-in-first-out, i.e. elements that are written last are
    read first.
  - The buffer contains fixed-size elements. The elements are either atomic
    byte sequences or pairs of them.
  - The buffer resides in the memory provided by the user. It is possible to
     = dynamically (ie. between write operations) add ajacent memory space to
       the buffer
     = dynamically remove unused space from the buffer.
    The intent of this is to allow to have two buffers on adjacent memory
    space, one is being read from (and so its space shrinks), while the other 
    is being written to (and so it needs more and more space).

  There are two concrete classes, Forward_lifo_buffer and Backward_lifo_buffer.
*/

class Lifo_buffer 
{
protected:
  size_t size1;
  size_t size2;

public:
  /**
    write() will put into buffer size1 bytes pointed by write_ptr1. If
    size2!=0, then they will be accompanied by size2 bytes pointed by
    write_ptr2.
  */
  uchar *write_ptr1;
  uchar *write_ptr2;

  /**
    read() will do reading by storing pointers to read data into read_ptr1 or
    into (read_ptr1, read_ptr2), depending on whether the buffer was set to
    store single objects or pairs.
  */
  uchar *read_ptr1;
  uchar *read_ptr2;

protected:
  uchar *start; /**< points to start of buffer space */
  uchar *end;   /**< points to just beyond the end of buffer space */
public:

  enum enum_direction {
    BACKWARD=-1, /**< buffer is filled/read from bigger to smaller memory addresses */
    FORWARD=1  /**< buffer is filled/read from smaller to bigger memory addresses */
  };

  virtual enum_direction type() = 0;

  /* Buffer space control functions */

  /** Let the buffer store data in the given space. */
  void set_buffer_space(uchar *start_arg, uchar *end_arg) 
  {
    start= start_arg;
    end= end_arg;
    if (end != start)
      TRASH_ALLOC(start, end - start);
    reset();
  }
  
  /** 
    Specify where write() should get the source data from, as well as source
    data size.
  */
  void setup_writing(size_t len1, size_t len2)
  {
    size1= len1;
    size2= len2;
  }

  /** 
    Specify where read() should store pointers to read data, as well as read
    data size. The sizes must match those passed to setup_writing().
  */
  void setup_reading(size_t len1, size_t len2)
  {
    DBUG_ASSERT(len1 == size1);
    DBUG_ASSERT(len2 == size2);
  }
  
  bool can_write()
  {
    return have_space_for(size1 + size2);
  }
  virtual void write() = 0;

  bool is_empty() { return used_size() == 0; }
  virtual bool read() = 0;
  
  void sort(qsort2_cmp cmp_func, void *cmp_func_arg)
  {
    size_t elem_size= size1 + size2;
    size_t n_elements= used_size() / elem_size;
    my_qsort2(used_area(), n_elements, elem_size, cmp_func, cmp_func_arg);
  }

  virtual void reset() = 0;
  virtual uchar *end_of_space() = 0;
protected:
  virtual size_t used_size() = 0;
  
  /* To be used only by iterator class: */
  virtual uchar *get_pos()= 0;
  virtual bool read(uchar **position, uchar **ptr1, uchar **ptr2)= 0;
  friend class Lifo_buffer_iterator;
public:
  virtual bool have_space_for(size_t bytes) = 0;

  virtual void remove_unused_space(uchar **unused_start, uchar **unused_end)=0;
  virtual uchar *used_area() = 0; 
  virtual ~Lifo_buffer() {};
};


/**
  Forward LIFO buffer

  The buffer that is being written to from start to end and read in the
  reverse.  'pos' points to just beyond the end of used space.

  It is possible to grow/shink the buffer at the end bound

     used space      unused space  
   *==============*-----------------*
   ^              ^                 ^
   |              |                 +--- end
   |              +---- pos              
   +--- start           
*/

class Forward_lifo_buffer: public Lifo_buffer
{
  uchar *pos;
public:
  enum_direction type() { return FORWARD; }
  size_t used_size()
  {
    return (size_t)(pos - start);
  }
  void reset()
  {
    pos= start;
  }
  uchar *end_of_space() { return pos; }
  bool have_space_for(size_t bytes)
  {
    return (pos + bytes < end);
  }

  void write()
  {
    write_bytes(write_ptr1, size1);
    if (size2)
      write_bytes(write_ptr2, size2);
  }
  void write_bytes(const uchar *data, size_t bytes)
  {
    DBUG_ASSERT(have_space_for(bytes));
    memcpy(pos, data, bytes);
    pos += bytes;
  }
  bool have_data(uchar *position, size_t bytes)
  {
    return ((position - start) >= (ptrdiff_t)bytes);
  }
  uchar *read_bytes(uchar **position, size_t bytes)
  {
    DBUG_ASSERT(have_data(*position, bytes));
    *position= (*position) - bytes;
    return *position;
  }
  bool read() { return read(&pos, &read_ptr1, &read_ptr2); }
  bool read(uchar **position, uchar **ptr1, uchar **ptr2)
  {
    if (!have_data(*position, size1 + size2))
      return TRUE;
    if (size2)
      *ptr2= read_bytes(position, size2);
    *ptr1= read_bytes(position, size1);
    return FALSE;
  }
  void remove_unused_space(uchar **unused_start, uchar **unused_end)
  {
    DBUG_ASSERT(0); /* Don't need this yet */
  }
  /**
    Add more space to the buffer. The caller is responsible that the space
    being added is adjacent to the end of the buffer.

    @param unused_start Start of space
    @param unused_end   End of space
  */
  void grow(uchar *unused_start, uchar *unused_end)
  {
    DBUG_ASSERT(unused_end >= unused_start);
    DBUG_ASSERT(end == unused_start);
    TRASH_ALLOC(unused_start, unused_end - unused_start);
    end= unused_end;
  }
  /* Return pointer to start of the memory area that is occupied by the data */
  uchar *used_area() { return start; }
  friend class Lifo_buffer_iterator;
  uchar *get_pos() { return pos; }
};



/**
  Backward LIFO buffer

  The buffer that is being written to from start to end and read in the
  reverse.  'pos' points to the start of used space.

  It is possible to grow/shink the buffer at the start.

     unused space      used space  
   *--------------*=================*
   ^              ^                 ^
   |              |                 +--- end
   |              +---- pos              
   +--- start           
*/
class Backward_lifo_buffer: public Lifo_buffer
{
  uchar *pos;
public:
  enum_direction type() { return BACKWARD; }
 
  size_t used_size()
  {
    return (size_t)(end - pos);
  }
  void reset()
  {
    pos= end;
  }
  uchar *end_of_space() { return end; }
  bool have_space_for(size_t bytes)
  {
    return (pos - bytes >= start);
  }
  void write()
  {
    if (write_ptr2)
      write_bytes(write_ptr2, size2);
    write_bytes(write_ptr1, size1);
  }
  void write_bytes(const uchar *data, size_t bytes)
  {
    DBUG_ASSERT(have_space_for(bytes));
    pos -= bytes;
    memcpy(pos, data, bytes);
  }
  bool read()
  {
    return read(&pos, &read_ptr1, &read_ptr2);
  }
  bool read(uchar **position, uchar **ptr1, uchar **ptr2)
  {
    if (!have_data(*position, size1 + size2))
      return TRUE;
    *ptr1= read_bytes(position, size1);
    if (size2)
      *ptr2= read_bytes(position, size2);
    return FALSE;
  }
  bool have_data(uchar *position, size_t bytes)
  {
    return ((end - position) >= (ptrdiff_t)bytes);
  }
  uchar *read_bytes(uchar **position, size_t bytes)
  {
    DBUG_ASSERT(have_data(*position, bytes));
    uchar *ret= *position;
    *position= *position + bytes;
    return ret;
  }
  /**
    Stop using/return the unused part of the space
    @param unused_start  OUT Start of the unused space
    @param unused_end    OUT End of the unused space
  */
  void remove_unused_space(uchar **unused_start, uchar **unused_end)
  {
    *unused_start= start;
    *unused_end= pos;
    start= pos;
  }
  void grow(uchar *unused_start, uchar *unused_end)
  {
    DBUG_ASSERT(0); /* Not used for backward buffers */
  }
  /* Return pointer to start of the memory area that is occupied by the data */
  uchar *used_area() { return pos; }
  friend class Lifo_buffer_iterator;
  uchar *get_pos() { return pos; }
};


/** Iterator to walk over contents of the buffer without reading from it */
class Lifo_buffer_iterator
{
  uchar *pos;
  Lifo_buffer *buf;
  
public:
  /* The data is read to here */
  uchar *read_ptr1;
  uchar *read_ptr2;

  void init(Lifo_buffer *buf_arg)
  {
    buf= buf_arg;
    pos= buf->get_pos();
  }
  /*
    Read the next value. The calling convention is the same as buf->read()
    has.

    @retval FALSE - ok
    @retval TRUE  - EOF, reached the end of the buffer
  */
  bool read() 
  {
    return buf->read(&pos, &read_ptr1, &read_ptr2);
  }
};

Edit Rename Chmod Delete

FILE FOLDER

Name	Size	Permission
atomic	---	0755
authors.h	9578 bytes	0644
bounded_queue.h	6764 bytes	0644
client_settings.h	1935 bytes	0644
compat56.h	2000 bytes	0644
config.h	14833 bytes	0644
contributors.h	2985 bytes	0644
create_options.h	4314 bytes	0644
custom_conf.h	1083 bytes	0644
datadict.h	1511 bytes	0644
debug_sync.h	1773 bytes	0644
derror.h	1040 bytes	0644
des_key_file.h	1244 bytes	0644
discover.h	1608 bytes	0644
dur_prop.h	1082 bytes	0644
embedded_priv.h	1510 bytes	0644
event_data_objects.h	3934 bytes	0644
event_db_repository.h	3495 bytes	0644
event_parse_data.h	2936 bytes	0644
event_queue.h	3365 bytes	0644
event_scheduler.h	3290 bytes	0644
events.h	4537 bytes	0644
field.h	151073 bytes	0644
filesort.h	4719 bytes	0644
filesort_utils.h	4098 bytes	0644
ft_global.h	3113 bytes	0644
gcalc_slicescan.h	17264 bytes	0644
gcalc_tools.h	11654 bytes	0644
group_by_handler.h	3156 bytes	0644
gstream.h	2503 bytes	0644
ha_partition.h	52089 bytes	0644
handler.h	159210 bytes	0644
hash.h	4491 bytes	0644
hash_filo.h	5531 bytes	0644
heap.h	9455 bytes	0644
hostname.h	5478 bytes	0644
ilist.h	6419 bytes	0644
init.h	955 bytes	0644
innodb_priv.h	1421 bytes	0644
item.h	208423 bytes	0644
item_cmpfunc.h	94174 bytes	0644
item_create.h	6926 bytes	0644
item_func.h	82802 bytes	0644
item_geofunc.h	23871 bytes	0644
item_inetfunc.h	7788 bytes	0644
item_jsonfunc.h	13354 bytes	0644
item_row.h	4437 bytes	0644
item_strfunc.h	47645 bytes	0644
item_subselect.h	52262 bytes	0644
item_sum.h	57567 bytes	0644
item_timefunc.h	41980 bytes	0644
item_windowfunc.h	22901 bytes	0644
item_xmlfunc.h	3507 bytes	0644
key.h	2100 bytes	0644
keycaches.h	1982 bytes	0644
lex.h	26952 bytes	0644
lex_hash.h	129086 bytes	0644
lex_symbol.h	1323 bytes	0644
lex_token.h	38866 bytes	0644
lf.h	6390 bytes	0644
lock.h	2156 bytes	0644
log.h	42645 bytes	0644
log_event.h	161962 bytes	0644
log_event_old.h	19658 bytes	0644
log_slow.h	1583 bytes	0644
maria.h	17699 bytes	0644
mdl.h	33819 bytes	0644
mem_root_array.h	6929 bytes	0644
message.h	2112 bytes	0644
multi_range_read.h	22701 bytes	0644
my_alarm.h	2297 bytes	0644
my_apc.h	4725 bytes	0644
my_atomic.h	17060 bytes	0644
my_base.h	25649 bytes	0644
my_bit.h	3229 bytes	0644
my_bitmap.h	6125 bytes	0644
my_check_opt.h	2618 bytes	0644
my_compare.h	5489 bytes	0644
my_context.h	6747 bytes	0644
my_cpu.h	1482 bytes	0644
my_crypt.h	904 bytes	0644
my_decimal.h	12824 bytes	0644
my_default.h	2526 bytes	0644
my_handler_errors.h	4633 bytes	0644
my_json_writer.h	4994 bytes	0644
my_libwrap.h	1183 bytes	0644
my_md5.h	1486 bytes	0644
my_nosys.h	1438 bytes	0644
my_rdtsc.h	3962 bytes	0644
my_rnd.h	1064 bytes	0644
my_service_manager.h	1504 bytes	0644
my_stacktrace.h	3042 bytes	0644
my_time.h	8958 bytes	0644
my_tree.h	3979 bytes	0644
my_uctype.h	69528 bytes	0644
my_user.h	1150 bytes	0644
myisam.h	17242 bytes	0644
myisamchk.h	4816 bytes	0644
myisammrg.h	4737 bytes	0644
myisampack.h	14930 bytes	0644
mysql_async.h	1810 bytes	0644
mysqld.h	32067 bytes	0644
mysqld_default_groups.h	169 bytes	0644
mysqld_suffix.h	1201 bytes	0644
mysys_err.h	2882 bytes	0644
nt_servc.h	3072 bytes	0644
opt_range.h	54523 bytes	0644
opt_subselect.h	14090 bytes	0644
parse_file.h	4215 bytes	0644
partition_element.h	4626 bytes	0644
partition_info.h	14596 bytes	0644
password.h	1194 bytes	0644
pcre.h	31718 bytes	0644
probes_mysql.h	973 bytes	0644
probes_mysql_dtrace.h	33005 bytes	0644
probes_mysql_nodtrace.h	5005 bytes	0644
procedure.h	5966 bytes	0644
protocol.h	9951 bytes	0644
queues.h	3598 bytes	0644
records.h	3062 bytes	0644
repl_failsafe.h	1730 bytes	0644
replication.h	16347 bytes	0644
rijndael.h	1711 bytes	0644
rpl_constants.h	3357 bytes	0644
rpl_filter.h	4513 bytes	0644
rpl_gtid.h	10720 bytes	0644
rpl_handler.h	5658 bytes	0644
rpl_injector.h	9646 bytes	0644
rpl_mi.h	12657 bytes	0644
rpl_parallel.h	13616 bytes	0644
rpl_record.h	1645 bytes	0644
rpl_record_old.h	1407 bytes	0644
rpl_reporting.h	3035 bytes	0644
rpl_rli.h	32653 bytes	0644
rpl_tblmap.h	3177 bytes	0644
rpl_utility.h	9544 bytes	0644
scheduler.h	3509 bytes	0644
service_versions.h	1861 bytes	0644
session_tracker.h	9014 bytes	0644
set_var.h	14867 bytes	0644
slave.h	11408 bytes	0644
sp.h	7303 bytes	0644
sp_cache.h	2068 bytes	0644
sp_head.h	37039 bytes	0644
sp_pcontext.h	17011 bytes	0644
sp_rcontext.h	15801 bytes	0644
span.h	3923 bytes	0644
spatial.h	21174 bytes	0644
sql_acl.h	17639 bytes	0644
sql_admin.h	2752 bytes	0644
sql_alter.h	12291 bytes	0644
sql_analyse.h	11173 bytes	0644
sql_analyze_stmt.h	7797 bytes	0644
sql_array.h	6060 bytes	0644
sql_audit.h	14921 bytes	0644
sql_base.h	25493 bytes	0644
sql_basic_types.h	951 bytes	0644
sql_binlog.h	895 bytes	0644
sql_bitmap.h	7373 bytes	0644
sql_bootstrap.h	1665 bytes	0644
sql_cache.h	21381 bytes	0644
sql_callback.h	1542 bytes	0644
sql_class.h	200140 bytes	0644
sql_cmd.h	7436 bytes	0644
sql_connect.h	3650 bytes	0644
sql_const.h	10685 bytes	0644
sql_crypt.h	1424 bytes	0644
sql_cte.h	14996 bytes	0644
sql_cursor.h	2066 bytes	0644
sql_db.h	2056 bytes	0644
sql_delete.h	1353 bytes	0644
sql_derived.h	1544 bytes	0644
sql_digest.h	3811 bytes	0644
sql_digest_stream.h	1567 bytes	0644
sql_do.h	954 bytes	0644
sql_error.h	30577 bytes	0644
sql_explain.h	25226 bytes	0644
sql_expression_cache.h	4314 bytes	0644
sql_get_diagnostics.h	7847 bytes	0644
sql_handler.h	2747 bytes	0644
sql_help.h	920 bytes	0644
sql_hset.h	3272 bytes	0644
sql_insert.h	2112 bytes	0644
sql_join_cache.h	47718 bytes	0644
sql_lex.h	105962 bytes	0644
sql_lifo_buffer.h	9455 bytes	0644
sql_list.h	21883 bytes	0644
sql_load.h	1270 bytes	0644
sql_locale.h	2729 bytes	0644
sql_manager.h	960 bytes	0644
sql_mode.h	6729 bytes	0644
sql_parse.h	8216 bytes	0644
sql_partition.h	11702 bytes	0644
sql_partition_admin.h	5821 bytes	0644
sql_plist.h	7765 bytes	0644
sql_plugin.h	7663 bytes	0644
sql_plugin_compat.h	2231 bytes	0644
sql_prepare.h	11569 bytes	0644
sql_priv.h	16377 bytes	0644
sql_profile.h	7567 bytes	0644
sql_reload.h	1036 bytes	0644
sql_rename.h	941 bytes	0644
sql_repl.h	3319 bytes	0644
sql_select.h	78882 bytes	0644
sql_servers.h	1826 bytes	0644
sql_show.h	9052 bytes	0644
sql_signal.h	4150 bytes	0644
sql_sort.h	4195 bytes	0644
sql_statistics.h	11834 bytes	0644
sql_string.h	22470 bytes	0644
sql_table.h	11327 bytes	0644
sql_tablespace.h	956 bytes	0644
sql_test.h	1484 bytes	0644
sql_time.h	10528 bytes	0644
sql_trigger.h	10831 bytes	0644
sql_truncate.h	2057 bytes	0644
sql_type.h	20208 bytes	0644
sql_type_int.h	2920 bytes	0644
sql_udf.h	4142 bytes	0644
sql_union.h	1125 bytes	0644
sql_update.h	1966 bytes	0644
sql_view.h	2319 bytes	0644
sql_window.h	6028 bytes	0644
sql_yacc.h	36038 bytes	0644
ssl_compat.h	3042 bytes	0644
strfunc.h	2264 bytes	0644
structs.h	20851 bytes	0644
sys_vars_shared.h	2665 bytes	0644
t_ctype.h	5639 bytes	0644
table.h	98196 bytes	0644
table_cache.h	4337 bytes	0644
thr_alarm.h	2934 bytes	0644
thr_lock.h	6821 bytes	0644
thr_malloc.h	1247 bytes	0644
thr_timer.h	1467 bytes	0644
thread_pool_priv.h	4586 bytes	0644
threadpool.h	4427 bytes	0644
transaction.h	1609 bytes	0644
tzfile.h	5014 bytes	0644
tztime.h	3363 bytes	0644
uniques.h	4146 bytes	0644
unireg.h	7396 bytes	0644
violite.h	10068 bytes	0644
waiting_threads.h	4556 bytes	0644
welcome_copyright_notice.h	1218 bytes	0644
win_tzname_data.h	6460 bytes	0644
winservice.h	1194 bytes	0644
wqueue.h	1588 bytes	0644
wsrep.h	3086 bytes	0644
wsrep_applier.h	1715 bytes	0644
wsrep_binlog.h	2109 bytes	0644
wsrep_mysqld.h	14213 bytes	0644
wsrep_mysqld_c.h	1227 bytes	0644
wsrep_priv.h	2117 bytes	0644
wsrep_sst.h	3154 bytes	0644
wsrep_thd.h	2102 bytes	0644
wsrep_utils.h	9237 bytes	0644
wsrep_var.h	3810 bytes	0644
wsrep_xid.h	1415 bytes	0644

File Content: sql_lifo_buffer.h

File Content: `sql_lifo_buffer.h`