25 #include "dbus-internals.h"
26 #include "dbus-connection-internal.h"
27 #include "dbus-nonce.h"
28 #include "dbus-transport-socket.h"
29 #include "dbus-transport-protected.h"
30 #include "dbus-watch.h"
31 #include "dbus-credentials.h"
76 _dbus_verbose (
"start\n");
98 _dbus_verbose (
"end\n");
106 _dbus_verbose (
"\n");
108 free_watches (transport);
146 DBusAuthState auth_state;
154 if (auth_state == DBUS_AUTH_STATE_HAVE_BYTES_TO_SEND ||
155 auth_state == DBUS_AUTH_STATE_WAITING_FOR_MEMORY)
162 _dbus_verbose (
"check_write_watch(): needed = %d on connection %p watch %p fd = %" DBUS_SOCKET_FORMAT
" outgoing messages exist %d\n",
164 _dbus_socket_printable (socket_transport->
fd),
180 _dbus_verbose (
"fd = %" DBUS_SOCKET_FORMAT
"\n",
181 _dbus_socket_printable (socket_transport->
fd));
201 need_read_watch =
TRUE;
208 DBusAuthState auth_state;
218 if (auth_state == DBUS_AUTH_STATE_WAITING_FOR_INPUT ||
219 auth_state == DBUS_AUTH_STATE_WAITING_FOR_MEMORY ||
220 auth_state == DBUS_AUTH_STATE_AUTHENTICATED)
221 need_read_watch =
TRUE;
223 need_read_watch =
FALSE;
227 _dbus_verbose (
" setting read watch enabled = %d\n", need_read_watch);
259 saved_errno = _dbus_save_socket_errno ();
265 _dbus_verbose (
" read %d bytes in auth phase\n", bytes_read);
269 else if (bytes_read < 0)
281 _dbus_verbose (
"Error reading from remote app: %s\n",
282 _dbus_strerror (saved_errno));
283 do_io_error (transport);
292 _dbus_verbose (
"Disconnected from remote app\n");
293 do_io_error (transport);
315 saved_errno = _dbus_save_socket_errno ();
317 if (bytes_written > 0)
322 else if (bytes_written < 0)
330 _dbus_verbose (
"Error writing to remote app: %s\n",
331 _dbus_strerror (saved_errno));
332 do_io_error (transport);
348 _dbus_verbose (
"exchange_credentials: do_reading = %d, do_writing = %d\n",
349 do_reading, do_writing);
360 _dbus_verbose (
"Failed to write credentials: %s\n", error.
message);
362 do_io_error (transport);
383 _dbus_verbose (
"Failed to read credentials %s\n", error.
message);
385 do_io_error (transport);
420 *auth_completed =
FALSE;
429 if (!exchange_credentials (transport, do_reading, do_writing))
439 _dbus_verbose (
"send_credentials_pending = %d receive_credentials_pending = %d\n",
445 #define TRANSPORT_SIDE(t) ((t)->is_server ? "server" : "client")
448 case DBUS_AUTH_STATE_WAITING_FOR_INPUT:
449 _dbus_verbose (
" %s auth state: waiting for input\n",
450 TRANSPORT_SIDE (transport));
451 if (!do_reading || !read_data_into_auth (transport, &oom))
455 case DBUS_AUTH_STATE_WAITING_FOR_MEMORY:
456 _dbus_verbose (
" %s auth state: waiting for memory\n",
457 TRANSPORT_SIDE (transport));
462 case DBUS_AUTH_STATE_HAVE_BYTES_TO_SEND:
463 _dbus_verbose (
" %s auth state: bytes to send\n",
464 TRANSPORT_SIDE (transport));
465 if (!do_writing || !write_data_from_auth (transport))
469 case DBUS_AUTH_STATE_NEED_DISCONNECT:
470 _dbus_verbose (
" %s auth state: need to disconnect\n",
471 TRANSPORT_SIDE (transport));
472 do_io_error (transport);
475 case DBUS_AUTH_STATE_AUTHENTICATED:
476 _dbus_verbose (
" %s auth state: authenticated\n",
477 TRANSPORT_SIDE (transport));
480 case DBUS_AUTH_STATE_INVALID:
491 check_read_watch (transport);
492 check_write_watch (transport);
512 _dbus_verbose (
"Not authenticated, not writing anything\n");
518 _dbus_verbose (
"Not connected, not writing anything\n");
523 _dbus_verbose (
"do_writing(), have_messages = %d, fd = %" DBUS_SOCKET_FORMAT
"\n",
525 _dbus_socket_printable (socket_transport->
fd));
538 int header_len, body_len;
539 int total_bytes_to_write;
544 _dbus_verbose (
"%d bytes exceeds %d bytes written per iteration, returning\n",
554 _dbus_verbose (
"writing message %p\n", message);
566 _dbus_assert(!DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport));
589 _dbus_verbose (
"encoded message is %d bytes\n",
590 total_bytes_to_write);
598 saved_errno = _dbus_save_socket_errno ();
602 total_bytes_to_write = header_len + body_len;
605 _dbus_verbose (
"message is %d bytes\n",
606 total_bytes_to_write);
609 #ifdef HAVE_UNIX_FD_PASSING
619 _dbus_write_socket_with_unix_fds_two (socket_transport->
fd,
627 saved_errno = _dbus_save_socket_errno ();
629 if (bytes_written > 0 && n > 0)
630 _dbus_verbose(
"Wrote %i unix fds\n", n);
655 saved_errno = _dbus_save_socket_errno ();
659 if (bytes_written < 0)
688 _dbus_verbose (
" discard message of %d bytes due to ETOOMANYREFS\n",
689 total_bytes_to_write);
703 _dbus_verbose (
"Error writing to remote app: %s\n",
704 _dbus_strerror (saved_errno));
705 do_io_error (transport);
711 _dbus_verbose (
" wrote %d bytes of %d\n", bytes_written,
712 total_bytes_to_write);
714 total += bytes_written;
718 total_bytes_to_write);
750 _dbus_verbose (
"fd = %" DBUS_SOCKET_FORMAT
"\n",
751 _dbus_socket_printable (socket_transport->
fd));
764 check_read_watch (transport);
768 _dbus_verbose (
"%d bytes exceeds %d bytes read per iteration, returning\n",
785 _dbus_assert(!DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport));
794 saved_errno = _dbus_save_socket_errno ();
810 _dbus_verbose (
"Out of memory decoding incoming data\n");
838 #ifdef HAVE_UNIX_FD_PASSING
839 if (DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport) && may_read_unix_fds)
844 if (!_dbus_message_loader_get_unix_fds(transport->
loader, &fds, &n_fds))
846 _dbus_verbose (
"Out of memory reading file descriptors\n");
856 saved_errno = _dbus_save_socket_errno ();
858 if (bytes_read >= 0 && n_fds > 0)
859 _dbus_verbose(
"Read %i unix fds\n", n_fds);
861 _dbus_message_loader_return_unix_fds(transport->
loader, fds, bytes_read < 0 ? 0 : n_fds);
867 buffer, max_to_read);
868 saved_errno = _dbus_save_socket_errno ();
881 _dbus_verbose (
"Out of memory in read()/do_reading()\n");
889 _dbus_verbose (
"Error reading from remote app: %s\n",
890 _dbus_strerror (saved_errno));
891 do_io_error (transport);
895 else if (bytes_read == 0)
897 _dbus_verbose (
"Disconnected from remote app\n");
898 do_io_error (transport);
903 _dbus_verbose (
" read %d bytes\n", bytes_read);
910 _dbus_verbose (
" out of memory when queueing messages we just read in the transport\n");
941 _dbus_watch_get_enabled (transport->
read_watch))
962 if (!(flags &
DBUS_WATCH_READABLE) && unix_error_with_read_to_come (transport, watch, flags))
964 _dbus_verbose (
"Hang up or error on watch\n");
970 (flags & DBUS_WATCH_READABLE))
974 _dbus_verbose (
"handling read watch %p flags = %x\n",
977 if (!do_authentication (transport,
TRUE,
FALSE, &auth_finished))
988 if (!do_reading (transport))
990 _dbus_verbose (
"no memory to read\n");
996 _dbus_verbose (
"Not reading anything since we just completed the authentication\n");
1003 _dbus_verbose (
"handling write watch, have_outgoing_messages = %d\n",
1009 if (!do_writing (transport))
1011 _dbus_verbose (
"no memory to write\n");
1016 check_write_watch (transport);
1018 #ifdef DBUS_ENABLE_VERBOSE_MODE
1022 _dbus_verbose (
"asked to handle read watch with non-read condition 0x%x\n",
1025 _dbus_verbose (
"asked to handle write watch with non-write condition 0x%x\n",
1028 _dbus_verbose (
"asked to handle watch %p on fd %" DBUS_SOCKET_FORMAT
" that we don't recognize\n",
1029 watch, _dbus_socket_printable (_dbus_watch_get_socket (watch)));
1041 _dbus_verbose (
"\n");
1043 free_watches (transport);
1046 _dbus_socket_invalidate (&socket_transport->
fd);
1074 check_read_watch (transport);
1075 check_write_watch (transport);
1090 int timeout_milliseconds)
1097 _dbus_verbose (
" iteration flags = %s%s timeout = %d read_watch = %p write_watch = %p fd = %" DBUS_SOCKET_FORMAT
"\n",
1098 flags & DBUS_ITERATION_DO_READING ?
"read" :
"",
1099 flags & DBUS_ITERATION_DO_WRITING ?
"write" :
"",
1100 timeout_milliseconds,
1103 _dbus_socket_printable (socket_transport->
fd));
1111 poll_fd.
fd = _dbus_socket_get_pollable (socket_transport->
fd);
1126 if ((flags & DBUS_ITERATION_DO_WRITING) &&
1127 !(flags & (DBUS_ITERATION_DO_READING | DBUS_ITERATION_BLOCK)) &&
1131 do_writing (transport);
1140 if (flags & DBUS_ITERATION_DO_READING)
1144 if (flags & DBUS_ITERATION_DO_WRITING)
1149 DBusAuthState auth_state;
1154 auth_state == DBUS_AUTH_STATE_WAITING_FOR_INPUT)
1158 auth_state == DBUS_AUTH_STATE_HAVE_BYTES_TO_SEND)
1166 if (flags & DBUS_ITERATION_BLOCK)
1167 poll_timeout = timeout_milliseconds;
1176 if (flags & DBUS_ITERATION_BLOCK)
1178 _dbus_verbose (
"unlock pre poll\n");
1183 poll_res =
_dbus_poll (&poll_fd, 1, poll_timeout);
1184 saved_errno = _dbus_save_socket_errno ();
1189 if (flags & DBUS_ITERATION_BLOCK)
1191 _dbus_verbose (
"lock post poll\n");
1204 do_io_error (transport);
1211 _dbus_verbose (
"in iteration, need_read=%d need_write=%d\n",
1212 need_read, need_write);
1213 do_authentication (transport, need_read, need_write,
1214 &authentication_completed);
1217 if (authentication_completed)
1220 if (need_read && (flags & DBUS_ITERATION_DO_READING))
1221 do_reading (transport);
1222 if (need_write && (flags & DBUS_ITERATION_DO_WRITING))
1223 do_writing (transport);
1228 _dbus_verbose (
"Error from _dbus_poll(): %s\n",
1229 _dbus_strerror (saved_errno));
1245 check_write_watch (transport);
1247 _dbus_verbose (
" ... leaving do_iteration()\n");
1254 check_read_watch (transport);
1264 *fd_p = socket_transport->
fd;
1271 socket_handle_watch,
1273 socket_connection_set,
1274 socket_do_iteration,
1275 socket_live_messages_changed,
1276 socket_get_socket_fd
1298 if (socket_transport ==
NULL)
1308 DBUS_WATCH_WRITABLE,
1315 DBUS_WATCH_READABLE,
1323 server_guid, address))
1326 #ifdef HAVE_UNIX_FD_PASSING
1330 socket_transport->
fd = fd;
1369 const char *noncefile,
1376 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1398 if (family !=
NULL &&
1403 if (noncefile !=
NULL &&
1408 fd = _dbus_connect_tcp_socket_with_nonce (host, port, family, noncefile, error);
1409 if (!_dbus_socket_is_valid (fd))
1411 _DBUS_ASSERT_ERROR_IS_SET (error);
1416 _dbus_verbose (
"Successfully connected to tcp socket %s:%s\n",
1421 if (transport ==
NULL)
1425 _dbus_socket_invalidate (&fd);
1444 DBusTransportOpenResult
1456 isTcp = strcmp (method,
"tcp") == 0;
1457 isNonceTcp = strcmp (method,
"nonce-tcp") == 0;
1459 if (isTcp || isNonceTcp)
1466 if ((isNonceTcp ==
TRUE) != (noncefile !=
NULL)) {
1468 return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
1474 return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
1478 if (*transport_p ==
NULL)
1480 _DBUS_ASSERT_ERROR_IS_SET (error);
1481 return DBUS_TRANSPORT_OPEN_DID_NOT_CONNECT;
1485 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1486 return DBUS_TRANSPORT_OPEN_OK;
1491 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1492 return DBUS_TRANSPORT_OPEN_NOT_HANDLED;