nsswitch/wb_common.c

ソースコードを見る。

関数
BOOL	winbind_env_set (void)
BOOL	winbind_off (void)
BOOL	winbind_on (void)
void	free_response (struct winbindd_response *response)
void	init_request (struct winbindd_request *request, int request_type)
static void	init_response (struct winbindd_response *response)
void	close_sock (void)
static int	make_nonstd_fd_internals (int fd, int limit)
static int	make_safe_fd (int fd)
static int	winbind_named_pipe_sock (const char *dir)
static int	winbind_open_pipe_sock (int recursing, int need_priv)
int	write_sock (void *buffer, int count, int recursing, int need_priv)
static int	read_sock (void *buffer, int count)
int	read_reply (struct winbindd_response *response)
NSS_STATUS	winbindd_send_request (int req_type, int need_priv, struct winbindd_request *request)
NSS_STATUS	winbindd_get_response (struct winbindd_response *response)
NSS_STATUS	winbindd_request_response (int req_type, struct winbindd_request *request, struct winbindd_response *response)
NSS_STATUS	winbindd_priv_request_response (int req_type, struct winbindd_request *request, struct winbindd_response *response)
変数
int	winbindd_fd = -1
static int	is_privileged = 0

---

関数

BOOL winbind_env_set

(

void

)

wb_common.c の 540 行で定義されています。

参照元 get_memberuids()・sys_getgrouplist()・winbindd_send_request().

{
        char *env;
        
        if ((env=getenv(WINBINDD_DONT_ENV)) != NULL) {
                if(strcmp(env, "1") == 0) {
                        return True;
                }
        }
        return False;
}

BOOL winbind_off

(

void

)

wb_common.c の 678 行で定義されています。

参照元 get_memberuids()・idmap_nss_sids_to_unixids()・idmap_nss_unixids_to_sids()・main()・make_server_info_sam()・sys_getgrouplist().

{
        static char *s = CONST_DISCARD(char *, WINBINDD_DONT_ENV "=1");

        return putenv(s) != -1;
}

BOOL winbind_on

(

void

)

wb_common.c の 685 行で定義されています。

参照元 get_memberuids()・idmap_nss_sids_to_unixids()・idmap_nss_unixids_to_sids()・sys_getgrouplist().

{
        static char *s = CONST_DISCARD(char *, WINBINDD_DONT_ENV "=0");

        return putenv(s) != -1;
}

void free_response

(

struct winbindd_response *

response

)

wb_common.c の 40 行で定義されています。

参照先 winbindd_response::data・winbindd_response::extra_data.

参照元 _nss_winbind_endgrent()・_nss_winbind_endpwent()・_nss_winbind_getgrgid_r()・_nss_winbind_getgrnam_r()・_nss_winbind_getpwent_r()・_nss_winbind_getpwnam_r()・_nss_winbind_getpwuid_r()・_nss_winbind_getusersids()・_nss_winbind_gidtosid()・_nss_winbind_hosts_getbyaddr()・_nss_winbind_hosts_getbyname()・_nss_winbind_ipnodes_getbyname()・_nss_winbind_nametosid()・_nss_winbind_setgrent()・_nss_winbind_setpwent()・_nss_winbind_sidtoname()・_nss_winbind_uidtosid()・contact_winbind_auth_crap()・contact_winbind_change_pswd_auth_crap()・do_ccache_ntlm_auth()・read_reply()・wb_aix_authenticate()・wb_aix_chpass()・wb_aix_getgrgid()・wb_aix_getgrnam()・wb_aix_getgrset()・wb_aix_getpwnam()・wb_aix_getpwuid()・wb_aix_lsgroup()・wb_aix_lsuser()・winbind_callback()・winbind_getgrent()・winbindd_get_response().

{
        /* Free any allocated extra_data */

        if (response)
                SAFE_FREE(response->extra_data.data);
}

void init_request	(	struct winbindd_request *	request,
		int	request_type
	)

wb_common.c の 50 行で定義されています。

参照先 winbindd_request::cmd・winbindd_request::length・winbindd_request::pid.

参照元 pam_winbind_request()・winbindd_send_request().

{
        request->length = sizeof(struct winbindd_request);

        request->cmd = (enum winbindd_cmd)request_type;
        request->pid = getpid();

}

static void init_response

(

struct winbindd_response *

response

)

[static]

wb_common.c の 61 行で定義されています。

