diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/vncBlockHandler.c.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/vncBlockHandler.c --- tigervnc-1.7.0/unix/xserver/hw/vnc/vncBlockHandler.c.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/vncBlockHandler.c 2016-10-04 17:17:35.618889747 +0200 @@ -30,6 +30,23 @@ #include "vncExtInit.h" #include "vncBlockHandler.h" +#include "xorg-version.h" + +#if XORG >= 119 + +static void vncBlockHandler(void* data, void* timeout) +{ + vncCallBlockHandlers(timeout); +} + +void vncRegisterBlockHandlers(void) +{ + if (!RegisterBlockAndWakeupHandlers(vncBlockHandler, + (ServerWakeupHandlerProcPtr)NoopDDA, 0)) + FatalError("RegisterBlockAndWakeupHandlers() failed\n"); +} + +#else static void vncBlockHandler(void * data, OSTimePtr t, void * readmask); static void vncWakeupHandler(void * data, int nfds, void * readmask); @@ -144,3 +161,5 @@ static void vncWriteWakeupHandlerFallbac vncWriteWakeupHandler(ret, &fallbackFds); } + +#endif diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.cc.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.cc --- tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.cc.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.cc 2016-10-04 17:17:35.618889747 +0200 @@ -241,6 +241,17 @@ int vncExtensionIsActive(int scrIdx) return (desktop[scrIdx] != NULL); } +#if XORG >= 119 + +void vncCallBlockHandlers(int* timeout) +{ + for (int scr = 0; scr < vncGetScreenCount(); scr++) + if (desktop[scr]) + desktop[scr]->blockHandler(timeout); +} + +#else + void vncCallReadBlockHandlers(fd_set * fds, struct timeval ** timeout) { for (int scr = 0; scr < vncGetScreenCount(); scr++) @@ -269,6 +280,8 @@ void vncCallWriteWakeupHandlers(fd_set * desktop[scr]->writeWakeupHandler(fds, nfds); } +#endif + int vncGetAvoidShiftNumLock(void) { return (bool)avoidShiftNumLock; diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.h.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.h --- tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.h.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/vncExtInit.h 2016-10-04 17:17:35.618889747 +0200 @@ -22,6 +22,7 @@ #include #include #include +#include "xorg-version.h" // Only from C++ #ifdef __cplusplus @@ -52,10 +53,14 @@ extern int vncInetdSock; void vncExtensionInit(void); int vncExtensionIsActive(int scrIdx); +#if XORG >= 119 +void vncCallBlockHandlers(int* timeout); +#else void vncCallReadBlockHandlers(fd_set * fds, struct timeval ** timeout); void vncCallReadWakeupHandlers(fd_set * fds, int nfds); void vncCallWriteBlockHandlers(fd_set * fds, struct timeval ** timeout); void vncCallWriteWakeupHandlers(fd_set * fds, int nfds); +#endif int vncGetAvoidShiftNumLock(void); diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/vncHooks.c.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/vncHooks.c --- tigervnc-1.7.0/unix/xserver/hw/vnc/vncHooks.c.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/vncHooks.c 2016-10-04 17:17:35.618889747 +0200 @@ -128,9 +128,11 @@ static Bool vncHooksDisplayCursor(Device #if XORG <= 112 static void vncHooksBlockHandler(int i, pointer blockData, pointer pTimeout, pointer pReadmask); -#else +#elif XORG <= 118 static void vncHooksBlockHandler(ScreenPtr pScreen, void * pTimeout, void * pReadmask); +#else +static void vncHooksBlockHandler(ScreenPtr pScreen, void * pTimeout); #endif #ifdef RENDER static void vncHooksComposite(CARD8 op, PicturePtr pSrc, PicturePtr pMask, @@ -716,9 +718,11 @@ out: #if XORG <= 112 static void vncHooksBlockHandler(int i, pointer blockData, pointer pTimeout, pointer pReadmask) -#else +#elif XORG <= 118 static void vncHooksBlockHandler(ScreenPtr pScreen_, void * pTimeout, void * pReadmask) +#else +static void vncHooksBlockHandler(ScreenPtr pScreen_, void * pTimeout) #endif { #if XORG <= 112 @@ -731,8 +735,10 @@ static void vncHooksBlockHandler(ScreenP #if XORG <= 112 (*pScreen->BlockHandler) (i, blockData, pTimeout, pReadmask); -#else +#elif XORG <= 118 (*pScreen->BlockHandler) (pScreen, pTimeout, pReadmask); +#else + (*pScreen->BlockHandler) (pScreen, pTimeout); #endif vncHooksScreen->ignoreHooks--; @@ -1033,12 +1039,21 @@ static void vncHooksCopyClip(GCPtr dst, // Unwrap and rewrap helpers +#if XORG >= 116 +#define GC_OP_PROLOGUE(pGC, name)\ + vncHooksGCPtr pGCPriv = vncHooksGCPrivate(pGC);\ + const GCFuncs *oldFuncs = pGC->funcs;\ + pGC->funcs = pGCPriv->wrappedFuncs;\ + pGC->ops = pGCPriv->wrappedOps; \ + DBGPRINT((stderr,"vncHooks" #name " called\n")) +#else #define GC_OP_PROLOGUE(pGC, name)\ vncHooksGCPtr pGCPriv = vncHooksGCPrivate(pGC);\ GCFuncs *oldFuncs = pGC->funcs;\ pGC->funcs = pGCPriv->wrappedFuncs;\ pGC->ops = pGCPriv->wrappedOps; \ DBGPRINT((stderr,"vncHooks" #name " called\n")) +#endif #define GC_OP_EPILOGUE(pGC)\ pGCPriv->wrappedOps = pGC->ops;\ diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/xorg-version.h.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/xorg-version.h --- tigervnc-1.7.0/unix/xserver/hw/vnc/xorg-version.h.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/xorg-version.h 2016-10-04 17:24:51.640654527 +0200 @@ -50,8 +50,10 @@ #define XORG 117 #elif XORG_VERSION_CURRENT < ((1 * 10000000) + (18 * 100000) + (99 * 1000)) #define XORG 118 +#elif XORG_VERSION_CURRENT < ((1 * 10000000) + (19 * 100000) + (99 * 1000)) +#define XORG 119 #else -#error "X.Org newer than 1.18 is not supported" +#error "X.Org newer than 1.19 is not supported" #endif #endif diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.cc.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.cc --- tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.cc.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.cc 2016-10-04 17:23:47.171977905 +0200 @@ -89,6 +89,30 @@ public: XserverDesktop* desktop; }; +#if XORG >= 119 +extern "C" { +/* + * xserver NotifyFd callbacks. Note we also expect write notifies to work, + * which only works with xserver >= 1.19. + */ +#include "os.h" + +static void HandleListenFd(int fd, int xevents, void *data) +{ + XserverDesktop *desktop = (XserverDesktop *)data; + + desktop->handleListenFd(fd); +} + +static void HandleSocketFd(int fd, int xevents, void *data) +{ + XserverDesktop *desktop = (XserverDesktop *)data; + + desktop->handleSocketFd(fd, xevents); +} + +} +#endif XserverDesktop::XserverDesktop(int screenIndex_, std::list listeners_, @@ -110,15 +134,35 @@ XserverDesktop::XserverDesktop(int scree if (!httpListeners.empty ()) httpServer = new FileHTTPServer(this); + +#if XORG >= 119 + for (std::list::iterator i = listeners.begin(); + i != listeners.end(); + i++) { + SetNotifyFd((*i)->getFd(), HandleListenFd, X_NOTIFY_READ, this); + } + + for (std::list::iterator i = httpListeners.begin(); + i != httpListeners.end(); + i++) { + SetNotifyFd((*i)->getFd(), HandleListenFd, X_NOTIFY_READ, this); + } +#endif } XserverDesktop::~XserverDesktop() { while (!listeners.empty()) { +#if XORG >= 119 + RemoveNotifyFd(listeners.back()->getFd()); +#endif delete listeners.back(); listeners.pop_back(); } while (!httpListeners.empty()) { +#if XORG >= 119 + RemoveNotifyFd(listeners.back()->getFd()); +#endif delete httpListeners.back(); httpListeners.pop_back(); } @@ -388,6 +432,140 @@ void XserverDesktop::add_copied(const rf } } +#if XORG >= 119 +void XserverDesktop::handleListenFd(int fd) +{ + std::list::iterator i; + SocketServer *fd_server = NULL; + bool is_http = false; + + for (i = listeners.begin(); i != listeners.end(); i++) { + if ((*i)->getFd() == fd) { + fd_server = server; + break; + } + } + if (httpServer && !fd_server) { + for (i = httpListeners.begin(); i != httpListeners.end(); i++) { + if ((*i)->getFd() == fd) { + fd_server = httpServer; + is_http = true; + break; + } + } + } + if (!fd_server) { + vlog.error("XserverDesktop::handleListenFd: Error cannot find fd"); + return; + } + + Socket* sock = (*i)->accept(); + sock->outStream().setBlocking(false); + vlog.debug("new %sclient, sock %d", is_http ? "http " : "", sock->getFd()); + fd_server->addSocket(sock); + SetNotifyFd(sock->getFd(), HandleSocketFd, X_NOTIFY_READ, this); +} + +void XserverDesktop::handleSocketFd(int fd, int xevents) +{ + std::list sockets; + std::list::iterator i; + SocketServer *fd_server = NULL; + bool is_http = false; + + server->getSockets(&sockets); + for (i = sockets.begin(); i != sockets.end(); i++) { + if ((*i)->getFd() == fd) { + fd_server = server; + break; + } + } + if (httpServer && !fd_server) { + httpServer->getSockets(&sockets); + for (i = sockets.begin(); i != sockets.end(); i++) { + if ((*i)->getFd() == fd) { + fd_server = httpServer; + is_http = true; + break; + } + } + } + if (!fd_server) { + vlog.error("XserverDesktop::handleSocketFd: Error cannot find fd"); + return; + } + + if (xevents & X_NOTIFY_READ) + fd_server->processSocketReadEvent(*i); + + if (xevents & X_NOTIFY_WRITE) + fd_server->processSocketWriteEvent(*i); + + if ((*i)->isShutdown()) { + vlog.debug("%sclient gone, sock %d", is_http ? "http " : "", fd); + RemoveNotifyFd(fd); + fd_server->removeSocket(*i); + if (!is_http) + vncClientGone(fd); + delete (*i); + } +} + +void XserverDesktop::blockHandler(int* timeout) +{ + // We don't have a good callback for when we can init input devices[1], + // so we abuse the fact that this routine will be called first thing + // once the dix is done initialising. + // [1] Technically Xvnc has InitInput(), but libvnc.so has nothing. + vncInitInputDevice(); + + try { + std::list sockets; + std::list::iterator i; + server->getSockets(&sockets); + for (i = sockets.begin(); i != sockets.end(); i++) { + int fd = (*i)->getFd(); + if ((*i)->isShutdown()) { + vlog.debug("client gone, sock %d",fd); + server->removeSocket(*i); + vncClientGone(fd); + delete (*i); + } else { + /* Update existing NotifyFD to listen for write (or not) */ + if ((*i)->outStream().bufferUsage() > 0) + SetNotifyFd(fd, HandleSocketFd, X_NOTIFY_READ | X_NOTIFY_WRITE, this); + else + SetNotifyFd(fd, HandleSocketFd, X_NOTIFY_READ, this); + } + } + if (httpServer) { + httpServer->getSockets(&sockets); + for (i = sockets.begin(); i != sockets.end(); i++) { + int fd = (*i)->getFd(); + if ((*i)->isShutdown()) { + vlog.debug("http client gone, sock %d",fd); + httpServer->removeSocket(*i); + delete (*i); + } else { + /* Update existing NotifyFD to listen for write (or not) */ + if ((*i)->outStream().bufferUsage() > 0) + SetNotifyFd(fd, HandleSocketFd, X_NOTIFY_READ | X_NOTIFY_WRITE, this); + else + SetNotifyFd(fd, HandleSocketFd, X_NOTIFY_READ, this); + } + } + } + + int nextTimeout = server->checkTimeouts(); + if (nextTimeout > 0 && (*timeout == -1 || nextTimeout < *timeout)) + *timeout = nextTimeout; + } catch (rdr::Exception& e) { + vlog.error("XserverDesktop::blockHandler: %s",e.str()); + } +} + +#else + void XserverDesktop::readBlockHandler(fd_set* fds, struct timeval ** timeout) { // We don't have a good callback for when we can init input devices[1], @@ -600,10 +778,15 @@ void XserverDesktop::writeWakeupHandler( } } +#endif + void XserverDesktop::addClient(Socket* sock, bool reverse) { vlog.debug("new client, sock %d reverse %d",sock->getFd(),reverse); server->addSocket(sock, reverse); +#if XORG >= 119 + SetNotifyFd(sock->getFd(), HandleSocketFd, X_NOTIFY_READ, this); +#endif } void XserverDesktop::disconnectClients() diff -up tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.h.xserver119 tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.h --- tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.h.xserver119 2016-09-08 12:31:18.000000000 +0200 +++ tigervnc-1.7.0/unix/xserver/hw/vnc/XserverDesktop.h 2016-10-04 17:17:35.617889712 +0200 @@ -38,6 +38,7 @@ #include #include #include "Input.h" +#include "xorg-version.h" namespace rfb { class VNCServerST; @@ -69,10 +70,16 @@ public: const unsigned char *rgbaData); void add_changed(const rfb::Region ®ion); void add_copied(const rfb::Region &dest, const rfb::Point &delta); +#if XORG >= 119 + void handleListenFd(int fd); + void handleSocketFd(int fd, int xevents); + void blockHandler(int* timeout); +#else void readBlockHandler(fd_set* fds, struct timeval ** timeout); void readWakeupHandler(fd_set* fds, int nfds); void writeBlockHandler(fd_set* fds, struct timeval ** timeout); void writeWakeupHandler(fd_set* fds, int nfds); +#endif void addClient(network::Socket* sock, bool reverse); void disconnectClients();