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 = %d outgoing messages exist %d\n",
164 socket_transport->
fd,
180 _dbus_verbose (
"fd = %d\n",socket_transport->
fd);
200 need_read_watch =
TRUE;
207 DBusAuthState auth_state;
217 if (auth_state == DBUS_AUTH_STATE_WAITING_FOR_INPUT ||
218 auth_state == DBUS_AUTH_STATE_WAITING_FOR_MEMORY ||
219 auth_state == DBUS_AUTH_STATE_AUTHENTICATED)
220 need_read_watch =
TRUE;
222 need_read_watch =
FALSE;
226 _dbus_verbose (
" setting read watch enabled = %d\n", need_read_watch);
259 bytes_read > 0 ? bytes_read : 0);
263 _dbus_verbose (
" read %d bytes in auth phase\n", bytes_read);
267 else if (bytes_read < 0)
279 _dbus_verbose (
"Error reading from remote app: %s\n",
281 do_io_error (transport);
290 _dbus_verbose (
"Disconnected from remote app\n");
291 do_io_error (transport);
311 0, _dbus_string_get_length (buffer));
313 if (bytes_written > 0)
318 else if (bytes_written < 0)
326 _dbus_verbose (
"Error writing to remote app: %s\n",
328 do_io_error (transport);
344 _dbus_verbose (
"exchange_credentials: do_reading = %d, do_writing = %d\n",
345 do_reading, do_writing);
356 _dbus_verbose (
"Failed to write credentials: %s\n", error.
message);
358 do_io_error (transport);
379 _dbus_verbose (
"Failed to read credentials %s\n", error.
message);
381 do_io_error (transport);
416 *auth_completed =
FALSE;
425 if (!exchange_credentials (transport, do_reading, do_writing))
435 _dbus_verbose (
"send_credentials_pending = %d receive_credentials_pending = %d\n",
441 #define TRANSPORT_SIDE(t) ((t)->is_server ? "server" : "client")
444 case DBUS_AUTH_STATE_WAITING_FOR_INPUT:
445 _dbus_verbose (
" %s auth state: waiting for input\n",
446 TRANSPORT_SIDE (transport));
447 if (!do_reading || !read_data_into_auth (transport, &oom))
451 case DBUS_AUTH_STATE_WAITING_FOR_MEMORY:
452 _dbus_verbose (
" %s auth state: waiting for memory\n",
453 TRANSPORT_SIDE (transport));
458 case DBUS_AUTH_STATE_HAVE_BYTES_TO_SEND:
459 _dbus_verbose (
" %s auth state: bytes to send\n",
460 TRANSPORT_SIDE (transport));
461 if (!do_writing || !write_data_from_auth (transport))
465 case DBUS_AUTH_STATE_NEED_DISCONNECT:
466 _dbus_verbose (
" %s auth state: need to disconnect\n",
467 TRANSPORT_SIDE (transport));
468 do_io_error (transport);
471 case DBUS_AUTH_STATE_AUTHENTICATED:
472 _dbus_verbose (
" %s auth state: authenticated\n",
473 TRANSPORT_SIDE (transport));
482 check_read_watch (transport);
483 check_write_watch (transport);
503 _dbus_verbose (
"Not authenticated, not writing anything\n");
509 _dbus_verbose (
"Not connected, not writing anything\n");
514 _dbus_verbose (
"do_writing(), have_messages = %d, fd = %d\n",
516 socket_transport->
fd);
529 int header_len, body_len;
530 int total_bytes_to_write;
534 _dbus_verbose (
"%d bytes exceeds %d bytes written per iteration, returning\n",
544 _dbus_verbose (
"writing message %p\n", message);
550 header_len = _dbus_string_get_length (header);
551 body_len = _dbus_string_get_length (body);
556 _dbus_assert(!DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport));
576 total_bytes_to_write = _dbus_string_get_length (&socket_transport->
encoded_outgoing);
579 _dbus_verbose (
"encoded message is %d bytes\n",
580 total_bytes_to_write);
591 total_bytes_to_write = header_len + body_len;
594 _dbus_verbose (
"message is %d bytes\n",
595 total_bytes_to_write);
598 #ifdef HAVE_UNIX_FD_PASSING
608 _dbus_write_socket_with_unix_fds_two (socket_transport->
fd,
617 if (bytes_written > 0 && n > 0)
618 _dbus_verbose(
"Wrote %i unix fds\n", n);
645 if (bytes_written < 0)
657 _dbus_verbose (
"Error writing to remote app: %s\n",
659 do_io_error (transport);
665 _dbus_verbose (
" wrote %d bytes of %d\n", bytes_written,
666 total_bytes_to_write);
668 total += bytes_written;
672 total_bytes_to_write);
703 _dbus_verbose (
"fd = %d\n",socket_transport->
fd);
716 check_read_watch (transport);
720 _dbus_verbose (
"%d bytes exceeds %d bytes read per iteration, returning\n",
737 _dbus_assert(!DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport));
758 _dbus_verbose (
"Out of memory decoding incoming data\n");
778 #ifdef HAVE_UNIX_FD_PASSING
779 if (DBUS_TRANSPORT_CAN_SEND_UNIX_FD(transport))
785 _dbus_verbose (
"Out of memory reading file descriptors\n");
796 if (bytes_read >= 0 && n_fds > 0)
797 _dbus_verbose(
"Read %i unix fds\n", n_fds);
818 _dbus_verbose (
"Out of memory in read()/do_reading()\n");
826 _dbus_verbose (
"Error reading from remote app: %s\n",
828 do_io_error (transport);
832 else if (bytes_read == 0)
834 _dbus_verbose (
"Disconnected from remote app\n");
835 do_io_error (transport);
840 _dbus_verbose (
" read %d bytes\n", bytes_read);
847 _dbus_verbose (
" out of memory when queueing messages we just read in the transport\n");
878 _dbus_watch_get_enabled (transport->
read_watch))
899 if (!(flags &
DBUS_WATCH_READABLE) && unix_error_with_read_to_come (transport, watch, flags))
901 _dbus_verbose (
"Hang up or error on watch\n");
907 (flags & DBUS_WATCH_READABLE))
911 _dbus_verbose (
"handling read watch %p flags = %x\n",
914 if (!do_authentication (transport,
TRUE,
FALSE, &auth_finished))
925 if (!do_reading (transport))
927 _dbus_verbose (
"no memory to read\n");
933 _dbus_verbose (
"Not reading anything since we just completed the authentication\n");
940 _dbus_verbose (
"handling write watch, have_outgoing_messages = %d\n",
946 if (!do_writing (transport))
948 _dbus_verbose (
"no memory to write\n");
953 check_write_watch (transport);
955 #ifdef DBUS_ENABLE_VERBOSE_MODE
959 _dbus_verbose (
"asked to handle read watch with non-read condition 0x%x\n",
962 _dbus_verbose (
"asked to handle write watch with non-write condition 0x%x\n",
965 _dbus_verbose (
"asked to handle watch %p on fd %d that we don't recognize\n",
978 _dbus_verbose (
"\n");
980 free_watches (transport);
983 socket_transport->
fd = -1;
1011 check_read_watch (transport);
1012 check_write_watch (transport);
1027 int timeout_milliseconds)
1034 _dbus_verbose (
" iteration flags = %s%s timeout = %d read_watch = %p write_watch = %p fd = %d\n",
1035 flags & DBUS_ITERATION_DO_READING ?
"read" :
"",
1036 flags & DBUS_ITERATION_DO_WRITING ?
"write" :
"",
1037 timeout_milliseconds,
1040 socket_transport->
fd);
1048 poll_fd.
fd = socket_transport->
fd;
1063 if ((flags & DBUS_ITERATION_DO_WRITING) &&
1064 !(flags & (DBUS_ITERATION_DO_READING | DBUS_ITERATION_BLOCK)) &&
1068 do_writing (transport);
1077 if (flags & DBUS_ITERATION_DO_READING)
1081 if (flags & DBUS_ITERATION_DO_WRITING)
1086 DBusAuthState auth_state;
1091 auth_state == DBUS_AUTH_STATE_WAITING_FOR_INPUT)
1095 auth_state == DBUS_AUTH_STATE_HAVE_BYTES_TO_SEND)
1101 if (flags & DBUS_ITERATION_BLOCK)
1102 poll_timeout = timeout_milliseconds;
1111 if (flags & DBUS_ITERATION_BLOCK)
1113 _dbus_verbose (
"unlock pre poll\n");
1118 poll_res =
_dbus_poll (&poll_fd, 1, poll_timeout);
1123 if (flags & DBUS_ITERATION_BLOCK)
1125 _dbus_verbose (
"lock post poll\n");
1138 do_io_error (transport);
1145 _dbus_verbose (
"in iteration, need_read=%d need_write=%d\n",
1146 need_read, need_write);
1147 do_authentication (transport, need_read, need_write,
1148 &authentication_completed);
1151 if (authentication_completed)
1154 if (need_read && (flags & DBUS_ITERATION_DO_READING))
1155 do_reading (transport);
1156 if (need_write && (flags & DBUS_ITERATION_DO_WRITING))
1157 do_writing (transport);
1162 _dbus_verbose (
"Error from _dbus_poll(): %s\n",
1179 check_write_watch (transport);
1181 _dbus_verbose (
" ... leaving do_iteration()\n");
1188 check_read_watch (transport);
1198 *fd_p = socket_transport->
fd;
1205 socket_handle_watch,
1207 socket_connection_set,
1208 socket_do_iteration,
1209 socket_live_messages_changed,
1210 socket_get_socket_fd
1232 if (socket_transport ==
NULL)
1242 DBUS_WATCH_WRITABLE,
1249 DBUS_WATCH_READABLE,
1257 server_guid, address))
1260 #ifdef HAVE_UNIX_FD_PASSING
1264 socket_transport->
fd = fd;
1303 const char *noncefile,
1310 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1332 if (family !=
NULL &&
1337 if (noncefile !=
NULL &&
1342 fd = _dbus_connect_tcp_socket_with_nonce (host, port, family, noncefile, error);
1345 _DBUS_ASSERT_ERROR_IS_SET (error);
1350 _dbus_verbose (
"Successfully connected to tcp socket %s:%s\n",
1355 if (transport ==
NULL)
1378 DBusTransportOpenResult
1390 isTcp = strcmp (method,
"tcp") == 0;
1391 isNonceTcp = strcmp (method,
"nonce-tcp") == 0;
1393 if (isTcp || isNonceTcp)
1400 if ((isNonceTcp ==
TRUE) != (noncefile !=
NULL)) {
1402 return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
1408 return DBUS_TRANSPORT_OPEN_BAD_ADDRESS;
1412 if (*transport_p ==
NULL)
1414 _DBUS_ASSERT_ERROR_IS_SET (error);
1415 return DBUS_TRANSPORT_OPEN_DID_NOT_CONNECT;
1419 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1420 return DBUS_TRANSPORT_OPEN_OK;
1425 _DBUS_ASSERT_ERROR_IS_CLEAR (error);
1426 return DBUS_TRANSPORT_OPEN_NOT_HANDLED;