参照先 winbindd_response::result・WINBINDD_ERROR.

参照元 winbindd_get_response().

{
        /* Initialise return value */

        response->result = WINBINDD_ERROR;
}

void close_sock

(

void

)

wb_common.c の 70 行で定義されています。

参照先 winbindd_fd.

参照元 pam_winbind_request()・read_sock()・winbind_open_pipe_sock()・write_sock().

{
        if (winbindd_fd != -1) {
                close(winbindd_fd);
                winbindd_fd = -1;
        }
}

static int make_nonstd_fd_internals	(	int	fd,
		int	limit
	)			[static]

wb_common.c の 83 行で定義されています。

参照元 make_safe_fd().

{
        int new_fd;
        if (fd >= 0 && fd <= 2) {
#ifdef F_DUPFD 
                if ((new_fd = fcntl(fd, F_DUPFD, 3)) == -1) {
                        return -1;
                }
                /* Paranoia */
                if (new_fd < 3) {
                        close(new_fd);
                        return -1;
                }
                close(fd);
                return new_fd;
#else
                if (limit <= 0)
                        return -1;
                
                new_fd = dup(fd);
                if (new_fd == -1) 
                        return -1;

                /* use the program stack to hold our list of FDs to close */
                new_fd = make_nonstd_fd_internals(new_fd, limit - 1);
                close(fd);
                return new_fd;
#endif
        }
        return fd;
}

static int make_safe_fd

(

int

fd

)

[static]

wb_common.c の 123 行で定義されています。

参照先 flags・make_nonstd_fd_internals()・result.

参照元 winbind_named_pipe_sock().

{
        int result, flags;
        int new_fd = make_nonstd_fd_internals(fd, RECURSION_LIMIT);
        if (new_fd == -1) {
                close(fd);
                return -1;
        }

        /* Socket should be nonblocking. */
#ifdef O_NONBLOCK
#define FLAG_TO_SET O_NONBLOCK
#else
#ifdef SYSV
#define FLAG_TO_SET O_NDELAY
#else /* BSD */
#define FLAG_TO_SET FNDELAY
#endif
#endif

        if ((flags = fcntl(new_fd, F_GETFL)) == -1) {
                close(new_fd);
                return -1;
        }

        flags |= FLAG_TO_SET;
        if (fcntl(new_fd, F_SETFL, flags) == -1) {
                close(new_fd);
                return -1;
        }

#undef FLAG_TO_SET

        /* Socket should be closed on exec() */
#ifdef FD_CLOEXEC
        result = flags = fcntl(new_fd, F_GETFD, 0);
        if (flags >= 0) {
                flags |= FD_CLOEXEC;
                result = fcntl( new_fd, F_SETFD, flags );
        }
        if (result < 0) {
                close(new_fd);
                return -1;
        }
#endif
        return new_fd;
}

static int winbind_named_pipe_sock

(

const char *

dir

)

[static]

wb_common.c の 173 行で定義されています。

参照先 errno・fd・make_safe_fd().

参照元 winbind_open_pipe_sock().

