diff options
Diffstat (limited to 'src/util/mac/k5_mig_client.c')
| -rw-r--r-- | src/util/mac/k5_mig_client.c | 256 |
1 files changed, 128 insertions, 128 deletions
diff --git a/src/util/mac/k5_mig_client.c b/src/util/mac/k5_mig_client.c index 603ffdc70..6964abcca 100644 --- a/src/util/mac/k5_mig_client.c +++ b/src/util/mac/k5_mig_client.c @@ -53,15 +53,15 @@ typedef struct k5_ipc_service_port { /* global service ports and mutex to protect it */ static k5_mutex_t g_service_ports_mutex = K5_MUTEX_PARTIAL_INITIALIZER; -static k5_ipc_service_port g_service_ports[KIPC_SERVICE_COUNT] = { +static k5_ipc_service_port g_service_ports[KIPC_SERVICE_COUNT] = { { "edu.mit.Kerberos.CCacheServer", MACH_PORT_NULL }, { "edu.mit.Kerberos.KerberosAgent", MACH_PORT_NULL } }; /* ------------------------------------------------------------------------ */ /* This struct exists to hold the per-thread connection port used for ipc - * messages to the server. Each thread is issued a separate connection - * port so that the server can distinguish between threads in the same + * messages to the server. Each thread is issued a separate connection + * port so that the server can distinguish between threads in the same * application. */ typedef struct k5_ipc_connection { @@ -76,7 +76,7 @@ typedef struct k5_ipc_connection_info { } *k5_ipc_connection_info; /* initializer for k5_ipc_request_port to fill in server names in TLS */ -static const char *k5_ipc_known_services[KIPC_SERVICE_COUNT] = { +static const char *k5_ipc_known_services[KIPC_SERVICE_COUNT] = { "edu.mit.Kerberos.CCacheServer", "edu.mit.Kerberos.KerberosAgent" }; @@ -87,11 +87,11 @@ static void k5_ipc_client_cinfo_free (void *io_cinfo) if (io_cinfo) { k5_ipc_connection_info cinfo = io_cinfo; int i; - + for (i = 0; i < KIPC_SERVICE_COUNT; i++) { if (MACH_PORT_VALID (cinfo->connections[i].port)) { - mach_port_mod_refs (mach_task_self(), - cinfo->connections[i].port, + mach_port_mod_refs (mach_task_self(), + cinfo->connections[i].port, MACH_PORT_RIGHT_SEND, -1 ); cinfo->connections[i].port = MACH_PORT_NULL; } @@ -107,29 +107,29 @@ static int k5_ipc_client_cinfo_allocate (k5_ipc_connection_info *out_cinfo) { int err = 0; k5_ipc_connection_info cinfo = NULL; - + cinfo = malloc (sizeof (*cinfo)); if (!cinfo) { err = ENOMEM; } - + if (!err) { int i; - + cinfo->server_died = 0; cinfo->reply_stream = NULL; - + for (i = 0; i < KIPC_SERVICE_COUNT; i++) { cinfo->connections[i].service_id = k5_ipc_known_services[i]; cinfo->connections[i].port = MACH_PORT_NULL; } } - + if (!err) { *out_cinfo = cinfo; cinfo = NULL; } - + k5_ipc_client_cinfo_free (cinfo); - + return err; } @@ -144,38 +144,38 @@ MAKE_FINI_FUNCTION(k5_cli_ipc_thread_fini); static int k5_cli_ipc_thread_init (void) { int err = 0; - - err = k5_key_register (K5_KEY_IPC_CONNECTION_INFO, + + err = k5_key_register (K5_KEY_IPC_CONNECTION_INFO, k5_ipc_client_cinfo_free); - + if (!err) { err = k5_mutex_finish_init (&g_service_ports_mutex); } - + return err; } /* ------------------------------------------------------------------------ */ static void k5_cli_ipc_thread_fini (void) -{ +{ int err = 0; - + err = k5_mutex_lock (&g_service_ports_mutex); if (!err) { int i; - + for (i = 0; i < KIPC_SERVICE_COUNT; i++) { if (MACH_PORT_VALID (g_service_ports[i].service_port)) { - mach_port_destroy (mach_task_self (), - g_service_ports[i].service_port); + mach_port_destroy (mach_task_self (), + g_service_ports[i].service_port); g_service_ports[i].service_port = MACH_PORT_NULL; } } k5_mutex_unlock (&g_service_ports_mutex); } - + k5_key_delete (K5_KEY_IPC_CONNECTION_INFO); k5_mutex_destroy (&g_service_ports_mutex); } @@ -187,22 +187,22 @@ static void k5_cli_ipc_thread_fini (void) static kern_return_t k5_ipc_client_lookup_server (const char *in_service_id, boolean_t in_launch_if_necessary, boolean_t in_use_cached_port, - mach_port_t *out_service_port) + mach_port_t *out_service_port) { kern_return_t err = 0; kern_return_t lock_err = 0; mach_port_t k5_service_port = MACH_PORT_NULL; boolean_t found_entry = 0; int i; - + if (!in_service_id ) { err = EINVAL; } if (!out_service_port) { err = EINVAL; } - + if (!err) { lock_err = k5_mutex_lock (&g_service_ports_mutex); if (lock_err) { err = lock_err; } } - + for (i = 0; !err && i < KIPC_SERVICE_COUNT; i++) { if (!strcmp (in_service_id, g_service_ports[i].service_id)) { found_entry = 1; @@ -212,65 +212,65 @@ static kern_return_t k5_ipc_client_lookup_server (const char *in_service_id, break; } } - + if (!err && (!MACH_PORT_VALID (k5_service_port) || !in_use_cached_port)) { mach_port_t boot_port = MACH_PORT_NULL; char *service = NULL; - + /* Get our bootstrap port */ err = task_get_bootstrap_port (mach_task_self (), &boot_port); - + if (!err && !in_launch_if_necessary) { char *lookup = NULL; mach_port_t lookup_port = MACH_PORT_NULL; - - int w = asprintf (&lookup, "%s%s", + + int w = asprintf (&lookup, "%s%s", in_service_id, K5_MIG_LOOKUP_SUFFIX); if (w < 0) { err = ENOMEM; } - + if (!err) { - /* Use the lookup name because the service name will return + /* Use the lookup name because the service name will return * a valid port even if the server isn't running */ err = bootstrap_look_up (boot_port, lookup, &lookup_port); } - + free (lookup); - if (MACH_PORT_VALID (lookup_port)) { - mach_port_deallocate (mach_task_self (), lookup_port); + if (MACH_PORT_VALID (lookup_port)) { + mach_port_deallocate (mach_task_self (), lookup_port); } } - + if (!err) { - int w = asprintf (&service, "%s%s", + int w = asprintf (&service, "%s%s", in_service_id, K5_MIG_SERVICE_SUFFIX); if (w < 0) { err = ENOMEM; } } - + if (!err) { err = bootstrap_look_up (boot_port, service, &k5_service_port); - + if (!err && found_entry) { /* Free old port if it is valid */ if (!err && MACH_PORT_VALID (g_service_ports[i].service_port)) { - mach_port_deallocate (mach_task_self (), + mach_port_deallocate (mach_task_self (), g_service_ports[i].service_port); } - + g_service_ports[i].service_port = k5_service_port; } } - + free (service); - if (MACH_PORT_VALID (boot_port)) { mach_port_deallocate (mach_task_self (), + if (MACH_PORT_VALID (boot_port)) { mach_port_deallocate (mach_task_self (), boot_port); } } - + if (!err) { *out_service_port = k5_service_port; } - + if (!lock_err) { k5_mutex_unlock (&g_service_ports_mutex); } - + return err; } @@ -278,29 +278,29 @@ static kern_return_t k5_ipc_client_lookup_server (const char *in_service_id, /* ------------------------------------------------------------------------ */ -static boolean_t k5_ipc_reply_demux (mach_msg_header_t *request, - mach_msg_header_t *reply) +static boolean_t k5_ipc_reply_demux (mach_msg_header_t *request, + mach_msg_header_t *reply) { boolean_t handled = 0; - + if (CALL_INIT_FUNCTION (k5_cli_ipc_thread_init) != 0) { return 0; - } - + } + if (!handled && request->msgh_id == MACH_NOTIFY_NO_SENDERS) { k5_ipc_connection_info cinfo = k5_getspecific (K5_KEY_IPC_CONNECTION_INFO); - if (cinfo) { + if (cinfo) { cinfo->server_died = 1; } - + handled = 1; /* server died */ } - + if (!handled) { handled = k5_ipc_reply_server (request, reply); } - - return handled; + + return handled; } /* ------------------------------------------------------------------------ */ @@ -313,34 +313,34 @@ kern_return_t k5_ipc_client_reply (mach_port_t in_reply_port, { kern_return_t err = KERN_SUCCESS; k5_ipc_connection_info cinfo = NULL; - + if (!err) { err = CALL_INIT_FUNCTION (k5_cli_ipc_thread_init); } - + if (!err) { cinfo = k5_getspecific (K5_KEY_IPC_CONNECTION_INFO); if (!cinfo || !cinfo->reply_stream) { err = EINVAL; } } - + if (!err) { if (in_inl_replyCnt) { - err = krb5int_ipc_stream_write (cinfo->reply_stream, + err = krb5int_ipc_stream_write (cinfo->reply_stream, in_inl_reply, in_inl_replyCnt); - + } else if (in_ool_replyCnt) { - err = krb5int_ipc_stream_write (cinfo->reply_stream, + err = krb5int_ipc_stream_write (cinfo->reply_stream, in_ool_reply, in_ool_replyCnt); - + } else { err = EINVAL; } } - - if (in_ool_replyCnt) { vm_deallocate (mach_task_self (), - (vm_address_t) in_ool_reply, + + if (in_ool_replyCnt) { vm_deallocate (mach_task_self (), + (vm_address_t) in_ool_reply, in_ool_replyCnt); } - + return err; } @@ -367,29 +367,29 @@ int32_t k5_ipc_send_request (const char *in_service_id, if (!in_request_stream) { err = EINVAL; } if (!out_reply_stream ) { err = EINVAL; } - + if (!err) { err = CALL_INIT_FUNCTION (k5_cli_ipc_thread_init); - } - + } + if (!err) { - /* depending on how big the message is, use the fast inline buffer or + /* depending on how big the message is, use the fast inline buffer or * the slow dynamically allocated buffer */ mach_msg_type_number_t request_length = krb5int_ipc_stream_size (in_request_stream); - + if (request_length > K5_IPC_MAX_INL_MSG_SIZE) { - /*dprintf ("%s choosing out of line buffer (size is %d)", + /*dprintf ("%s choosing out of line buffer (size is %d)", * __FUNCTION__, request_length); */ - - err = vm_read (mach_task_self (), - (vm_address_t) krb5int_ipc_stream_data (in_request_stream), - request_length, - (vm_address_t *) &ool_request, - &ool_request_length); + + err = vm_read (mach_task_self (), + (vm_address_t) krb5int_ipc_stream_data (in_request_stream), + request_length, + (vm_address_t *) &ool_request, + &ool_request_length); } else { /*dprintf ("%s choosing in line buffer (size is %d)", * __FUNCTION__, request_length); */ - + inl_request_length = request_length; inl_request = krb5int_ipc_stream_data (in_request_stream); } @@ -405,7 +405,7 @@ int32_t k5_ipc_send_request (const char *in_service_id, err = k5_setspecific (K5_KEY_IPC_CONNECTION_INFO, cinfo); } } - + if (!err) { int i, found = 0; @@ -416,114 +416,114 @@ int32_t k5_ipc_send_request (const char *in_service_id, break; } } - + if (!found) { err = EINVAL; } } } - + if (!err) { - err = k5_ipc_client_lookup_server (in_service_id, in_launch_server, + err = k5_ipc_client_lookup_server (in_service_id, in_launch_server, TRUE, &server_port); } if (!err) { - err = mach_port_allocate (mach_task_self (), MACH_PORT_RIGHT_RECEIVE, + err = mach_port_allocate (mach_task_self (), MACH_PORT_RIGHT_RECEIVE, &reply_port); } - + while (!err && !done) { if (!err && !MACH_PORT_VALID (connection->port)) { - err = k5_ipc_client_create_client_connection (server_port, + err = k5_ipc_client_create_client_connection (server_port, &connection->port); } - + if (!err) { err = k5_ipc_client_request (connection->port, reply_port, inl_request, inl_request_length, ool_request, ool_request_length); - + } - + if (err == MACH_SEND_INVALID_DEST) { - if (try_count < 2) { + if (try_count < 2) { try_count++; err = 0; } if (MACH_PORT_VALID (connection->port)) { - mach_port_mod_refs (mach_task_self(), connection->port, + mach_port_mod_refs (mach_task_self(), connection->port, MACH_PORT_RIGHT_SEND, -1 ); connection->port = MACH_PORT_NULL; - } - + } + /* Look up server name again without using the cached copy */ - err = k5_ipc_client_lookup_server (in_service_id, - in_launch_server, + err = k5_ipc_client_lookup_server (in_service_id, + in_launch_server, FALSE, &server_port); - + } else { /* Talked to server, though we may have gotten an error */ done = 1; - - /* Because we use ",dealloc" ool_request will be freed by mach. + + /* Because we use ",dealloc" ool_request will be freed by mach. * Don't double free it. */ - ool_request = NULL; - ool_request_length = 0; - } + ool_request = NULL; + ool_request_length = 0; + } } - + if (!err) { err = krb5int_ipc_stream_new (&cinfo->reply_stream); } - + if (!err) { mach_port_t old_notification_target = MACH_PORT_NULL; /* request no-senders notification so we know when server dies */ - err = mach_port_request_notification (mach_task_self (), reply_port, - MACH_NOTIFY_NO_SENDERS, 1, - reply_port, - MACH_MSG_TYPE_MAKE_SEND_ONCE, + err = mach_port_request_notification (mach_task_self (), reply_port, + MACH_NOTIFY_NO_SENDERS, 1, + reply_port, + MACH_MSG_TYPE_MAKE_SEND_ONCE, &old_notification_target); - + if (!err && old_notification_target != MACH_PORT_NULL) { mach_port_deallocate (mach_task_self (), old_notification_target); } } - + if (!err) { cinfo->server_died = 0; - - err = mach_msg_server_once (k5_ipc_reply_demux, K5_IPC_MAX_MSG_SIZE, + + err = mach_msg_server_once (k5_ipc_reply_demux, K5_IPC_MAX_MSG_SIZE, reply_port, MACH_MSG_TIMEOUT_NONE); - + if (!err && cinfo->server_died) { err = ENOTCONN; } } - + if (err == BOOTSTRAP_UNKNOWN_SERVICE && !in_launch_server) { err = 0; /* If server is not running just return an empty stream. */ } - + if (!err) { *out_reply_stream = cinfo->reply_stream; cinfo->reply_stream = NULL; } - - if (reply_port != MACH_PORT_NULL) { - mach_port_destroy (mach_task_self (), reply_port); + + if (reply_port != MACH_PORT_NULL) { + mach_port_destroy (mach_task_self (), reply_port); } - if (ool_request_length) { - vm_deallocate (mach_task_self (), - (vm_address_t) ool_request, ool_request_length); + if (ool_request_length) { + vm_deallocate (mach_task_self (), + (vm_address_t) ool_request, ool_request_length); } - if (cinfo && cinfo->reply_stream) { - krb5int_ipc_stream_release (cinfo->reply_stream); + if (cinfo && cinfo->reply_stream) { + krb5int_ipc_stream_release (cinfo->reply_stream); cinfo->reply_stream = NULL; } - - return err; + + return err; } #endif /* LEAN CLIENT */ |