2N/A/*
2N/A * CDDL HEADER START
2N/A *
2N/A * The contents of this file are subject to the terms of the
2N/A * Common Development and Distribution License (the "License").
2N/A * You may not use this file except in compliance with the License.
2N/A *
2N/A * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
2N/A * or http://www.opensolaris.org/os/licensing.
2N/A * See the License for the specific language governing permissions
2N/A * and limitations under the License.
2N/A *
2N/A * When distributing Covered Code, include this CDDL HEADER in each
2N/A * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
2N/A * If applicable, add the following below this CDDL HEADER, with the
2N/A * fields enclosed by brackets "[]" replaced with your own identifying
2N/A * information: Portions Copyright [yyyy] [name of copyright owner]
2N/A *
2N/A * CDDL HEADER END
2N/A */
2N/A/*
2N/A * Copyright (c) 1999, 2010, Oracle and/or its affiliates. All rights reserved.
2N/A */
2N/A
2N/A/*
2N/A * l_misc.c :
2N/A * This file contains the miscelleneous routines for libsm.so
2N/A */
2N/A
2N/A#include <sys/types.h>
2N/A#include <sys/stat.h>
2N/A#include <fcntl.h>
2N/A#include <sys/dkio.h>
2N/A#include <sys/vtoc.h>
2N/A#include <sys/dktp/fdisk.h>
2N/A#include <dirent.h>
2N/A#include <dlfcn.h>
2N/A#include <stdlib.h>
2N/A#include <sys/stat.h>
2N/A#include <strings.h>
2N/A#include "l_defines.h"
2N/A#include <rpc/rpc.h>
2N/A#include "smed.h"
2N/A#include <sys/smedia.h>
2N/A#include "../inc/rmedia.h"
2N/A#include <smserver.h>
2N/A#include <sys/mman.h>
2N/A#include <utmpx.h>
2N/A#include <limits.h>
2N/A#include <netdir.h>
2N/A
2N/A#ifdef _LP64
2N/A#ifdef __sparc
2N/A#define PATHNAME "/usr/lib/smedia/sparcv9"
2N/A#else
2N/A#define PATHNAME "/usr/lib/smedia/amd64"
2N/A#endif
2N/A#else
2N/A#define PATHNAME "/usr/lib/smedia"
2N/A#endif
2N/A
2N/A#define PERROR(string) my_perror(gettext(string))
2N/A
2N/Astatic void
2N/Amy_perror(char *err_string)
2N/A{
2N/A
2N/A int error_no;
2N/A if (errno == 0)
2N/A return;
2N/A
2N/A error_no = errno;
2N/A (void) fprintf(stderr, gettext(err_string));
2N/A (void) fprintf(stderr, gettext(" : "));
2N/A errno = error_no;
2N/A perror("");
2N/A}
2N/A
2N/Astatic int
2N/Ais_server_running(rmedia_handle_t *handle)
2N/A{
2N/A door_arg_t door_args;
2N/A smedia_reqping_t reqping;
2N/A smedia_retping_t *retping;
2N/A int ret_val;
2N/A int door_fd;
2N/A CLIENT *clnt;
2N/A char rbuf[sizeof (smedia_services_t) + sizeof (door_desc_t)];
2N/A smserver_info *server_info;
2N/A
2N/A /*
2N/A * We will assume that we are running at level 2 or greater
2N/A * and attempt to contact the server using RPC mecahnisms.
2N/A * If that fails then we will attempt to contact the server
2N/A * using non-rpc mechanism. This will enable the libsmedia
2N/A * to be used in SINGLE user mode when inetd is not running.
2N/A * We expect the server to have been started manually by user.
2N/A */
2N/A
2N/A clnt = clnt_create(HOST_SELF, SMSERVERPROG, SMSERVERVERS, "local");
2N/A if (clnt == (CLIENT *)NULL) {
2N/A /*
2N/A * The failure could be that we are running at level 1
2N/A */
2N/A door_fd = open(smedia_service, O_RDONLY, 0644);
2N/A if (door_fd < 0) {
2N/A DPRINTF1("Error in opening %s\n",
2N/A smedia_service);
2N/A return (0);
2N/A }
2N/A
2N/A DPRINTF1("rbuf address=%p\n", rbuf);
2N/A reqping.cnum = SMEDIA_CNUM_PING;
2N/A door_args.data_ptr = (char *)&reqping;
2N/A door_args.data_size = sizeof (smedia_services_t);
2N/A door_args.desc_ptr = NULL;
2N/A door_args.desc_num = 0;
2N/A door_args.rbuf = rbuf;
2N/A door_args.rsize = sizeof (rbuf);
2N/A
2N/A ret_val = door_call(door_fd, &door_args);
2N/A (void) close(door_fd);
2N/A if (ret_val < 0) {
2N/A return (0);
2N/A }
2N/A DPRINTF3("rsize = %d data_size = %d data_ptr = %p \n",
2N/A door_args.rsize, door_args.data_size,
2N/A door_args.data_ptr);
2N/A retping = (smedia_retping_t *)(
2N/A (void *)door_args.data_ptr);
2N/A if (retping->cnum != SMEDIA_CNUM_PING) {
2N/A DPRINTF1("*** door call failed *** cnum "
2N/A "returned = 0x%x\n", retping->cnum);
2N/A return (0);
2N/A }
2N/A return (1);
2N/A }
2N/A server_info = smserverproc_get_serverinfo_1(NULL, clnt);
2N/A if (server_info == NULL) {
2N/A if (clnt)
2N/A clnt_destroy(clnt);
2N/A return (0);
2N/A }
2N/A if (server_info->status != 0) {
2N/A if (clnt)
2N/A clnt_destroy(clnt);
2N/A DPRINTF1("get server_info call failed. "
2N/A "status = %d\n", server_info->status);
2N/A return (0);
2N/A }
2N/A if (server_info->vernum != SMSERVERVERS) {
2N/A if (clnt)
2N/A clnt_destroy(clnt);
2N/A DPRINTF2("version expected = %d version "
2N/A "returned = %d\n", SMSERVERVERS,
2N/A server_info->vernum);
2N/A return (0);
2N/A }
2N/A
2N/A door_fd = open(smedia_service, O_RDONLY, 0644);
2N/A if (door_fd < 0) {
2N/A DPRINTF1("Error in opening %s\n", smedia_service);
2N/A return (0);
2N/A }
2N/A
2N/A DPRINTF1("rbuf address=%p\n", rbuf);
2N/A reqping.cnum = SMEDIA_CNUM_PING;
2N/A door_args.data_ptr = (char *)&reqping;
2N/A door_args.data_size = sizeof (smedia_services_t);
2N/A door_args.desc_ptr = NULL;
2N/A door_args.desc_num = 0;
2N/A door_args.rbuf = rbuf;
2N/A door_args.rsize = sizeof (rbuf);
2N/A
2N/A ret_val = door_call(door_fd, &door_args);
2N/A (void) close(door_fd);
2N/A if (ret_val < 0) {
2N/A return (0);
2N/A }
2N/A DPRINTF3("rsize = %d data_size = %d data_ptr = %p \n",
2N/A door_args.rsize, door_args.data_size,
2N/A door_args.data_ptr);
2N/A retping = (smedia_retping_t *)((void *)door_args.data_ptr);
2N/A if (retping->cnum != SMEDIA_CNUM_PING) {
2N/A DPRINTF1("*** door call failed *** cnum returned "
2N/A "= 0x%x\n", retping->cnum);
2N/A return (0);
2N/A }
2N/A handle->sm_clnt = clnt;
2N/A return (1);
2N/A}
2N/A
2N/Astatic void *
2N/Aget_dev_library_handle(int32_t fd)
2N/A{
2N/A void *handle;
2N/A void *old_handle = NULL;
2N/A struct dk_cinfo dkinfo;
2N/A DIR *dirp;
2N/A struct dirent *dp;
2N/A char *pathname;
2N/A int32_t (*d_fcn_ptr)(ushort_t, ushort_t);
2N/A int32_t (*v_fcn_ptr)(void);
2N/A int32_t ret_val;
2N/A
2N/A if (ioctl(fd, DKIOCINFO, &dkinfo) == -1) {
2N/A PERROR("DKIOCINFO failed");
2N/A return (NULL);
2N/A }
2N/A DPRINTF1("dki_ctype = 0x%x\n", dkinfo.dki_ctype);
2N/A
2N/A if ((pathname = malloc(PATH_MAX)) == NULL) {
2N/A PERROR("malloc failed");
2N/A return (NULL);
2N/A }
2N/A
2N/A dirp = opendir(PATHNAME);
2N/A if (dirp == NULL) {
2N/A (void) fprintf(stderr, gettext("Couldnot open %s\n"), PATHNAME);
2N/A free(pathname);
2N/A return (NULL);
2N/A }
2N/A
2N/A while ((dp = readdir(dirp)) != NULL) {
2N/A if (strncmp("sm_", dp->d_name, 3) != 0) {
2N/A DPRINTF1("not a library %s\n", dp->d_name);
2N/A continue;
2N/A }
2N/A if (snprintf(pathname, PATH_MAX, "%s/%s",
2N/A PATHNAME, dp->d_name) >= PATH_MAX) {
2N/A continue;
2N/A }
2N/A
2N/A handle = dlopen(pathname, RTLD_LAZY);
2N/A if (handle == NULL) {
2N/A PERROR("Error opening library file");
2N/A continue;
2N/A }
2N/A d_fcn_ptr = (int32_t (*)(ushort_t, ushort_t))dlsym(handle,
2N/A "_m_device_type");
2N/A if (d_fcn_ptr == NULL) {
2N/A DPRINTF("Could not find _m_device_type\n");
2N/A (void) dlclose(handle);
2N/A continue;
2N/A }
2N/A ret_val = (*d_fcn_ptr)(dkinfo.dki_ctype, 0);
2N/A if (ret_val == 0) {
2N/A DPRINTF1("NAME %s\n", dp->d_name);
2N/A v_fcn_ptr = (int32_t (*)(void))dlsym(handle,
2N/A "_m_version_no");
2N/A if (v_fcn_ptr == NULL) {
2N/A DPRINTF("Could not find _m_version_no\n");
2N/A (void) dlclose(handle);
2N/A continue;
2N/A }
2N/A ret_val = (*v_fcn_ptr)();
2N/A if ((ret_val >= 0) &&
2N/A (ret_val >= SM_PLUGIN_VERSION)) {
2N/A if (old_handle != NULL)
2N/A (void) dlclose(old_handle);
2N/A old_handle = handle;
2N/A continue;
2N/A } else {
2N/A (void) dlclose(handle);
2N/A }
2N/A } else {
2N/A (void) dlclose(handle);
2N/A }
2N/A }
2N/A free(pathname);
2N/A (void) closedir(dirp);
2N/A return (old_handle);
2N/A}
2N/A
2N/Aint32_t
2N/Acall_function(rmedia_handle_t *handle, void *ip, char *func_name)
2N/A{
2N/A
2N/A int32_t ret_val;
2N/A int32_t (*fcn_ptr)(rmedia_handle_t *handle, void *ip);
2N/A void *lib_handle;
2N/A
2N/A if (handle == NULL) {
2N/A DPRINTF("Handle is NULL\n");
2N/A errno = EINVAL;
2N/A return (-1);
2N/A }
2N/A lib_handle = handle->sm_lib_handle;
2N/A if (handle->sm_signature != LIBSMEDIA_SIGNATURE) {
2N/A DPRINTF2("call_function:signature expected=0x%x, found=0x%x\n",
2N/A LIBSMEDIA_SIGNATURE, handle->sm_signature);
2N/A errno = EINVAL;
2N/A return (-1);
2N/A }
2N/A
2N/A fcn_ptr = (int32_t (*)(rmedia_handle_t *, void*))
2N/A dlsym(lib_handle, func_name);
2N/A if (fcn_ptr == NULL) {
2N/A DPRINTF1("Could not find %s\n", func_name);
2N/A errno = ENOTSUP;
2N/A return (-1);
2N/A }
2N/A ret_val = (*fcn_ptr)(handle, ip);
2N/A return (ret_val);
2N/A}
2N/A
2N/Aint32_t
2N/Arelease_handle(rmedia_handle_t *handle)
2N/A{
2N/A if (handle == NULL) {
2N/A DPRINTF("Handle is NULL\n");
2N/A errno = EINVAL;
2N/A return (-1);
2N/A }
2N/A if ((handle->sm_dkinfo.dki_ctype == DKC_SCSI_CCS) ||
2N/A (handle->sm_dkinfo.dki_ctype == DKC_MD21) ||
2N/A (handle->sm_dkinfo.dki_ctype == DKC_CDROM)) {
2N/A (void) close(handle->sm_door);
2N/A (void) close(handle->sm_death_door);
2N/A if (handle->sm_buf != NULL)
2N/A (void) munmap(handle->sm_buf, handle->sm_bufsize);
2N/A if (handle->sm_clnt != NULL)
2N/A clnt_destroy(handle->sm_clnt);
2N/A }
2N/A (void) close(handle->sm_buffd);
2N/A handle->sm_signature = 0;
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A return (0);
2N/A}
2N/A
2N/Asmedia_handle_t
2N/Aget_handle_from_fd(int32_t fd)
2N/A{
2N/A rmedia_handle_t *handle;
2N/A void *lib_handle;
2N/A int door_fd, door_server;
2N/A int ret_val;
2N/A door_arg_t door_args;
2N/A smedia_reqopen_t reqopen;
2N/A smedia_reterror_t *reterror;
2N/A door_desc_t ddesc[2];
2N/A char rbuf[sizeof (smedia_services_t) + sizeof (door_desc_t)];
2N/A struct stat stat;
2N/A
2N/A DPRINTF("smedia_get_handle called\n");
2N/A handle = (rmedia_handle_t *)malloc(sizeof (rmedia_handle_t));
2N/A if (handle == NULL) {
2N/A DPRINTF("Could not allocate memory for handle\n");
2N/A return (NULL);
2N/A }
2N/A (void) memset((void *) handle, 0, sizeof (rmedia_handle_t));
2N/A handle->sm_fd = -1;
2N/A handle->sm_door = -1;
2N/A handle->sm_death_door = -1;
2N/A handle->sm_buffd = -1;
2N/A handle->sm_buf = NULL;
2N/A handle->sm_bufsize = 0;
2N/A
2N/A if (ioctl(fd, DKIOCINFO, &handle->sm_dkinfo) == -1) {
2N/A free(handle);
2N/A PERROR("DKIOCINFO failed");
2N/A return (NULL);
2N/A }
2N/A lib_handle = get_dev_library_handle(fd);
2N/A if (lib_handle == NULL) {
2N/A free(handle);
2N/A DPRINTF("lib_Handle is NULL\n");
2N/A errno = ENOTSUP;
2N/A return (NULL);
2N/A }
2N/A DPRINTF("Handle initialised successfully.\n");
2N/A /* Initialise the handle elements */
2N/A handle->sm_lib_handle = lib_handle;
2N/A handle->sm_signature = LIBSMEDIA_SIGNATURE;
2N/A DPRINTF2("fd=%d signature=0x%x\n", handle->sm_fd, handle->sm_signature);
2N/A
2N/A if ((handle->sm_dkinfo.dki_ctype == DKC_SCSI_CCS) ||
2N/A (handle->sm_dkinfo.dki_ctype == DKC_MD21) ||
2N/A (handle->sm_dkinfo.dki_ctype == DKC_CDROM)) {
2N/A
2N/A ret_val = is_server_running(handle);
2N/A if (ret_val == 0) {
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A return (NULL);
2N/A }
2N/A door_fd = open(smedia_service, O_RDONLY, 0644);
2N/A if (door_fd < 0) {
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A DPRINTF1("Error in opening %s\n", smedia_service);
2N/A PERROR(smedia_service);
2N/A return (NULL);
2N/A }
2N/A
2N/A DPRINTF1("rbuf address=%p\n", rbuf);
2N/A ddesc[0].d_data.d_desc.d_descriptor = fd;
2N/A ddesc[0].d_attributes = DOOR_DESCRIPTOR;
2N/A reqopen.cnum = SMEDIA_CNUM_OPEN_FD;
2N/A door_args.data_ptr = (char *)&reqopen;
2N/A door_args.data_size = sizeof (smedia_services_t);
2N/A door_args.desc_ptr = &ddesc[0];
2N/A door_args.desc_num = 1;
2N/A door_args.rbuf = rbuf;
2N/A door_args.rsize = sizeof (rbuf);
2N/A
2N/A ret_val = door_call(door_fd, &door_args);
2N/A (void) close(door_fd);
2N/A if (ret_val < 0) {
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A PERROR("door_call");
2N/A return (NULL);
2N/A }
2N/A DPRINTF3("rsize = %d data_size = %d data_ptr = %p \n",
2N/A door_args.rsize, door_args.data_size,
2N/A door_args.data_ptr);
2N/A reterror = (smedia_reterror_t *)((void *)door_args.data_ptr);
2N/A if (reterror->cnum != SMEDIA_CNUM_OPEN_FD) {
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A DPRINTF1(
2N/A "*** door call failed *** cnum returned = 0x%x\n", reterror->cnum);
2N/A errno = reterror->errnum;
2N/A return (NULL);
2N/A }
2N/A /*
2N/A * 2 door descriptors are returned after the above door call.
2N/A * The first door descriptor is the one that will be used
2N/A * in subsequent smedia calls. A dedicated thread is
2N/A * associated with this door to handle client calls.
2N/A * The second door descriptor is needed to signal unexpected
2N/A * death of the client to the server. This will help the server
2N/A * to do the necessary cleanup.
2N/A */
2N/A if (door_args.desc_num != 2) {
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A DPRINTF("Num of door descriptors returned by "
2N/A "server is not 2");
2N/A if (door_args.desc_num)
2N/A (void) close(door_args.desc_ptr->\
2N/A d_data.d_desc.d_descriptor);
2N/A return (NULL);
2N/A }
2N/A door_server = door_args.desc_ptr->d_data.d_desc.d_descriptor;
2N/A /* Check if the descriptor returned is S_IFDOOR */
2N/A if (fstat(door_server, &stat) < 0) {
2N/A PERROR("fstat");
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A return (NULL);
2N/A }
2N/A if (!S_ISDOOR(stat.st_mode)) {
2N/A DPRINTF(
2N/A "Descriptor returned by door_call is not of type DOOR\n");
2N/A (void) dlclose(handle->sm_lib_handle);
2N/A free(handle);
2N/A if (handle->sm_clnt)
2N/A clnt_destroy(handle->sm_clnt);
2N/A return (NULL);
2N/A }
2N/A handle->sm_door = door_server;
2N/A handle->sm_fd = fd;
2N/A door_args.desc_ptr++;
2N/A handle->sm_death_door =
2N/A door_args.desc_ptr->d_data.d_desc.d_descriptor;
2N/A DPRINTF("door call succeeded.\n");
2N/A return ((smedia_handle_t)handle);
2N/A
2N/A } else {
2N/A handle->sm_fd = fd;
2N/A return ((smedia_handle_t)handle);
2N/A }
2N/A
2N/A}