{
        struct sockaddr_un sunaddr;
        struct stat st;
        pstring path;
        int fd;
        int wait_time;
        int slept;
        
        /* Check permissions on unix socket directory */
        
        if (lstat(dir, &st) == -1) {
                errno = ENOENT;
                return -1;
        }
        
        if (!S_ISDIR(st.st_mode) || 
            (st.st_uid != 0 && st.st_uid != geteuid())) {
                errno = ENOENT;
                return -1;
        }
        
        /* Connect to socket */
        
        strncpy(path, dir, sizeof(path) - 1);
        path[sizeof(path) - 1] = '\0';
        
        strncat(path, "/", sizeof(path) - 1 - strlen(path));
        path[sizeof(path) - 1] = '\0';
        
        strncat(path, WINBINDD_SOCKET_NAME, sizeof(path) - 1 - strlen(path));
        path[sizeof(path) - 1] = '\0';
        
        ZERO_STRUCT(sunaddr);
        sunaddr.sun_family = AF_UNIX;
        strncpy(sunaddr.sun_path, path, sizeof(sunaddr.sun_path) - 1);
        
        /* If socket file doesn't exist, don't bother trying to connect
           with retry.  This is an attempt to make the system usable when
           the winbindd daemon is not running. */

        if (lstat(path, &st) == -1) {
                errno = ENOENT;
                return -1;
        }
        
        /* Check permissions on unix socket file */
        
        if (!S_ISSOCK(st.st_mode) || 
            (st.st_uid != 0 && st.st_uid != geteuid())) {
                errno = ENOENT;
                return -1;
        }
        
        /* Connect to socket */
        
        if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) == -1) {
                return -1;
        }

        /* Set socket non-blocking and close on exec. */

        if ((fd = make_safe_fd( fd)) == -1) {
                return fd;
        }

        for (wait_time = 0; connect(fd, (struct sockaddr *)&sunaddr, sizeof(sunaddr)) == -1;
                        wait_time += slept) {
                struct timeval tv;
                fd_set w_fds;
                int ret;
                int connect_errno = 0;
                socklen_t errnosize;

                if (wait_time >= CONNECT_TIMEOUT)
                        goto error_out;

                switch (errno) {
                        case EINPROGRESS:
                                FD_ZERO(&w_fds);
                                FD_SET(fd, &w_fds);
                                tv.tv_sec = CONNECT_TIMEOUT - wait_time;
                                tv.tv_usec = 0;

                                ret = select(fd + 1, NULL, &w_fds, NULL, &tv);

                                if (ret > 0) {
                                        errnosize = sizeof(connect_errno);

                                        ret = getsockopt(fd, SOL_SOCKET,
                                                        SO_ERROR, &connect_errno, &errnosize);

                                        if (ret >= 0 && connect_errno == 0) {
                                                /* Connect succeed */
                                                goto out;
                                        }
                                }

                                slept = CONNECT_TIMEOUT;
                                break;
                        case EAGAIN:
                                slept = rand() % 3 + 1;
                                sleep(slept);
                                break;
                        default:
                                goto error_out;
                }

        }

  out:

        return fd;

  error_out:

        close(fd);
        return -1;
}

static int winbind_open_pipe_sock	(	int	recursing,
		int	need_priv
	)			[static]

wb_common.c の 295 行で定義されています。

参照先 close_sock()・winbindd_response::data・winbindd_response::extra_data・fd・winbindd_request::flags・winbindd_response::interface_version・is_privileged・NSS_STATUS_SUCCESS・winbind_named_pipe_sock()・winbindd_fd・WINBINDD_INTERFACE_VERSION・WINBINDD_PRIV_PIPE_DIR・winbindd_request_response().

参照元 write_sock().

{
#ifdef HAVE_UNIXSOCKET
        static pid_t our_pid;
        struct winbindd_request request;
        struct winbindd_response response;
        ZERO_STRUCT(request);
        ZERO_STRUCT(response);

        if (our_pid != getpid()) {
                close_sock();
                our_pid = getpid();
        }

        if ((need_priv != 0) && (is_privileged == 0)) {
                close_sock();
        }
        
        if (winbindd_fd != -1) {
                return winbindd_fd;
        }

        if (recursing) {
                return -1;
        }

        if ((winbindd_fd = winbind_named_pipe_sock(WINBINDD_SOCKET_DIR)) == -1) {
                return -1;
        }

        is_privileged = 0;

        /* version-check the socket */

        request.flags = WBFLAG_RECURSE;
        if ((winbindd_request_response(WINBINDD_INTERFACE_VERSION, &request, &response) != NSS_STATUS_SUCCESS) || (response.data.interface_version != WINBIND_INTERFACE_VERSION)) {
                close_sock();
                return -1;
        }

        /* try and get priv pipe */

        request.flags = WBFLAG_RECURSE;
        if (winbindd_request_response(WINBINDD_PRIV_PIPE_DIR, &request, &response) == NSS_STATUS_SUCCESS) {
                int fd;
                if ((fd = winbind_named_pipe_sock((char *)response.extra_data.data)) != -1) {
                        close(winbindd_fd);
                        winbindd_fd = fd;
                        is_privileged = 1;
                }
        }

        if ((need_priv != 0) && (is_privileged == 0)) {
                return -1;
        }

        SAFE_FREE(response.extra_data.data);

        return winbindd_fd;
#else
        return -1;
#endif /* HAVE_UNIXSOCKET */
}

int write_sock	(	void *	buffer,
		int	count,
		int	recursing,
		int	need_priv
	)

wb_common.c の 361 行で定義されています。

参照先 close_sock()・errno・result・winbind_open_pipe_sock()・winbindd_fd.

参照元 pam_winbind_request()・winbindd_send_request().

