2 Copyright (C) 2009 Paul Davis
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or
7 (at your option) any later version.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
20 CrossThreadChannel::CrossThreadChannel (bool non_blocking)
28 struct sockaddr_in send_address;
31 send_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
32 send_address.sin_family = AF_INET;
33 send_address.sin_addr.s_addr = inet_addr("127.0.0.1");
34 send_address.sin_port = htons(0);
35 int status = bind(send_socket, (SOCKADDR*)&send_address,
36 sizeof(send_address));
39 std::cerr << "CrossThreadChannel::CrossThreadChannel() Send socket binding failed with error: " << WSAGetLastError() << std::endl;
43 // make the socket non-blockable if required
44 u_long mode = (u_long)non_blocking;
47 otp_result = ioctlsocket(send_socket, FIONBIO, &mode);
48 if (otp_result != NO_ERROR) {
49 std::cerr << "CrossThreadChannel::CrossThreadChannel() Send socket cannot be set to non blocking mode with error: " << WSAGetLastError() << std::endl;
52 // Create Receive Socket, this socket will be set to unblockable mode by IO channel
53 receive_socket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
54 recv_address.sin_family = AF_INET;
55 recv_address.sin_addr.s_addr = inet_addr("127.0.0.1");
56 recv_address.sin_port = htons(0);
57 status = bind(receive_socket, (SOCKADDR*)&recv_address,
58 sizeof(recv_address));
61 std::cerr << "CrossThreadChannel::CrossThreadChannel() Receive socket binding failed with error: " << WSAGetLastError() << std::endl;
65 // recieve socket will be made non-blocking by GSource which will use it
67 // get assigned port number for Receive Socket
68 int recv_addr_len = sizeof(recv_address);
69 status = getsockname(receive_socket, (SOCKADDR*)&recv_address, &recv_addr_len);
72 std::cerr << "CrossThreadChannel::CrossThreadChannel() Setting receive socket address to local failed with error: " << WSAGetLastError() << std::endl;
76 // construct IOChannel
77 receive_channel = g_io_channel_win32_new_socket((gint)receive_socket);
79 // set binary data type
80 GIOStatus g_status = g_io_channel_set_encoding (receive_channel, NULL, NULL);
81 if (G_IO_STATUS_NORMAL != g_status ) {
82 std::cerr << "CrossThreadChannel::CrossThreadChannel() Cannot set flag for IOChannel. " << g_status << std::endl;
86 // disable channel buffering
87 g_io_channel_set_buffered (receive_channel, false);
90 CrossThreadChannel::~CrossThreadChannel ()
93 /* this disconnects it from any main context it was attached in
94 in ::attach(), this prevent its callback from being invoked
95 after the destructor has finished.
97 g_source_destroy (receive_source);
102 if (receive_channel) {
103 g_io_channel_unref (receive_channel);
106 closesocket(send_socket);
107 closesocket(receive_socket);
111 CrossThreadChannel::wakeup ()
115 // write one byte to wake up a thread which is listening our IOS
116 sendto(send_socket, &c, sizeof(c), 0, (SOCKADDR*)&recv_address, sizeof(recv_address) );
120 CrossThreadChannel::drain ()
122 /* flush the buffer - empty the channel from all requests */
128 GIOStatus g_status = g_io_channel_read_chars (receive_channel, buffer, sizeof(buffer), &read, &g_error);
130 if (G_IO_STATUS_AGAIN == g_status) {
134 if (G_IO_STATUS_NORMAL != g_status) {
135 std::cerr << "CrossThreadChannel::CrossThreadChannel() Cannot drain from read buffer! " << g_status << std::endl;
138 std::cerr << "Error is Domain: " << g_error->domain << " Code: " << g_error->code << std::endl;
139 g_clear_error(&g_error);
141 std::cerr << "No error provided\n";
150 CrossThreadChannel::deliver (char msg)
153 // write one particular byte to wake up the thread which is listening our IOS
154 int status = sendto(send_socket, &msg, sizeof(msg), 0, (SOCKADDR*)&recv_address, sizeof(recv_address) );
156 if (SOCKET_ERROR == status) {
164 CrossThreadChannel::poll_for_request()
166 // windows before Vista has no poll
170 FD_SET(receive_socket, &rfds);
171 if ((select(receive_socket+1, &rfds, NULL, NULL, NULL)) < 0) {
172 if (errno == EINTR) {
177 if(FD_ISSET(receive_socket, &rfds)) {
185 CrossThreadChannel::receive (char& msg, bool wait)
191 if (!poll_for_request ()) {
196 // fetch the message from the channel.
197 GIOStatus g_status = g_io_channel_read_chars (receive_channel, &msg, sizeof(msg), &read, &g_error);
199 if (G_IO_STATUS_NORMAL != g_status) {