CrossThreadChannel::CrossThreadChannel (bool non_blocking)
: receive_channel (0)
+ , receive_source (0)
{
fds[0] = -1;
fds[1] = -1;
CrossThreadChannel::~CrossThreadChannel ()
{
- if (receive_channel) {
+ if (receive_source) {
+ /* this disconnects it from any main context it was attached in
+ in ::attach(), this prevent its callback from being invoked
+ after the destructor has finished.
+ */
+ g_source_destroy (receive_source);
+ }
+
+ if (receive_channel) {
g_io_channel_unref (receive_channel);
+ receive_channel = 0;
}
if (fds[0] >= 0) {