{
        int result, nwritten;
        
        /* Open connection to winbind daemon */
        
 restart:
        
        if (winbind_open_pipe_sock(recursing, need_priv) == -1) {
                errno = ENOENT;
                return -1;
        }
        
        /* Write data to socket */
        
        nwritten = 0;
        
        while(nwritten < count) {
                struct timeval tv;
                fd_set r_fds;
                
                /* Catch pipe close on other end by checking if a read()
                   call would not block by calling select(). */

                FD_ZERO(&r_fds);
                FD_SET(winbindd_fd, &r_fds);
                ZERO_STRUCT(tv);
                
                if (select(winbindd_fd + 1, &r_fds, NULL, NULL, &tv) == -1) {
                        close_sock();
                        return -1;                   /* Select error */
                }
                
                /* Write should be OK if fd not available for reading */
                
                if (!FD_ISSET(winbindd_fd, &r_fds)) {
                        
                        /* Do the write */
                        
                        result = write(winbindd_fd,
                                       (char *)buffer + nwritten, 
                                       count - nwritten);
                        
                        if ((result == -1) || (result == 0)) {
                                
                                /* Write failed */
                                
                                close_sock();
                                return -1;
                        }
                        
                        nwritten += result;
                        
                } else {
                        
                        /* Pipe has closed on remote end */
                        
                        close_sock();
                        goto restart;
                }
        }
        
        return nwritten;
}

static int read_sock	(	void *	buffer,
		int	count
	)			[static]

wb_common.c の 428 行で定義されています。

参照先 close_sock()・result・winbindd_fd.

参照元 read_reply().

{
        int nread = 0;
        int total_time = 0, selret;

        if (winbindd_fd == -1) {
                return -1;
        }

        /* Read data from socket */
        while(nread < count) {
                struct timeval tv;
                fd_set r_fds;
                
                /* Catch pipe close on other end by checking if a read()
                   call would not block by calling select(). */

                FD_ZERO(&r_fds);
                FD_SET(winbindd_fd, &r_fds);
                ZERO_STRUCT(tv);
                /* Wait for 5 seconds for a reply. May need to parameterise this... */
                tv.tv_sec = 5;

                if ((selret = select(winbindd_fd + 1, &r_fds, NULL, NULL, &tv)) == -1) {
                        close_sock();
                        return -1;                   /* Select error */
                }
                
                if (selret == 0) {
                        /* Not ready for read yet... */
                        if (total_time >= 30) {
                                /* Timeout */
                                close_sock();
                                return -1;
                        }
                        total_time += 5;
                        continue;
                }

                if (FD_ISSET(winbindd_fd, &r_fds)) {
                        
                        /* Do the Read */
                        
                        int result = read(winbindd_fd, (char *)buffer + nread, 
                              count - nread);
                        
                        if ((result == -1) || (result == 0)) {
                                
                                /* Read failed.  I think the only useful thing we
                                   can do here is just return -1 and fail since the
                                   transaction has failed half way through. */
                        
                                close_sock();
                                return -1;
                        }
                        
                        nread += result;
                        
                }
        }
        
        return nread;
}

int read_reply

(

struct winbindd_response *

response

)

wb_common.c の 494 行で定義されています。

参照先 winbindd_response::data・winbindd_response::extra_data・free_response()・winbindd_response::length・read_sock().

参照元 pam_winbind_request()・winbindd_get_response().

{
        int result1, result2 = 0;

        if (!response) {
                return -1;
        }
        
        /* Read fixed length response */
        
        if ((result1 = read_sock(response, sizeof(struct winbindd_response)))
            == -1) {
                
                return -1;
        }
        
        /* We actually send the pointer value of the extra_data field from
           the server.  This has no meaning in the client's address space
           so we clear it out. */

        response->extra_data.data = NULL;

        /* Read variable length response */
        
        if (response->length > sizeof(struct winbindd_response)) {
                int extra_data_len = response->length - 
                        sizeof(struct winbindd_response);
                
                /* Mallocate memory for extra data */
                
                if (!(response->extra_data.data = malloc(extra_data_len))) {
                        return -1;
                }
                
                if ((result2 = read_sock(response->extra_data.data, extra_data_len))
                    == -1) {
                        free_response(response);
                        return -1;
                }
        }
        
        /* Return total amount of data read */
        
        return result1 + result2;
}

