X-Git-Url: http://git.demorecorder.com/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=src%2Fxcb_util.c;h=ba0f10867d8b1c6659e967460bba2a0700380097;hb=c3cfa04b09ff042fed731b17dac3e40de1a10187;hp=f5c7cecc3ddd6c2eacb7602babcd9616544e236c;hpb=829188cdd6274b5b5271dff5612b30c978a61a38;p=free-sw%2Fxcb%2Flibxcb diff --git a/src/xcb_util.c b/src/xcb_util.c index f5c7cec..ba0f108 100644 --- a/src/xcb_util.c +++ b/src/xcb_util.c @@ -25,393 +25,520 @@ /* Utility functions implementable using only public APIs. */ +#ifdef HAVE_CONFIG_H +#include "config.h" +#endif + #include #include -#include -#include -#ifdef DNETCONN -#include -#include -#endif -#include +#include #include #include #include +#include #include #include +#ifdef _WIN32 +#include "xcb_windefs.h" +#else +#include +#include +#include +#include +#include +#include +#include +#endif /* _WIN32 */ + #include "xcb.h" #include "xcbext.h" #include "xcbint.h" -int XCBPopcount(CARD32 mask) +#if defined(HAVE_TSOL_LABEL_H) && defined(HAVE_IS_SYSTEM_LABELED) +# include +# include +#endif + +#ifdef HAVE_LAUNCHD +#include +#endif + +int xcb_popcount(uint32_t mask) { - unsigned long y; + uint32_t y; y = (mask >> 1) & 033333333333; y = mask - y - ((y >> 1) & 033333333333); return ((y + (y >> 3)) & 030707070707) % 077; } -int XCBParseDisplay(const char *name, char **host, int *displayp, int *screenp) +int xcb_sumof(uint8_t *list, int len) +{ + int i, s = 0; + for(i=0; i[.] + * Upon success: + * host = + * protocol = "unix" + * display = 0 + * screen = + */ +static int _xcb_parse_display_path_to_socket(const char *name, char **host, char **protocol, + int *displayp, int *screenp) +{ + struct stat sbuf; + char path[PATH_MAX]; + int _screen = 0; + + strlcpy(path, name, sizeof(path)); + if (0 != stat(path, &sbuf)) { + char *dot = strrchr(path, '.'); + if (!dot) + return 0; + *dot = '\0'; + + if (0 != stat(path, &sbuf)) + return 0; + + _screen = atoi(dot + 1); + } + + if (host) { + *host = strdup(path); + if (!*host) + return 0; + } + + if (protocol) { + *protocol = strdup("unix"); + if (!*protocol) { + if (host) + free(*host); + return 0; + } + } + + if (displayp) + *displayp = 0; + + if (screenp) + *screenp = _screen; + + return 1; +} +#endif + +static int _xcb_parse_display(const char *name, char **host, char **protocol, + int *displayp, int *screenp) { int len, display, screen; - char *colon, *dot, *end; + char *slash, *colon, *dot, *end; + if(!name || !*name) name = getenv("DISPLAY"); if(!name) return 0; + +#ifdef HAVE_LAUNCHD + /* First check for [.] */ + if (_xcb_parse_display_path_to_socket(name, host, protocol, displayp, screenp)) + return 1; +#endif + + slash = strrchr(name, '/'); + + if (slash) { + len = slash - name; + if (protocol) { + *protocol = malloc(len + 1); + if(!*protocol) + return 0; + memcpy(*protocol, name, len); + (*protocol)[len] = '\0'; + } + name = slash + 1; + } else + if (protocol) + *protocol = NULL; + colon = strrchr(name, ':'); if(!colon) - return 0; + goto error_out; len = colon - name; ++colon; display = strtoul(colon, &dot, 10); if(dot == colon) - return 0; + goto error_out; if(*dot == '\0') screen = 0; else { if(*dot != '.') - return 0; + goto error_out; ++dot; screen = strtoul(dot, &end, 10); if(end == dot || *end != '\0') - return 0; + goto error_out; } /* At this point, the display string is fully parsed and valid, but * the caller's memory is untouched. */ *host = malloc(len + 1); if(!*host) - return 0; + goto error_out; memcpy(*host, name, len); (*host)[len] = '\0'; *displayp = display; if(screenp) *screenp = screen; return 1; + +error_out: + if (protocol) { + free(*protocol); + *protocol = NULL; + } + + return 0; +} + +int xcb_parse_display(const char *name, char **host, int *displayp, + int *screenp) +{ + return _xcb_parse_display(name, host, NULL, displayp, screenp); } -static int _xcb_open_tcp(const char *host, const unsigned short port); -static int _xcb_open_unix(const char *file); -#ifdef DNETCONN -static int _xcb_open_decnet(const char *host, const unsigned short port); +static int _xcb_open_tcp(const char *host, char *protocol, const unsigned short port); +#ifndef _WIN32 +static int _xcb_open_unix(char *protocol, const char *file); +#endif /* !WIN32 */ +#ifdef HAVE_ABSTRACT_SOCKETS +static int _xcb_open_abstract(char *protocol, const char *file, size_t filelen); #endif -static int _xcb_open(const char *host, const int display) +static int _xcb_open(const char *host, char *protocol, const int display) { int fd; - - if(*host) - { -#ifdef DNETCONN - if (strchr(host, ':')) - { - /* DECnet displays have two colons, so the parser will have left - one at the end */ - char *dnethost = strdup(host); - - dnethost[strlen(dnethost)-1] = '\0'; - fd = _xcb_open_decnet(dnethost, display); - free(dnethost); - } - else +#ifdef __hpux + static const char unix_base[] = "/usr/spool/sockets/X11/"; +#else + static const char unix_base[] = "/tmp/.X11-unix/X"; #endif - { - /* display specifies TCP */ - unsigned short port = X_TCP_PORT + display; - fd = _xcb_open_tcp(host, port); - } - } - else + const char *base = unix_base; + size_t filelen; + char *file = NULL; + int actual_filelen; + + /* If protocol or host is "unix", fall through to Unix socket code below */ + if ((!protocol || (strcmp("unix",protocol) != 0)) && + (*host != '\0') && (strcmp("unix",host) != 0)) { - /* display specifies Unix socket */ - static const char base[] = "/tmp/.X11-unix/X"; - char file[sizeof(base) + 20]; - snprintf(file, sizeof(file), "%s%d", base, display); - fd = _xcb_open_unix(file); + /* display specifies TCP */ + unsigned short port = X_TCP_PORT + display; + return _xcb_open_tcp(host, protocol, port); } - return fd; -} +#ifndef _WIN32 +#if defined(HAVE_TSOL_LABEL_H) && defined(HAVE_IS_SYSTEM_LABELED) + /* Check special path for Unix sockets under Solaris Trusted Extensions */ + if (is_system_labeled()) + { + struct stat sbuf; + const char *tsol_base = "/var/tsol/doors/.X11-unix/X"; + char tsol_socket[PATH_MAX]; -#ifdef DNETCONN -static int _xcb_open_decnet(const char *host, const unsigned short port) -{ - int fd; - struct sockaddr_dn addr; - struct accessdata_dn accessdata; - struct nodeent *nodeaddr = getnodebyname(host); + snprintf(tsol_socket, sizeof(tsol_socket), "%s%d", tsol_base, display); - if(!nodeaddr) - return -1; - addr.sdn_family = AF_DECnet; + if (stat(tsol_socket, &sbuf) == 0) + base = tsol_base; + } +#endif - addr.sdn_add.a_len = nodeaddr->n_length; - memcpy(addr.sdn_add.a_addr, nodeaddr->n_addr, addr.sdn_add.a_len); +#ifdef HAVE_LAUNCHD + struct stat sbuf; + if (0 == stat(host, &sbuf)) { + file = strdup(host); + filelen = actual_filelen = strlen(file); + } else +#endif + { + filelen = strlen(base) + 1 + sizeof(display) * 3 + 1; + file = malloc(filelen); + if(file == NULL) + return -1; - sprintf((char *)addr.sdn_objname, "X$X%d", port); - addr.sdn_objnamel = strlen((char *)addr.sdn_objname); - addr.sdn_objnum = 0; + /* display specifies Unix socket */ + actual_filelen = snprintf(file, filelen, "%s%d", base, display); + } - fd = socket(PF_DECnet, SOCK_STREAM, 0); - if(fd == -1) + if(actual_filelen < 0) + { + free(file); return -1; + } + /* snprintf may truncate the file */ + filelen = MIN(actual_filelen, filelen - 1); +#ifdef HAVE_ABSTRACT_SOCKETS + fd = _xcb_open_abstract(protocol, file, filelen); + if (fd >= 0 || (errno != ENOENT && errno != ECONNREFUSED)) + { + free(file); + return fd; + } - memset(&accessdata, 0, sizeof(accessdata)); - sprintf((char*)accessdata.acc_acc, "%d", getuid()); - accessdata.acc_accl = strlen((char *)accessdata.acc_acc); - setsockopt(fd, DNPROTO_NSP, SO_CONACCESS, &accessdata, sizeof(accessdata)); - - if(connect(fd, (struct sockaddr *) &addr, sizeof(addr)) == -1) - return -1; - return fd; -} #endif + fd = _xcb_open_unix(protocol, file); + free(file); -static int _xcb_open_tcp(const char *host, const unsigned short port) -{ - int fd; - struct sockaddr_in addr; - struct hostent *hostaddr = gethostbyname(host); - if(!hostaddr) - return -1; - addr.sin_family = AF_INET; - addr.sin_port = htons(port); - memcpy(&addr.sin_addr, hostaddr->h_addr_list[0], sizeof(addr.sin_addr)); + if (fd < 0 && !protocol && *host == '\0') { + unsigned short port = X_TCP_PORT + display; + fd = _xcb_open_tcp(host, protocol, port); + } - fd = socket(PF_INET, SOCK_STREAM, 0); - if(fd == -1) - return -1; - if(connect(fd, (struct sockaddr *) &addr, sizeof(addr)) == -1) - return -1; return fd; +#endif /* !_WIN32 */ + return -1; /* if control reaches here then something has gone wrong */ } -static int _xcb_open_unix(const char *file) +static int _xcb_socket(int family, int type, int proto) { int fd; - struct sockaddr_un addr = { AF_UNIX }; - strcpy(addr.sun_path, file); - fd = socket(AF_UNIX, SOCK_STREAM, 0); - if(fd == -1) - return -1; - if(connect(fd, (struct sockaddr *) &addr, sizeof(addr)) == -1) - return -1; +#ifdef SOCK_CLOEXEC + fd = socket(family, type | SOCK_CLOEXEC, proto); + if (fd == -1 && errno == EINVAL) +#endif + { + fd = socket(family, type, proto); +#ifndef _WIN32 + if (fd >= 0) + fcntl(fd, F_SETFD, FD_CLOEXEC); +#endif + } return fd; } -XCBConnection *XCBConnect(const char *displayname, int *screenp) -{ - int fd, display = 0; - char *host; - XCBConnection *c; - XCBAuthInfo auth; - - if(!XCBParseDisplay(displayname, &host, &display, screenp)) - return 0; - fd = _xcb_open(host, display); - free(host); - if(fd == -1) - return 0; - - _xcb_get_auth_info(fd, &auth); - c = XCBConnectToFD(fd, &auth); - free(auth.name); - free(auth.data); - return c; -} - -XCBConnection *XCBConnectToDisplayWithAuthInfo(const char *displayname, XCBAuthInfo *auth, int *screenp) -{ - int fd, display = 0; - char *host; - - if(!XCBParseDisplay(displayname, &host, &display, screenp)) - return 0; - fd = _xcb_open(host, display); - free(host); - if(fd == -1) - return 0; - return XCBConnectToFD(fd, auth); -} +static int _xcb_do_connect(int fd, const struct sockaddr* addr, int addrlen) { + int on = 1; -/* backwards compatible interfaces: remove before 1.0 release */ -int XCBSync(XCBConnection *c, XCBGenericError **e) -{ - XCBGetInputFocusRep *reply = XCBGetInputFocusReply(c, XCBGetInputFocus(c), e); - free(reply); - return reply != 0; -} + if(fd < 0) + return -1; -XCBConnection *XCBConnectBasic() -{ - XCBConnection *c = XCBConnect(0, 0); - if(c) - return c; - perror("XCBConnect"); - abort(); -} + setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on)); + setsockopt(fd, SOL_SOCKET, SO_KEEPALIVE, &on, sizeof(on)); -int XCBOpen(const char *host, const int display) -{ - return _xcb_open(host, display); + return connect(fd, addr, addrlen); } -int XCBOpenTCP(const char *host, const unsigned short port) +static int _xcb_open_tcp(const char *host, char *protocol, const unsigned short port) { - return _xcb_open_tcp(host, port); -} + int fd = -1; +#if HAVE_GETADDRINFO + struct addrinfo hints; + char service[6]; /* "65535" with the trailing '\0' */ + struct addrinfo *results, *addr; + char *bracket; +#endif -int XCBOpenUnix(const char *file) -{ - return _xcb_open_unix(file); -} + if (protocol && strcmp("tcp",protocol) && strcmp("inet",protocol) +#ifdef AF_INET6 + && strcmp("inet6",protocol) +#endif + ) + return -1; -int XCBGetAuthInfo(int fd, XCBAuthInfo *info) -{ - return _xcb_get_auth_info(fd, info); -} + if (*host == '\0') + host = "localhost"; -char *XCBConnSetupReqAuthorizationProtocolName(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolName(R); -} +#if HAVE_GETADDRINFO + memset(&hints, 0, sizeof(hints)); +#ifdef AI_NUMERICSERV + hints.ai_flags |= AI_NUMERICSERV; +#endif + hints.ai_family = AF_UNSPEC; + hints.ai_socktype = SOCK_STREAM; -int XCBConnSetupReqAuthorizationProtocolNameLength(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolNameLength(R); -} +#ifdef AF_INET6 + /* Allow IPv6 addresses enclosed in brackets. */ + if(host[0] == '[' && (bracket = strrchr(host, ']')) && bracket[1] == '\0') + { + *bracket = '\0'; + ++host; + hints.ai_flags |= AI_NUMERICHOST; + hints.ai_family = AF_INET6; + } +#endif -XCBGenericIter XCBConnSetupReqAuthorizationProtocolNameEnd(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolNameEnd(R); -} + snprintf(service, sizeof(service), "%hu", port); + if(getaddrinfo(host, service, &hints, &results)) + /* FIXME: use gai_strerror, and fill in error connection */ + return -1; -char *XCBConnSetupReqAuthorizationProtocolData(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolData(R); -} + for(addr = results; addr; addr = addr->ai_next) + { + fd = _xcb_socket(addr->ai_family, addr->ai_socktype, addr->ai_protocol); + if (_xcb_do_connect(fd, addr->ai_addr, addr->ai_addrlen) >= 0) + break; + close(fd); + fd = -1; + } + freeaddrinfo(results); + return fd; +#else + { + struct hostent* _h; + struct sockaddr_in _s; + struct in_addr ** _c; -int XCBConnSetupReqAuthorizationProtocolDataLength(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolDataLength(R); -} + if((_h = gethostbyname(host)) == NULL) + return -1; -XCBGenericIter XCBConnSetupReqAuthorizationProtocolDataEnd(XCBSetupReq *R) -{ - return XCBSetupReqAuthorizationProtocolDataEnd(R); -} + _c = (struct in_addr**)_h->h_addr_list; + fd = -1; -void XCBConnSetupReqNext(XCBSetupReqIter *i) -{ - XCBSetupReqNext(i); -} + while(*_c) { + _s.sin_family = AF_INET; + _s.sin_port = htons(port); + _s.sin_addr = *(*_c); -XCBGenericIter XCBConnSetupReqEnd(XCBSetupReqIter i) -{ - return XCBSetupReqEnd(i); -} + fd = _xcb_socket(_s.sin_family, SOCK_STREAM, 0); + if(_xcb_do_connect(fd, (struct sockaddr*)&_s, sizeof(_s)) >= 0) + break; -char *XCBConnSetupFailedRepReason(XCBSetupFailed *R) -{ - return XCBSetupFailedReason(R); -} + close(fd); + fd = -1; + ++_c; + } -int XCBConnSetupFailedRepReasonLength(XCBSetupFailed *R) -{ - return XCBSetupFailedReasonLength(R); + return fd; + } +#endif } -XCBGenericIter XCBConnSetupFailedRepReasonEnd(XCBSetupFailed *R) +#ifndef _WIN32 +static int _xcb_open_unix(char *protocol, const char *file) { - return XCBSetupFailedReasonEnd(R); -} + int fd; + struct sockaddr_un addr; -void XCBConnSetupFailedRepNext(XCBSetupFailedIter *i) -{ - XCBSetupFailedNext(i); -} + if (protocol && strcmp("unix",protocol)) + return -1; -XCBGenericIter XCBConnSetupFailedRepEnd(XCBSetupFailedIter i) -{ - return XCBSetupFailedEnd(i); + strcpy(addr.sun_path, file); + addr.sun_family = AF_UNIX; +#ifdef HAVE_SOCKADDR_SUN_LEN + addr.sun_len = SUN_LEN(&addr); +#endif + fd = _xcb_socket(AF_UNIX, SOCK_STREAM, 0); + if(fd == -1) + return -1; + if(connect(fd, (struct sockaddr *) &addr, sizeof(addr)) == -1) { + close(fd); + return -1; + } + return fd; } +#endif /* !_WIN32 */ -char *XCBConnSetupAuthenticateRepReason(XCBSetupAuthenticate *R) +#ifdef HAVE_ABSTRACT_SOCKETS +static int _xcb_open_abstract(char *protocol, const char *file, size_t filelen) { - return XCBSetupAuthenticateReason(R); -} + int fd; + struct sockaddr_un addr = {0}; + socklen_t namelen; -int XCBConnSetupAuthenticateRepReasonLength(XCBSetupAuthenticate *R) -{ - return XCBSetupAuthenticateReasonLength(R); -} + if (protocol && strcmp("unix",protocol)) + return -1; -XCBGenericIter XCBConnSetupAuthenticateRepReasonEnd(XCBSetupAuthenticate *R) -{ - return XCBSetupAuthenticateReasonEnd(R); + strcpy(addr.sun_path + 1, file); + addr.sun_family = AF_UNIX; + namelen = offsetof(struct sockaddr_un, sun_path) + 1 + filelen; +#ifdef HAVE_SOCKADDR_SUN_LEN + addr.sun_len = 1 + filelen; +#endif + fd = _xcb_socket(AF_UNIX, SOCK_STREAM, 0); + if (fd == -1) + return -1; + if (connect(fd, (struct sockaddr *) &addr, namelen) == -1) { + close(fd); + return -1; + } + return fd; } +#endif -void XCBConnSetupAuthenticateRepNext(XCBSetupAuthenticateIter *i) +xcb_connection_t *xcb_connect(const char *displayname, int *screenp) { - XCBSetupAuthenticateNext(i); + return xcb_connect_to_display_with_auth_info(displayname, NULL, screenp); } -XCBGenericIter XCBConnSetupAuthenticateRepEnd(XCBSetupAuthenticateIter i) +xcb_connection_t *xcb_connect_to_display_with_auth_info(const char *displayname, xcb_auth_info_t *auth, int *screenp) { - return XCBSetupAuthenticateEnd(i); -} + int fd, display = 0; + char *host = NULL; + char *protocol = NULL; + xcb_auth_info_t ourauth; + xcb_connection_t *c; -char *XCBConnSetupSuccessRepVendor(XCBSetup *R) -{ - return XCBSetupVendor(R); -} + int parsed = _xcb_parse_display(displayname, &host, &protocol, &display, screenp); -int XCBConnSetupSuccessRepVendorLength(XCBSetup *R) -{ - return XCBSetupVendorLength(R); -} + if(!parsed) { + c = _xcb_conn_ret_error(XCB_CONN_CLOSED_PARSE_ERR); + goto out; + } -XCBGenericIter XCBConnSetupSuccessRepVendorEnd(XCBSetup *R) -{ - return XCBSetupVendorEnd(R); -} +#ifdef _WIN32 + WSADATA wsaData; + if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0) { + c = _xcb_conn_ret_error(XCB_CONN_ERROR); + goto out; + } +#endif -XCBFORMAT *XCBConnSetupSuccessRepPixmapFormats(XCBSetup *R) -{ - return XCBSetupPixmapFormats(R); -} + fd = _xcb_open(host, protocol, display); -int XCBConnSetupSuccessRepPixmapFormatsLength(XCBSetup *R) -{ - return XCBSetupPixmapFormatsLength(R); -} + if(fd == -1) { + c = _xcb_conn_ret_error(XCB_CONN_ERROR); +#ifdef _WIN32 + WSACleanup(); +#endif + goto out; + } -XCBFORMATIter XCBConnSetupSuccessRepPixmapFormatsIter(XCBSetup *R) -{ - return XCBSetupPixmapFormatsIter(R); -} + if(auth) { + c = xcb_connect_to_fd(fd, auth); + goto out; + } -int XCBConnSetupSuccessRepRootsLength(XCBSetup *R) -{ - return XCBSetupRootsLength(R); -} + if(_xcb_get_auth_info(fd, &ourauth, display)) + { + c = xcb_connect_to_fd(fd, &ourauth); + free(ourauth.name); + free(ourauth.data); + } + else + c = xcb_connect_to_fd(fd, 0); -XCBSCREENIter XCBConnSetupSuccessRepRootsIter(XCBSetup *R) -{ - return XCBSetupRootsIter(R); -} + if(c->has_error) + goto out; -void XCBConnSetupSuccessRepNext(XCBSetupIter *i) -{ - XCBSetupNext(i); -} + /* Make sure requested screen number is in bounds for this server */ + if((screenp != NULL) && (*screenp >= (int) c->setup->roots_len)) { + xcb_disconnect(c); + c = _xcb_conn_ret_error(XCB_CONN_CLOSED_INVALID_SCREEN); + goto out; + } -XCBGenericIter XCBConnSetupSuccessRepEnd(XCBSetupIter i) -{ - return XCBSetupEnd(i); +out: + free(host); + free(protocol); + return c; }