1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
/* - mode: c; c-basic-offset: 2; indent-tabs-mode: nil; -*-
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
*
* Copyright (C) 2010 Brian Aker
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
*/
#include "config.h"
#include <drizzled/gettext.h>
#include <drizzled/error.h>
#include <drizzled/query_id.h>
#include <drizzled/sql_state.h>
#include <drizzled/session.h>
#include "drizzled/internal/my_sys.h"
#include "drizzled/internal/m_string.h"
#include <algorithm>
#include <iostream>
#include <boost/program_options.hpp>
#include <drizzled/module/option_map.h>
#include "drizzle_protocol.h"
#include "plugin/drizzle_protocol/status_table.h"
namespace po= boost::program_options;
using namespace drizzled;
using namespace std;
namespace drizzle_plugin
{
namespace drizzle_protocol
{
static port_constraint port;
static timeout_constraint connect_timeout;
static timeout_constraint read_timeout;
static timeout_constraint write_timeout;
static retry_constraint retry_count;
static buffer_constraint buffer_length;
static const uint32_t DRIZZLE_TCP_PORT= 4427;
ListenDrizzleProtocol::~ListenDrizzleProtocol()
{
}
in_port_t ListenDrizzleProtocol::getPort(void) const
{
return port;
}
static int init(drizzled::module::Context &context)
{
const module::option_map &vm= context.getOptions();
context.add(new StatusTable);
context.add(new ListenDrizzleProtocol("drizzle_protocol", vm["bind-address"].as<std::string>(), true));
context.registerVariable(new sys_var_constrained_value_readonly<in_port_t>("port", port));
context.registerVariable(new sys_var_constrained_value_readonly<uint32_t>("connect_timeout", connect_timeout));
context.registerVariable(new sys_var_constrained_value_readonly<uint32_t>("read_timeout", read_timeout));
context.registerVariable(new sys_var_constrained_value_readonly<uint32_t>("write_timeout", write_timeout));
context.registerVariable(new sys_var_constrained_value_readonly<uint32_t>("retry_count", retry_count));
context.registerVariable(new sys_var_constrained_value_readonly<uint32_t>("buffer_length", buffer_length));
context.registerVariable(new sys_var_const_string_val("bind_address",
vm["bind-address"].as<std::string>()));
return 0;
}
static void init_options(drizzled::module::option_context &context)
{
context("port",
po::value<port_constraint>(&port)->default_value(DRIZZLE_TCP_PORT),
N_("Port number to use for connection or 0 for default to with Drizzle/MySQL protocol."));
context("connect-timeout",
po::value<timeout_constraint>(&connect_timeout)->default_value(10),
N_("Connect Timeout."));
context("read-timeout",
po::value<timeout_constraint>(&read_timeout)->default_value(30),
N_("Read Timeout."));
context("write-timeout",
po::value<timeout_constraint>(&write_timeout)->default_value(60),
N_("Write Timeout."));
context("retry-count",
po::value<retry_constraint>(&retry_count)->default_value(10),
N_("Retry Count."));
context("buffer-length",
po::value<buffer_constraint>(&buffer_length)->default_value(16384),
N_("Buffer length."));
context("bind-address",
po::value<std::string>()->default_value(""),
N_("Address to bind to."));
}
} /* namespace drizzle_protocol */
} /* namespace drizzle_plugin */
DRIZZLE_PLUGIN(drizzle_plugin::drizzle_protocol::init, NULL, drizzle_plugin::drizzle_protocol::init_options);
|