Merge lp:~percona-dev/percona-server/release-5.5.10-20.1 into lp:~percona-dev/percona-server/5.5.10

[Ignacio Nin]

Addition of scripts and fixes for building in all platforms. Includes HandlerSocket and the Maatkit UDF functions.

[Alexey Kopytov (akopytov)]

review: Approve

=== added directory 'HandlerSocket-Plugin-for-MySQL'
=== added file 'HandlerSocket-Plugin-for-MySQL/AUTHORS'
--- HandlerSocket-Plugin-for-MySQL/AUTHORS	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/AUTHORS	2011-04-12 04:16:24 +0000
@@ -0,0 +1,19 @@
+Akira Higuchi (https://github.com/ahiguti)
+  - developed HanderSocket plugin, libhsclient, and perl-Net-HandlerSocket
+
+Yoshinori Matsunobu (https://github.com/yoshinorim)
+  - introduced autotools, added support for MySQL 5.5.6, added statistics
+    variables
+
+Jeff Hodges (https://github.com/jmhodges)
+  - fixed some autotools scripts
+
+Toru Yamaguchi (https://github.com/zigorou)
+  - ported to MacOS X
+
+Moriyoshi Koizumi (https://github.com/moriyoshi)
+  - fixed some autotools scripts
+
+takeda-at (https://github.com/takada-at)
+  - added simple authorization function
+

=== added file 'HandlerSocket-Plugin-for-MySQL/COPYING'
--- HandlerSocket-Plugin-for-MySQL/COPYING	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/COPYING	2011-04-12 04:16:24 +0000
@@ -0,0 +1,30 @@
+-----------------------------------------------------------------------------
+HandlerSocket plugin for MySQL
+
+ Copyright (c) 2010 DeNA Co.,Ltd.
+ All rights reserved.
+
+ Redistribution and use in source and binary forms, with or without
+ modification, are permitted provided that the following conditions are met:
+
+     * Redistributions of source code must retain the above copyright
+       notice, this list of conditions and the following disclaimer.
+     * Redistributions in binary form must reproduce the above copyright
+       notice, this list of conditions and the following disclaimer in the
+       documentation and/or other materials provided with the distribution.
+     * Neither the name of DeNA Co.,Ltd. nor the names of its contributors
+       may be used to endorse or promote products derived from this software
+       without specific prior written permission.
+
+ THIS SOFTWARE IS PROVIDED BY DeNA Co.,Ltd. "AS IS" AND ANY EXPRESS OR
+ IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+ MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
+ EVENT SHALL DeNA Co.,Ltd. BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+ PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
+ OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+ WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+ OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+

=== added file 'HandlerSocket-Plugin-for-MySQL/ChangeLog'
--- HandlerSocket-Plugin-for-MySQL/ChangeLog	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/ChangeLog	2011-04-12 04:16:24 +0000
@@ -0,0 +1,12 @@
+1.0.6 - 2010-10-29
+  * Changed build instruction (autoreconf/configure/make), removed auto-generated files (Contributed by jmhodges)
+  * 
+
+1.0.5 - 2010-10-18
+  * Changed build procedures (using typical configure/make)
+  * Supported 5.5.6
+  * Added status variables
+
+1.0.4 - 2010-08-15 
+  * Initial public release
+

=== added file 'HandlerSocket-Plugin-for-MySQL/Makefile.am'
--- HandlerSocket-Plugin-for-MySQL/Makefile.am	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/Makefile.am	2011-04-12 04:16:24 +0000
@@ -0,0 +1,87 @@
+
+ACLOCAL_AMFLAGS = -I m4
+
+SUBDIRS = @HANDLERSOCKET_SUBDIRS@
+
+perl:
+	cd perl-Net-HandlerSocket && perl Makefile.PL && make
+
+install_perl:
+	cd perl-Net-HandlerSocket && make install
+
+rpms: rpm_cli rpm_perl rpm_c
+
+rpm_dir:
+	- mkdir dist
+	- mkdir dist/BUILD dist/RPMS dist/SOURCES dist/SPECS dist/SRPMS
+
+rpm_cli: clean_cli rpm_dir
+	sed -e "s/HANDLERSOCKET_VERSION/$(VERSION)/" \
+		libhsclient/libhsclient.spec.template \
+		> libhsclient/libhsclient.spec
+	tar cvfz dist/libhsclient.tar.gz libhsclient
+	rpmbuild --define "_topdir `pwd`/dist" -ta \
+		dist/libhsclient.tar.gz
+
+rpm_perl: clean_perl rpm_dir
+	sed -e "s/HANDLERSOCKET_VERSION/$(VERSION)/" \
+		perl-Net-HandlerSocket/perl-Net-HandlerSocket.spec.template \
+		> perl-Net-HandlerSocket/perl-Net-HandlerSocket.spec 
+	cd perl-Net-HandlerSocket && perl Makefile.PL && make clean && \
+		rm -f Makefile.old
+	tar cvfz dist/perl-Net-HandlerSocket.tar.gz perl-Net-HandlerSocket
+	rpmbuild --define "_topdir `pwd`/dist" -ta \
+		dist/perl-Net-HandlerSocket.tar.gz
+
+rpm_c: clean_c rpm_dir
+	sed -e "s/HANDLERSOCKET_VERSION/$(VERSION)/" \
+		handlersocket/handlersocket.spec.template \
+		> handlersocket/handlersocket.spec
+	sed -e "s|HANDLERSOCKET_MYSQL_INC|$(MYSQL_CFLAGS) $(MYSQL_INC)|" \
+		-e "s|HANDLERSOCKET_MYSQL_LIB|$(MYSQL_LIB)|" \
+		handlersocket/Makefile.plain.template \
+		> handlersocket/Makefile.plain
+	tar cvfz dist/handlersocket.tar.gz handlersocket
+	rpmbuild --define "_topdir `pwd`/dist" -ta \
+		dist/handlersocket.tar.gz
+
+install_rpm_pl:
+	- sudo rpm -e perl-Net-HandlerSocket
+	- sudo rpm -e perl-Net-HandlerSocket-debuginfo
+	make clean
+	make rpm_perl
+	- sudo rpm -U dist/RPMS/*/perl*.rpm
+
+installrpms:
+	- sudo rpm -e handlersocket
+	- sudo rpm -e handlersocket-debuginfo
+	- sudo rpm -e perl-Net-HandlerSocket
+	- sudo rpm -e perl-Net-HandlerSocket-debuginfo
+	- sudo rpm -e libhsclient
+	- sudo rpm -e libhsclient-debuginfo
+	make clean
+	make rpm_cli
+	- sudo rpm -U dist/RPMS/*/libhsclient*.rpm
+	make clean
+	make rpm_perl
+	- sudo rpm -U dist/RPMS/*/perl*.rpm
+	make clean
+	make rpm_c
+	- sudo rpm -U dist/RPMS/*/handlersocket*.rpm
+
+clean_cli:
+	cd libhsclient && make clean
+	cd client && make clean
+
+clean_perl:
+	cd perl-Net-HandlerSocket && perl Makefile.PL && make clean && \
+                rm -f Makefile.old
+
+clean_c:
+	cd handlersocket && make clean
+
+clean_all: clean_cli clean_perl clean_c
+	cd regtest && make clean
+	rm -rf dist/*/*
+	rm -f dist/*.tar.gz
+

=== added file 'HandlerSocket-Plugin-for-MySQL/README'
--- HandlerSocket-Plugin-for-MySQL/README	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/README	2011-04-12 04:16:24 +0000
@@ -0,0 +1,76 @@
+
+-----------------------------------------------------------------------------
+HandlerSocket plugin for MySQL
+
+Copyright (c) 2010 DeNA Co.,Ltd.
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+    * Redistributions of source code must retain the above copyright
+      notice, this list of conditions and the following disclaimer.
+    * Redistributions in binary form must reproduce the above copyright
+      notice, this list of conditions and the following disclaimer in the
+      documentation and/or other materials provided with the distribution.
+    * Neither the name of DeNA Co.,Ltd. nor the names of its contributors
+      may be used to endorse or promote products derived from this software
+      without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY DeNA Co.,Ltd. "AS IS" AND ANY EXPRESS OR
+IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
+EVENT SHALL DeNA Co.,Ltd. BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
+OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+
+-----------------------------------------------------------------------------
+About HandlerSocket
+
+HandlerSocket is a NoSQL plugin for MySQL. It works as a daemon inside the
+mysqld process, accept tcp connections, and execute requests from clients.
+HandlerSocket does not support SQL queries. Instead, it supports simple CRUD
+operations on tables.
+
+Because of the following reasons, HandlerSocket is much faster than the
+mysqld/libmysql pair in some circumstances:
+
+  - HandlerSocket manipulates data without parsing SQL, which causes less
+    CPU usage.
+  - HandlerSocket reads many requests from clients and executes their
+    requests in bulk, which causes less CPU and disk usage.
+  - HandlerSocket client/server protocol is more compact than the 
+    mysql/libmysql pair, which causes less network usage.
+
+The current version of HandlerSocket only works with GNU/Linux. The source
+archive of HandlerSocket includes a C++ and a Perl client libraries.
+Here is a list of client libraries for other languages:
+
+  - PHP
+    http://openpear.org/package/Net_HandlerSocket
+    http://github.com/tz-lom/HSPHP
+    http://code.google.com/p/php-handlersocket/
+  - Java
+    http://code.google.com/p/hs4j/
+    http://code.google.com/p/handlersocketforjava/
+  - Python
+    http://pypi.python.org/pypi/python-handler-socket
+    https://code.launchpad.net/~songofacandy/+junk/pyhandlersocket
+  - Ruby
+    https://github.com/winebarrel/ruby-handlersocket
+    https://github.com/miyucy/handlersocket
+  - JavaScript
+    https://github.com/koichik/node-handlersocket
+  - Scala
+    https://github.com/fujohnwang/hs2client
+
+The home of HandlerSocket is here:
+    https://github.com/ahiguti/HandlerSocket-Plugin-for-MySQL
+
+More documents are available in docs-en/ and docs-ja/ directories.
+

=== added file 'HandlerSocket-Plugin-for-MySQL/autogen.sh'
--- HandlerSocket-Plugin-for-MySQL/autogen.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/autogen.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,117 @@
+#!/bin/sh
+
+warn() {
+echo -e "\tWARNING: $@" 1>&2
+}
+
+# init
+
+LIBTOOLIZE=libtoolize
+ACLOCAL=aclocal
+AUTOCONF=autoconf
+AUTOHEADER=autoheader
+AUTOMAKE=automake
+
+case `uname -s` in
+Darwin)
+LIBTOOLIZE=glibtoolize
+;;
+FreeBSD)
+ACLOCAL_ARGS="$ACLOCAL_ARGS -I /usr/local/share/aclocal/"
+;;
+esac
+
+
+# libtoolize
+echo "Searching libtoolize..."
+if [ `which $LIBTOOLIZE` ] ; then
+echo -e "\tFOUND: libtoolize -> $LIBTOOLIZE"
+else
+warn "Cannot Found libtoolize... input libtool command"
+  read LIBTOOLIZE
+  LIBTOOLIZE=`which $LIBTOOLIZE`
+  if [ `which $LIBTOOLIZE` ] ; then
+echo -e "\tSET: libtoolize -> $LIBTOOLIZE"
+  else
+warn "$LIBTOOLIZE: Command not found."
+    exit 1;
+  fi
+fi
+
+# aclocal
+echo "Searching aclocal..."
+if [ `which $ACLOCAL` ] ; then
+echo -e "\tFOUND: aclocal -> $ACLOCAL"
+else
+warn "Cannot Found aclocal... input aclocal command"
+  read ACLOCAL
+  ACLOCAL=`which $ACLOCAL`
+  if [ `which $ACLOCAL` ] ; then
+echo -e "\tSET: aclocal -> $ACLOCAL"
+  else
+warn "$ACLOCAL: Command not found."
+    exit 1;
+  fi
+fi
+
+# automake
+echo "Searching automake..."
+if [ `which $AUTOMAKE` ] ; then
+echo -e "\tFOUND: automake -> $AUTOMAKE"
+else
+warn "Cannot Found automake... input automake command"
+  read AUTOMAKE
+  ACLOCAL=`which $AUTOMAKE`
+  if [ `which $AUTOMAKE` ] ; then
+echo -e "\tSET: automake -> $AUTOMAKE"
+  else
+warn "$AUTOMAKE: Command not found."
+    exit 1;
+  fi
+fi
+
+# autoheader
+echo "Searching autoheader..."
+if [ `which $AUTOHEADER` ] ; then
+echo -e "\tFOUND: autoheader -> $AUTOHEADER"
+else
+warn "Cannot Found autoheader... input autoheader command"
+  read AUTOHEADER
+  ACLOCAL=`which $AUTOHEADER`
+  if [ `which $AUTOHEADER` ] ; then
+echo -e "\tSET: autoheader -> $AUTOHEADER"
+  else
+warn "$AUTOHEADER: Command not found."
+    exit 1;
+  fi
+fi
+
+# autoconf
+echo "Searching autoconf..."
+if [ `which $AUTOCONF` ] ; then
+echo -e "\tFOUND: autoconf -> $AUTOCONF"
+else
+warn "Cannot Found autoconf... input autoconf command"
+  read AUTOCONF
+  ACLOCAL=`which $AUTOCONF`
+  if [ `which $AUTOCONF` ] ; then
+echo -e "\tSET: autoconf -> $AUTOCONF"
+  else
+warn "$AUTOCONF: Command not found."
+    exit 1;
+  fi
+fi
+
+echo "Running libtoolize ..."
+$LIBTOOLIZE --force --copy
+echo "Running aclocal ..."
+$ACLOCAL ${ACLOCAL_ARGS} -I .
+echo "Running autoheader..."
+$AUTOHEADER
+echo "Running automake ..."
+$AUTOMAKE --add-missing --copy
+echo "Running autoconf ..."
+$AUTOCONF
+
+#mkdir m4 2> /dev/null
+

=== added directory 'HandlerSocket-Plugin-for-MySQL/client'
=== added file 'HandlerSocket-Plugin-for-MySQL/client/Makefile.am'
--- HandlerSocket-Plugin-for-MySQL/client/Makefile.am	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/Makefile.am	2011-04-12 04:16:24 +0000
@@ -0,0 +1,13 @@
+AM_INCLUDES= -I../libhsclient
+bin_PROGRAMS=hsclient 
+hsclient_SOURCES= hsclient.cpp
+hsclient_LDFLAGS= -static -L../libhsclient -lhsclient
+hsclient_CXXFLAGS= $(AM_INCLUDES)
+
+hstest: hstest.o
+	$(CXX) $(CXXFLAGS) $(LFLAGS) hstest.o \
+		-L../libhsclient/.libs -lhsclient $(MYSQL_LIB) -o hstest
+
+hstest.o: hstest.cpp
+	$(CXX) $(CXXFLAGS) $(MYSQL_INC) $(AM_INCLUDES) -c hstest.cpp
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hsclient.cpp'
--- HandlerSocket-Plugin-for-MySQL/client/hsclient.cpp	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hsclient.cpp	2011-04-12 04:16:24 +0000
@@ -0,0 +1,88 @@
+
+// vim:sw=2:ai
+
+#include "hstcpcli.hpp"
+#include "string_util.hpp"
+
+namespace dena {
+
+int
+hstcpcli_main(int argc, char **argv)
+{
+  config conf;
+  parse_args(argc, argv, conf);
+  socket_args sockargs;
+  sockargs.set(conf);
+  hstcpcli_ptr cli = hstcpcli_i::create(sockargs);
+  const std::string dbname = conf.get_str("dbname", "hstest");
+  const std::string table = conf.get_str("table", "hstest_table1");
+  const std::string index = conf.get_str("index", "PRIMARY");
+  const std::string fields = conf.get_str("fields", "k,v");
+  const int limit = conf.get_int("limit", 0);
+  const int skip = conf.get_int("skip", 0);
+  std::vector<std::string> keys;
+  std::vector<string_ref> keyrefs;
+  size_t num_keys = 0;
+  while (true) {
+    const std::string conf_key = std::string("k") + to_stdstring(num_keys);
+    const std::string k = conf.get_str(conf_key, "");
+    const std::string kx = conf.get_str(conf_key, "x");
+    if (k.empty() && kx == "x") {
+      break;
+    }
+    ++num_keys;
+    keys.push_back(k);
+  }
+  for (size_t i = 0; i < keys.size(); ++i) {
+    const string_ref ref(keys[i].data(), keys[i].size());
+    keyrefs.push_back(ref);
+  }
+  const std::string op = conf.get_str("op", "=");
+  const string_ref op_ref(op.data(), op.size());
+  cli->request_buf_open_index(0, dbname.c_str(), table.c_str(),
+    index.c_str(), fields.c_str());
+  cli->request_buf_exec_generic(0, op_ref, num_keys == 0 ? 0 : &keyrefs[0],
+    num_keys, limit, skip, string_ref(), 0, 0);
+  int code = 0;
+  size_t numflds = 0;
+  do {
+    if (cli->request_send() != 0) {
+      fprintf(stderr, "request_send: %s\n", cli->get_error().c_str());
+      break;
+    }
+    if ((code = cli->response_recv(numflds)) != 0) {
+      fprintf(stderr, "response_recv: %s\n", cli->get_error().c_str());
+      break;
+    }
+  } while (false);
+  cli->response_buf_remove();
+  do {
+    if ((code = cli->response_recv(numflds)) != 0) {
+      fprintf(stderr, "response_recv: %s\n", cli->get_error().c_str());
+      break;
+    }
+    while (true) {
+      const string_ref *const row = cli->get_next_row();
+      if (row == 0) {
+	break;
+      }
+      printf("REC:");
+      for (size_t i = 0; i < numflds; ++i) {
+	const std::string val(row[i].begin(), row[i].size());
+	printf(" %s", val.c_str());
+      }
+      printf("\n");
+    }
+  } while (false);
+  cli->response_buf_remove();
+  return 0;
+}
+
+};
+
+int
+main(int argc, char **argv)
+{
+  return dena::hstcpcli_main(argc, argv);
+}
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hspool_test.pl'
--- HandlerSocket-Plugin-for-MySQL/client/hspool_test.pl	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hspool_test.pl	2011-04-12 04:16:24 +0000
@@ -0,0 +1,224 @@
+#!/usr/bin/perl
+
+use strict;
+use warnings;
+use DB::HandlerSocket::Pool;
+use DBI;
+
+my %conf = ();
+for my $i (@ARGV) {
+	my ($k, $v) = split(/=/, $i);
+	$conf{$k} = $v;
+}
+
+my $verbose = get_conf("verbose", 0);
+my $actions_str = get_conf("actions",
+	"create,insert,verify,verify2,verify3,verify4,clean");
+my $tablesize = get_conf("tablesize", 1000);
+my $db = get_conf("db", "hstestdb");
+my $table = get_conf("table", "testtbl");
+my $table_schema = get_conf("table_schema", undef);
+my $engine = get_conf("engine", "innodb");
+my $host = get_conf("host", "localhost");
+my $mysqlport = get_conf("mysqlport", 3306);
+my $hsport_rd = get_conf("hsport_rd", 9998);
+my $hsport_wr = get_conf("hsport_wr", 9999);
+my $loop = get_conf("loop", 10000);
+my $op = get_conf("op", "=");
+my $ssps = get_conf("ssps", 0);
+my $num_moreflds = get_conf("moreflds", 0);
+my $moreflds_prefix = get_conf("moreflds_prefix", "f");
+my $mysql_user = 'root';
+my $mysql_password = '';
+
+my $dsn = "DBI:mysql:database=;host=$host;port=$mysqlport"
+        . ";mysql_server_prepare=$ssps";
+my $dbh = DBI->connect($dsn, $mysql_user, $mysql_password,
+	{ RaiseError => 1 });
+my $hsargs = { 'host' => $host, 'port' => $hsport_rd };
+my $hspool = new DB::HandlerSocket::Pool({
+	hostmap => {
+		"$db.$table" => {
+			host => $host,
+			port => $hsport_rd,
+		},
+	},
+	resolve => undef,
+	error => undef,
+});
+$table_schema = "(k int primary key, fc30 varchar(30), ft text)"
+	if (!defined($table_schema));
+
+my @actions = split(/,/, $actions_str);
+for my $action (@actions) {
+	print "ACTION: $action\n";
+	eval "hstest_$action()";
+	if ($@) {
+		die $@;
+	}
+	print "ACTION: $action DONE\n";
+}
+
+sub get_conf {
+	my ($key, $def) = @_;
+	my $val = $conf{$key};
+	if ($val) {
+		print "$key=$val\n";
+	} else {
+		$val = $def;
+		my $defstr = $def || "(undef)";
+		print "$key=$defstr(default)\n";
+	}
+	return $val;
+}
+
+sub hstest_create {
+	$dbh->do("drop database if exists $db");
+	$dbh->do("create database $db");
+	$dbh->do("use $db");
+	$dbh->do("create table $table $table_schema engine=$engine");
+}
+
+sub hstest_dump {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("select * from $table");
+	$sth->execute();
+	my $arr = $sth->fetchall_arrayref();
+	for my $rec (@$arr) {
+		print "REC:";
+		for my $row (@$rec) {
+			print " $row";
+		}
+		print "\n";
+	}
+}
+
+sub hstest_insert {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("insert into $table values (?, ?, ?)");
+	for (my $k = 0; $k < $tablesize; ++$k) {
+		my $fc30 = "fc30_$k";
+		my $ft = "ft_$k";
+		$sth->execute($k, $fc30, $ft);
+	}
+}
+
+sub hstest_verify {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("select * from $table order by k");
+	$sth->execute();
+	my $arr = $sth->fetchall_arrayref();
+	my $hsres = $hspool->index_find($db, $table, "PRIMARY", "k,fc30,ft",
+		">=", [ 0 ], $tablesize, 0);
+	for (my $i = 0; $i < $tablesize; ++$i) {
+		my $rec = $arr->[$i];
+		my $differ = 0;
+		print "REC:" if $verbose;
+		for (my $j = 0; $j < 3; ++$j) {
+			my $fld = $rec->[$j];
+			my $hsidx = $i * 3 + $j;
+			my $hsfld = $hsres->[$hsidx];
+			if ($hsfld ne $fld) {
+				$differ = 1;
+			}
+			if ($differ) {
+				print " $fld:$hsfld" if $verbose;
+			} else {
+				print " $hsfld" if $verbose;
+			}
+		}
+		print "\n" if $verbose;
+		if ($differ) {
+			die "verification failed";
+		}
+	}
+}
+
+sub hstest_verify2 {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("select * from $table order by k");
+	$sth->execute();
+	my $arr = $sth->fetchall_arrayref();
+	my $hsresa = $hspool->index_find_multi($db, $table, "PRIMARY",
+		"k,fc30,ft", [ [ -1, ">=", [ 0 ], $tablesize, 0 ] ]);
+	my $hsres = $hsresa->[0];
+	for (my $i = 0; $i < $tablesize; ++$i) {
+		my $rec = $arr->[$i];
+		my $differ = 0;
+		print "REC:" if $verbose;
+		for (my $j = 0; $j < 3; ++$j) {
+			my $fld = $rec->[$j];
+			my $hsidx = $i * 3 + $j;
+			my $hsfld = $hsres->[$hsidx];
+			if ($hsfld ne $fld) {
+				$differ = 1;
+			}
+			if ($differ) {
+				print " $fld:$hsfld" if $verbose;
+			} else {
+				print " $hsfld" if $verbose;
+			}
+		}
+		print "\n" if $verbose;
+		if ($differ) {
+			die "verification failed";
+		}
+	}
+}
+
+sub hashref_to_str {
+	my $href = $_[0];
+	my $r = '';
+	for my $k (sort keys %$href) {
+		my $v = $href->{$k};
+		$r .= "($k=>$v)";
+	}
+	return $r;
+}
+
+sub hstest_verify3 {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("select * from $table order by k");
+	$sth->execute();
+	my $hsres_t = $hspool->index_find($db, $table, "PRIMARY", "k,fc30,ft",
+			">=", [ 0 ], $tablesize, 0);
+	my $hsres = DB::HandlerSocket::Pool::result_single_to_hasharr(
+		[ 'k', 'fc30', 'ft' ], $hsres_t);
+	for (my $i = 0; $i < $tablesize; ++$i) {
+		my $mystr = hashref_to_str($sth->fetchrow_hashref());
+		my $hsstr = hashref_to_str($hsres->[$i]);
+		if ($mystr ne $hsstr) {
+			print "DIFF my=[$mystr] hs=[$hsstr]\n" if $verbose;
+			die "verification failed";
+		} else {
+			print "OK $hsstr\n" if $verbose;
+		}
+	}
+}
+
+sub hstest_verify4 {
+	$dbh->do("use $db");
+	my $sth = $dbh->prepare("select * from $table order by k");
+	$sth->execute();
+	my $hsres_t = $hspool->index_find($db, $table, "PRIMARY", "k,fc30,ft",
+			">=", [ 0 ], $tablesize, 0);
+	my $hsres = DB::HandlerSocket::Pool::result_single_to_hashhash(
+		[ 'k', 'fc30', 'ft' ], 'k', $hsres_t);
+	my $rechash = $sth->fetchall_hashref('k');
+	while (my ($k, $href) = each (%$rechash)) {
+		my $mystr = hashref_to_str($href);
+		my $hsstr = hashref_to_str($hsres->{$k});
+		if ($mystr ne $hsstr) {
+			print "DIFF my=[$mystr] hs=[$hsstr]\n" if $verbose;
+			die "verification failed";
+		} else {
+			print "OK $hsstr\n" if $verbose;
+		}
+	}
+}
+
+sub hstest_clean {
+	$hspool->clear_pool();
+	$dbh->do("drop database if exists $db");
+}
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest.cpp'
--- HandlerSocket-Plugin-for-MySQL/client/hstest.cpp	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest.cpp	2011-04-12 04:16:24 +0000
@@ -0,0 +1,1494 @@
+
+// vim:sw=2:ai
+
+#include <signal.h>
+#include <sys/time.h>
+#include <stdio.h>
+#include <string.h>
+#include <vector>
+#include <stdlib.h>
+#include <memory>
+#include <errno.h>
+#include <mysql.h>
+#include <time.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+
+#include "util.hpp"
+#include "auto_ptrcontainer.hpp"
+#include "socket.hpp"
+#include "thread.hpp"
+#include "hstcpcli.hpp"
+
+#if __GNUC__ >= 4
+long atomic_exchange_and_add(volatile long *valp, long c)
+{
+  return __sync_fetch_and_add(valp, c);
+}
+#else
+#include <bits/atomicity.h>
+using namespace __gnu_cxx;
+long atomic_exchange_and_add(volatile long *valp, long c)
+{
+  return __exchange_and_add((volatile _Atomic_word *)valp, c);
+}
+#endif
+
+namespace dena {
+
+struct auto_mysql : private noncopyable {
+  auto_mysql() : db(0) {
+    reset();
+  }
+  ~auto_mysql() {
+    if (db) {
+      mysql_close(db);
+    }
+  }
+  void reset() {
+    if (db) {
+      mysql_close(db);
+    }
+    if ((db = mysql_init(0)) == 0) {
+      fatal_abort("failed to initialize mysql client");
+    }
+  }
+  operator MYSQL *() const { return db; }
+ private:
+  MYSQL *db;
+};
+
+struct auto_mysql_res : private noncopyable {
+  auto_mysql_res(MYSQL *db) {
+    res = mysql_store_result(db);
+  }
+  ~auto_mysql_res() {
+    if (res) {
+      mysql_free_result(res);
+    }
+  }
+  operator MYSQL_RES *() const { return res; }
+ private:
+  MYSQL_RES *res;
+};
+
+struct auto_mysql_stmt : private noncopyable {
+  auto_mysql_stmt(MYSQL *db) {
+    stmt = mysql_stmt_init(db);
+  }
+  ~auto_mysql_stmt() {
+    if (stmt) {
+      mysql_stmt_close(stmt);
+    }
+  }
+  operator MYSQL_STMT *() const { return stmt; }
+ private:
+  MYSQL_STMT *stmt;
+};
+
+namespace {
+
+double
+gettimeofday_double()
+{
+  struct timeval tv = { };
+  if (gettimeofday(&tv, 0) != 0) {
+    fatal_abort("gettimeofday");
+  }
+  return static_cast<double>(tv.tv_usec) / 1000000 + tv.tv_sec;
+}
+
+// unused
+void
+wait_close(int fd)
+{
+  char buf[1024];
+  while (true) {
+    int r = read(fd, buf, sizeof(buf));
+    if (r <= 0) {
+      break;
+    }
+  }
+}
+
+// unused
+void
+gentle_close(int fd)
+{
+  int r = shutdown(fd, SHUT_WR);
+  if (r != 0) {
+    return;
+  }
+  wait_close(fd);
+}
+
+};
+
+struct hstest_shared {
+  config conf;
+  socket_args arg;
+  int verbose;
+  size_t loop;
+  size_t pipe;
+  char op;
+  long num_threads;
+  mutable volatile long count;
+  mutable volatile long conn_count;
+  long wait_conn;
+  volatile char *keygen;
+  long keygen_size;
+  mutable volatile int enable_timing;
+  int usleep;
+  int dump;
+  hstest_shared() : verbose(0), loop(0), pipe(0), op('G'), num_threads(0),
+    count(0), conn_count(0), wait_conn(0), keygen(0), keygen_size(0),
+    enable_timing(0), usleep(0), dump(0) { }
+  void increment_count(unsigned int c = 1) const volatile {
+    atomic_exchange_and_add(&count, c);
+  }
+  void increment_conn(unsigned int c) const volatile {
+    atomic_exchange_and_add(&conn_count, c);
+    while (wait_conn != 0 && conn_count < wait_conn) {
+      sleep(1);
+    }
+    // fprintf(stderr, "wait_conn=%ld done\n", wait_conn);
+  }
+};
+
+struct hstest_thread {
+  struct arg_type {
+    size_t id;
+    const hstest_shared& sh;
+    bool watch_flag;
+    arg_type(size_t i, const hstest_shared& s, bool w)
+      : id(i), sh(s), watch_flag(w) { }
+  };
+  hstest_thread(const arg_type& a) : arg(a), io_success_count(0),
+    op_success_count(0), response_min(99999), response_max(0),
+    response_sum(0), response_avg(0) { }
+  void operator ()();
+  void test_1();
+  void test_2_3(int test_num);
+  void test_4_5(int test_num);
+  void test_6(int test_num);
+  void test_7(int test_num);
+  void test_8(int test_num);
+  void test_9(int test_num);
+  void test_10(int test_num);
+  void test_11(int test_num);
+  void test_12(int test_num);
+  void test_21(int test_num);
+  void test_22(int test_num);
+  void test_watch();
+  void sleep_if();
+  void set_timing(double time_spent);
+  arg_type arg;
+  auto_file fd;
+  size_t io_success_count;
+  size_t op_success_count;
+  double response_min, response_max, response_sum, response_avg;
+};
+
+void
+hstest_thread::test_1()
+{
+  char buf[1024];
+  unsigned int seed = arg.id;
+  seed ^= arg.sh.conf.get_int("seed_xor", 0);
+  std::string err;
+  if (socket_connect(fd, arg.sh.arg, err) != 0) {
+    fprintf(stderr, "connect: %d %s\n", errno, strerror(errno));
+    return;
+  }
+  const char op = arg.sh.op;
+  const int tablesize = arg.sh.conf.get_int("tablesize", 0);
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, v = 0, len = 0;
+      if (op == 'G') {
+	k = rand_r(&seed);
+	v = rand_r(&seed); /* unused */
+	if (tablesize != 0) {
+	  k &= tablesize;
+	}
+	len = snprintf(buf, sizeof(buf), "%c\tk%d\n", op, k);
+      } else {
+	k = rand_r(&seed);
+	v = rand_r(&seed);
+	if (tablesize != 0) {
+	  k &= tablesize;
+	}
+	len = snprintf(buf, sizeof(buf), "%c\tk%d\tv%d\n", op, k, v);
+      }
+      const int wlen = write(fd.get(), buf, len);
+      if (wlen != len) {
+	return;
+      }
+    }
+    size_t read_cnt = 0;
+    size_t read_pos = 0;
+    while (read_cnt < arg.sh.pipe) {
+      const int rlen = read(fd.get(), buf + read_pos, sizeof(buf) - read_pos);
+      if (rlen <= 0) {
+	return;
+      }
+      read_pos += rlen;
+      while (true) {
+	const char *const p = static_cast<const char *>(memchr(buf, '\n',
+	  read_pos));
+	if (p == 0) {
+	  break;
+	}
+	++read_cnt;
+	++io_success_count;
+	arg.sh.increment_count();
+	if (p != buf && buf[0] == '=') {
+	  ++op_success_count;
+	}
+	const size_t rest_size = buf + read_pos - (p + 1);
+	if (rest_size != 0) {
+	  memmove(buf, p + 1, rest_size);
+	}
+	read_pos = rest_size;
+      }
+    }
+  }
+}
+
+void
+hstest_thread::test_2_3(int test_num)
+{
+#if 0
+  char buf_k[128], buf_v[128];
+  unsigned int seed = arg.id;
+  op_base_t op = static_cast<op_base_t>(arg.sh.op);
+  micli_ptr hnd;
+  if (test_num == 2) {
+    hnd = micli_i::create_remote(arg.sh.conf);
+  } else if (test_num == 3) {
+    // hnd = micli_i::create_inproc(arg.sh.localdb);
+  }
+  if (hnd.get() == 0) {
+    return;
+  }
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, v = 0, klen = 0, vlen = 0;
+      k = rand_r(&seed);
+      klen = snprintf(buf_k, sizeof(buf_k), "k%d", k);
+      v = rand_r(&seed); /* unused */
+      vlen = snprintf(buf_v, sizeof(buf_v), "v%d", v);
+      string_ref arr[2];
+      arr[0] = string_ref(buf_k, klen);
+      arr[1] = string_ref(buf_v, vlen);
+      pstrarr_ptr rec(arr, 2);
+      if (hnd->execute(op, 0, 0, rec.get_const())) {
+	++io_success_count;
+	arg.sh.increment_count();
+	const dataset& res = hnd->get_result_ref();
+	if (res.size() == 1) {
+	  ++op_success_count;
+	}
+      }
+    }
+  }
+#endif
+}
+
+void
+hstest_thread::test_4_5(int test_num)
+{
+#if 0
+  char buf_k[128], buf_v[8192];
+  memset(buf_v, ' ', sizeof(buf_v));
+  unsigned int seed = arg.id;
+  op_base_t op = static_cast<op_base_t>(arg.sh.op);
+  micli_ptr hnd;
+  if (test_num == 4) {
+    hnd = micli_i::create_remote(arg.sh.conf);
+  } else if (test_num == 5) {
+    hnd = micli_i::create_inproc(arg.sh.localdb);
+  }
+  if (hnd.get() == 0) {
+    return;
+  }
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, klen = 0, vlen = 0;
+      k = i & 0x0000ffffUL;
+      if (k == 0) {
+	fprintf(stderr, "k=0\n");
+      }
+      klen = snprintf(buf_k, sizeof(buf_k), "k%d", k);
+      vlen = rand_r(&seed) % 8192;
+      string_ref arr[2];
+      arr[0] = string_ref(buf_k, klen);
+      arr[1] = string_ref(buf_v, vlen);
+      pstrarr_ptr rec(arr, 2);
+      if (hnd->execute(op, 0, 0, rec.get_const())) {
+	++io_success_count;
+	const dataset& res = hnd->get_result_ref();
+	if (res.size() == 1) {
+	  ++op_success_count;
+	}
+      }
+    }
+  }
+#endif
+}
+
+void
+hstest_thread::test_6(int test_num)
+{
+  int count = arg.sh.conf.get_int("count", 1);
+  auto_file fds[count];
+  for (int i = 0; i < count; ++i) {
+    const double t1 = gettimeofday_double();
+    std::string err;
+    if (socket_connect(fds[i], arg.sh.arg, err) != 0) {
+      fprintf(stderr, "id=%zu i=%d err=%s\n", arg.id, i, err.c_str());
+    }
+    const double t2 = gettimeofday_double();
+    if (t2 - t1 > 1) {
+      fprintf(stderr, "id=%zu i=%d time %f\n", arg.id, i, t2 - t1);
+    }
+  }
+}
+
+void
+hstest_thread::test_7(int num)
+{
+  /*
+    set foo 0 0 10
+    0123456789
+    STORED
+    get foo
+    VALUE foo 0 10
+    0123456789
+    END
+    get var
+    END
+   */
+  char buf[1024];
+  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
+  unsigned int seed = arg.id;
+  seed ^= arg.sh.conf.get_int("seed_xor", 0);
+  const int tablesize = arg.sh.conf.get_int("tablesize", 0);
+  const char op = arg.sh.op;
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    const double tm1 = gettimeofday_double();
+    std::string err;
+    if (fd.get() < 0 && socket_connect(fd, arg.sh.arg, err) != 0) {
+      fprintf(stderr, "connect: %d %s\n", errno, strerror(errno));
+      return;
+    }
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, v = 0, len = 0;
+      if (op == 'G') {
+	k = rand_r(&seed);
+	v = rand_r(&seed); /* unused */
+	if (tablesize != 0) {
+	  k &= tablesize;
+	}
+	len = snprintf(buf, sizeof(buf), "get k%d\r\n", k);
+      } else {
+	k = rand_r(&seed);
+	v = rand_r(&seed);
+	if (tablesize != 0) {
+	  k &= tablesize;
+	}
+	char vbuf[1024];
+	int vlen = snprintf(vbuf, sizeof(vbuf),
+	  "v%d"
+	  // "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+	  // "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+	  // "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+	  // "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+	  // "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+	  , v);
+	len = snprintf(buf, sizeof(buf), "set k%d 0 0 %d\r\n%s\r\n",
+	  k, vlen, vbuf);
+      }
+      const int wlen = write(fd.get(), buf, len);
+      if (wlen != len) {
+	return;
+      }
+    }
+    size_t read_cnt = 0;
+    size_t read_pos = 0;
+    bool read_response_done = false;
+    bool expect_value = false;
+    while (!read_response_done) {
+      const int rlen = read(fd.get(), buf + read_pos, sizeof(buf) - read_pos);
+      if (rlen <= 0) {
+	return;
+      }
+      read_pos += rlen;
+      while (true) {
+	const char *const p = static_cast<const char *>(memchr(buf, '\n',
+	  read_pos));
+	if (p == 0) {
+	  break;
+	}
+	++read_cnt;
+	if (expect_value) {
+	  expect_value = false;
+	} else if (p >= buf + 6 && memcmp(buf, "VALUE ", 6) == 0) {
+	  expect_value = true;
+	  ++op_success_count;
+	} else {
+	  if (p == buf + 7 && memcmp(buf, "STORED\r", 7) == 0) {
+	    ++op_success_count;
+	  }
+	  read_response_done = true;
+	}
+	const size_t rest_size = buf + read_pos - (p + 1);
+	if (rest_size != 0) {
+	  memmove(buf, p + 1, rest_size);
+	}
+	read_pos = rest_size;
+      }
+      ++io_success_count;
+    }
+    arg.sh.increment_count();
+    if (!keep_connection) {
+      fd.close();
+    }
+    const double tm2 = gettimeofday_double();
+    set_timing(tm2 - tm1);
+    sleep_if();
+  }
+}
+
+struct rec {
+  std::string key;
+  std::string value;
+};
+
+void
+hstest_thread::test_8(int test_num)
+{
+#if 0
+  char buf_k[128], buf_v[128];
+  unsigned int seed = arg.id;
+  // op_base_t op = static_cast<op_base_t>(arg.sh.op);
+  using namespace boost::multi_index;
+  typedef member<rec, std::string, &rec::key> rec_get_key;
+  typedef ordered_unique<rec_get_key> oui;
+  typedef multi_index_container< rec, indexed_by<oui> > mic;
+  #if 0
+  typedef std::map<std::string, std::string> m_type;
+  m_type m;
+  #endif
+  mic m;
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, v = 0, klen = 0, vlen = 0;
+      k = rand_r(&seed);
+      klen = snprintf(buf_k, sizeof(buf_k), "k%d", k);
+      v = rand_r(&seed); /* unused */
+      vlen = snprintf(buf_v, sizeof(buf_v), "v%d", v);
+      const std::string ks(buf_k, klen);
+      const std::string vs(buf_v, vlen);
+      rec r;
+      r.key = ks;
+      r.value = vs;
+      m.insert(r);
+      // m.insert(std::make_pair(ks, vs));
+      ++io_success_count;
+      ++op_success_count;
+      arg.sh.increment_count();
+    }
+  }
+#endif
+}
+
+struct mysqltest_thread_initobj : private noncopyable {
+  mysqltest_thread_initobj() {
+    mysql_thread_init();
+  }
+  ~mysqltest_thread_initobj() {
+    mysql_thread_end();
+  }
+};
+
+void
+hstest_thread::test_9(int test_num)
+{
+  /* create table hstest
+   * ( k varchar(255) not null, v varchar(255) not null, primary key(k))
+   * engine = innodb; */
+  auto_mysql db;
+  // mysqltest_thread_initobj initobj;
+  std::string err;
+  const char op = arg.sh.op;
+  const std::string suffix = arg.sh.conf.get_str("value_suffix", "upd");
+  unsigned long long err_cnt = 0;
+  unsigned long long query_cnt = 0;
+  #if 0
+  my_bool reconnect = 0;
+  if (mysql_options(db, MYSQL_OPT_RECONNECT, &reconnect) != 0) {
+    err = "mysql_options() failed";
+    ++err_cnt;
+    return;
+  }
+  #endif
+  unsigned int seed = time(0) + arg.id + 1;
+  seed ^= arg.sh.conf.get_int("seed_xor", 0);
+  drand48_data randbuf;
+  srand48_r(seed, &randbuf);
+  const std::string mysql_host = arg.sh.conf.get_str("host", "localhost");
+  const int mysql_port = arg.sh.conf.get_int("mysqlport", 3306);
+  const int num = arg.sh.loop;
+  const std::string mysql_user = arg.sh.conf.get_str("mysqluser", "root");
+  const std::string mysql_passwd = arg.sh.conf.get_str("mysqlpass", "");
+  const std::string mysql_dbname = arg.sh.conf.get_str("dbname", "hstest");
+  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
+  const int verbose = arg.sh.conf.get_int("verbose", 1);
+  const int tablesize = arg.sh.conf.get_int("tablesize", 10000);
+  const int moreflds = arg.sh.conf.get_int("moreflds", 0);
+  const std::string moreflds_prefix = arg.sh.conf.get_str(
+    "moreflds_prefix", "column0123456789_");
+  const int use_handler = arg.sh.conf.get_int("handler", 0);
+  const int sched_flag = arg.sh.conf.get_int("sched", 0);
+  const int ssps = arg.sh.conf.get_int("ssps", 0);
+  std::string flds = "v";
+  for (int i = 0; i < moreflds; ++i) {
+    char buf[1024];
+    snprintf(buf, sizeof(buf), ",%s%d", moreflds_prefix.c_str(), i);
+    flds += std::string(buf);
+  }
+  int connected = 0;
+  std::auto_ptr<auto_mysql_stmt> stmt;
+  for (int i = 0; i < num; ++i) {
+    const double tm1 = gettimeofday_double();
+    const int flags = 0;
+    if (connected == 0) {
+      if (!mysql_real_connect(db, mysql_host.c_str(),
+	mysql_user.c_str(), mysql_user.empty() ? 0 : mysql_passwd.c_str(),
+	mysql_dbname.c_str(), mysql_port, 0, flags)) {
+	err = "failed to connect: " + std::string(mysql_error(db));
+	if (verbose >= 1) {
+	  fprintf(stderr, "e=[%s]\n", err.c_str());
+	}
+	++err_cnt;
+	return;
+      }
+      arg.sh.increment_conn(1);
+    }
+    int r = 0;
+    if (connected == 0 && use_handler) {
+      const char *const q = "handler hstest_table1 open";
+      r = mysql_real_query(db, q, strlen(q));
+      if (r != 0) {
+	err = 1;
+      }
+    }
+    if (connected == 0 && ssps) {
+      stmt.reset(new auto_mysql_stmt(db));
+      const char *const q = "select v from hstest_table1 where k = ?";
+      r = mysql_stmt_prepare(*stmt, q, strlen(q));
+      if (r != 0) {
+	fprintf(stderr, "ssps err\n");
+	++err_cnt;
+	return;
+      }
+    }
+    connected = 1;
+    std::string result_str;
+    unsigned int err = 0;
+    unsigned int num_flds = 0, num_affected_rows = 0;
+    int got_data = 0;
+    char buf_query[16384];
+    int buf_query_len = 0;
+    int k = 0, v = 0;
+    {
+      double kf = 0, vf = 0;
+      drand48_r(&randbuf, &kf);
+      drand48_r(&randbuf, &vf);
+      k = int(kf * tablesize);
+      v = int(vf * tablesize);
+      #if 0
+      k = rand_r(&seed);
+      v = rand_r(&seed);
+      if (tablesize != 0) {
+	k %= tablesize;
+      }
+      #endif
+      if (op == 'G') {
+	if (use_handler) {
+	  buf_query_len = snprintf(buf_query, sizeof(buf_query),
+	    "handler hstest_table1 read `primary` = ( '%d' )", k);
+	    // TODO: moreflds
+	} else if (ssps) {
+	    //
+	} else {
+	  buf_query_len = snprintf(buf_query, sizeof(buf_query),
+	    "select %s from hstest_table1 where k = '%d'", flds.c_str(), k);
+	}
+      } else if (op == 'U') {
+	buf_query_len = snprintf(buf_query, sizeof(buf_query),
+	  "update hstest_table1 set v = '%d_%d%s' where k = '%d'",
+	    v, k, suffix.c_str(), k);
+      } else if (op == 'R') {
+	buf_query_len = snprintf(buf_query, sizeof(buf_query),
+	  "replace into hstest_table1 values ('%d', 'v%d')", k, v);
+	  // TODO: moreflds
+      }
+    }
+    if (r == 0) {
+      if (ssps) {
+	MYSQL_BIND bind[1] = { };
+	bind[0].buffer_type = MYSQL_TYPE_LONG;
+	bind[0].buffer = (char *)&k;
+	bind[0].is_null = 0;
+	bind[0].length = 0;
+	if (mysql_stmt_bind_param(*stmt, bind)) {
+	  fprintf(stderr, "err: %s\n", mysql_stmt_error(*stmt));
+	  ++err_cnt;
+	  return;
+	}
+	r = mysql_stmt_execute(*stmt);
+	// fprintf(stderr, "stmt exec\n");
+      } else {
+	r = mysql_real_query(db, buf_query, buf_query_len);
+	// fprintf(stderr, "real query\n");
+      }
+      ++query_cnt;
+    }
+    if (r != 0) {
+      err = 1;
+    } else if (ssps) {
+      if (verbose >= 0) {
+	char resbuf[1024];
+	unsigned long res_len = 0;
+	MYSQL_BIND bind[1] = { };
+	bind[0].buffer_type = MYSQL_TYPE_STRING;
+	bind[0].buffer = resbuf;
+	bind[0].buffer_length = sizeof(resbuf);
+	bind[0].length = &res_len;
+	if (mysql_stmt_bind_result(*stmt, bind)) {
+	  fprintf(stderr, "err: %s\n", mysql_stmt_error(*stmt));
+	  ++err_cnt;
+	  return;
+	}
+	if (mysql_stmt_fetch(*stmt)) {
+	  fprintf(stderr, "err: %s\n", mysql_stmt_error(*stmt));
+	  ++err_cnt;
+	  return;
+	}
+	if (!result_str.empty()) {
+	  result_str += " ";
+	}
+	result_str += std::string(resbuf, res_len);
+	// fprintf(stderr, "SSPS RES: %s\n", result_str.c_str());
+	got_data = 1;
+      } else {
+	got_data = 1;
+      }
+    } else {
+      auto_mysql_res res(db);
+      if (res != 0) {
+	if (verbose >= 0) {
+	  num_flds = mysql_num_fields(res);
+	  MYSQL_ROW row = 0;
+	  while ((row = mysql_fetch_row(res)) != 0) {
+	    got_data = 1;
+	    unsigned long *const lengths = mysql_fetch_lengths(res);
+	    if (verbose >= 2) {
+	      for (unsigned int i = 0; i < num_flds; ++i) {
+		if (!result_str.empty()) {
+		  result_str += " ";
+		}
+		result_str += std::string(row[i], lengths[i]);
+	      }
+	    }
+	  }
+	} else {
+	  got_data = 1;
+	}
+      } else {
+	if (mysql_field_count(db) == 0) {
+	  num_affected_rows = mysql_affected_rows(db);
+	} else {
+	  err = 1;
+	}
+      }
+    }
+    if (verbose >= 2 || (verbose >= 1 && err != 0)) {
+      if (err) {
+	++err_cnt;
+	const char *const errstr = mysql_error(db);
+	fprintf(stderr, "e=[%s] a=%u q=[%s]\n", errstr,
+	  num_affected_rows, buf_query);
+      } else {
+	fprintf(stderr, "a=%u q=[%s] r=[%s]\n", num_affected_rows, buf_query,
+	  result_str.c_str());
+      }
+    }
+    if (err == 0) {
+      ++io_success_count;
+      if (num_affected_rows > 0 || got_data > 0) {
+	++op_success_count;
+      } else {
+	if (verbose >= 1) {
+	  fprintf(stderr, "k=%d numaff=%u gotdata=%d\n",
+	    k, num_affected_rows, got_data);
+	}
+      }
+      arg.sh.increment_count();
+    }
+    if (!keep_connection) {
+      if (stmt.get() != 0) {
+	stmt.reset();
+      }
+      db.reset();
+      connected = 0;
+    }
+    const double tm2 = gettimeofday_double();
+    set_timing(tm2 - tm1);
+    sleep_if();
+    if (sched_flag) {
+      sched_yield();
+    }
+  }
+  if (verbose >= 1) {
+    fprintf(stderr, "thread finished (error_count=%llu)\n", err_cnt);
+  }
+}
+
+void
+hstest_thread::test_10(int test_num)
+{
+  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
+  unsigned int seed = time(0) + arg.id + 1;
+  seed ^= arg.sh.conf.get_int("seed_xor", 0);
+  drand48_data randbuf;
+  srand48_r(seed, &randbuf);
+  std::string err;
+  int keepconn_count = 0;
+  const char op = arg.sh.op;
+  const int verbose = arg.sh.conf.get_int("verbose", 1);
+  const std::string suffix = arg.sh.conf.get_str("value_suffix", "upd");
+  const int tablesize = arg.sh.conf.get_int("tablesize", 10000);
+  const int firstkey = arg.sh.conf.get_int("firstkey", 0);
+  const int sched_flag = arg.sh.conf.get_int("sched", 0);
+  const int moreflds = arg.sh.conf.get_int("moreflds", 0);
+  const std::string dbname = arg.sh.conf.get_str("dbname", "hstest");
+  const std::string table = arg.sh.conf.get_str("table", "hstest_table1");
+  const std::string index = arg.sh.conf.get_str("index", "PRIMARY");
+  const std::string field = arg.sh.conf.get_str("field", "v");
+  const std::string moreflds_prefix = arg.sh.conf.get_str(
+    "moreflds_prefix", "column0123456789_");
+  const int dump = arg.sh.dump;
+  const int nodup = arg.sh.conf.get_int("nodup", 0);
+  std::string moreflds_str;
+  for (int i = 0; i < moreflds; ++i) {
+    char sbuf[1024];
+    snprintf(sbuf, sizeof(sbuf), ",%s%d", moreflds_prefix.c_str(), i);
+    moreflds_str += std::string(sbuf);
+  }
+  char wbuf[16384], rbuf[16384];
+  int wbuflen = 0;
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    int len = 0, rlen = 0, wlen = 0;
+    #if 0
+    const double tm1 = gettimeofday_double();
+    #endif
+    if (fd.get() < 0) {
+      if (socket_connect(fd, arg.sh.arg, err) != 0) {
+	fprintf(stderr, "connect: %d %s\n", errno, strerror(errno));
+	return;
+      }
+      len = snprintf(wbuf, sizeof(wbuf),
+	"P\t1\t%s\t%s\tPRIMARY\t%s%s\n", dbname.c_str(), table.c_str(),
+	  field.c_str(), moreflds_str.c_str());
+	/* pst_num, db, table, index, retflds */
+      wlen = write(fd.get(), wbuf, len);
+      if (len != wlen) {
+	fprintf(stderr, "write: %d %d\n", len, wlen);
+	return;
+      }
+      rlen = read(fd.get(), rbuf, sizeof(rbuf));
+      if (rlen <= 0 || rbuf[rlen - 1] != '\n') {
+	fprintf(stderr, "read: rlen=%d errno=%d\n", rlen, errno);
+	return;
+      }
+      if (rbuf[0] != '0') {
+	fprintf(stderr, "failed to open table\n");
+	return;
+      }
+      arg.sh.increment_conn(1);
+    }
+    const double tm1 = gettimeofday_double();
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      int k = 0, v = 0;
+      wbuflen = 0;
+      {
+	while (true) {
+	  double kf = 0, vf = 0;
+	  drand48_r(&randbuf, &kf);
+	  drand48_r(&randbuf, &vf);
+	  k = int(kf * tablesize) + firstkey;
+	  v = int(vf * tablesize) + firstkey;
+	  // k = rand_r(&seed);
+	  // v = rand_r(&seed); /* unused */
+	  #if 0
+	  if (tablesize != 0) {
+	    k &= tablesize;
+	  }
+	  #endif
+	  if (op == 'G') {
+	    wbuflen = snprintf(wbuf, sizeof(wbuf), "1\t=\t1\t%d\n", k);
+	  } else if (op == 'U') {
+	    wbuflen = snprintf(wbuf, sizeof(wbuf),
+	      "1\t=\t1\t%d\t1\t0\tU\t%d_%d%s\n", k, v, k, suffix.c_str());
+	  }
+	  if (k - firstkey < arg.sh.keygen_size) {
+	    volatile char *const ptr = arg.sh.keygen + (k - firstkey);
+	    // int oldv = __sync_fetch_and_or(ptr, 1);
+	    int oldv = *ptr;
+	    *ptr += 1;
+	    if (nodup && oldv != 0) {
+	      if (dump) {
+		fprintf(stderr, "retry\n");
+	      }
+	      continue;
+	    }
+	  } else {
+	    if (nodup) {
+	      if (dump) {
+		fprintf(stderr, "retry2\n");
+	      }
+	      continue;
+	    }
+	  }
+	  break;
+	}
+      }
+      wlen = write(fd.get(), wbuf, wbuflen);
+      if (wlen != wbuflen) {
+	fprintf(stderr, "write: %d %d\n", wbuflen, wlen);
+	return;
+      }
+    }
+    size_t read_cnt = 0;
+    size_t read_pos = 0;
+    while (read_cnt < arg.sh.pipe) {
+      rlen = read(fd.get(), rbuf + read_pos, sizeof(rbuf) - read_pos);
+      if (rlen <= 0) {
+	fprintf(stderr, "read: %d\n", rlen);
+	return;
+      }
+      read_pos += rlen;
+      while (true) {
+	const char *const nl = static_cast<const char *>(memchr(rbuf, '\n',
+	  read_pos));
+	if (nl == 0) {
+	  break;
+	}
+	++read_cnt;
+	++io_success_count;
+	const char *t1 = static_cast<const char *>(memchr(rbuf, '\t',
+	  nl - rbuf));
+	if (t1 == 0) {
+	  fprintf(stderr, "error \n");
+	  break;
+	}
+	++t1;
+	const char *t2 = static_cast<const char *>(memchr(t1, '\t',
+	  nl - t1));
+	if (t2 == 0) {
+	  if (verbose > 1) {
+	    fprintf(stderr, "key: notfound \n");
+	  }
+	  break;
+	}
+	++t2;
+	if (t1 == rbuf + 2 && rbuf[0] == '0') {
+	  if (op == 'G') {
+	    ++op_success_count;
+	    arg.sh.increment_count();
+	  } else if (op == 'U') {
+	    const char *t3 = t2;
+	    while (t3 != nl && t3[0] >= 0x10) {
+	      ++t3;
+	    }
+	    if (t3 != t2 + 1 || t2[0] != '1') {
+	      const std::string mess(t2, t3);
+	      fprintf(stderr, "mod: %s\n", mess.c_str());
+	    } else {
+	      ++op_success_count;
+	      arg.sh.increment_count();
+	      if (arg.sh.dump && arg.sh.pipe == 1) {
+		fwrite(wbuf, wbuflen, 1, stderr);
+	      }
+	    }
+	  }
+	} else {
+	  const char *t3 = t2;
+	  while (t3 != nl && t3[0] >= 0x10) {
+	    ++t3;
+	  }
+	  const std::string mess(t2, t3);
+	  fprintf(stderr, "err: %s\n", mess.c_str());
+	}
+	const size_t rest_size = rbuf + read_pos - (nl + 1);
+	if (rest_size != 0) {
+	  memmove(rbuf, nl + 1, rest_size);
+	}
+	read_pos = rest_size;
+      }
+    }
+    if (!keep_connection) {
+      fd.reset();
+      arg.sh.increment_conn(-1);
+    } else if (keep_connection > 1 && ++keepconn_count > keep_connection) {
+      keepconn_count = 0;
+      fd.reset();
+      arg.sh.increment_conn(-1);
+    }
+    const double tm2 = gettimeofday_double();
+    set_timing(tm2 - tm1);
+    sleep_if();
+    if (sched_flag) {
+      sched_yield();
+    }
+  }
+  if (dump) {
+    fprintf(stderr, "done\n");
+  }
+}
+
+void
+hstest_thread::sleep_if()
+{
+  if (arg.sh.usleep) {
+    struct timespec ts = {
+      arg.sh.usleep / 1000000,
+      (arg.sh.usleep % 1000000) * 1000
+    };
+    nanosleep(&ts, 0);
+  }
+}
+
+void
+hstest_thread::set_timing(double time_spent)
+{
+  response_min = std::min(response_min, time_spent);
+  response_max = std::max(response_max, time_spent);
+  response_sum += time_spent;
+  if (op_success_count != 0) {
+    response_avg = response_sum / op_success_count;
+  }
+}
+
+void
+hstest_thread::test_11(int test_num)
+{
+  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
+  const int tablesize = arg.sh.conf.get_int("tablesize", 0);
+  unsigned int seed = arg.id;
+  seed ^= arg.sh.conf.get_int("seed_xor", 0);
+  std::string err;
+  hstcpcli_ptr cli;
+  for (size_t i = 0; i < arg.sh.loop; ++i) {
+    if (cli.get() == 0) {
+      cli = hstcpcli_i::create(arg.sh.arg);
+      cli->request_buf_open_index(0, "hstest", "hstest_table1", "", "v");
+	/* pst_num, db, table, index, retflds */
+      if (cli->request_send() != 0) {
+	fprintf(stderr, "reuqest_send: %s\n", cli->get_error().c_str());
+	return;
+      }
+      size_t num_flds = 0;
+      if (cli->response_recv(num_flds) != 0) {
+	fprintf(stderr, "reuqest_recv: %s\n", cli->get_error().c_str());
+	return;
+      }
+      cli->response_buf_remove();
+    }
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      char buf[256];
+      int k = 0, v = 0, len = 0;
+      {
+	k = rand_r(&seed);
+	v = rand_r(&seed); /* unused */
+	if (tablesize != 0) {
+	  k &= tablesize;
+	}
+	len = snprintf(buf, sizeof(buf), "%d", k);
+      }
+      const string_ref key(buf, len);
+      const string_ref op("=", 1);
+      cli->request_buf_exec_generic(0, op, &key, 1, 1, 0, string_ref(), 0, 0);
+    }
+    if (cli->request_send() != 0) {
+      fprintf(stderr, "reuqest_send: %s\n", cli->get_error().c_str());
+      return;
+    }
+    size_t read_cnt = 0;
+    for (size_t j = 0; j < arg.sh.pipe; ++j) {
+      size_t num_flds = 0;
+      if (cli->response_recv(num_flds) != 0) {
+	fprintf(stderr, "reuqest_recv: %s\n", cli->get_error().c_str());
+	return;
+      }
+      {
+	++read_cnt;
+	++io_success_count;
+	arg.sh.increment_count();
+	{
+	  ++op_success_count;
+	}
+      }
+      cli->response_buf_remove();
+    }
+    if (!keep_connection) {
+      cli.reset();
+    }
+  }
+}
+
+void
+hstest_thread::test_watch()
+{
+  const int timelimit = arg.sh.conf.get_int("timelimit", 0);
+  const int timelimit_offset = timelimit / 2;
+  int loop = 0;
+  double t1 = 0, t2 = 0;
+  size_t cnt_t1 = 0, cnt_t2 = 0;
+  size_t prev_cnt = 0;
+  double now_f = 0;
+  while (true) {
+    sleep(1);
+    const size_t cnt = arg.sh.count;
+    const size_t df = cnt - prev_cnt;
+    prev_cnt = cnt;
+    const double now_prev = now_f;
+    now_f = gettimeofday_double();
+    if (now_prev != 0) {
+      const double rps = static_cast<double>(df) / (now_f - now_prev);
+      fprintf(stderr, "now: %zu cntdiff: %zu tdiff: %f rps: %f\n",
+        static_cast<size_t>(now_f), df, now_f - now_prev, rps);
+    }
+    if (timelimit != 0) {
+      if (arg.sh.wait_conn == 0 || arg.sh.conn_count >= arg.sh.wait_conn) {
+	++loop;
+      }
+      if (loop == timelimit_offset) {
+        t1 = gettimeofday_double();
+        cnt_t1 = cnt;
+	arg.sh.enable_timing = 1;
+	fprintf(stderr, "start timing\n");
+      } else if (loop == timelimit_offset + timelimit) {
+        t2 = gettimeofday_double();
+        cnt_t2 = cnt;
+        const size_t cnt_diff = cnt_t2 - cnt_t1;
+        const double tdiff = t2 - t1;
+        const double qps = cnt_diff / (tdiff != 0 ? tdiff : 1);
+        fprintf(stderr, "(%f: %zu, %f: %zu), %10.5f qps\n",
+          t1, cnt_t1, t2, cnt_t2, qps);
+	size_t keycnt = 0;
+	for (int i = 0; i < arg.sh.keygen_size; ++i) {
+	  if (arg.sh.keygen[i]) {
+	    ++keycnt;
+	  }
+	}
+	fprintf(stderr, "keygen=%zu\n", keycnt);
+	break;
+      }
+    }
+  }
+#if 0
+  int loop = 0;
+  double t1 = 0, t2 = 0;
+  size_t cnt_t1 = 0, cnt_t2 = 0;
+  size_t prev_cnt = 0;
+  while (true) {
+    sleep(1);
+    const size_t cnt = arg.sh.count;
+    const size_t df = cnt - prev_cnt;
+    prev_cnt = cnt;
+    const size_t now = time(0);
+    fprintf(stderr, "%zu %zu\n", now, df);
+    if (timelimit != 0) {
+      ++loop;
+      if (loop == timelimit_offset) {
+	t1 = gettimeofday_double();
+	cnt_t1 = cnt;
+      } else if (loop == timelimit_offset + timelimit) {
+	t2 = gettimeofday_double();
+	cnt_t2 = cnt;
+	const size_t cnt_diff = cnt_t2 - cnt_t1;
+	const double tdiff = t2 - t1;
+	const double qps = cnt_diff / (tdiff != 0 ? tdiff : 1);
+	fprintf(stderr, "(%f: %zu, %f: %zu), %10.5f qps\n",
+	  t1, cnt_t1, t2, cnt_t2, qps);
+	size_t keycnt = 0;
+	for (int i = 0; i < arg.sh.keygen_size; ++i) {
+	  if (arg.sh.keygen[i]) {
+	    ++keycnt;
+	  }
+	}
+	fprintf(stderr, "keygen=%zu\n", keycnt);
+	_exit(0);
+      }
+    }
+  }
+#endif
+}
+
+void
+hstest_thread::test_12(int test_num)
+{
+  /* NOTE: num_threads should be 1 */
+  /* create table hstest
+   * ( k varchar(255) not null, v varchar(255) not null, primary key(k))
+   * engine = innodb; */
+  mysqltest_thread_initobj initobj;
+  auto_mysql db;
+  std::string err;
+  unsigned long long err_cnt = 0;
+  unsigned long long query_cnt = 0;
+  #if 0
+  my_bool reconnect = 0;
+  if (mysql_options(db, MYSQL_OPT_RECONNECT, &reconnect) != 0) {
+    err = "mysql_options() failed";
+    ++err_cnt;
+    return;
+  }
+  #endif
+  const std::string mysql_host = arg.sh.conf.get_str("host", "localhost");
+  const int mysql_port = arg.sh.conf.get_int("mysqlport", 3306);
+  const unsigned int num = arg.sh.loop;
+  const size_t pipe = arg.sh.pipe;
+  const std::string mysql_user = arg.sh.conf.get_str("mysqluser", "root");
+  const std::string mysql_passwd = arg.sh.conf.get_str("mysqlpass", "");
+  const std::string mysql_dbname = arg.sh.conf.get_str("db", "hstest");
+  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
+  const int verbose = arg.sh.conf.get_int("verbose", 1);
+  const int use_handler = arg.sh.conf.get_int("handler", 0);
+  int connected = 0;
+  unsigned int k = 0;
+  string_buffer buf;
+  for (unsigned int i = 0; i < num; ++i) {
+    const int flags = 0;
+    if (connected == 0 && !mysql_real_connect(db, mysql_host.c_str(),
+      mysql_user.c_str(), mysql_user.empty() ? 0 : mysql_passwd.c_str(),
+      mysql_dbname.c_str(), mysql_port, 0, flags)) {
+      err = "failed to connect: " + std::string(mysql_error(db));
+      if (verbose >= 1) {
+	fprintf(stderr, "e=[%s]\n", err.c_str());
+      }
+      ++err_cnt;
+      return;
+    }
+    int r = 0;
+    if (connected == 0 && use_handler) {
+      const char *const q = "handler hstest open";
+      r = mysql_real_query(db, q, strlen(q));
+      if (r != 0) {
+	err = 1;
+      }
+    }
+    connected = 1;
+    std::string result_str;
+    unsigned int err = 0;
+    unsigned int num_flds = 0, num_affected_rows = 0;
+    int got_data = 0;
+    buf.clear();
+    buf.append_literal("insert into hstest values ");
+    for (size_t j = 0; j < pipe; ++j) {
+      const unsigned int v = ~k;
+      if (j != 0) {
+	buf.append_literal(",");
+      }
+      char *wp = buf.make_space(64);
+      int buf_query_len = snprintf(wp, 64, "('k%u', 'v%u')", k, v);
+      buf.space_wrote(buf_query_len);
+      ++k;
+    }
+    if (r == 0) {
+      r = mysql_real_query(db, buf.begin(), buf.size());
+      ++query_cnt;
+    }
+    if (r != 0) {
+      err = 1;
+    } else {
+      auto_mysql_res res(db);
+      if (res != 0) {
+	if (verbose >= 0) {
+	  num_flds = mysql_num_fields(res);
+	  MYSQL_ROW row = 0;
+	  while ((row = mysql_fetch_row(res)) != 0) {
+	    got_data = 1;
+	    unsigned long *const lengths = mysql_fetch_lengths(res);
+	    if (verbose >= 2) {
+	      for (unsigned int i = 0; i < num_flds; ++i) {
+		if (!result_str.empty()) {
+		  result_str += " ";
+		}
+		result_str += std::string(row[i], lengths[i]);
+	      }
+	    }
+	  }
+	}
+      } else {
+	if (mysql_field_count(db) == 0) {
+	  num_affected_rows = mysql_affected_rows(db);
+	} else {
+	  err = 1;
+	}
+      }
+    }
+    if (verbose >= 2 || (verbose >= 1 && err != 0)) {
+      if (err) {
+	++err_cnt;
+	const char *const errstr = mysql_error(db);
+	fprintf(stderr, "e=[%s] a=%u q=[%s]\n", errstr,
+	  num_affected_rows, std::string(buf.begin(), buf.size()).c_str());
+      } else {
+	fprintf(stderr, "a=%u q=[%s] r=[%s]\n", num_affected_rows,
+	  std::string(buf.begin(), buf.size()).c_str(),
+	  result_str.c_str());
+      }
+    }
+    if (err == 0) {
+      ++io_success_count;
+      if (num_affected_rows > 0 || got_data > 0) {
+	++op_success_count;
+      }
+      arg.sh.increment_count(pipe);
+    }
+    if (!keep_connection) {
+      db.reset();
+      connected = 0;
+    }
+  }
+  if (verbose >= 1) {
+    fprintf(stderr, "thread finished (error_count=%llu)\n", err_cnt);
+  }
+}
+
+void
+hstest_thread::test_21(int num)
+{
+  /* fsync test */
+  unsigned int id = arg.id;
+  std::string err;
+  #if 0
+  if (socket_connect(fd, arg.sh.arg, err) != 0) {
+    fprintf(stderr, "connect: %d %s\n", errno, strerror(errno));
+    return;
+  }
+  #endif
+  auto_file logfd;
+  char fname[1024];
+  snprintf(fname, sizeof(fname), "synctest_%u", id);
+  int open_flags = O_WRONLY | O_CREAT | O_TRUNC | O_APPEND;
+  logfd.reset(open(fname, open_flags, 0644));
+  if (logfd.get() < 0) {
+    fprintf(stderr, "open: %s: %d %s\n", fname, errno, strerror(errno));
+    return;
+  }
+  char buf[1024];
+  unsigned long long count = 0;
+  while (true) {
+    snprintf(buf, sizeof(buf), "%u %llu\n", id, count);
+    const size_t len = strlen(buf);
+    if (write(logfd.get(), buf, len) != (ssize_t)len) {
+      fprintf(stderr, "write: %s: %d %s\n", fname, errno, strerror(errno));
+      return;
+    }
+    #if 0
+    if (write(fd.get(), buf, len) != (ssize_t)len) {
+      fprintf(stderr, "write(sock): %d %s\n", errno, strerror(errno));
+      return;
+    }
+    #endif
+    if (fdatasync(logfd.get()) != 0) {
+      fprintf(stderr, "fsync: %s: %d %s\n", fname, errno, strerror(errno));
+      return;
+    }
+    ++count;
+    ++op_success_count;
+    arg.sh.increment_count();
+  }
+}
+
+void
+hstest_thread::test_22(int num)
+{
+  /* dd if=/dev/zero of=dummy.dat bs=1024M count=100 */
+  unsigned int id = arg.id;
+  std::string err;
+  auto_file filefd;
+  char fname[1024];
+  snprintf(fname, sizeof(fname), "dummy.dat");
+  int open_flags = O_RDONLY | O_DIRECT;
+  filefd.reset(open(fname, open_flags, 0644));
+  if (filefd.get() < 0) {
+    fprintf(stderr, "open: %s: %d %s\n", fname, errno, strerror(errno));
+    return;
+  }
+  char buf_x[4096 * 2];
+  char *const buf = (char *)(size_t(buf_x + 4096) / 4096 * 4096);
+  unsigned long long count = 0;
+  drand48_data randbuf;
+  unsigned long long seed = time(0);
+  seed *= 10;
+  seed += id;
+  srand48_r(seed, &randbuf);
+  for (unsigned int i = 0; i < arg.sh.loop; ++i) {
+    double kf = 0;
+    drand48_r(&randbuf, &kf);
+    kf *= (209715200 / 1);
+    // fprintf(stderr, "v=%f\n", kf);
+    off_t v = static_cast<off_t>(kf);
+    v %= (209715200 / 1);
+    v *= (512 * 1);
+    const double tm1 = gettimeofday_double();
+    const ssize_t r = pread(filefd.get(), buf, (512 * 1), v);
+    const double tm2 = gettimeofday_double();
+    if (r < 0) {
+      fprintf(stderr, "pread: %s: %d %s\n", fname, errno, strerror(errno));
+      return;
+    }
+    ++count;
+    ++op_success_count;
+    arg.sh.increment_count();
+    set_timing(tm2 - tm1);
+  }
+}
+
+void
+hstest_thread::operator ()()
+{
+  if (arg.watch_flag) {
+    return test_watch();
+  }
+  int test_num = arg.sh.conf.get_int("test", 1);
+  if (test_num == 1) {
+    test_1();
+  } else if (test_num == 2 || test_num == 3) {
+    test_2_3(test_num);
+  } else if (test_num == 4 || test_num == 5) {
+    test_4_5(test_num);
+  } else if (test_num == 6) {
+    test_6(test_num);
+  } else if (test_num == 7) {
+    test_7(test_num);
+  } else if (test_num == 8) {
+    test_8(test_num);
+  } else if (test_num == 9) {
+    test_9(test_num);
+  } else if (test_num == 10) {
+    test_10(test_num);
+  } else if (test_num == 11) {
+    test_11(test_num);
+  } else if (test_num == 12) {
+    test_12(test_num);
+  } else if (test_num == 21) {
+    test_21(test_num);
+  } else if (test_num == 22) {
+    test_22(test_num);
+  }
+  const int halt = arg.sh.conf.get_int("halt", 0);
+  if (halt) {
+    fprintf(stderr, "thread halted\n");
+    while (true) {
+      sleep(100000);
+    }
+  }
+  fprintf(stderr, "thread finished\n");
+}
+
+int
+hstest_main(int argc, char **argv)
+{
+  ignore_sigpipe();
+  hstest_shared shared;
+  parse_args(argc, argv, shared.conf);
+  shared.conf["port"] = shared.conf["hsport"];
+  shared.arg.set(shared.conf);
+  shared.loop = shared.conf.get_int("num", 1000);
+  shared.pipe = shared.conf.get_int("pipe", 1);
+  shared.verbose = shared.conf.get_int("verbose", 1);
+  const int tablesize = shared.conf.get_int("tablesize", 0);
+  std::vector<char> keygen(tablesize);
+  shared.keygen = &keygen[0];
+  shared.keygen_size = tablesize;
+  shared.usleep = shared.conf.get_int("usleep", 0);
+  shared.dump = shared.conf.get_int("dump", 0);
+  shared.num_threads = shared.conf.get_int("num_threads", 10);
+  shared.wait_conn = shared.conf.get_int("wait_conn", 0);
+  const std::string op = shared.conf.get_str("op", "G");
+  if (op.size() > 0) {
+    shared.op = op[0];
+  }
+  #if 0
+  const int localdb_flag = shared.conf.get_int("local", 0);
+  if (localdb_flag) {
+    shared.localdb = database_i::create(shared.conf);
+  }
+  #endif
+  const int num_thrs = shared.num_threads;
+  typedef thread<hstest_thread> thread_type;
+  typedef std::auto_ptr<thread_type> thread_ptr;
+  typedef auto_ptrcontainer< std::vector<thread_type *> > thrs_type;
+  thrs_type thrs;
+  for (int i = 0; i < num_thrs; ++i) {
+    const hstest_thread::arg_type arg(i, shared, false);
+    thread_ptr thr(new thread<hstest_thread>(arg));
+    thrs.push_back_ptr(thr);
+  }
+  for (size_t i = 0; i < thrs.size(); ++i) {
+    thrs[i]->start();
+  }
+  thread_ptr watch_thread;
+  const int timelimit = shared.conf.get_int("timelimit", 0);
+  {
+    const hstest_thread::arg_type arg(0, shared, true);
+    watch_thread = thread_ptr(new thread<hstest_thread>(arg));
+    watch_thread->start();
+  }
+  size_t iocnt = 0, opcnt = 0;
+  double respmin = 999999, respmax = 0;
+  double respsum = 0;
+  if (timelimit != 0) {
+    watch_thread->join();
+  }
+  for (size_t i = 0; i < thrs.size(); ++i) {
+    if (timelimit == 0) {
+      thrs[i]->join();
+    }
+    iocnt += (*thrs[i])->io_success_count;
+    opcnt += (*thrs[i])->op_success_count;
+    respmin = std::min(respmin, (*thrs[i])->response_min);
+    respmax = std::max(respmax, (*thrs[i])->response_max);
+    respsum += (*thrs[i])->response_sum;
+  }
+  fprintf(stderr, "io_success_count=%zu op_success_count=%zu\n", iocnt, opcnt);
+  fprintf(stderr, "respmin=%f respmax=%f respsum=%f respavg=%f\n",
+    respmin, respmax, respsum, respsum / opcnt);
+  size_t keycnt = 0;
+  for (size_t i = 0; i < keygen.size(); ++i) {
+    if (keygen[i]) {
+      ++keycnt;
+    }
+  }
+  fprintf(stderr, "keycnt=%zu\n", keycnt);
+  _exit(0);
+  return 0;
+}
+
+};
+
+int
+main(int argc, char **argv)
+{
+  return dena::hstest_main(argc, argv);
+}
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest.pl'
--- HandlerSocket-Plugin-for-MySQL/client/hstest.pl	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest.pl	2011-04-12 04:16:24 +0000
@@ -0,0 +1,228 @@
+#!/usr/bin/perl
+
+# vim:sw=8:ai:ts=8
+
+use strict;
+use warnings;
+
+use DBI;
+use Net::HandlerSocket;
+
+my %conf = ();
+for my $i (@ARGV) {
+	my ($k, $v) = split(/=/, $i);
+	$conf{$k} = $v;
+}
+
+my $verbose = get_conf("verbose", 0);
+my $actions_str = get_conf("actions", "hsread");
+my $tablesize = get_conf("tablesize", 10000);
+my $db = get_conf("db", "hstest");
+my $table = get_conf("table", "hstest_table1");
+my $engine = get_conf("engine", "innodb");
+my $host = get_conf("host", "localhost");
+my $mysqlport = get_conf("mysqlport", 3306);
+my $mysqluser = get_conf("mysqluser", "root");
+my $mysqlpass = get_conf("mysqlpass", "");
+my $hsport = get_conf("hsport", 9999);
+my $loop = get_conf("loop", 10000);
+my $op = get_conf("op", "=");
+my $ssps = get_conf("ssps", 0);
+my $num_moreflds = get_conf("moreflds", 0);
+my $moreflds_prefix = get_conf("moreflds_prefix", "column0123456789_");
+my $keytype = get_conf("keytype", "varchar(32)");
+my $file = get_conf("file", undef);
+
+my $dsn = "DBI:mysql:database=;host=$host;port=$mysqlport"
+	. ";mysql_server_prepare=$ssps";
+my $dbh = DBI->connect($dsn, $mysqluser, $mysqlpass, { RaiseError => 1 });
+my $hsargs = { 'host' => $host, 'port' => $hsport };
+my $cli = new Net::HandlerSocket($hsargs);
+
+my @actions = split(/,/, $actions_str);
+for my $action (@actions) {
+	if ($action eq "table") {
+		print("TABLE $db.$table\n");
+		$dbh->do("drop database if exists $db");
+		$dbh->do("create database $db");
+		$dbh->do("use $db");
+		my $moreflds = get_createtbl_moreflds_str();
+		$dbh->do(
+			"create table $table (" .
+			"k $keytype primary key" .
+			",v varchar(32) not null" .
+			$moreflds .
+			") character set utf8 collate utf8_bin " .
+			"engine = $engine");
+	} elsif ($action eq "insert") {
+		print("INSERT $db.$table tablesize=$tablesize\n");
+		$dbh->do("use $db");
+		my $moreflds = get_insert_moreflds_str();
+		for (my $i = 0; $i < $tablesize; $i += 100) {
+			my $qstr = "insert into $db.$table values";
+			for (my $j = 0; $j < 100; ++$j) {
+				if ($j != 0) {
+					$qstr .= ",";
+				}
+				my $k = "" . ($i + $j);
+				my $v = "v" . int(rand(1000)) . ($i + $j);
+				$qstr .= "('$k', '$v'";
+				for (my $j = 0; $j < $num_moreflds; ++$j) {
+					$qstr .= ",'$j'";
+				}
+				$qstr .= ")";
+			}
+			$dbh->do($qstr);
+			print "$i/$tablesize\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "read") {
+		print("READ $db.$table op=$op loop=$loop\n");
+		$dbh->do("use $db");
+		my $moreflds = get_select_moreflds_str();
+		my $sth = $dbh->prepare(
+			"select k,v$moreflds from $db.$table where k = ?");
+		for (my $i = 0; $i < $loop; ++$i) {
+			my $k = "" . int(rand($tablesize));
+			# print "k=$k\n";
+			$sth->execute($k);
+			if ($verbose >= 10) {
+				print "RET:";
+				while (my $ref = $sth->fetchrow_arrayref()) {
+					my $rk = $ref->[0];
+					my $rv = $ref->[1];
+					print " $rk $rv";
+				}
+				print "\n";
+			}
+			print "$i/$loop\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "hsinsert") {
+		print("HSINSERT $db.$table tablesize=$tablesize\n");
+		$cli->open_index(1, $db, $table, '', 'k,v');
+		for (my $i = 0; $i < $tablesize; ++$i) {
+			my $k = "" . $i;
+			my $v = "v" . int(rand(1000)) . $i;
+			my $r = $cli->execute_insert(1, [ $k, $v ]);
+			if ($r->[0] != 0) {
+				die;
+			}
+			print "$i/$tablesize\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "hsread") {
+		print("HSREAD $db.$table op=$op loop=$loop\n");
+		my $moreflds = get_select_moreflds_str();
+		$cli->open_index(1, $db, $table, '', "k,v$moreflds");
+		for (my $i = 0; $i < $loop; ++$i) {
+			my $k = "" . int(rand($tablesize));
+			# print "k=$k\n";
+			my $r = $cli->execute_find(1, $op, [ $k ], 1, 0);
+			if ($verbose >= 10) {
+				my $len = scalar(@{$r});
+				print "LEN=$len";
+				for my $e (@{$r}) {
+					print " [$e]";
+				}
+				print "\n";
+			}
+			print "$i/$loop\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "hsupdate") {
+		my $vbase = "v" . int(rand(1000));
+		print("HSUPDATE $db.$table op=$op loop=$loop vbase=$vbase\n");
+		$cli->open_index(1, $db, $table, '', 'v');
+		for (my $i = 0; $i < $loop; ++$i) {
+			my $k = "" . int(rand($tablesize));
+			my $v = $vbase . $i;
+			print "k=$k v=$v\n";
+			my $r = $cli->execute_update(1, $op, [ $k ], 1, 0,
+				[ $v ]);
+			if ($verbose >= 10) {
+				print "UP k=$k v=$v\n";
+			}
+			print "$i/$loop\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "hsdelete") {
+		print("HSDELETE $db.$table op=$op loop=$loop\n");
+		$cli->open_index(1, $db, $table, '', '');
+		for (my $i = 0; $i < $loop; ++$i) {
+			my $k = "" . int(rand($tablesize));
+			print "k=$k\n";
+			my $r = $cli->execute_delete(1, $op, [ $k ], 1, 0);
+			if ($verbose >= 10) {
+				print "DEL k=$k\n";
+			}
+			print "$i/$loop\n" if $i % 1000 == 0;
+		}
+	} elsif ($action eq "verify") {
+		verify_do();
+	}
+}
+
+sub verify_do {
+	my ($fail_cnt, $ok_cnt) = (0, 0);
+	my $sth = $dbh->prepare("select v from $db.$table where k = ?");
+	use FileHandle;
+	my $fh = new FileHandle($file, "r");
+	while (my $line = <$fh>) {
+		chomp($line);
+		my @vec = split(/\t/, $line);
+		my $k = $vec[3];
+		my $v = $vec[7];
+		next if (!defined($k) || !defined($v));
+		# print "$k $v\n";
+		$sth->execute($k);
+		my $aref = $sth->fetchrow_arrayref();
+		if (!defined($aref)) {
+			print "FAILED: $k notfound\n";
+			++$fail_cnt;
+		} else {
+			my $gv = $aref->[0];
+			if ($gv ne $v) {
+				print "FAILED: $k got=$gv expected=$v\n";
+				++$fail_cnt;
+			} else {
+				print "OK: $k $v $gv\n" if $verbose >= 10;
+				++$ok_cnt;
+			}
+		}
+	}
+	print "OK=$ok_cnt FAIL=$fail_cnt\n";
+}
+
+sub get_conf {
+	my ($key, $def) = @_;
+	my $val = $conf{$key};
+	if ($val) {
+		print "$key=$val\n";
+	} else {
+		$val = $def;
+		$def ||= '';
+		print "$key=$def(default)\n";
+	}
+	return $val;
+}
+
+sub get_createtbl_moreflds_str {
+	my $s = "";
+	for (my $j = 0; $j < $num_moreflds; ++$j) {
+		$s .= ",$moreflds_prefix$j varchar(30)";
+	}
+	return $s;
+}
+
+sub get_select_moreflds_str {
+	my $s = "";
+	for (my $i = 0; $i < $num_moreflds; ++$i) {
+		$s .= ",$moreflds_prefix$i";
+	}
+	return $s;
+}
+
+sub get_insert_moreflds_str {
+	my $s = "";
+	for (my $i = 0; $i < $num_moreflds; ++$i) {
+		$s .= ",?";
+	}
+	return $s;
+}
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest_hs.sh'
--- HandlerSocket-Plugin-for-MySQL/client/hstest_hs.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest_hs.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,4 @@
+#!/bin/bash
+
+exec ./hstest test=10 tablesize=10000 host=localhost hsport=9998 num=10000000 \
+	num_threads=100 timelimit=10 $@

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest_hs_more50.sh'
--- HandlerSocket-Plugin-for-MySQL/client/hstest_hs_more50.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest_hs_more50.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,4 @@
+#!/bin/bash
+
+exec ./hstest test=10 key_mask=9999 host=localhost port=9998 num=10000000 \
+	num_threads=100 timelimit=10 moreflds=50 $@

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest_md.sh'
--- HandlerSocket-Plugin-for-MySQL/client/hstest_md.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest_md.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,7 @@
+#!/bin/bash
+
+./hstest test=7 key_mask=9999 host=localhost port=11211 num=10000 \
+	num_threads=10 timelimit=10 op=R $@
+./hstest test=7 key_mask=9999 host=localhost port=11211 num=1000000 \
+	num_threads=100 timelimit=10 op=G $@
+

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest_my.sh'
--- HandlerSocket-Plugin-for-MySQL/client/hstest_my.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest_my.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,3 @@
+#!/bin/bash
+exec ./hstest test=9 tablesize=9999 host=localhost mysqlport=3306 num=1000000 \
+	num_threads=100 verbose=1 timelimit=10 $@

=== added file 'HandlerSocket-Plugin-for-MySQL/client/hstest_my_more50.sh'
--- HandlerSocket-Plugin-for-MySQL/client/hstest_my_more50.sh	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/client/hstest_my_more50.sh	2011-04-12 04:16:24 +0000
@@ -0,0 +1,3 @@
+#!/bin/bash
+exec ./hstest test=9 key_mask=9999 host=localhost port=3306 num=1000000 \
+	num_threads=100 verbose=1 timelimit=10 moreflds=50 $@

=== added file 'HandlerSocket-Plugin-for-MySQL/configure.ac'
--- HandlerSocket-Plugin-for-MySQL/configure.ac	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/configure.ac	2011-04-12 04:16:24 +0000
@@ -0,0 +1,134 @@
+#                                               -*- Autoconf -*-
+# Process this file with autoconf to produce a configure script.
+
+#AC_PREREQ([2.63b])
+AC_INIT([handlersocket-plugin], [1.0.6], [https://github.com/ahiguti/HandlerSocket-Plugin-for-MySQL/issues])
+AC_CONFIG_HEADERS([config.h])
+AM_INIT_AUTOMAKE([-Wall -Werror foreign])
+AC_CONFIG_SRCDIR([libhsclient/fatal.cpp])
+AC_CONFIG_MACRO_DIR([m4])
+
+AC_PROG_CC
+AC_PROG_CXX
+AC_PROG_CPP
+AC_PROG_LIBTOOL
+
+AC_DEFUN([CONFIG_OPTION_MYSQL],[
+  AC_MSG_CHECKING([mysql source])
+
+  MYSQL_SOURCE_VERSION=
+  MYSQL_INC=
+  ac_mysql_source_dir=
+  AC_ARG_WITH([mysql-source],
+    [AS_HELP_STRING([--with-mysql-source=PATH], [MySQL source directory PATH])],
+    [
+      ac_mysql_source_dir=`cd $withval && pwd`
+      if test -f "$ac_mysql_source_dir/sql/handler.h" ; then
+        MYSQL_INC="-I$ac_mysql_source_dir/sql"
+        MYSQL_INC="$MYSQL_INC -I$ac_mysql_source_dir/include"
+        MYSQL_INC="$MYSQL_INC -I$ac_mysql_source_dir/regex"
+        MYSQL_INC="$MYSQL_INC -I$ac_mysql_source_dir"
+        AC_SUBST(MYSQL_INC)
+        if test -f "$ac_mysql_source_dir/VERSION"; then
+          source "$ac_mysql_source_dir/VERSION"
+          MYSQL_SOURCE_VERSION="$MYSQL_VERSION_MAJOR.$MYSQL_VERSION_MINOR.$MYSQL_VERSION_PATCH"
+        else
+          if test -f "$ac_mysql_source_dir/configure.in"; then
+            MYSQL_SOURCE_VERSION=`cat $ac_mysql_source_dir/configure.in | grep "\[[MySQL Server\]]" | sed -e "s|.*\([[0-9]]\+\.[[0-9]]\+\.[[0-9]]\+[[0-9a-zA-Z\_\-]]*\).*|\1|"`
+          else
+            AC_MSG_ERROR([invalid MySQL source directory: $ac_mysql_source_dir])
+          fi
+        fi
+        AC_MSG_RESULT([yes: Using $ac_mysql_source_dir, version $MYSQL_SOURCE_VERSION])
+      else
+        AC_MSG_ERROR([invalid MySQL source directory: $ac_mysql_source_dir])
+      fi
+    ],
+    [AC_MSG_ERROR([--with-mysql-source=PATH is required for standalone build])]
+  )
+
+  MYSQL_BIN_VERSION=
+  ac_mysql_config=
+  AC_ARG_WITH([mysql-bindir],
+    [AS_HELP_STRING([--with-mysql-bindir=PATH], [MySQL binary directory PATH. This should be the directory where mysql_config is located.])],
+    [
+      mysql_bin_dir=`cd $withval 2> /dev/null && pwd || echo ""`
+      ac_mysql_config="$mysql_bin_dir/mysql_config"
+    ],
+    [
+      AC_PATH_PROG([ac_mysql_config], [mysql_config])
+    ]
+  )
+
+  AC_MSG_CHECKING([mysql binary])
+  if test ! -x "$ac_mysql_config" ; then
+    AC_MSG_ERROR([mysql_config not found! You have to specify the directory where mysql_config resides to --with-mysql-bindir=PATH.])
+  fi
+
+  MYSQL_CFLAGS_ADD=`"$ac_mysql_config" --cflags`
+  MYSQL_CFLAGS="$MYSQL_CFLAGS $MYSQL_CFLAGS_ADD -DFORCE_DBUG_OFF"
+    # FIXME
+  AC_SUBST(MYSQL_CFLAGS)
+
+  MYSQL_BIN_VERSION=`"$ac_mysql_config" --version`
+  AC_MSG_RESULT([yes: Using $ac_mysql_config, version $MYSQL_BIN_VERSION])
+
+  MYSQL_LIB=`"$ac_mysql_config" --libs_r`
+  LIB_DIR=`echo $MYSQL_LIB | sed -e "s|.*-L/|/|" | sed -e "s| .*||"`
+    # FIXME
+  if test a`basename "$LIB_DIR"` = amysql ; then
+    MYSQL_LIB="-L`dirname $LIB_DIR` $MYSQL_LIB" 
+      # FIXME
+  fi
+  AC_SUBST(MYSQL_LIB)
+
+  if test a$MYSQL_SOURCE_VERSION != a$MYSQL_BIN_VERSION ; then
+    AC_MSG_ERROR([MySQL source version does not match MySQL binary version])
+  fi
+
+  AC_MSG_CHECKING([mysql plugin dir])
+  ac_mysql_plugin_dir=
+  AC_ARG_WITH([mysql-plugindir],
+    [AS_HELP_STRING([--with-mysql-plugindir=PATH], [MySQL plugin directory where handlersocket.so to be copied])],
+    [
+      ac_mysql_plugin_dir=`cd $withval && pwd`
+      if test -d "$ac_mysql_plugin_dir/" ; then
+        PLUGIN_DIR="$ac_mysql_plugin_dir"
+        AC_SUBST(PLUGIN_DIR)
+        AC_MSG_RESULT([yes: Using $ac_mysql_plugin_dir])
+      else
+        AC_MSG_ERROR([invalid MySQL plugin directory : $ac_mysql_plugin_dir])
+      fi
+    ],
+    [
+      LIB_DIR_TMP=`"$ac_mysql_config" --plugindir`
+      if test ! -d "$LIB_DIR_TMP"; then
+        LIB_DIR_TMP=`"$ac_mysql_config" --libs_r | sed -e "s|.*-L/|/|" | sed -e "s| .*||"`/plugin
+          # FIXME
+      fi
+      ac_mysql_plugin_dir=$LIB_DIR_TMP
+      PLUGIN_DIR="$ac_mysql_plugin_dir"
+      AC_SUBST(PLUGIN_DIR)
+      AC_MSG_RESULT([--with-mysql-plugindir was not set. Using $ac_mysql_plugin_dir])
+    ]
+  )
+])
+
+HANDLERSOCKET_SUBDIRS="libhsclient"
+AC_ARG_ENABLE(handlersocket_server,
+  [  --enable-handlersocket-server    build HandlerSocket plugin (defalut=yes)])
+if test "$enable_handlersocket_server" != "no"; then
+  CONFIG_OPTION_MYSQL
+  HANDLERSOCKET_SUBDIRS="libhsclient handlersocket client"
+fi
+AC_SUBST(HANDLERSOCKET_SUBDIRS)
+
+CFLAGS="$CFLAGS -Werror"
+CXXFLAGS="$CXXFLAGS -Wall -g -fno-rtti -fno-exceptions -fPIC -DPIC"
+
+AC_CONFIG_FILES([Makefile
+                 handlersocket/Makefile
+                 libhsclient/Makefile
+                 client/Makefile])
+
+AC_OUTPUT

=== added directory 'HandlerSocket-Plugin-for-MySQL/docs-en'
=== added file 'HandlerSocket-Plugin-for-MySQL/docs-en/about-handlersocket.en.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-en/about-handlersocket.en.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-en/about-handlersocket.en.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,72 @@
+
+-----------------------------------------------------------------------------
+HandlerSocket plugin for MySQL
+
+Copyright (c) 2010 DeNA Co.,Ltd.
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+    * Redistributions of source code must retain the above copyright
+      notice, this list of conditions and the following disclaimer.
+    * Redistributions in binary form must reproduce the above copyright
+      notice, this list of conditions and the following disclaimer in the
+      documentation and/or other materials provided with the distribution.
+    * Neither the name of DeNA Co.,Ltd. nor the names of its contributors
+      may be used to endorse or promote products derived from this software
+      without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY DeNA Co.,Ltd. "AS IS" AND ANY EXPRESS OR
+IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
+EVENT SHALL DeNA Co.,Ltd. BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
+OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+
+-----------------------------------------------------------------------------
+About HandlerSocket
+
+HandlerSocket is a NoSQL plugin for MySQL. It works as a daemon inside the
+mysqld process, accept tcp connections, and execute requests from clients.
+HandlerSocket does not support SQL queries. Instead, it supports simple CRUD
+operations on tables.
+
+Because of the following reasons, HandlerSocket is much faster than the
+mysqld/libmysql pair in some circumstances:
+
+  - HandlerSocket manipulates data without parsing SQL, which causes less
+    CPU usage.
+  - HandlerSocket reads many requests from clients and executes their
+    requests in bulk, which causes less CPU and disk usage.
+  - HandlerSocket client/server protocol is more compact than the 
+    mysql/libmysql pair, which causes less network usage.
+
+The current version of HandlerSocket only works with GNU/Linux. The source
+archive of HandlerSocket includes a C++ and a Perl client libraries.
+Here is a list of other language bindings:
+
+  - PHP
+    http://openpear.org/package/Net_HandlerSocket
+    http://github.com/tz-lom/HSPHP
+    http://code.google.com/p/php-handlersocket/
+  - Java
+    http://code.google.com/p/handlersocketforjava/
+  - Python
+    https://code.launchpad.net/~songofacandy/+junk/pyhandlersocket
+  - Ruby
+    https://github.com/winebarrel/ruby-handlersocket
+    https://github.com/miyucy/handlersocket
+  - JavaScript(Node.js)
+    https://github.com/koichik/node-handlersocket
+
+The home of HandlerSocket is here:
+    https://github.com/ahiguti/HandlerSocket-Plugin-for-MySQL
+
+More documents are available in docs-en/ and docs-ja/ directories.
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-en/configuration-options.en.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-en/configuration-options.en.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-en/configuration-options.en.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,87 @@
+
+-----------------------------------------------------------------
+handlersocket_verbose (default = 10, min = 0, max = 10000)
+
+  Specify the logging verboseness.
+
+-----------------------------------------------------------------
+handlersocket_address (default = '')
+
+  Specify the address to bind. If empty, it binds to 0.0.0.0.
+
+-----------------------------------------------------------------
+handlersocket_port (default = '9998')
+
+  Specify the port to bind. This option is for the listener for
+  read requests. If empty, the listener is disabled.
+
+-----------------------------------------------------------------
+handlersocket_port_wr (default = '9999')
+
+  Specify the port to bind. This option is for the listener for
+  write requests. If empty, the listener is disabled.
+
+-----------------------------------------------------------------
+handlersocket_epoll (default = 1, min = 0, max = 1)
+
+  Specify whether handlersocket uses epoll for I/O multiplexing.
+
+-----------------------------------------------------------------
+handlersocket_threads (default = 16, min = 1, max = 3000)
+
+  Specify the number of handlersocket worker threads. This option
+  is for the listener for read requests. Recommended value is
+  (the number of CPU cores * 2).
+
+-----------------------------------------------------------------
+handlersocket_threads_wr (default = 1, min = 1, max = 3000)
+
+  Specify the number of handlersocket worker threads. This option
+  is for the listener for write requests. Recommended value is 1.
+
+-----------------------------------------------------------------
+handlersocket_timeout (default = 300, min = 30, max = 3600)
+
+  Specify the socket timeout in seconds.
+
+-----------------------------------------------------------------
+handlersocket_backlog (default = 32768, min = 5, max = 1000000)
+
+  Specify the length of the listen backlog.
+
+-----------------------------------------------------------------
+handlersocket_sndbuf (default = 0, min = 0, max = 1677216)
+
+  Specify the maximum socket send buffer in bytes. If 0, the
+  system-wide default value is set.
+
+-----------------------------------------------------------------
+handlersocket_rcvbuf (default = 0, min = 0, max = 1677216)
+
+  Specify the maximum socket receive buffer in bytes. If 0, the
+  system-wide default value is set.
+
+-----------------------------------------------------------------
+handlersocket_readsize (default = 0, min = 0, max = 1677216)
+
+  Specify the minimum length of the handlersocket request buffer.
+  Larger value can make handlersocket faster for large requests,
+  but can consume memory. The default value is possibly 4096.
+
+-----------------------------------------------------------------
+handlersocket_accept_balance (default = 0, min = 0, max = 10000)
+
+  When this option is set to non-zero, handlersocket tries to
+  balance accepted connections among threads. Non-zero is
+  recommended if you use persistent connections (i.e., connection
+  pooling on the client side).
+
+-----------------------------------------------------------------
+handlersocket_wrlock_timeout (default = 12, min = 0, max = 3600)
+
+  Specify the lock timeout in seconds. When a write request is
+  performed, handlersocket locks an advisory lock named
+  'handlersocket_wr'. This option sets the timeout for the
+  locking.
+
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-en/installation.en.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-en/installation.en.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-en/installation.en.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,91 @@
+1. Building Handlersocket
+
+ Handlersocket mainly consists of libhsclient, handlersocket, and C++/Perl clients. libhsclient is a common library shared from both client and server(plugin). handlersocket is a MySQL daemon plugin.
+ To build Handlersocket, you need both MySQL source code and MySQL binary. It is not required to pre-build MySQL source code, but source itself is needed because Handlersocket depends on MySQL header files that only MySQL source distribution contains. MySQL binary is just a normal MySQL binary distribution. You can use official MySQL binaries provided by Oracle.
+ Since Handlersocket uses daemon plugin interface supported from MySQL 5.1,
+MySQL 5.1 or higher version is required.
+ Please make sure that you use identical MySQL version between MySQL source
+and MySQL binary. Otherwise you might encounter serious problems (i.e. server
+crash, etc). 
+ Here are steps to build Handlersocket.
+
+* Get MySQL source code
+
+* Get MySQL binary
+
+* Build Handlersocket
+  $ ./autogen.sh
+  $ ./configure --with-mysql-source=/work/mysql-5.1.50 --with-mysql-bindir=/work/mysql-5.1.50-linux-x86_64-glibc23/bin  --with-mysql-plugindir=/work/mysql-5.1.50-linux-x86_64-glibc23/lib/plugin
+
+ --with-mysql-source refers to the top of MySQL source directory,
+--with-mysql-bindir refers to where MySQL binary executables (i.e.
+mysql_config) are located, and --with-mysql-plugindir refers to a plugin
+directory where plugin libraries (*.so) are installed.  
+
+  $ make
+  $ sudo make install
+
+ Both libhsclient and the handlersocket plugin will be installed.
+
+ 
+2. Using Handlersocket
+
+Append configuration options for handlersocket to my.cnf.
+
+  [mysqld]
+  loose_handlersocket_port = 9998
+    # the port number to bind to (for read requests)
+  loose_handlersocket_port_wr = 9999
+    # the port number to bind to (for write requests)
+  loose_handlersocket_threads = 16
+    # the number of worker threads (for read requests)
+  loose_handlersocket_threads_wr = 1
+    # the number of worker threads (for write requests)
+  open_files_limit = 65535
+    # to allow handlersocket accept many concurrent
+    # connections, make open_files_limit as large as
+    # possible.
+
+Log in to mysql as root, and execute the following query.
+
+  mysql> install plugin handlersocket soname 'handlersocket.so';
+
+If handlersocket.so is successfully installed, it starts
+accepting connections on port 9998 and 9999. Running
+'show processlist' should show handlersocket worker threads.
+
+-----------------------------------------------------------------
+On the client side, you need to install libhsclient for c++ apps
+and perl-Net-HandlerSocket for perl apps. They do not require
+MySQL to compile.
+
+  $ ./autogen.sh
+  $ ./configure --disable-handlersocket-server
+  $ make
+  $ sudo make install
+  $ cd perl-Net-HandlerSocket
+  $ perl Makefile.PL
+  $ make
+  $ sudo make install
+
+-----------------------------------------------------------------
+Alternatively, you can use the rpm installation. If your OS
+supports rpms, you can use the following commands to build and
+install handlersocket rpm packages.
+
+(Server side, installs HandlerSocket plugin)
+  $ ./autogen.sh
+  $ ./configure --with-mysql-source=/work/mysql-5.1.50 --with-mysql-bindir=/work/mysql-5.1.50-linux-x86_64-glibc23/bin  --with-mysql-plugindir=/work/mysql-5.1.50-linux-x86_64-glibc23/lib/plugin
+  $ make rpm_cli
+  $ sudo rpm -U dist/RPMS/*/libhsclient*.rpm
+  $ make rpm_c
+  $ sudo rpm -U dist/RPMS/*/handlersocket*.rpm
+
+(Client side, installs client libraries)
+  $ ./autogen.sh
+  $ ./configure --disable-handlersocket-server
+  $ make rpm_cli
+  $ sudo rpm -U dist/RPMS/*/libhsclient*.rpm
+  $ make rpm_perl
+  $ sudo rpm -U dist/RPMS/*/perl-Net-HandlerSocket*.rpm
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-en/perl-client.en.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-en/perl-client.en.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-en/perl-client.en.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,126 @@
+
+-----------------------------------------------------------------
+To open a connection to the handlersocket plugin, you need to
+create a Net::HandlerSocket object.
+
+  use Net::HandlerSocket;
+  my $args = { host => 'localhost', port => 9998 };
+  my $hs = new Net::HandlerSocket($args);
+
+-----------------------------------------------------------------
+Before executing table operations, you need to open an index to
+work with.
+
+  my $err = $hs->open_index(3, 'database1', 'table1', 'PRIMARY',
+    'f1,f2');
+  die $hs->get_error() if $res->[0] != 0;
+
+The first argument for open_index is an integer value which is
+used to identify an open table, which is only valid within the
+same Net::HandlerSocket object. The 4th argument is the name of
+index to open. If 'PRIMARY' is specified, the primary index is
+open. The 5th argument is a comma-separated list of column names.
+
+-----------------------------------------------------------------
+To read a record from a table using an index, call the
+execute_single method.
+
+  my $res = $hs->execute_single(3, '=', [ 'foo' ], 1, 0);
+  die $hs->get_error() if $res->[0] != 0;
+  shift(@$res);
+
+The first argument must be an integer which has specified as the
+first argument for open_index on the same Net::HandlerSocket
+object. The second argument specifies the search operation. The
+current version of handlersocket supports '=', '>=', '<=', '>',
+and '<'. The 3rd argument specifies the key to find, which must
+an arrayref whose length is equal to or smaller than the number
+of key columns of the index. The 4th and the 5th arguments
+specify the maximum number of records to be retrieved, and the
+number of records skipped before retrieving records. The columns
+to be retrieved are specified by the 5th argument for the
+corresponding open_index call.
+
+The execute_single method always returns an arrayref. The first
+element is the error code, which is 0 when no error is occured.
+The remaining are the field values. If more than one record is
+returned, it is flatten to an 1-dimensional array. For example,
+when 5 records that have 3 columns are returned, you can retrieve
+values using the following code.
+
+  die $hs->get_error() if $res->[0] != 0;
+  shift(@$res);
+  for (my $row = 0; $row < 5; ++$row) {
+    for (my $col = 0; $col < 3; ++$col) {
+      my $value = $res->[$row * 5 + $col];
+      # ...
+    }
+  }
+
+-----------------------------------------------------------------
+To update or delete records, you need to specify more arguments
+for the execute_single method. Note that the Net::HandlerSocket
+object must be connected to a handlersocket worker for write
+operations, which is port 9999 by default.
+(For safety, the port 9998 only allows read operations, and the
+port 9999 allows write operations also. The port 9999 allows
+read operations too, but slower than 9998 because of record
+locking etc.. Port numbers can be changed using the
+'handlersocket_port' and the 'handlersocket_port_wr'
+configuration options of mysqld.)
+
+  my $args = { host => 'localhost', port => 9999 };
+  my $hs = new Net::HandlerSocket($args);
+
+  my $res = $hs->execute_single(3, '=', [ 'bar' ], 1, 0, 'U',
+    [ 'fubar', 'hoge' ]);
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_updated_rows = $res->[1];
+
+  my $res = $hs->execute_single(3, '=', [ 'baz' ], 1, 0, 'D');
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_deleted_rows = $res->[1];
+
+The 6th argument for execute_single specifies the modification
+operation. The current version supports 'U' and 'D'. For the 'U'
+operation, the 7th argument specifies the new value for the row.
+The columns to be modified are specified by the 5th argument for
+the corresponding open_index call. For the 'D' operation, the
+7th argument can be omitted.
+
+-----------------------------------------------------------------
+The execute_single method can be used for inserting records also.
+
+  my $res = $hs->execute_single(3, '+', [ 'foo', 'bar', 'baz' ]);
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_inserted_rows = $res->[1];
+
+The 3rd argument must be an arrayref whose elements correspond to
+the 5th argument for the corresponding open_index call. If there
+is a column which is not appeared in the 5th argument for the
+open_index, the default value for the column is set.
+
+-----------------------------------------------------------------
+Multiple operations can be executed in a single call. Executing
+multiple operations in a single call is much faster than
+executing them separatedly. 
+
+  my $rarr = $hs->execute_multi([
+    [ 0, '>=', [ 'foo' ], 5, 0 ],
+    [ 2, '=', [ 'bar' ], 1, 0 ],
+    [ 4, '<', [ 'baz' ], 10, 5 ],
+  ]);
+  for my $res (@$rarr) {
+    die $hs->get_error() if $res->[0] != 0;
+    shift(@$res);
+    # ...
+  }
+
+-----------------------------------------------------------------
+When an error is occured, the first element of the returned
+arrayref becomes a non-zero value. A negative value indicates
+that an I/O error is occured and the Net::HandlerSocket object
+should be disposed. A positive value means that the connection is
+still active and the Net::HandlerSocket object can be reused
+later.
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-en/protocol.en.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-en/protocol.en.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-en/protocol.en.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,148 @@
+
+----------------------------------------------------------------------------
+The HandlerSocket protocol
+
+----------------------------------------------------------------------------
+Basic syntax
+
+- The HandlerSocket protocol is line-based. Each line ends with LF(0x0a).
+- Each line consists a concatenation of tokens separated by HT(0x09).
+- A token is either NULL or an encoded string. Note that you need to
+  distinguish NULL from an empty string, as most DBMs does so.
+- NULL is expressed as a single NUL(0x00).
+- An encoded string is a string with the following encoding rules.
+  	- Characters in the range [0x10 - 0xff] are not encoded.
+	- A character in the range [0x00 - 0x0f] is prefixed by 0x01 and
+	  shifted by 0x40. For example, 0x03 is encoded as 0x01 0x43.
+- Note that a string can be empty. A continuation of 0x09 0x09 means that
+  there is an empty string between them. A continuation of 0x09 0x0a means
+  that there is an empty string at the end of the line.
+
+----------------------------------------------------------------------------
+Request and Response
+
+- The HandlerSocket protocol is a simple request/response protocol. After a
+  connection is established, the client side sends a request, and then the
+  server side sends a response.
+- A request/response consists of a single line.
+- Requests can be pipelined; That is, you can send multiple requests (ie.
+  lines) at one time, and receive responses for them at one time.
+
+----------------------------------------------------------------------------
+'open_index' request
+
+The 'open_index' request has the following syntax.
+
+    P <indexid> <dbname> <tablename> <indexname> <columns>
+
+- <indexid> is a number in decimal.
+- <dbname>, <tablename>, and <indexname> are strings. To open the primary
+  key, use PRIMARY as <indexname>.
+- <columns> is a comma-separated list of column names.
+
+Once an 'open_index' request is issued, the HandlerSocket plugin opens the
+specified index and keep it open until the client connection is closed. Each
+open index is identified by <indexid>. If <indexid> is already open, the old
+open index is closed. You can open the same combination of <dbname>
+<tablename> <indexname> multple times, possibly with different <columns>.
+For efficiency, keep <indexid> small as far as possible.
+
+----------------------------------------------------------------------------
+Getting data
+
+The 'find' request has the following syntax.
+
+    <indexid> <op> <vlen> <v1> ... <vn> <limit> <offset>
+
+- <indexid> is a number. This number must be an <indexid> specified by a
+  'open_index' request executed previously on the same connection.
+- <op> specifies the comparison operation to use. The current version of
+  HandlerSocket supports '=', '>', '>=', '<', and '<='.
+- <vlen> indicates the length of the trailing parameters <v1> ... <vn>. This
+  must be smaller than or equal to the number of index columns specified by
+  specified by the corresponding 'open_index' request.
+- <v1> ... <vn> specify the index column values to fetch.
+- <limit> and <offset> are numbers. These parameters can be omitted. When
+  omitted, it works as if 1 and 0 are specified.
+
+----------------------------------------------------------------------------
+Updating/Deleting data
+
+The 'find_modify' request has the following syntax.
+
+    <indexid> <op> <vlen> <v1> ... <vn> <limit> <offset> <mop> <m1> ... <mk>
+
+- <mop> is either 'U' (update) or 'D' (delete).
+- <m1> ... <mk> specifies the column values to set. The length of <m1> ...
+  <mk> must be smaller than or equal to the length of <columns> specified by
+  the corresponding 'open_index' request. If <mop> is 'D', these parameters
+  are ignored.
+
+----------------------------------------------------------------------------
+Inserting data
+
+The 'insert' request has the following syntax.
+
+    <indexid> '+' <vlen> <v1> ... <vn>
+
+- <vlen> indicates the length of the trailing parameters <v1> ... <vn>. This
+  must be smaller than or equal to the length of <columns> specified by the
+  corresponding 'open_index' request.
+- <v1> ... <vn> specify the column values to set. For columns not in
+  <columns>, the default values for each column are set.
+
+----------------------------------------------------------------------------
+Response syntax
+
+HandlerSocket returns a response of the following syntax for each request.
+
+    <errorcode> <numcolumns> <r1> ... <rn>
+
+- <errorcode> indicates whether the request has successfully executed or not.
+  '0' means success. Non-zero means an error.
+- <numcolumns> indicates the number of columns of the result set.
+- <r1> ... <rn> is the result set. The length of <r1> ... <rn> is always a
+  multiple of <numcolumns>. It is possible that <r1> ... <rn> is empty.
+
+If <errorcode> is non-zero, <numcolumns> is always 1 and <r1> indicates a
+human-readable error message, though sometimes <r1> is not provided.
+
+----------------------------------------------------------------------------
+Response for 'open_index'
+
+If 'open_index' is succeeded, HandlerSocket returns a line of the following
+syntax.
+
+    0 1
+
+----------------------------------------------------------------------------
+Response for 'find'
+
+If 'find' is succeeded, HandlerSocket returns a line of the following
+syntax.
+
+   0 <numcolumns> <r1> ... <rn>
+
+- <numcolumns> always equals to the length of <columns> of the corresponding
+  'open_index' request.
+- <r1> ... <rn> is the result set. If N rows are found, the length of <r1>
+  ... <rn> becomes ( <numcolumns> * N ).
+
+----------------------------------------------------------------------------
+Response for 'find_modify'
+
+If 'find_modify' is succeeded, HandlerSocket returns a line of the following
+syntax.
+
+   0 1 <nummod>
+
+- <nummod> is the number of modified rows.
+
+----------------------------------------------------------------------------
+Response for 'insert'
+
+If 'insert' is succeeded, HanderSocket returns a line of the following
+syntax.
+
+   0 1
+

=== added directory 'HandlerSocket-Plugin-for-MySQL/docs-ja'
=== added file 'HandlerSocket-Plugin-for-MySQL/docs-ja/about-handlersocket.ja.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-ja/about-handlersocket.ja.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-ja/about-handlersocket.ja.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,51 @@
+
+
+-----------------------------------------------------------------
+ソースコード�利用�������責事項
+
+本ソフトウェア�開発者�よ�株�会社ディー・エヌ・エー��本フト
+ウェア��稼動�稼動�良を�む法律上�瑕疵担�責任���他�証責
+任を負���も�����。���本ソフトウエア�開発者�よ�株�
+会社ディー・エヌ・エー��本ソフトウェア�商�性�����客様�
+特定�目的�対�る��性��������る�証も負���も���
+��。
+
+-----------------------------------------------------------------
+handlersocket plugin����
+
+mysqlサー��常���innodb等�ストレージエンジン��直接�アクセ
+スを�供�るプラグイン��。handlersocketプラグイン�自��リス
+ナーを���専用�クライアントライブラリ(libhsclient)を使���れ
+�アクセス���。
+
+mysql�標準クライアントライブラリ(libmysql)を使��アクセス�比�
+��以下�よ��利点��り��。
+・接続��り�消費�るリソース�少������時接続数�事実上無
+  制�。�����接続数を気����続接続を使���。
+・高速(�純��照クエリ�3�〜10�程度)。
+・通信プロトコル�コンパクト。libmysqlを使��データ転�時�レ
+  コード����付��る���通信内容�冗長����libhsclient�
+  �データ���転��れる���帯域消費�少���り��。場��
+  よ���10�以上libmysql����冗長��り��。
+
+�在��ージョン��以下�よ��処�をサ�ート�����。
+・指定�れ�索引�����指定�れ�値�完全一致�るよ��レコー
+  ドを�得。(SELECT ??? FROM tbl WHERE k1 = v1 AND k2 = v2...)。
+  索引を使���検索�サ�ート�����ん。
+・指定�れ�索引�����指定�れ�値��置��後�レコードを�
+  得。(SELECT ??? FROM tbl WHERE k1 >= v1 LIMIT 100)
+・�述�よ��手段��得��レコード�対�るUPDATE�DELETE
+・レコード�INSERT
+
+以下�よ��言語をサ�ート���。
+・C++。libhsclientをリンク���。
+・Perl。Net::HandlerSocketをuse���。
+
+�在��ージョン��GNU/Linux���動作���。
+
+-----------------------------------------------------------------
+既知��題
+
+・kill�handlersocketスレッドを殺���スレッド数�減����回復
+  ���ん。
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-ja/installation.ja.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-ja/installation.ja.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-ja/installation.ja.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,87 @@
+
+-----------------------------------------------------------------
+HandlerSocketプラグイン�ビルド方法(RPMを使���方法)
+
+以下�よ����configureを実行���。
+
+  $ ./autogen.sh
+  $ ./configure --with-mysql-source=/work/mysql-5.1.50 --with-mysql-bindir=/work/mysql-5.1.50-linux-x86_64-glibc23/bin  --with-mysql-plugindir=/work/mysql-5.1.50-linux-x86_64-glibc23/lib/plugin
+
+���--with-mysql-source��MySQL�ソースコード�トップディレク
+トリを指定���。--with-mysql-bindir��インストール済��MySQL
+�mysql_configコマンド�有るディレクトリを指定���。
+��後以下�よ��ビルド・インストール���。
+
+  $ make
+  $ sudo make install
+
+-----------------------------------------------------------------
+クライアントライブラリ�ビルド方法(RPMを使���方法)
+
+クライアントライブラリをビルド�る際���MySQL�ソースコード�
+必��り��ん。��MySQL�インストール�れ��る必�も�り��ん。
+
+  $ ./autogen.sh
+  $ ./configure --disable-handlersocket-server
+  $ make
+  $ sudo make install
+  $ cd perl-Net-HandlerSocket
+  $ perl Makefile.PL
+  $ make
+  $ sudo make install
+
+-----------------------------------------------------------------
+ビルド方法(RPM)
+
+以下�よ��実行�れ��rpmパッケージ�ビルド＆インストール�れ�
+�。
+
+(MySQLサー���HandlerSocketプラグインをインストール�る)
+  $ ./autogen.sh
+  $ ./configure --with-mysql-source=/work/mysql-5.1.50 --with-mysql-bindir=/work/mysql-5.1.50-linux-x86_64-glibc23/bin  --with-mysql-plugindir=/work/mysql-5.1.50-linux-x86_64-glibc23/lib/plugin
+  $ make rpm_cli
+  $ sudo rpm -U dist/RPMS/*/libhsclient*.rpm
+  $ make rpm_c
+  $ sudo rpm -U dist/RPMS/*/handlersocket*.rpm
+
+(クライアント��クライアントライブラリをインストール�る)
+  $ ./autogen.sh
+  $ ./configure --disable-handlersocket-server
+  $ make rpm_cli
+  $ sudo rpm -U dist/RPMS/*/libhsclient*.rpm
+  $ make rpm_perl
+  $ sudo rpm -U dist/RPMS/*/perl-Net-HandlerSocket*.rpm
+
+-----------------------------------------------------------------
+èµ·å‹•
+
+mysqlを起動��状態��mysql�設定ファイル(my.cnf等)�以下�内容を
+追加���。
+
+  [mysqld]
+  handlersocket_port = 9998
+      # handlersocket�接続を��付�る�ート(�照系リクエスト用)
+  handlersocket_port_wr = 9999
+      # handlersocket�接続を��付�る�ート(更新系リクエスト用)
+  handlersocket_address =
+      # handlersocket��インド�るアドレス(空����OK)
+  handlersocket_verbose = 0
+      # デ�ッグ用
+  handlersocket_timeout = 300
+      # 通信タイムアウト(秒)
+  handlersocket_threads = 16
+      # handlersocket�ワーカースレッド数
+  thread_concurrency = 128
+      # handlersocket�幾���スレッドを�有�る���大���
+      # 値を指定������
+  open_files_limit = 65535
+      # ソケットを大��開�るよ���る���大���値を指定�
+      # �����
+
+以下�クエリを実行���。
+
+  mysql> install plugin handlersocket soname 'handlersocket.so';
+  Query OK, 0 rows affected (0.06 sec)
+
+以上�handlersocket�クライアント�らアクセス��るよ���り��。
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-ja/perl-client.ja.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-ja/perl-client.ja.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-ja/perl-client.ja.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,118 @@
+
+-----------------------------------------------------------------
+handlersocketプラグイン��接続を開����Net::HandlerSocketオブ
+ジェクトを作����。
+
+  use Net::HandlerSocket;
+  my $args = { host => 'localhost', port => 9998 };
+  my $hs = new Net::HandlerSocket($args);
+
+-----------------------------------------------------------------
+検索���命令を実行�る���処�対象��る索引を開�必���り
+��。
+
+  my $err = $hs->open_index(3, 'database1', 'table1', 'PRIMARY',
+    'f1,f2');
+  die $hs->get_error() if $res->[0] != 0;
+
+最��引数�開�索引�付�る番���。付��番���一�
+Net::HandlerSocketオブジェクト������有効��。第4引数�開�
+索引�����「PRIMARY��指定�れ場��プライマリキー�開�れ�
+�。第5引数�「,��区切られ�列��リスト��。
+
+-----------------------------------------------------------------
+テーブル�ら索引を使��行を�得�る���execute_singleメソッド
+を呼���。
+
+  my $res = $hs->execute_single(3, '=', [ 'foo' ], 1, 0);
+  die $hs->get_error() if $res->[0] != 0;
+  shift(@$res);
+
+最��引数�索引�番�����Net::HandlerSocketオブジェクト�
+open_index�付��も����れ��り��ん。第2引数���作を指定
+���。�在��ージョン���「=��「>=��「<=��「>��「<�
+��作�利用�能��。第3引数��列���照���れ�探���行�
+キー値を指定���。�列�長��索引�キー�個数����少��数
+���れ��り��ん。第4引数�第5引数��れ�れ��得�る最大行
+数��得��読�飛��行数を指定���。�得�れる列�対応�る
+open_index呼�出��第5引数�指定�れ�も���り��。
+
+execute_singleメソッド�常��列���照を返���。最���素�
+エラーコード���れ�0�ら��功を表���。残り��素�列�値�
+�。も��得�れ�データ�複数行�場����れ�一���列�連�
+�れ�形�格��れ����。例���5行3列�データ�場��次�よ
+��コード�よ����内容を�得����。
+
+  die $hs->get_error() if $res->[0] != 0;
+  shift(@$res);
+  for (my $row = 0; $row < 5; ++$row) {
+    for (my $col = 0; $col < 3; ++$col) {
+      my $value = $res->[$row * 5 + $col];
+      # ...
+    }
+  }
+
+-----------------------------------------------------------------
+行を更新���削除�る���更�多��引数を指定��
+execute_singleメソッドを呼�出���。書�込�処�を�る���
+対象�Net::HandlerSocketオブジェクト�更新用handlersocketワーカ(既
+定���ート9999)�接続�れ�も�������り��ん。
+(安全�����ート9998��照処���を��付���ート9999�更新
+処�も��付�るよ��������。�ート9999��照処�も��付
+�����レコードロック等�影響����り��。�ート番��
+mysqld�「handlersocket_port��「handlersocket_port_wr��設定項
+目�変更����。)
+
+  my $args = { host => 'localhost', port => 9999 };
+  my $hs = new Net::HandlerSocket($args);
+
+  my $res = $hs->execute_single(3, '=', [ 'bar' ], 1, 0, 'U',
+    [ 'fubar', 'hoge' ]);
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_updated_rows = $res->[1];
+
+  my $res = $hs->execute_single(3, '=', [ 'baz' ], 1, 0, 'D');
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_deleted_rows = $res->[1];
+
+execute_single�第6引数�変更処��種類を指定���。�在��ー
+ジョン��「U��「D��利用�能��。「U�������第7引数�
+新��値を指定���。更新�れる列��対応�るopen_index呼�出�
+�第5引数�指定�れ�も���り��。「D������第7引数��
+略����。
+
+-----------------------------------------------------------------
+execute_singleメソッド�列�挿入�も使用����。
+
+  my $res = $hs->execute_single(3, '+', [ 'foo', 'bar', 'baz' ]);
+  die $hs->get_error() if $res->[0] != 0;
+  my $num_inserted_rows = $res->[1];
+
+第3引数��対応�るopen_index呼�出��第5引数�列リスト����
+��長���列���照���れ��り��ん。open_index呼�出��
+第5引数�指定�れ����列��������列�既定値�セット�れ
+��。
+
+-----------------------------------------------------------------
+execute_multiメソッドを使���複数�リクエストを一��呼�出��
+実行�る�������。�れ�リクエストを個別�実行�るより高速
+��。
+
+  my $rarr = $hs->execute_multi([
+    [ 0, '>=', [ 'foo' ], 5, 0 ],
+    [ 2, '=', [ 'bar' ], 1, 0 ],
+    [ 4, '<', [ 'baz' ], 10, 5 ],
+  ]);
+  for my $res (@$rarr) {
+    die $hs->get_error() if $res->[0] != 0;
+    shift(@$res);
+    # ...
+  }
+
+-----------------------------------------------------------------
+エラー�起�る�返値��列�照�最���素�0以外��り��。負�
+数�場��I/Oエラー�起�����を示����場����
+Net::HandlerSocketオブジェクト�破棄�る����。正�値�場��
+接続�維��れ��る�����オブジェクト��れ以後も�利用��
+��。
+

=== added file 'HandlerSocket-Plugin-for-MySQL/docs-ja/protocol.ja.txt'
--- HandlerSocket-Plugin-for-MySQL/docs-ja/protocol.ja.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/docs-ja/protocol.ja.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,94 @@
+
+-----------------------------------------------------------------
+handlersocket�通信プロトコル
+
+-----------------------------------------------------------------
+構文
+
+・コマンド行�改行(LF)�終�る。
+・コマンド行�複数�トークン�ら�り�トークン間�TAB�区切られる。
+・トークン�NULLトークン��文字列トークン���れ�。
+・NULLトークン��一�NUL文字��ら��れる。
+・文字列トークン��0�イト以上�文字列��ら��れる。���0x10
+  未満�文字�����0x01を�置��0x40を加��コード��ら��
+  れる。�れ以外�文字���文字自身�コード��ら��れる。
+
+-----------------------------------------------------------------
+リクエスト�レス�ンス
+
+・接続�確立��直後�状態�����クライアント�コマンド行を�
+  る。(リクエスト)
+・サー��クライアント����リクエスト��度��数�コマンド行
+  を返�。(レス�ンス)
+・リクエスト�パイプライン化��よ�。��りクライアント���
+  ���リクエスト�対�る返事を待���次�リクエストを���も
+  よ�。
+
+-----------------------------------------------------------------
+リクエスト
+
+・open_index命令�次�よ��構文を��。
+        'P' indexid dbname tablename indexname fieldlist
+  indexid�開���る索引�付�られる番����一接続上�後�実行
+  �る命令��対象索引を指定�る���使�れる。dbname�tablename�
+  indexname��れ�れ開���DB�テーブル�索引���。索引���
+  ���"PRIMARY"を指定�る�プライマリキー�開�れる。fieldlist
+  �カンマ区切り�列��リスト。
+・find命令�次�よ��構文を��。
+        indexid op nflds v1 ... vn limit offset
+  indexid�実行対象�索引を指定�る。op�索引検索�演算�(後述)。
+  v1�らvn��変長����個数�nflds。nflds�indexid�指定�れ�
+  open_index命令�indexname�索引�fieldlist�フィールド数�等�
+  ����������ら��。m2�らmk��変長����個数�
+  indexid�指定�れ�open_index命令�発行�れ�際�fieldlist�一
+  致���れ��ら��。コマンド行�limit以���略��る。limit
+  �offset��検索�件��致�る列���レス�ンス�返�列数�上
+  ���スキップ�る列数。limit�offsetを�略��場���れ�れ1
+  �0�指定�れ������動作を�る。find命令�レス�ンス����
+  �件��致��列�リストを返�。op���指定��る演算��次�
+  ��り。
+      '='       -  v1 ... vn�一致�るも�を�得
+      '>'       -  v1 ... vnより大��も�を昇順��得
+      '>='      -  v1 ... vn�一致�る�大��も�を昇順��得
+      '<'       -  v1 ... vnより���も�を�順��得
+      '<='      -  v1 ... vn�一致�る�等��も�を�順��得
+  nflds�1より大��(v1 ... vn�2個以上)���辞書�順��比較�
+  れる。
+・find_modify命令�次�よ��構文を��。
+        indexid op nflds v1 ... vn limit offset modop m1 ... mk
+  modopより��部分�find命令��等���れ�よ���作対象�行を
+  指定�る。���作対象�行�対�modop�指定�れ�変更処�を実行
+  �る。m1 ... mk��変長���略��る。modop�次��れ�。
+      'U'       -  indexid�指定�れ�open_index命令�fieldlist列
+                   �内容を�m1 ... mk�値�更新�る。
+      'D'       -  対象�行を削除�る。m1 ... mk�値�無視�れる。
+・insert命令��よ��構文を��。
+        indexid '+' nflds v1 ... vn
+  indexid�指定�れ�テーブル��列を挿入�る。v1 ... vn��変長
+  ����個数�nflds。nflds�indexid�指定�れ�open_index命令�
+  indexname�索引�fieldlist�フィールド数�等���������
+  ��ら��。
+
+-----------------------------------------------------------------
+レス�ンス
+
+・open_index命令��功�����レス�ンス�次�構文を��。
+        '0' '1'
+・find命令��功�����レス�ンス�次�構文を��。
+        '0' nflds v1 ... vn
+  nflds��果セット�列�数を�ら��。v1 ... vn��変長����
+  長��nflds�整数�。v1 ... vn�空���も�り��れ��件��
+  致�るレコード�存在�������を�ら��。�果セット�複数
+  行�������v1 ... vn�長��nflds�2�以上��り�最��
+  行�ら順�v1 ... vn�セット�れる。
+・modify命令��功�����レス�ンス�次�構文を��。
+        '0' '1' nummod
+  nummod�変更�施�れ�行数。nummod�0����変更�れ�行�無
+  �����を�ら��。
+・insert命令��功�����レス�ンス�次�構文を��。
+        '0' '1'
+・命令�失敗�����レス�ンス�命令�関�ら�次�構文を��。
+        err '1' message
+  err�0以外�数値��エラーコードを�ら��。message�人間�読�
+  エラーメッセージ。���message�無���も�る。
+

=== added directory 'HandlerSocket-Plugin-for-MySQL/handlersocket'
=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/COPYRIGHT.txt'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/COPYRIGHT.txt	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/COPYRIGHT.txt	2011-04-12 04:16:24 +0000
@@ -0,0 +1,27 @@
+
+ Copyright (c) 2010 DeNA Co.,Ltd.
+ All rights reserved.
+
+ Redistribution and use in source and binary forms, with or without
+ modification, are permitted provided that the following conditions are met:
+
+     * Redistributions of source code must retain the above copyright
+       notice, this list of conditions and the following disclaimer.
+     * Redistributions in binary form must reproduce the above copyright
+       notice, this list of conditions and the following disclaimer in the
+       documentation and/or other materials provided with the distribution.
+     * Neither the name of DeNA Co.,Ltd. nor the names of its contributors
+       may be used to endorse or promote products derived from this software
+       without specific prior written permission.
+
+ THIS SOFTWARE IS PROVIDED BY DeNA Co.,Ltd. "AS IS" AND ANY EXPRESS OR
+ IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+ MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
+ EVENT SHALL DeNA Co.,Ltd. BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+ PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
+ OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+ WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+ OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+

=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.am'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.am	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.am	2011-04-12 04:16:24 +0000
@@ -0,0 +1,10 @@
+pkgplugindir =  $(PLUGIN_DIR)
+noinst_HEADERS = database.hpp hstcpsvr.hpp hstcpsvr_worker.hpp mysql_incl.hpp
+pkgplugin_LTLIBRARIES = handlersocket.la
+handlersocket_la_LDFLAGS = -module ../libhsclient/libhsclient.la
+handlersocket_la_CFLAGS = $(MYSQL_INC) $(MYSQL_CFLAGS) $(AM_CFLAGS) \
+	-I../libhsclient
+handlersocket_la_CXXFLAGS = $(MYSQL_INC) $(MYSQL_CFLAGS) $(AM_CFLAGS) \
+	-I../libhsclient
+handlersocket_la_SOURCES = database.cpp handlersocket.cpp \
+	hstcpsvr_worker.cpp hstcpsvr.cpp

=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.plain.template'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.plain.template	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/Makefile.plain.template	2011-04-12 04:16:24 +0000
@@ -0,0 +1,31 @@
+
+MYSQL_INC = HANDLERSOCKET_MYSQL_INC
+MYSQL_LIB = HANDLERSOCKET_MYSQL_LIB
+
+CXX = g++ -Wall -g -fno-rtti -fno-exceptions -fPIC -DPIC
+LIBS = $(MYSQL_LIB) -lhsclient -lpthread -lz
+CXXFLAGS = -I/usr/include/handlersocket $(MYSQL_INC)
+LDFLAGS =
+
+CXXFLAGS += -O3 -DNDEBUG
+
+HANDLERSOCKET_OBJS = database.o hstcpsvr.o hstcpsvr_worker.o
+
+all: handlersocket.so
+
+handlersocket.so: $(HANDLERSOCKET_OBJS) handlersocket.cpp
+	$(CXX) $(CXXFLAGS) -fno-strict-aliasing -shared $^ -o $@ $(LDFLAGS) \
+		-Wl,-soname -Wl,$@ $(LIBS)
+clean:
+	rm -f *.a *.so *.o
+
+LIBDIR = $(shell \
+  if [ -e /usr/lib64/mysql ]; then echo /usr/lib64; else echo /usr/lib; fi)
+
+install: handlersocket.so
+	sudo sh -c 'ulimit -c unlimited ; /etc/init.d/mysql stop ; \
+		cp handlersocket.so handlersocket.so.cpy && \
+		mv handlersocket.so.cpy \
+			$(LIBDIR)/mysql/plugin/handlersocket.so && \
+		/etc/init.d/mysql start'
+

=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/database.cpp'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/database.cpp	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/database.cpp	2011-04-12 04:16:24 +0000
@@ -0,0 +1,1143 @@
+
+// vim:sw=2:ai
+
+/*
+ * Copyright (C) 2010 DeNA Co.,Ltd.. All rights reserved.
+ * See COPYRIGHT.txt for details.
+ */
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+
+#include "database.hpp"
+#include "string_util.hpp"
+#include "escape.hpp"
+#include "mysql_incl.hpp"
+
+#define DBG_KEY(x)
+#define DBG_SHUT(x)
+#define DBG_LOCK(x)
+#define DBG_THR(x)
+#define DBG_CMP(x)
+#define DBG_FLD(x)
+#define DBG_FILTER(x)
+#define DBG_REFCNT(x)
+#define DBG_DELETED
+
+/* status variables */
+unsigned long long int open_tables_count;
+unsigned long long int close_tables_count;
+unsigned long long int lock_tables_count;
+unsigned long long int unlock_tables_count;
+unsigned long long int index_exec_count;
+
+namespace dena {
+
+prep_stmt::prep_stmt()
+  : dbctx(0), table_id(static_cast<size_t>(-1)),
+    idxnum(static_cast<size_t>(-1))
+{
+}
+prep_stmt::prep_stmt(dbcontext_i *c, size_t tbl, size_t idx,
+  const fields_type& rf, const fields_type& ff)
+  : dbctx(c), table_id(tbl), idxnum(idx), ret_fields(rf), filter_fields(ff)
+{
+  if (dbctx) {
+    dbctx->table_addref(table_id);
+  }
+}
+prep_stmt::~prep_stmt()
+{
+  if (dbctx) {
+    dbctx->table_release(table_id);
+  }
+}
+
+prep_stmt::prep_stmt(const prep_stmt& x)
+  : dbctx(x.dbctx), table_id(x.table_id), idxnum(x.idxnum),
+  ret_fields(x.ret_fields), filter_fields(x.filter_fields)
+{
+  if (dbctx) {
+    dbctx->table_addref(table_id);
+  }
+}
+
+prep_stmt&
+prep_stmt::operator =(const prep_stmt& x)
+{
+  if (this != &x) {
+    if (dbctx) {
+      dbctx->table_release(table_id);
+    }
+    dbctx = x.dbctx;
+    table_id = x.table_id;
+    idxnum = x.idxnum;
+    ret_fields = x.ret_fields;
+    filter_fields = x.filter_fields;
+    if (dbctx) {
+      dbctx->table_addref(table_id);
+    }
+  }
+  return *this;
+}
+
+struct database : public database_i, private noncopyable {
+  database(const config& c);
+  virtual ~database();
+  virtual dbcontext_ptr create_context(bool for_write) volatile;
+  virtual void stop() volatile;
+  virtual const config& get_conf() const volatile;
+ public:
+  int child_running;
+ private:
+  config conf;
+};
+
+struct tablevec_entry {
+  TABLE *table;
+  size_t refcount;
+  bool modified;
+  tablevec_entry() : table(0), refcount(0), modified(false) { }
+};
+
+struct expr_user_lock : private noncopyable {
+  expr_user_lock(THD *thd, int timeout)
+    : lck_key("handlersocket_wr", 16, &my_charset_latin1),
+      lck_timeout(timeout),
+      lck_func_get_lock(&lck_key, &lck_timeout),
+      lck_func_release_lock(&lck_key)
+  {
+    lck_key.fix_fields(thd, 0);
+    lck_timeout.fix_fields(thd, 0);
+    lck_func_get_lock.fix_fields(thd, 0);
+    lck_func_release_lock.fix_fields(thd, 0);
+  }
+  long long get_lock() {
+    return lck_func_get_lock.val_int();
+  }
+  long long release_lock() {
+    return lck_func_release_lock.val_int();
+  }
+ private:
+  Item_string lck_key;
+  Item_int lck_timeout;
+  Item_func_get_lock lck_func_get_lock;
+  Item_func_release_lock lck_func_release_lock;
+};
+
+struct dbcontext : public dbcontext_i, private noncopyable {
+  dbcontext(volatile database *d, bool for_write);
+  virtual ~dbcontext();
+  virtual void init_thread(const void *stack_botton,
+    volatile int& shutdown_flag);
+  virtual void term_thread();
+  virtual bool check_alive();
+  virtual void lock_tables_if();
+  virtual void unlock_tables_if();
+  virtual bool get_commit_error();
+  virtual void clear_error();
+  virtual void close_tables_if();
+  virtual void table_addref(size_t tbl_id);
+  virtual void table_release(size_t tbl_id);
+  virtual void cmd_open_index(dbcallback_i& cb, size_t pst_id, const char *dbn,
+    const char *tbl, const char *idx, const char *retflds,
+    const char *filflds);
+  virtual void cmd_exec_on_index(dbcallback_i& cb, const cmd_exec_args& args);
+  virtual void set_statistics(size_t num_conns, size_t num_active);
+ private:
+  int set_thread_message(const char *fmt, ...)
+    __attribute__((format (printf, 2, 3)));
+  bool parse_fields(TABLE *const table, const char *str,
+    prep_stmt::fields_type& flds);
+  void cmd_insert_internal(dbcallback_i& cb, const prep_stmt& pst,
+    const string_ref *fvals, size_t fvalslen);
+  void cmd_sql_internal(dbcallback_i& cb, const prep_stmt& pst,
+    const string_ref *fvals, size_t fvalslen);
+  void cmd_find_internal(dbcallback_i& cb, const prep_stmt& pst,
+    ha_rkey_function find_flag, const cmd_exec_args& args);
+  size_t calc_filter_buf_size(TABLE *table, const prep_stmt& pst,
+    const record_filter *filters);
+  bool fill_filter_buf(TABLE *table, const prep_stmt& pst,
+    const record_filter *filters, uchar *filter_buf, size_t len);
+  int check_filter(dbcallback_i& cb, TABLE *table, const prep_stmt& pst,
+    const record_filter *filters, const uchar *filter_buf);
+  void resp_record(dbcallback_i& cb, TABLE *const table, const prep_stmt& pst);
+  void dump_record(dbcallback_i& cb, TABLE *const table, const prep_stmt& pst);
+  int modify_record(dbcallback_i& cb, TABLE *const table,
+    const prep_stmt& pst, const cmd_exec_args& args, char mod_op,
+    size_t& modified_count);
+ private:
+  typedef std::vector<tablevec_entry> table_vec_type;
+  typedef std::pair<std::string, std::string> table_name_type;
+  typedef std::map<table_name_type, size_t> table_map_type;
+ private:
+  volatile database *const dbref;
+  bool for_write_flag;
+  THD *thd;
+  MYSQL_LOCK *lock;
+  bool lock_failed;
+  std::auto_ptr<expr_user_lock> user_lock;
+  int user_level_lock_timeout;
+  bool user_level_lock_locked;
+  bool commit_error;
+  std::vector<char> info_message_buf;
+  table_vec_type table_vec;
+  table_map_type table_map;
+  #if MYSQL_VERSION_ID >= 50505
+  MDL_request *mdl_request;
+  #else
+  void *mdl_request;
+  #endif
+};
+
+database::database(const config& c)
+  : child_running(1), conf(c)
+{
+}
+
+database::~database()
+{
+}
+
+dbcontext_ptr
+database::create_context(bool for_write) volatile
+{
+  return dbcontext_ptr(new dbcontext(this, for_write));
+}
+
+void
+database::stop() volatile
+{
+  child_running = false;
+}
+
+const config&
+database::get_conf() const volatile
+{
+  return const_cast<const config&>(conf);
+}
+
+database_ptr
+database_i::create(const config& conf)
+{
+  return database_ptr(new database(conf));
+}
+
+dbcontext::dbcontext(volatile database *d, bool for_write)
+  : dbref(d), for_write_flag(for_write), thd(0), lock(0), lock_failed(false),
+    user_level_lock_timeout(0), user_level_lock_locked(false),
+    commit_error(false), mdl_request(0)
+{
+  info_message_buf.resize(8192);
+  user_level_lock_timeout = d->get_conf().get_int("wrlock_timeout", 12);
+}
+
+dbcontext::~dbcontext()
+{
+}
+
+namespace {
+
+int
+wait_server_to_start(THD *thd, volatile int& shutdown_flag)
+{
+  int r = 0;
+  DBG_SHUT(fprintf(stderr, "HNDSOCK wsts\n"));
+  pthread_mutex_lock(&LOCK_server_started);
+  while (!mysqld_server_started) {
+    timespec abstime = { };
+    set_timespec(abstime, 1);
+    pthread_cond_timedwait(&COND_server_started, &LOCK_server_started,
+      &abstime);
+    pthread_mutex_unlock(&LOCK_server_started);
+    pthread_mutex_lock(&thd->mysys_var->mutex);
+    THD::killed_state st = thd->killed;
+    pthread_mutex_unlock(&thd->mysys_var->mutex);
+    DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d\n", (int)st));
+    pthread_mutex_lock(&LOCK_server_started);
+    if (st != THD::NOT_KILLED) {
+      DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst %d break\n", (int)st));
+      r = -1;
+      break;
+    }
+    if (shutdown_flag) {
+      DBG_SHUT(fprintf(stderr, "HNDSOCK wsts kst shut break\n"));
+      r = -1;
+      break;
+    }
+  }
+  pthread_mutex_unlock(&LOCK_server_started);
+  DBG_SHUT(fprintf(stderr, "HNDSOCK wsts done\n"));
+  return r;
+}
+
+}; // namespace
+
+void
+dbcontext::init_thread(const void *stack_bottom, volatile int& shutdown_flag)
+{
+  DBG_THR(fprintf(stderr, "HNDSOCK init thread\n"));
+  {
+    my_thread_init();
+    thd = new THD;
+    thd->thread_stack = (char *)stack_bottom;
+    DBG_THR(const size_t of = (char *)(&thd->thread_stack) - (char *)thd);
+    DBG_THR(fprintf(stderr, "thread_stack = %p sz=%zu of=%zu\n",
+      thd->thread_stack, sizeof(THD), of));
+    thd->store_globals();
+    thd->system_thread = static_cast<enum_thread_type>(1<<30UL);
+    const NET v = { 0 };
+    thd->net = v;
+    if (for_write_flag) {
+      #if MYSQL_VERSION_ID >= 50505
+      thd->variables.option_bits |= OPTION_BIN_LOG;
+      #else
+      thd->options |= OPTION_BIN_LOG;
+      #endif
+      safeFree(thd->db);
+      thd->db = 0;
+      thd->db = my_strdup("handlersocket", MYF(0));
+    }
+    my_pthread_setspecific_ptr(THR_THD, thd);
+    DBG_THR(fprintf(stderr, "HNDSOCK x0 %p\n", thd));
+  }
+  {
+    pthread_mutex_lock(&LOCK_thread_count);
+    thd->thread_id = thread_id++;
+    threads.append(thd);
+    ++thread_count;
+    pthread_mutex_unlock(&LOCK_thread_count);
+  }
+
+  DBG_THR(fprintf(stderr, "HNDSOCK init thread wsts\n"));
+  wait_server_to_start(thd, shutdown_flag);
+  DBG_THR(fprintf(stderr, "HNDSOCK init thread done\n"));
+
+  thd_proc_info(thd, &info_message_buf[0]);
+  set_thread_message("hs:listening");
+  DBG_THR(fprintf(stderr, "HNDSOCK x1 %p\n", thd));
+
+  #if MYSQL_VERSION_ID >= 50508
+  mdl_request = new(thd->mem_root) MDL_request;
+  mdl_request->init(MDL_key::TABLE, "", "",
+    for_write_flag ?  MDL_SHARED_WRITE : MDL_SHARED_READ, MDL_STATEMENT);
+  #elif MYSQL_VERSION_ID >= 50505
+  mdl_request = MDL_request::create(MDL_key::TABLE, "", "",
+    for_write_flag ?  MDL_SHARED_WRITE : MDL_SHARED_READ, thd->mem_root);
+  #endif
+
+  lex_start(thd);
+
+  user_lock.reset(new expr_user_lock(thd, user_level_lock_timeout));
+}
+
+int
+dbcontext::set_thread_message(const char *fmt, ...)
+{
+  va_list ap;
+  va_start(ap, fmt);
+  const int n = vsnprintf(&info_message_buf[0], info_message_buf.size(),
+    fmt, ap);
+  va_end(ap);
+  return n;
+}
+
+void
+dbcontext::term_thread()
+{
+  DBG_THR(fprintf(stderr, "HNDSOCK thread end %p\n", thd));
+  unlock_tables_if();
+  my_pthread_setspecific_ptr(THR_THD, 0);
+  {
+    pthread_mutex_lock(&LOCK_thread_count);
+    delete thd;
+    thd = 0;
+    --thread_count;
+    pthread_mutex_unlock(&LOCK_thread_count);
+    my_thread_end();
+  }
+}
+
+bool
+dbcontext::check_alive()
+{
+  pthread_mutex_lock(&thd->mysys_var->mutex);
+  THD::killed_state st = thd->killed;
+  pthread_mutex_unlock(&thd->mysys_var->mutex);
+  DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %p %p %d %zu\n", thd, &thd->killed,
+    (int)st, sizeof(*thd)));
+  if (st != THD::NOT_KILLED) {
+    DBG_SHUT(fprintf(stderr, "chk HNDSOCK kst %d break\n", (int)st));
+    return false;
+  }
+  return true;
+}
+
+void
+dbcontext::lock_tables_if()
+{
+  if (lock_failed) {
+    return;
+  }
+  if (for_write_flag && !user_level_lock_locked) {
+    if (user_lock->get_lock()) {
+      user_level_lock_locked = true;
+    } else {
+      lock_failed = true;
+      return;
+    }
+  }
+  if (lock == 0) {
+    const size_t num_max = table_vec.size();
+    TABLE *tables[num_max ? num_max : 1]; /* GNU */
+    size_t num_open = 0;
+    for (size_t i = 0; i < num_max; ++i) {
+      if (table_vec[i].refcount > 0) {
+	tables[num_open++] = table_vec[i].table;
+      }
+      table_vec[i].modified = false;
+    }
+    #if MYSQL_VERSION_ID >= 50505
+    lock = thd->lock = mysql_lock_tables(thd, &tables[0], num_open, 0);
+    #else
+    bool need_reopen= false;
+    lock = thd->lock = mysql_lock_tables(thd, &tables[0], num_open,
+      MYSQL_LOCK_NOTIFY_IF_NEED_REOPEN, &need_reopen);
+    #endif
+    statistic_increment(lock_tables_count, &LOCK_status);
+    thd_proc_info(thd, &info_message_buf[0]);
+    DENA_VERBOSE(100, fprintf(stderr, "HNDSOCK lock tables %p %p %zu %zu\n",
+      thd, lock, num_max, num_open));
+    if (lock == 0) {
+      lock_failed = true;
+      DENA_VERBOSE(10, fprintf(stderr, "HNDSOCK failed to lock tables %p\n",
+	thd));
+    }
+    if (for_write_flag) {
+      #if MYSQL_VERSION_ID >= 50505
+      thd->set_current_stmt_binlog_format_row();
+      #else
+      thd->current_stmt_binlog_row_based = 1;
+      #endif
+    }
+  }
+  DBG_LOCK(fprintf(stderr, "HNDSOCK tblnum=%d\n", (int)tblnum));
+}
+
+void
+dbcontext::unlock_tables_if()
+{
+  if (lock != 0) {
+    DENA_VERBOSE(100, fprintf(stderr, "HNDSOCK unlock tables\n"));
+    if (for_write_flag) {
+      for (size_t i = 0; i < table_vec.size(); ++i) {
+	if (table_vec[i].modified) {
+	  query_cache_invalidate3(thd, table_vec[i].table, 0);
+	    /* invalidate immediately */
+	}
+      }
+      bool suc = true;
+      #if MYSQL_VERSION_ID >= 50505
+      suc = (trans_commit_stmt(thd) == 0);
+      #else
+      suc = (ha_autocommit_or_rollback(thd, 0) == 0);
+      #endif
+      if (!suc) {
+	commit_error = true;
+	DENA_VERBOSE(10, fprintf(stderr,
+	  "HNDSOCK unlock tables: commit failed\n"));
+      }
+    }
+    mysql_unlock_tables(thd, lock);
+    lock = thd->lock = 0;
+    statistic_increment(unlock_tables_count, &LOCK_status);
+  }
+  if (user_level_lock_locked) {
+    if (user_lock->release_lock()) {
+      user_level_lock_locked = false;
+    }
+  }
+}
+
+bool
+dbcontext::get_commit_error()
+{
+  return commit_error;
+}
+
+void
+dbcontext::clear_error()
+{
+  lock_failed = false;
+  commit_error = false;
+}
+
+void
+dbcontext::close_tables_if()
+{
+  unlock_tables_if();
+  if (!table_vec.empty()) {
+    DENA_VERBOSE(100, fprintf(stderr, "HNDSOCK close tables\n"));
+    close_thread_tables(thd);
+    statistic_increment(close_tables_count, &LOCK_status);
+    table_vec.clear();
+    table_map.clear();
+  }
+}
+
+void
+dbcontext::table_addref(size_t tbl_id)
+{
+  table_vec[tbl_id].refcount += 1;
+  DBG_REFCNT(fprintf(stderr, "%p %zu %zu addref\n", this, tbl_id,
+    table_vec[tbl_id].refcount));
+}
+
+void
+dbcontext::table_release(size_t tbl_id)
+{
+  table_vec[tbl_id].refcount -= 1;
+  DBG_REFCNT(fprintf(stderr, "%p %zu %zu release\n", this, tbl_id,
+    table_vec[tbl_id].refcount));
+}
+
+void
+dbcontext::resp_record(dbcallback_i& cb, TABLE *const table,
+  const prep_stmt& pst)
+{
+  char rwpstr_buf[64];
+  String rwpstr(rwpstr_buf, sizeof(rwpstr_buf), &my_charset_bin);
+  const prep_stmt::fields_type& rf = pst.get_ret_fields();
+  const size_t n = rf.size();
+  for (size_t i = 0; i < n; ++i) {
+    uint32_t fn = rf[i];
+    Field *const fld = table->field[fn];
+    DBG_FLD(fprintf(stderr, "fld=%p %zu\n", fld, fn));
+    if (fld->is_null()) {
+      /* null */
+      cb.dbcb_resp_entry(0, 0);
+    } else {
+      fld->val_str(&rwpstr, &rwpstr);
+      const size_t len = rwpstr.length();
+      if (len != 0) {
+	/* non-empty */
+	cb.dbcb_resp_entry(rwpstr.ptr(), rwpstr.length());
+      } else {
+	/* empty */
+	static const char empty_str[] = "";
+	cb.dbcb_resp_entry(empty_str, 0);
+      }
+    }
+  }
+}
+
+void
+dbcontext::dump_record(dbcallback_i& cb, TABLE *const table,
+  const prep_stmt& pst)
+{
+  char rwpstr_buf[64];
+  String rwpstr(rwpstr_buf, sizeof(rwpstr_buf), &my_charset_bin);
+  const prep_stmt::fields_type& rf = pst.get_ret_fields();
+  const size_t n = rf.size();
+  for (size_t i = 0; i < n; ++i) {
+    uint32_t fn = rf[i];
+    Field *const fld = table->field[fn];
+    if (fld->is_null()) {
+      /* null */
+      cb.dbcb_resp_entry(0, 0);
+      fprintf(stderr, "NULL");
+    } else {
+      fld->val_str(&rwpstr, &rwpstr);
+      const std::string s(rwpstr.ptr(), rwpstr.length());
+      fprintf(stderr, "[%s]", s.c_str());
+    }
+  }
+  fprintf(stderr, "\n");
+}
+
+int
+dbcontext::modify_record(dbcallback_i& cb, TABLE *const table,
+  const prep_stmt& pst, const cmd_exec_args& args, char mod_op,
+  size_t& modified_count)
+{
+  if (mod_op == 'U') {
+    /* update */
+    handler *const hnd = table->file;
+    uchar *const buf = table->record[0];
+    store_record(table, record[1]);
+    const prep_stmt::fields_type& rf = pst.get_ret_fields();
+    const size_t n = rf.size();
+    for (size_t i = 0; i < n; ++i) {
+      const string_ref& nv = args.uvals[i];
+      uint32_t fn = rf[i];
+      Field *const fld = table->field[fn];
+      if (nv.begin() == 0) {
+	fld->set_null();
+      } else {
+	fld->set_notnull();
+	fld->store(nv.begin(), nv.size(), &my_charset_bin);
+      }
+    }
+    table_vec[pst.get_table_id()].modified = true;
+    const int r = hnd->ha_update_row(table->record[1], buf);
+    if (r != 0 && r != HA_ERR_RECORD_IS_THE_SAME) {
+      return r;
+    }
+    ++modified_count; /* TODO: HA_ERR_RECORD_IS_THE_SAME? */
+  } else if (mod_op == 'D') {
+    /* delete */
+    handler *const hnd = table->file;
+    table_vec[pst.get_table_id()].modified = true;
+    const int r = hnd->ha_delete_row(table->record[0]);
+    if (r != 0) {
+      return r;
+    }
+    ++modified_count;
+  } else if (mod_op == '+' || mod_op == '-') {
+    /* increment/decrement */
+    handler *const hnd = table->file;
+    uchar *const buf = table->record[0];
+    store_record(table, record[1]);
+    const prep_stmt::fields_type& rf = pst.get_ret_fields();
+    const size_t n = rf.size();
+    size_t i = 0;
+    for (i = 0; i < n; ++i) {
+      const string_ref& nv = args.uvals[i];
+      uint32_t fn = rf[i];
+      Field *const fld = table->field[fn];
+      if (fld->is_null() || nv.begin() == 0) {
+	continue;
+      }
+      const long long pval = fld->val_int();
+      const long long llv = atoll_nocheck(nv.begin(), nv.end());
+      /* TODO: llv == 0? */
+      long long nval = 0;
+      if (mod_op == '+') {
+	/* increment */
+	nval = pval + llv;
+      } else {
+	/* decrement */
+	nval = pval - llv;
+	if ((pval < 0 && nval > 0) || (pval > 0 && nval < 0)) {
+	  break; /* don't modify */
+	}
+	if ((pval < 0) != (nval < 0)) {
+	  nval = 0; /* crip */
+	}
+      }
+      fld->store(nval, false);
+    }
+    if (i == n) {
+      /* modify */
+      table_vec[pst.get_table_id()].modified = true;
+      const int r = hnd->ha_update_row(table->record[1], buf);
+      if (r != 0 && r != HA_ERR_RECORD_IS_THE_SAME) {
+	return r;
+      }
+      ++modified_count;
+    }
+  }
+  return 0;
+}
+
+void
+dbcontext::cmd_insert_internal(dbcallback_i& cb, const prep_stmt& pst,
+  const string_ref *fvals, size_t fvalslen)
+{
+  if (!for_write_flag) {
+    return cb.dbcb_resp_short(2, "readonly");
+  }
+  lock_tables_if();
+  if (lock == 0) {
+    return cb.dbcb_resp_short(2, "lock_tables");
+  }
+  if (pst.get_table_id() >= table_vec.size()) {
+    return cb.dbcb_resp_short(2, "tblnum");
+  }
+  TABLE *const table = table_vec[pst.get_table_id()].table;
+  handler *const hnd = table->file;
+  uchar *const buf = table->record[0];
+  empty_record(table);
+  memset(buf, 0, table->s->null_bytes); /* clear null flags */
+  Field **fld = table->field;
+  size_t i = 0;
+  for (; *fld && i < fvalslen; ++fld, ++i) {
+    if (fvals[i].begin() == 0) {
+      (*fld)->set_null();
+    } else {
+      (*fld)->store(fvals[i].begin(), fvals[i].size(), &my_charset_bin);
+    }
+  }
+  table->next_number_field = table->found_next_number_field;
+  const int r = hnd->ha_write_row(buf);
+  table->next_number_field = 0;
+  table_vec[pst.get_table_id()].modified = true;
+  return cb.dbcb_resp_short(r != 0 ? 1 : 0, "");
+}
+
+void
+dbcontext::cmd_sql_internal(dbcallback_i& cb, const prep_stmt& pst,
+  const string_ref *fvals, size_t fvalslen)
+{
+  if (fvalslen < 1) {
+    return cb.dbcb_resp_short(2, "syntax");
+  }
+  return cb.dbcb_resp_short(2, "notimpl");
+}
+
+void
+dbcontext::cmd_find_internal(dbcallback_i& cb, const prep_stmt& pst,
+  ha_rkey_function find_flag, const cmd_exec_args& args)
+{
+  const bool debug_out = (verbose_level >= 100);
+  bool need_resp_record = true;
+  char mod_op = 0;
+  const string_ref& mod_op_str = args.mod_op;
+  if (mod_op_str.size() != 0) {
+    if (!for_write_flag) {
+      return cb.dbcb_resp_short(2, "readonly");
+    }
+    mod_op = mod_op_str.begin()[0];
+    need_resp_record = mod_op_str.size() > 1 && mod_op_str.begin()[1] == '?';
+    switch (mod_op) {
+    case 'U': /* update */
+    case 'D': /* delete */
+    case '+': /* increment */
+    case '-': /* decrement */
+      break;
+    default:
+      if (debug_out) {
+	fprintf(stderr, "unknown modop: %c\n", mod_op);
+      }
+      return cb.dbcb_resp_short(2, "modop");
+    }
+  }
+  lock_tables_if();
+  if (lock == 0) {
+    return cb.dbcb_resp_short(2, "lock_tables");
+  }
+  if (pst.get_table_id() >= table_vec.size()) {
+    return cb.dbcb_resp_short(2, "tblnum");
+  }
+  TABLE *const table = table_vec[pst.get_table_id()].table;
+  /* keys */
+  if (pst.get_idxnum() >= table->s->keys) {
+    return cb.dbcb_resp_short(2, "idxnum");
+  }
+  KEY& kinfo = table->key_info[pst.get_idxnum()];
+  if (args.kvalslen > kinfo.key_parts) {
+    return cb.dbcb_resp_short(2, "kpnum");
+  }
+  uchar key_buf[kinfo.key_length]; /* GNU */
+  size_t kplen_sum = 0;
+  {
+    DBG_KEY(fprintf(stderr, "SLOW\n"));
+    for (size_t i = 0; i < args.kvalslen; ++i) {
+      const KEY_PART_INFO & kpt = kinfo.key_part[i];
+      const string_ref& kval = args.kvals[i];
+      if (kval.begin() == 0) {
+	kpt.field->set_null();
+      } else {
+	kpt.field->set_notnull();
+      }
+      kpt.field->store(kval.begin(), kval.size(), &my_charset_bin);
+      kplen_sum += kpt.store_length;
+    }
+    key_copy(key_buf, table->record[0], &kinfo, kplen_sum);
+  }
+  /* filters */
+  uchar *filter_buf = 0;
+  if (args.filters != 0) {
+    const size_t filter_buf_len = calc_filter_buf_size(table, pst,
+      args.filters);
+    filter_buf = reinterpret_cast<uchar *>(alloca(filter_buf_len));
+      /* FIXME: TEST */
+    if (!fill_filter_buf(table, pst, args.filters, filter_buf,
+      filter_buf_len)) {
+      return cb.dbcb_resp_short(2, "filterblob");
+    }
+  }
+  /* handler */
+  table->read_set = &table->s->all_set;
+  handler *const hnd = table->file;
+  if (!for_write_flag) {
+    hnd->init_table_handle_for_HANDLER();
+  }
+  hnd->ha_index_or_rnd_end();
+  hnd->ha_index_init(pst.get_idxnum(), 1);
+  #if 0
+  statistic_increment(index_exec_count, &LOCK_status);
+  #endif
+  if (need_resp_record) {
+    cb.dbcb_resp_begin(pst.get_ret_fields().size());
+  }
+  const uint32_t limit = args.limit ? args.limit : 1;
+  uint32_t skip = args.skip;
+  size_t modified_count = 0;
+  int r = 0;
+  for (uint32_t i = 0; i < limit + skip; ++i) {
+    if (i == 0) {
+      const key_part_map kpm = (1U << args.kvalslen) - 1;
+      r = hnd->index_read_map(table->record[0], key_buf, kpm, find_flag);
+    } else {
+      switch (find_flag) {
+      case HA_READ_BEFORE_KEY:
+      case HA_READ_KEY_OR_PREV:
+	r = hnd->index_prev(table->record[0]);
+	break;
+      case HA_READ_AFTER_KEY:
+      case HA_READ_KEY_OR_NEXT:
+	r = hnd->index_next(table->record[0]);
+	break;
+      case HA_READ_KEY_EXACT:
+	r = hnd->index_next_same(table->record[0], key_buf, kplen_sum);
+	break;
+      default:
+	r = HA_ERR_END_OF_FILE; /* to finish the loop */
+	break;
+      }
+    }
+    if (debug_out) {
+      fprintf(stderr, "r=%d\n", r);
+      if (r == 0 || r == HA_ERR_RECORD_DELETED) { 
+	dump_record(cb, table, pst);
+      }
+    }
+    int filter_res = 0;
+    if (r != 0) {
+      /* no-count */
+    } else if (args.filters != 0 && (filter_res = check_filter(cb, table, 
+      pst, args.filters, filter_buf)) != 0) {
+      if (filter_res < 0) {
+	break;
+      }
+    } else if (skip > 0) {
+      --skip;
+    } else {
+      if (need_resp_record) {
+	resp_record(cb, table, pst);
+      }
+      if (mod_op != 0) {
+	r = modify_record(cb, table, pst, args, mod_op, modified_count);
+      }
+    }
+    if (r != 0 && r != HA_ERR_RECORD_DELETED) {
+      break;
+    }
+  }
+  hnd->ha_index_or_rnd_end();
+  if (r != 0 && r != HA_ERR_RECORD_DELETED && r != HA_ERR_KEY_NOT_FOUND &&
+    r != HA_ERR_END_OF_FILE) {
+    /* failed */
+    if (need_resp_record) {
+      /* revert dbcb_resp_begin() and dbcb_resp_entry() */
+      cb.dbcb_resp_cancel();
+    }
+    cb.dbcb_resp_short_num(2, r);
+  } else {
+    /* succeeded */
+    if (need_resp_record) {
+      cb.dbcb_resp_end();
+    } else {
+      cb.dbcb_resp_short_num(0, modified_count);
+    }
+  }
+}
+
+size_t
+dbcontext::calc_filter_buf_size(TABLE *table, const prep_stmt& pst,
+  const record_filter *filters)
+{
+  size_t filter_buf_len = 0;
+  for (const record_filter *f = filters; f->op.begin() != 0; ++f) {
+    if (f->val.begin() == 0) {
+      continue;
+    }
+    const uint32_t fn = pst.get_filter_fields()[f->ff_offset];
+    filter_buf_len += table->field[fn]->pack_length();
+  }
+  return filter_buf_len;
+}
+
+bool
+dbcontext::fill_filter_buf(TABLE *table, const prep_stmt& pst,
+  const record_filter *filters, uchar *filter_buf, size_t len)
+{
+  memset(filter_buf, 0, len);
+  size_t pos = 0;
+  for (const record_filter *f = filters; f->op.begin() != 0; ++f) {
+    if (f->val.begin() == 0) {
+      continue;
+    }
+    const uint32_t fn = pst.get_filter_fields()[f->ff_offset];
+    Field *const fld = table->field[fn];
+    if ((fld->flags & BLOB_FLAG) != 0) {
+      return false;
+    }
+    fld->store(f->val.begin(), f->val.size(), &my_charset_bin);
+    const size_t packlen = fld->pack_length();
+    memcpy(filter_buf + pos, fld->ptr, packlen);
+    pos += packlen;
+  }
+  return true;
+}
+
+int
+dbcontext::check_filter(dbcallback_i& cb, TABLE *table, const prep_stmt& pst,
+  const record_filter *filters, const uchar *filter_buf)
+{
+  DBG_FILTER(fprintf(stderr, "check_filter\n"));
+  size_t pos = 0;
+  for (const record_filter *f = filters; f->op.begin() != 0; ++f) {
+    const string_ref& op = f->op;
+    const string_ref& val = f->val;
+    const uint32_t fn = pst.get_filter_fields()[f->ff_offset];
+    Field *const fld = table->field[fn];
+    const size_t packlen = fld->pack_length();
+    const uchar *const bval = filter_buf + pos;
+    int cv = 0;
+    if (fld->is_null()) {
+      cv = (val.begin() == 0) ? 0 : -1;
+    } else {
+      cv = (val.begin() == 0) ? 1 : fld->cmp(bval);
+    }
+    DBG_FILTER(fprintf(stderr, "check_filter cv=%d\n", cv));
+    bool cond = true;
+    if (op.size() == 1) {
+      switch (op.begin()[0]) {
+      case '>':
+	DBG_FILTER(fprintf(stderr, "check_filter op: >\n"));
+	cond = (cv > 0);
+	break;
+      case '<':
+	DBG_FILTER(fprintf(stderr, "check_filter op: <\n"));
+	cond = (cv < 0);
+	break;
+      case '=':
+	DBG_FILTER(fprintf(stderr, "check_filter op: =\n"));
+	cond = (cv == 0);
+	break;
+      default:
+	DBG_FILTER(fprintf(stderr, "check_filter op: unknown\n"));
+	cond = false; /* FIXME: error */
+	break;
+      }
+    } else if (op.size() == 2 && op.begin()[1] == '=') {
+      switch (op.begin()[0]) {
+      case '>':
+	DBG_FILTER(fprintf(stderr, "check_filter op: >=\n"));
+	cond = (cv >= 0);
+	break;
+      case '<':
+	DBG_FILTER(fprintf(stderr, "check_filter op: <=\n"));
+	cond = (cv <= 0);
+	break;
+      case '!':
+	DBG_FILTER(fprintf(stderr, "check_filter op: !=\n"));
+	cond = (cv != 0);
+	break;
+      default:
+	DBG_FILTER(fprintf(stderr, "check_filter op: unknown\n"));
+	cond = false; /* FIXME: error */
+	break;
+      }
+    }
+    DBG_FILTER(fprintf(stderr, "check_filter cond: %d\n", (int)cond));
+    if (!cond) {
+      return (f->filter_type == record_filter_type_skip) ? 1 : -1;
+    }
+    if (val.begin() != 0) {
+      pos += packlen;
+    }
+  }
+  return 0;
+}
+
+void
+dbcontext::cmd_open_index(dbcallback_i& cb, size_t pst_id, const char *dbn,
+  const char *tbl, const char *idx, const char *retflds, const char *filflds)
+{
+  unlock_tables_if();
+  const table_name_type k = std::make_pair(std::string(dbn), std::string(tbl));
+  const table_map_type::const_iterator iter = table_map.find(k);
+  uint32_t tblnum = 0;
+  if (iter != table_map.end()) {
+    tblnum = iter->second;
+    DBG_CMP(fprintf(stderr, "HNDSOCK k=%s tblnum=%d\n", k.c_str(),
+      (int)tblnum));
+  } else {
+    TABLE_LIST tables;
+    TABLE *table = 0;
+    bool refresh = true;
+    const thr_lock_type lock_type = for_write_flag ? TL_WRITE : TL_READ;
+    #if MYSQL_VERSION_ID >= 50505
+    tables.init_one_table(dbn, strlen(dbn), tbl, strlen(tbl), tbl,
+      lock_type);
+    tables.mdl_request = mdl_request;
+    Open_table_context ot_act(thd, MYSQL_OPEN_REOPEN);
+    if (!open_table(thd, &tables, thd->mem_root, &ot_act)) {
+      table = tables.table;
+    }
+    #else
+    tables.init_one_table(dbn, tbl, lock_type);
+    table = open_table(thd, &tables, thd->mem_root, &refresh,
+      OPEN_VIEW_NO_PARSE);
+    #endif
+    if (table == 0) {
+      DENA_VERBOSE(10, fprintf(stderr,
+	"HNDSOCK failed to open %p [%s] [%s] [%d]\n",
+	thd, dbn, tbl, static_cast<int>(refresh)));
+      return cb.dbcb_resp_short(2, "open_table");
+    }
+    statistic_increment(open_tables_count, &LOCK_status);
+    table->reginfo.lock_type = lock_type;
+    table->use_all_columns();
+    tblnum = table_vec.size();
+    tablevec_entry e;
+    e.table = table;
+    table_vec.push_back(e);
+    table_map[k] = tblnum;
+  }
+  size_t idxnum = static_cast<size_t>(-1);
+  if (idx[0] >= '0' && idx[0] <= '9') {
+    /* numeric */
+    TABLE *const table = table_vec[tblnum].table;
+    idxnum = atoi(idx);
+    if (idxnum >= table->s->keys) {
+      return cb.dbcb_resp_short(2, "idxnum");
+    }
+  } else {
+    const char *const idx_name_to_open = idx[0]  == '\0' ? "PRIMARY" : idx;
+    TABLE *const table = table_vec[tblnum].table;
+    for (uint i = 0; i < table->s->keys; ++i) {
+      KEY& kinfo = table->key_info[i];
+      if (strcmp(kinfo.name, idx_name_to_open) == 0) {
+	idxnum = i;
+	break;
+      }
+    }
+  }
+  if (idxnum == size_t(-1)) {
+    return cb.dbcb_resp_short(2, "idxnum");
+  }
+  prep_stmt::fields_type rf;
+  prep_stmt::fields_type ff;
+  if (!parse_fields(table_vec[tblnum].table, retflds, rf)) {
+    return cb.dbcb_resp_short(2, "fld");
+  }
+  if (!parse_fields(table_vec[tblnum].table, filflds, ff)) {
+    return cb.dbcb_resp_short(2, "fld");
+  }
+  prep_stmt p(this, tblnum, idxnum, rf, ff);
+  cb.dbcb_set_prep_stmt(pst_id, p);
+  return cb.dbcb_resp_short(0, "");
+}
+
+bool
+dbcontext::parse_fields(TABLE *const table, const char *str,
+  prep_stmt::fields_type& flds)
+{
+  string_ref flds_sr(str, strlen(str));
+  std::vector<string_ref> fldnms;
+  if (flds_sr.size() != 0) {
+    split(',', flds_sr, fldnms);
+  }
+  for (size_t i = 0; i < fldnms.size(); ++i) {
+    Field **fld = 0;
+    size_t j = 0;
+    for (fld = table->field; *fld; ++fld, ++j) {
+      DBG_FLD(fprintf(stderr, "f %s\n", (*fld)->field_name));
+      string_ref fn((*fld)->field_name, strlen((*fld)->field_name));
+      if (fn == fldnms[i]) {
+	break;
+      }
+    }
+    if (*fld == 0) {
+      DBG_FLD(fprintf(stderr, "UNKNOWN FLD %s [%s]\n", retflds,
+	std::string(fldnms[i].begin(), fldnms[i].size()).c_str()));
+      return false;
+    }
+    DBG_FLD(fprintf(stderr, "FLD %s %zu\n", (*fld)->field_name, j));
+    flds.push_back(j);
+  }
+  return true;
+}
+
+enum db_write_op {
+  db_write_op_none = 0,
+  db_write_op_insert = 1,
+  db_write_op_sql = 2,
+};
+
+void
+dbcontext::cmd_exec_on_index(dbcallback_i& cb, const cmd_exec_args& args)
+{
+  const prep_stmt& p = *args.pst;
+  if (p.get_table_id() == static_cast<size_t>(-1)) {
+    return cb.dbcb_resp_short(2, "stmtnum");
+  }
+  ha_rkey_function find_flag = HA_READ_KEY_EXACT;
+  db_write_op wrop = db_write_op_none;
+  if (args.op.size() == 1) {
+    switch (args.op.begin()[0]) {
+    case '=':
+      find_flag = HA_READ_KEY_EXACT;
+      break;
+    case '>':
+      find_flag = HA_READ_AFTER_KEY;
+      break;
+    case '<':
+      find_flag = HA_READ_BEFORE_KEY;
+      break;
+    case '+':
+      wrop = db_write_op_insert;
+      break;
+    case 'S':
+      wrop = db_write_op_sql;
+      break;
+    default:
+      return cb.dbcb_resp_short(1, "op");
+    }
+  } else if (args.op.size() == 2 && args.op.begin()[1] == '=') {
+    switch (args.op.begin()[0]) {
+    case '>':
+      find_flag = HA_READ_KEY_OR_NEXT;
+      break;
+    case '<':
+      find_flag = HA_READ_KEY_OR_PREV;
+      break;
+    default:
+      return cb.dbcb_resp_short(1, "op");
+    }
+  } else {
+    return cb.dbcb_resp_short(1, "op");
+  }
+  if (args.kvalslen <= 0) {
+    return cb.dbcb_resp_short(2, "klen");
+  }
+  switch (wrop) {
+  case db_write_op_none:
+    return cmd_find_internal(cb, p, find_flag, args);
+  case db_write_op_insert:
+    return cmd_insert_internal(cb, p, args.kvals, args.kvalslen);
+  case db_write_op_sql:
+    return cmd_sql_internal(cb, p, args.kvals, args.kvalslen);
+  }
+}
+
+void
+dbcontext::set_statistics(size_t num_conns, size_t num_active)
+{
+  thd_proc_info(thd, &info_message_buf[0]);
+  if (for_write_flag) {
+    set_thread_message("handlersocket: mode=wr, %zu conns, %zu active",
+      num_conns, num_active);
+  } else {
+    set_thread_message("handlersocket: mode=rd, %zu conns, %zu active",
+      num_conns, num_active);
+  }
+}
+
+};
+

=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/database.hpp'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/database.hpp	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/database.hpp	2011-04-12 04:16:24 +0000
@@ -0,0 +1,130 @@
+
+// vim:sw=2:ai
+
+/*
+ * Copyright (C) 2010 DeNA Co.,Ltd.. All rights reserved.
+ * See COPYRIGHT.txt for details.
+ */
+
+#ifndef DENA_DATABASE_HPP
+#define DENA_DATABASE_HPP
+
+#include <string>
+#include <memory>
+#include <vector>
+#include <stdint.h>
+
+#include "string_buffer.hpp"
+#include "string_ref.hpp"
+#include "config.hpp"
+
+namespace dena {
+
+struct database_i;
+typedef std::auto_ptr<volatile database_i> database_ptr;
+
+struct dbcontext_i;
+typedef std::auto_ptr<dbcontext_i> dbcontext_ptr;
+
+struct database_i {
+  virtual ~database_i() { }
+  virtual dbcontext_ptr create_context(bool for_write) volatile = 0;
+  virtual void stop() volatile = 0;
+  virtual const config& get_conf() const volatile = 0;
+  static database_ptr create(const config& conf);
+};
+
+struct prep_stmt {
+  typedef std::vector<uint32_t> fields_type;
+ private:
+  dbcontext_i *dbctx; /* must be valid while *this is alive */
+  size_t table_id; /* a prep_stmt object holds a refcount of the table */
+  size_t idxnum;
+  fields_type ret_fields;
+  fields_type filter_fields;
+ public:
+  prep_stmt();
+  prep_stmt(dbcontext_i *c, size_t tbl, size_t idx, const fields_type& rf,
+    const fields_type& ff);
+  ~prep_stmt();
+  prep_stmt(const prep_stmt& x);
+  prep_stmt& operator =(const prep_stmt& x);
+ public:
+  size_t get_table_id() const { return table_id; }
+  size_t get_idxnum() const { return idxnum; }
+  const fields_type& get_ret_fields() const { return ret_fields; }
+  const fields_type& get_filter_fields() const { return filter_fields; }
+};
+
+struct dbcallback_i {
+  virtual ~dbcallback_i () { }
+  virtual void dbcb_set_prep_stmt(size_t pst_id, const prep_stmt& v) = 0;
+  virtual const prep_stmt *dbcb_get_prep_stmt(size_t pst_id) const = 0;
+  virtual void dbcb_resp_short(uint32_t code, const char *msg) = 0;
+  virtual void dbcb_resp_short_num(uint32_t code, uint32_t value) = 0;
+  virtual void dbcb_resp_begin(size_t num_flds) = 0;
+  virtual void dbcb_resp_entry(const char *fld, size_t fldlen) = 0;
+  virtual void dbcb_resp_end() = 0;
+  virtual void dbcb_resp_cancel() = 0;
+};
+
+enum record_filter_type {
+  record_filter_type_skip = 0,
+  record_filter_type_break = 1,
+};
+
+struct record_filter {
+  record_filter_type filter_type;
+  string_ref op;
+  uint32_t ff_offset; /* offset in filter_fields */
+  string_ref val;
+  record_filter() : filter_type(record_filter_type_skip), ff_offset(0) { }
+};
+
+struct cmd_exec_args {
+  const prep_stmt *pst;
+  string_ref op;
+  const string_ref *kvals;
+  size_t kvalslen;
+  uint32_t limit;
+  uint32_t skip;
+  string_ref mod_op;
+  const string_ref *uvals; /* size must be pst->retfieelds.size() */
+  const record_filter *filters;
+  cmd_exec_args() : pst(0), kvals(0), kvalslen(0), limit(0), skip(0),
+    uvals(0), filters(0) { }
+};
+
+struct dbcontext_i {
+  virtual ~dbcontext_i() { }
+  virtual void init_thread(const void *stack_bottom,
+    volatile int& shutdown_flag) = 0;
+  virtual void term_thread() = 0;
+  virtual bool check_alive() = 0;
+  virtual void lock_tables_if() = 0;
+  virtual void unlock_tables_if() = 0;
+  virtual bool get_commit_error() = 0;
+  virtual void clear_error() = 0;
+  virtual void close_tables_if() = 0;
+  virtual void table_addref(size_t tbl_id) = 0; /* TODO: hide */
+  virtual void table_release(size_t tbl_id) = 0; /* TODO: hide */
+  virtual void cmd_open_index(dbcallback_i& cb, size_t pst_id, const char *dbn,
+    const char *tbl, const char *idx, const char *retflds,
+    const char *filflds) = 0;
+  virtual void cmd_exec_on_index(dbcallback_i& cb, const cmd_exec_args& args)
+    = 0;
+  virtual void set_statistics(size_t num_conns, size_t num_active) = 0;
+};
+
+};
+
+extern unsigned long long int open_tables_count;
+extern unsigned long long int close_tables_count;
+extern unsigned long long int lock_tables_count;
+extern unsigned long long int unlock_tables_count;
+#if 0
+extern unsigned long long int index_exec_count;
+#endif
+
+#endif
+

=== added file 'HandlerSocket-Plugin-for-MySQL/handlersocket/handlersocket.cpp'
--- HandlerSocket-Plugin-for-MySQL/handlersocket/handlersocket.cpp	1970-01-01 00:00:00 +0000
+++ HandlerSocket-Plugin-for-MySQL/handlersocket/handlersocket.cpp	2011-04-12 04:16:24 +0000
@@ -0,0 +1,216 @@
+
+// vim:sw=2:ai
+
+/*
+ * Copyright (C) 2010 DeNA Co.,Ltd.. All rights reserved.
+ * See COPYRIGHT.txt for details.
+ */
+
+#include <memory>
+#include <string>
+#include <stdio.h>
+
+#include "config.hpp"
+#include "hstcpsvr.hpp"
+#include "string_util.hpp"
+#include "mysql_incl.hpp"
+
+#define DBG_LOG \
+  if (dena::verbose_level >= 100) { \
+    fprintf(stderr, "%s %p\n", __PRETTY_FUNCTION__, this); \
+  }
+#define DBG_DO(x) if (dena::verbose_level >= 100) { x; }
+
+#define DBG_DIR(x)
+
+using namespace dena;
+
+static char *handlersocket_address = 0;
+static char *handlersocket_port = 0;
+static char *handlersocket_port_wr = 0;
+static unsigned int handlersocket_epoll = 1;
+static unsigned int handlersocket_threads = 32;
+static unsigned int handlersocket_threads_wr = 1;
+static unsigned int handlersocket_timeout = 30;
+static unsigned int handlersocket_backlog = 32768;
+static unsigned int handlersocket_sndbuf = 0;
+static unsigned int handlersocket_rcvbuf = 0;
+static unsigned int handlersocket_readsize = 0;
+static unsigned int handlersocket_accept_balance = 0;
+static unsigned int handlersocket_wrlock_timeout = 0;
+static char *handlersocket_plain_secret = 0;
+static char *handlersocket_plain_secret_wr = 0;
+
+struct daemon_handlersocket_data {
+  hstcpsvr_ptr hssvr_rd;
+  hstcpsvr_ptr hssvr_wr;
+};
+
+static int
+daemon_handlersocket_init(void *p)
+{
+  DENA_VERBOSE(10, fprintf(stderr, "handlersocket: initialized\n"));
+  config conf;
+  conf["use_epoll"] = handlersocket_epoll ? "1" : "0";
+  if (handlersocket_address) {
+    conf["host"] = handlersocket_address;
+  }
+  if (handlersocket_port) {
+    conf["port"] = handlersocket_port;
+  }
+  /*
+   * unix domain socket
+   * conf["host"] = "/";
+   * conf["port"] = "/tmp/handlersocket";
+   */
+  if (handlersocket_threads > 0) {
+    conf["num_threads"] = to_stdstring(handlersocket_threads);
+  } else {
+    conf["num_threads"] = "1";
+  }
+  conf["timeout"] = to_stdstring(handlersocket_timeout);
+  conf["listen_backlog"] = to_stdstring(handlersocket_backlog);
+  conf["sndbuf"] = to_stdstring(handlersocket_sndbuf);
+  conf["rcvbuf"] = to_stdstring(handlersocket_rcvbuf);
+  conf["readsize"] = to_stdstring(handlersocket_readsize);
+  conf["accept_balance"] = to_stdstring(handlersocket_accept_balance);
+  conf["wrlock_timeout"] = to_stdstring(handlersocket_wrlock_timeout);
+  std::auto_ptr<daemon_handlersocket_data> ap(new daemon_handlersocket_data);