NSS_STATUS winbindd_send_request	(	int	req_type,
		int	need_priv,
		struct winbindd_request *	request
	)

wb_common.c の 556 行で定義されています。

参照先 errno・winbindd_request::flags・init_request()・NSS_STATUS_NOTFOUND・NSS_STATUS_SUCCESS・NSS_STATUS_UNAVAIL・winbind_env_set()・write_sock().

参照元 send_next_request()・winbindd_priv_request_response()・winbindd_request_response().

{
        struct winbindd_request lrequest;

        /* Check for our tricky environment variable */

        if (winbind_env_set()) {
                return NSS_STATUS_NOTFOUND;
        }

        if (!request) {
                ZERO_STRUCT(lrequest);
                request = &lrequest;
        }
        
        /* Fill in request and send down pipe */

        init_request(request, req_type);
        
        if (write_sock(request, sizeof(*request),
                       request->flags & WBFLAG_RECURSE, need_priv) == -1) {
                /* Set ENOENT for consistency.  Required by some apps */
                errno = ENOENT;
                
                return NSS_STATUS_UNAVAIL;
        }

        if ((request->extra_len != 0) &&
            (write_sock(request->extra_data.data, request->extra_len,
                        request->flags & WBFLAG_RECURSE, need_priv) == -1)) {
                /* Set ENOENT for consistency.  Required by some apps */
                errno = ENOENT;

                return NSS_STATUS_UNAVAIL;
        }
        
        return NSS_STATUS_SUCCESS;
}

NSS_STATUS winbindd_get_response

(

struct winbindd_response *

response

)

wb_common.c の 600 行で定義されています。

参照先 errno・free_response()・init_response()・NSS_STATUS_NOTFOUND・NSS_STATUS_SUCCESS・NSS_STATUS_UNAVAIL・read_reply()・winbindd_response::result・WINBINDD_OK.

参照元 winbind_callback()・winbindd_priv_request_response()・winbindd_request_response().

{
        struct winbindd_response lresponse;

        if (!response) {
                ZERO_STRUCT(lresponse);
                response = &lresponse;
        }

        init_response(response);

        /* Wait for reply */
        if (read_reply(response) == -1) {
                /* Set ENOENT for consistency.  Required by some apps */
                errno = ENOENT;

                return NSS_STATUS_UNAVAIL;
        }

        /* Throw away extra data if client didn't request it */
        if (response == &lresponse) {
                free_response(response);
        }

        /* Copy reply data from socket */
        if (response->result != WINBINDD_OK) {
                return NSS_STATUS_NOTFOUND;
        }
        
        return NSS_STATUS_SUCCESS;
}

NSS_STATUS winbindd_request_response	(	int	req_type,
		struct winbindd_request *	request,
		struct winbindd_response *	response
	)

wb_common.c の 634 行で定義されています。

参照先 NSS_STATUS_SUCCESS・NSS_STATUS_UNAVAIL・status・winbindd_get_response()・winbindd_send_request().

{
        NSS_STATUS status = NSS_STATUS_UNAVAIL;
        int count = 0;

        while ((status == NSS_STATUS_UNAVAIL) && (count < 10)) {
                status = winbindd_send_request(req_type, 0, request);
                if (status != NSS_STATUS_SUCCESS) 
                        return(status);
                status = winbindd_get_response(response);
                count += 1;
        }

        return status;
}

NSS_STATUS winbindd_priv_request_response	(	int	req_type,
		struct winbindd_request *	request,
		struct winbindd_response *	response
	)

wb_common.c の 652 行で定義されています。

参照先 NSS_STATUS_SUCCESS・NSS_STATUS_UNAVAIL・status・winbindd_get_response()・winbindd_send_request().

参照元 check_winbind_security().

{
        NSS_STATUS status = NSS_STATUS_UNAVAIL;
        int count = 0;

        while ((status == NSS_STATUS_UNAVAIL) && (count < 10)) {
                status = winbindd_send_request(req_type, 1, request);
                if (status != NSS_STATUS_SUCCESS) 
                        return(status);
                status = winbindd_get_response(response);
                count += 1;
        }

        return status;
}

---

変数

int winbindd_fd = -1

wb_common.c の 35 行で定義されています。

参照元 close_sock()・read_sock()・wbinfo_ping()・winbind_open_pipe_sock()・write_sock().

int is_privileged = 0 [static]

wb_common.c の 36 行で定義されています。

参照元 winbind_open_pipe_sock().

---