1 /***************************************************************************
\r
2 * Copyright (C) 2008 *
\r
4 * This program is free software; you can redistribute it and/or modify *
\r
5 * it under the terms of the GNU General Public License as published by *
\r
6 * the Free Software Foundation; either version 2 of the License, or *
\r
7 * (at your option) any later version. *
\r
9 * This program is distributed in the hope that it will be useful, *
\r
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
\r
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
\r
12 * GNU General Public License for more details. *
\r
14 * You should have received a copy of the GNU General Public License *
\r
15 * along with this program; if not, write to the *
\r
16 * Free Software Foundation, Inc., *
\r
17 * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
\r
18 ***************************************************************************/
\r
20 #ifdef HAVE_CONFIG_H
\r
24 #include "tcl_server.h"
\r
28 #include "command.h"
\r
36 #define TCL_SERVER_VERSION "TCL Server 0.1"
\r
37 #define TCL_MAX_LINE (4096)
\r
39 typedef struct tcl_connection_s {
\r
42 char tc_line[TCL_MAX_LINE];
\r
44 int tc_outerror; /* flag an output error */
\r
47 extern Jim_Interp *interp;
\r
48 static unsigned short tcl_port = 0;
\r
51 static int handle_tcl_port_command(struct command_context_s *cmd_ctx, char *cmd, char **args, int argc);
\r
54 static int tcl_new_connection(connection_t *connection);
\r
55 static int tcl_input(connection_t *connection);
\r
56 static int tcl_output(connection_t *connection, const void *buf, ssize_t len);
\r
57 static int tcl_closed(connection_t *connection);
\r
59 /* write data out to a socket.
\r
61 * this is a blocking write, so the return value must equal the length, if
\r
62 * that is not the case then flag the connection with an output error.
\r
64 int tcl_output(connection_t *connection, const void *data, ssize_t len)
\r
67 tcl_connection_t *tclc;
\r
69 tclc = connection->priv;
\r
70 if (tclc->tc_outerror)
\r
71 return ERROR_SERVER_REMOTE_CLOSED;
\r
73 wlen = write_socket(connection->fd, data, len);
\r
77 LOG_ERROR("error during write: %d != %d", wlen, len);
\r
78 tclc->tc_outerror = 1;
\r
79 return ERROR_SERVER_REMOTE_CLOSED;
\r
84 static int tcl_new_connection(connection_t *connection)
\r
87 tcl_connection_t *tclc;
\r
89 tclc = malloc(sizeof(tcl_connection_t));
\r
91 return ERROR_CONNECTION_REJECTED;
\r
93 memset(tclc, 0, sizeof(tcl_connection_t));
\r
94 connection->priv = tclc;
\r
98 static int tcl_input(connection_t *connection)
\r
103 const char *result;
\r
105 tcl_connection_t *tclc;
\r
108 rlen = read_socket(connection->fd, &in, sizeof(in));
\r
111 LOG_ERROR("error during read: %s", strerror(errno));
\r
112 return ERROR_SERVER_REMOTE_CLOSED;
\r
115 tclc = connection->priv;
\r
117 return ERROR_CONNECTION_REJECTED;
\r
119 /* push as much data into the line as possible */
\r
120 for (i = 0; i < rlen; i++)
\r
122 if (!isprint(in[i]) && !isspace(in[i]))
\r
124 /* drop this line */
\r
125 tclc->tc_linedrop = 1;
\r
129 /* buffer the data */
\r
130 tclc->tc_line[tclc->tc_lineoffset] = in[i];
\r
131 if (tclc->tc_lineoffset < TCL_MAX_LINE)
\r
132 tclc->tc_lineoffset++;
\r
134 tclc->tc_linedrop = 1;
\r
139 /* process the line */
\r
140 if (tclc->tc_linedrop) {
\r
141 #define ESTR "line too long\n"
\r
142 retval = tcl_output(connection, ESTR, sizeof(ESTR));
\r
143 if (retval != ERROR_OK)
\r
147 tclc->tc_line[tclc->tc_lineoffset-1] = '\0';
\r
148 retval = Jim_Eval(interp, tclc->tc_line);
\r
149 result = Jim_GetString(Jim_GetResult(interp), &reslen);
\r
150 retval = tcl_output(connection, result, reslen);
\r
151 if (retval != ERROR_OK)
\r
153 if (memchr(result, '\n', reslen) == NULL)
\r
154 tcl_output(connection, "\n", 1);
\r
156 tclc->tc_lineoffset = 0;
\r
157 tclc->tc_linedrop = 0;
\r
163 static int tcl_closed(connection_t *connection)
\r
165 /* cleanup connection context */
\r
166 if (connection->priv) {
\r
167 free(connection->priv);
\r
168 connection->priv = NULL;
\r
179 LOG_WARNING("no tcl port specified, using default port 5555");
\r
183 retval = add_service("tcl", CONNECTION_TCL, tcl_port, 1, tcl_new_connection, tcl_input, tcl_closed, NULL);
\r
188 int tcl_register_commands(command_context_t *cmd_ctx)
\r
190 register_command(cmd_ctx, NULL, "tcl_port", handle_tcl_port_command, COMMAND_CONFIG, "");
\r
194 static int handle_tcl_port_command(struct command_context_s *cmd_ctx, char *cmd, char **args, int argc)
\r
197 tcl_port = strtoul(args[0], NULL, 0);
\r