Revision 2259 libsylph/socket.c
| socket.c (revision 2259) | ||
|---|---|---|
| 1329 | 1329 |
{
|
| 1330 | 1330 |
SockConnectData *conn_data = (SockConnectData *)data; |
| 1331 | 1331 |
|
| 1332 |
g_print("sock_connect_async_func: connect\n");
|
|
| 1333 | 1332 |
conn_data->sock = sock_connect(conn_data->hostname, conn_data->port); |
| 1334 | 1333 |
conn_data->flag = 1; |
| 1335 | 1334 |
|
| 1336 |
g_print("sock_connect_async_func: connected\n");
|
|
| 1335 |
debug_print("sock_connect_async_func: connected\n");
|
|
| 1337 | 1336 |
g_main_context_wakeup(NULL); |
| 1338 | 1337 |
|
| 1339 | 1338 |
return GINT_TO_POINTER(0); |
| ... | ... | |
| 1380 | 1379 |
return -1; |
| 1381 | 1380 |
} |
| 1382 | 1381 |
|
| 1383 |
g_print("sock_connect_async_wait: waiting thread\n");
|
|
| 1382 |
debug_print("sock_connect_async_wait: waiting thread\n");
|
|
| 1384 | 1383 |
while (conn_data->flag == 0) |
| 1385 | 1384 |
event_loop_iterate(); |
| 1386 | 1385 |
|
| 1387 |
g_print("sock_connect_async_wait: flagged\n");
|
|
| 1386 |
debug_print("sock_connect_async_wait: flagged\n");
|
|
| 1388 | 1387 |
g_thread_join(conn_data->thread); |
| 1389 |
g_print("sock_connect_async_wait: thread exited\n");
|
|
| 1388 |
debug_print("sock_connect_async_wait: thread exited\n");
|
|
| 1390 | 1389 |
|
| 1391 | 1390 |
*sock = conn_data->sock; |
| 1392 | 1391 |
|
Also available in: Unified diff