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
|
/*
* Smart Common Input Method
*
* Copyright (c) 2004 James Su <suzhe@tsinghua.org.cn>
*
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library 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 Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser 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
*
* $Id: testsocketserver.cpp,v 1.2 2005/01/05 13:41:13 suzhe Exp $
*
*/
#define Uses_SCIM_SOCKET
#define Uses_SCIM_SOCKET_TRANSACTION
#define Uses_C_STRING
#include "scim_private.h"
#include "scim.h"
#include <ctype.h>
void accept_callback (scim::SocketServer *server, const scim::Socket &client)
{
std::cerr << "Accept client: " << client.get_id () << "\n";
}
void receive_callback (scim::SocketServer *server, const scim::Socket &client)
{
char buffer [32768];
int size;
if (client.wait_for_data (100) <= 0) {
std::cerr << "Error! timeout.\n";
return;
}
if ((size = client.read_with_timeout (buffer, 32768, 100)) > 0) {
buffer [size] = 0;
std::cerr << "Read " << size << " chars from client: " << client.get_id () << "\n";
std::cerr << buffer << "\n";
if (client.write (buffer, size) == size) {
std::cerr << "Write back ok!\n";
} else {
std::cerr << "Write back failed!\n";
}
} else {
std::cerr << "Error! Close the client.\n";
server->close_connection (client);
return;
}
if (strcmp (buffer, "exit") == 0)
server->shutdown ();
std::cerr << "\n";
}
void exception_callback (scim::SocketServer *server, const scim::Socket &client)
{
std::cerr << "Client: " << client.get_id () << " got an exception\n";
}
int main (int argc, char **argv)
{
scim::SocketAddress address;
scim::SocketAddress address2;
scim::SocketServer server;
scim::DebugOutput::set_verbose_level (4);
if (argc > 1)
address.set_address (argv[1]);
else
address.set_address ("inet:localhost:12345");
address2 = address;
server.signal_connect_accept (slot (accept_callback));
server.signal_connect_receive (slot (receive_callback));
server.signal_connect_exception (slot (exception_callback));
if (server.create (address2)) {
if (!server.run ()) {
std::cerr << "Error occurred when server running: "
<< server.get_error_message () << "\n";
} else {
std::cerr << "Server exit OK.\n";
}
} else {
std::cerr << "Error creating server: "
<< server.get_error_message () << "\n";
}
return 0;
}
/*
vi:ts=4:nowrap:ai
*/
|
