root/platform/mysql/mycached/trunk/mycached_as_udf.cc @ 35019

/*
 * mycached - memcached protocol handler for mysqld
 * 
 * Copyright (C) 2009 Cybozu Labs, Inc.
 * 
 * This program is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License as published by the FreeSoftware
 * Foundation; either version 2 of the License.
 * 
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
 * details.
 * 
 * You should have received a copy of the GNU General Public License along with
 * this program; if not, write to the Free Software Foundation, Inc., 59 Temple
 * Place, Suite 330, Boston, MA 02111-1307 USA
 */

#include "mycached.hh"
#include "mycached.cc"
extern "C" {
#ifdef MYCACHED_USE_SELECT
# include "picoev_select.c"
#elif defined(MYCACHED_USE_KQUEUE)
# include "picoev_kqueue.c"
#elif defined(MYCACHED_USE_EPOLL)
# include "picoev_epoll.c"
#else
# error "define one of: MYCACHED_USE_SELECT, MYCACHED_USE_KQUEUE, MYCACHED_USE_EPOLL"
#endif
}

#define SETUP_ARG(i, t, n) \
  do { \
    args->arg_type[i] = t; \
    args->maybe_null[i] = n; \
  } while (0)
#define SETUP_ARG_IF(i, t, n) \
  do { \
    if (i < args->arg_count) \
      SETUP_ARG(i, t, n); \
  } while (0)

extern "C"
my_bool
mycached_start_init(UDF_INIT* initid, UDF_ARGS* args, char* message)
{
  if (args->arg_count != 2) {
    strcpy(message, "mycached_start(host,port): invalid arguments");
    return 1;
  }
  initid->maybe_null = 0;
  SETUP_ARG(0, INT_RESULT, 0);
  SETUP_ARG(1, INT_RESULT, 0);
  return 0;
}

extern "C"
void
mycached_start_deinit(UDF_INIT* initid)
{
}

extern "C"
long long
mycached_start(UDF_INIT* initid, UDF_ARGS* args, char* is_null, char* error)
{
  return mycached::conn_t::start_server(*(long long*)args->args[0],
                                        *(long long*)args->args[1]);
}