| /**************************************************************************** |
| * graphics/nxmu/nxmu_server.c |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. The |
| * ASF licenses this file to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance with the |
| * License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT |
| * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the |
| * License for the specific language governing permissions and limitations |
| * under the License. |
| * |
| ****************************************************************************/ |
| |
| /**************************************************************************** |
| * Included Files |
| ****************************************************************************/ |
| |
| #include <nuttx/config.h> |
| |
| #include <inttypes.h> |
| #include <stdint.h> |
| #include <stdio.h> |
| #include <string.h> |
| #include <mqueue.h> |
| #include <fcntl.h> |
| #include <assert.h> |
| #include <errno.h> |
| #include <debug.h> |
| |
| #include <nuttx/mqueue.h> |
| #include <nuttx/nx/nx.h> |
| |
| #include "nxmu.h" |
| |
| /**************************************************************************** |
| * Private Functions |
| ****************************************************************************/ |
| |
| /**************************************************************************** |
| * Name: nxmu_disconnect |
| ****************************************************************************/ |
| |
| static inline void nxmu_disconnect(FAR struct nxmu_conn_s *conn) |
| { |
| struct nxclimsg_disconnected_s outmsg; |
| int ret; |
| |
| /* Send the handshake message back to the client */ |
| |
| outmsg.msgid = NX_CLIMSG_DISCONNECTED; |
| |
| ret = nxmu_sendclient(conn, &outmsg, |
| sizeof(struct nxclimsg_disconnected_s)); |
| if (ret < 0) |
| { |
| gerr("ERROR: nxmu_sendclient failed: %d\n", ret); |
| } |
| |
| /* Close the outgoing client message queue */ |
| |
| nxmq_close(conn->swrmq); |
| } |
| |
| /**************************************************************************** |
| * Name: nxmu_connect |
| ****************************************************************************/ |
| |
| static inline void nxmu_connect(FAR struct nxmu_conn_s *conn) |
| { |
| char mqname[NX_CLIENT_MXNAMELEN]; |
| struct nxclimsg_connected_s outmsg; |
| int ret; |
| |
| /* Create the client MQ name */ |
| |
| snprintf(mqname, sizeof(mqname), NX_CLIENT_MQNAMEFMT, conn->cid); |
| |
| /* Open the client MQ -- this should have already been created by the |
| * client |
| */ |
| |
| conn->swrmq = nxmq_open(mqname, O_WRONLY); |
| if (conn->swrmq < 0) |
| { |
| gerr("ERROR: nxmq_open(%s) failed: %d\n", mqname, conn->swrmq); |
| outmsg.msgid = NX_CLIMSG_DISCONNECTED; |
| } |
| |
| /* Send the handshake message back to the client */ |
| |
| outmsg.msgid = NX_CLIMSG_CONNECTED; |
| ret = nxmu_sendclient(conn, &outmsg, sizeof(struct nxclimsg_connected_s)); |
| if (ret < 0) |
| { |
| gerr("ERROR: nxmu_sendclient failed: %d\n", ret); |
| } |
| } |
| |
| /**************************************************************************** |
| * Name: nxmu_shutdown |
| ****************************************************************************/ |
| |
| static inline void nxmu_shutdown(FAR struct nxmu_state_s *nxmu) |
| { |
| FAR struct nxbe_window_s *wnd; |
| |
| /* Inform all of the clients in the window list that the server is |
| * exit-ting. Notes: (1) that the following loop will probably attempt to |
| * disconnect clients multiple times because one client may have multiple |
| * windows: The first disconnect will fail; subsequent will return errors |
| * that are ignored. (2) The final window to be disconnected will be the |
| * background window, thus close all of the servers message queues. |
| */ |
| |
| for (wnd = nxmu->be.topwnd; wnd; wnd = wnd->below) |
| { |
| nxmu_disconnect(wnd->conn); |
| } |
| } |
| |
| /**************************************************************************** |
| * Name: nxmu_event |
| ****************************************************************************/ |
| |
| static void nxmu_event(FAR struct nxbe_window_s *wnd, enum nx_event_e event, |
| FAR void *arg) |
| { |
| struct nxclimsg_event_s outmsg; |
| int ret; |
| |
| outmsg.msgid = NX_CLIMSG_EVENT; |
| outmsg.wnd = wnd; |
| outmsg.arg = arg; |
| outmsg.event = event; |
| |
| ret = nxmu_sendclient(wnd->conn, &outmsg, |
| sizeof(struct nxclimsg_event_s)); |
| if (ret < 0) |
| { |
| gerr("ERROR: nxmu_sendclient failed: %d\n", ret); |
| } |
| } |
| |
| /**************************************************************************** |
| * Name: nxmu_setup |
| ****************************************************************************/ |
| |
| static inline int nxmu_setup(FAR const char *mqname, FAR NX_DRIVERTYPE *dev, |
| FAR struct nxmu_state_s *nxmu) |
| { |
| struct mq_attr attr; |
| int ret; |
| |
| memset(nxmu, 0, sizeof(struct nxmu_state_s)); |
| |
| /* Configure the framebuffer/LCD device */ |
| |
| ret = nxbe_configure(dev, &nxmu->be); |
| if (ret < 0) |
| { |
| gerr("ERROR: nxbe_configure failed: %d\n", ret); |
| return ret; |
| } |
| |
| #ifdef CONFIG_FB_CMAP |
| ret = nxbe_colormap(dev); |
| if (ret < 0) |
| { |
| gerr("ERROR: nxbe_colormap failed: %d\n", ret); |
| return ret; |
| } |
| #endif /* CONFIG_FB_CMAP */ |
| |
| /* Initialize the non-NULL elements of the server connection structure. |
| * Oddly, this structure represents the connection between the server and |
| * itself. |
| * |
| * Open the incoming server MQ. The server receives messages on the |
| * background window's incoming message queue. |
| */ |
| |
| attr.mq_maxmsg = CONFIG_NX_MXSERVERMSGS; |
| attr.mq_msgsize = NX_MXSVRMSGLEN; |
| attr.mq_flags = 0; |
| |
| nxmu->conn.crdmq = nxmq_open(mqname, O_RDONLY | O_CREAT, 0666, &attr); |
| if (nxmu->conn.crdmq < 0) |
| { |
| gerr("ERROR: nxmq_open(%s) failed: %d\n", mqname, nxmu->conn.crdmq); |
| return nxmu->conn.crdmq; |
| } |
| |
| /* NOTE that the outgoing client MQ (cwrmq) is not initialized. The |
| * background window never initiates messages. |
| */ |
| |
| /* Open the outgoing server MQ. This is used to send messages to the |
| * background window which will, of course, be received and handled by |
| * the server message loop. |
| */ |
| |
| nxmu->conn.swrmq = nxmq_open(mqname, O_WRONLY); |
| if (nxmu->conn.swrmq < 0) |
| { |
| gerr("ERROR: nxmq_open(%s) failed: %d\n", mqname, nxmu->conn.swrmq); |
| nxmq_close(nxmu->conn.crdmq); |
| return nxmu->conn.swrmq; |
| } |
| |
| /* The server is now "connected" to itself via the background window */ |
| |
| nxmu->conn.state = NX_CLISTATE_CONNECTED; |
| |
| /* Initialize the non-NULL elements of the background window */ |
| |
| nxmu->be.bkgd.conn = &nxmu->conn; |
| nxmu->be.bkgd.be = (FAR struct nxbe_state_s *)nxmu; |
| |
| nxmu->be.bkgd.bounds.pt2.x = nxmu->be.vinfo.xres - 1; |
| nxmu->be.bkgd.bounds.pt2.y = nxmu->be.vinfo.yres - 1; |
| |
| /* Complete initialization of the server state structure. The |
| * window list contains only one element: The background window |
| * with nothing else above or below it |
| */ |
| |
| nxmu->be.topwnd = &nxmu->be.bkgd; |
| |
| /* Initialize the mouse position */ |
| |
| #ifdef CONFIG_NX_XYINPUT |
| nxmu_mouseinit(nxmu->be.vinfo.xres, nxmu->be.vinfo.yres); |
| #endif |
| return OK; |
| } |
| |
| /**************************************************************************** |
| * Public Functions |
| ****************************************************************************/ |
| |
| /**************************************************************************** |
| * Name: nx_runinstance |
| * |
| * Description: |
| * This is the server entry point. It does not return; the calling thread |
| * is dedicated to supporting NX server. |
| * |
| * NOTE that multiple instances of the NX server may run at the same time, |
| * each with different callback and message queue names. |
| * |
| * Input Parameters: |
| * mqname - The name for the server incoming message queue |
| * dev - Vtable "object" of the framebuffer/LCD "driver" to use |
| * |
| * Returned Value: |
| * This function usually does not return. If it does return, it will |
| * return a negated errno value indicating the cause of the failure. |
| * |
| ****************************************************************************/ |
| |
| int nx_runinstance(FAR const char *mqname, FAR NX_DRIVERTYPE *dev) |
| { |
| struct nxmu_state_s nxmu; |
| FAR struct nxsvrmsg_s *msg; |
| char buffer[NX_MXSVRMSGLEN]; |
| int nbytes; |
| int ret; |
| |
| /* Initialization *********************************************************/ |
| |
| DEBUGASSERT(mqname != NULL || dev != NULL); |
| |
| /* Initialize and configure the server */ |
| |
| ret = nxmu_setup(mqname, dev, &nxmu); |
| if (ret < 0) |
| { |
| return ret; |
| } |
| |
| /* Produce the initial, background display */ |
| |
| nxbe_redraw(&nxmu.be, &nxmu.be.bkgd, &nxmu.be.bkgd.bounds); |
| |
| /* Message Loop ***********************************************************/ |
| |
| /* Then loop forever processing incoming messages */ |
| |
| for (; ; ) |
| { |
| /* Receive the next server message */ |
| |
| nbytes = nxmq_receive(nxmu.conn.crdmq, buffer, NX_MXSVRMSGLEN, 0); |
| if (nbytes < 0) |
| { |
| if (nbytes != -EINTR) |
| { |
| gerr("ERROR: nxmq_receive() failed: %d\n", nbytes); |
| ret = nbytes; |
| goto errout; |
| } |
| |
| continue; |
| } |
| |
| /* Dispatch the message appropriately */ |
| |
| DEBUGASSERT(nbytes >= sizeof(struct nxsvrmsg_releasebkgd_s)); |
| msg = (FAR struct nxsvrmsg_s *)buffer; |
| |
| ginfo("Received opcode=%" PRId32 " nbytes=%d\n", msg->msgid, nbytes); |
| switch (msg->msgid) |
| { |
| /* Messages sent from clients to the NX server ********************/ |
| |
| case NX_SVRMSG_CONNECT: /* Establish connection with new NX server client */ |
| { |
| FAR struct nxsvrmsg_s *connmsg = |
| (FAR struct nxsvrmsg_s *)buffer; |
| nxmu_connect(connmsg->conn); |
| } |
| break; |
| |
| case NX_SVRMSG_DISCONNECT: /* Tear down connection with terminating client */ |
| { |
| FAR struct nxsvrmsg_s *disconnmsg = |
| (FAR struct nxsvrmsg_s *)buffer; |
| nxmu_disconnect(disconnmsg->conn); |
| } |
| break; |
| |
| case NX_SVRMSG_OPENWINDOW: /* Create a new window */ |
| { |
| FAR struct nxsvrmsg_openwindow_s *openmsg = |
| (FAR struct nxsvrmsg_openwindow_s *)buffer; |
| nxmu_openwindow(&nxmu.be, openmsg->wnd); |
| } |
| break; |
| |
| case NX_SVRMSG_CLOSEWINDOW: /* Close an existing window */ |
| { |
| FAR struct nxsvrmsg_closewindow_s *closemsg = |
| (FAR struct nxsvrmsg_closewindow_s *)buffer; |
| nxbe_closewindow(closemsg->wnd); |
| } |
| break; |
| |
| case NX_SVRMSG_BLOCKED: /* Block messages to a window */ |
| { |
| FAR struct nxsvrmsg_blocked_s *blocked = |
| (FAR struct nxsvrmsg_blocked_s *)buffer; |
| nxmu_event(blocked->wnd, NXEVENT_BLOCKED, blocked->arg); |
| } |
| break; |
| |
| case NX_SVRMSG_SYNCH: /* Synchronization request */ |
| { |
| FAR struct nxsvrmsg_synch_s *synch = |
| (FAR struct nxsvrmsg_synch_s *)buffer; |
| nxmu_event(synch->wnd, NXEVENT_SYNCHED, synch->arg); |
| } |
| break; |
| |
| #if defined(CONFIG_NX_SWCURSOR) || defined(CONFIG_NX_HWCURSOR) |
| case NX_SVRMSG_CURSOR_ENABLE: /* Enable/disable cursor */ |
| { |
| FAR struct nxsvrmsg_curenable_s *enabmsg = |
| (FAR struct nxsvrmsg_curenable_s *)buffer; |
| nxbe_cursor_enable(&nxmu.be, enabmsg->enable); |
| } |
| break; |
| |
| #if defined(CONFIG_NX_HWCURSORIMAGE) || defined(CONFIG_NX_SWCURSOR) |
| case NX_SVRMSG_CURSOR_IMAGE: /* Set cursor image */ |
| { |
| FAR struct nxsvrmsg_curimage_s *imgmsg = |
| (FAR struct nxsvrmsg_curimage_s *)buffer; |
| nxbe_cursor_setimage(&nxmu.be, &imgmsg->image); |
| } |
| break; |
| #endif |
| case NX_SVRMSG_CURSOR_SETPOS: /* Set cursor position */ |
| { |
| FAR struct nxsvrmsg_curpos_s *posmsg = |
| (FAR struct nxsvrmsg_curpos_s *)buffer; |
| nxbe_cursor_setposition(&nxmu.be, &posmsg->pos); |
| } |
| break; |
| #endif |
| |
| case NX_SVRMSG_REQUESTBKGD: /* Give access to the background window */ |
| { |
| FAR struct nxsvrmsg_requestbkgd_s *rqbgmsg = |
| (FAR struct nxsvrmsg_requestbkgd_s *)buffer; |
| nxmu_requestbkgd(rqbgmsg->conn, &nxmu.be, rqbgmsg->cb, |
| rqbgmsg->arg); |
| } |
| break; |
| |
| case NX_SVRMSG_RELEASEBKGD: /* End access to the background window */ |
| { |
| nxmu_releasebkgd(&nxmu); |
| } |
| break; |
| |
| case NX_SVRMSG_SETPOSITION: /* Change window position */ |
| { |
| FAR struct nxsvrmsg_setposition_s *setposmsg = |
| (FAR struct nxsvrmsg_setposition_s *)buffer; |
| nxbe_setposition(setposmsg->wnd, &setposmsg->pos); |
| } |
| break; |
| |
| case NX_SVRMSG_SETSIZE: /* Change window size */ |
| { |
| FAR struct nxsvrmsg_setsize_s *setsizemsg = |
| (FAR struct nxsvrmsg_setsize_s *)buffer; |
| nxbe_setsize(setsizemsg->wnd, &setsizemsg->size); |
| } |
| break; |
| |
| case NX_SVRMSG_GETPOSITION: /* Get the window size/position */ |
| { |
| FAR struct nxsvrmsg_getposition_s *getposmsg = |
| (FAR struct nxsvrmsg_getposition_s *)buffer; |
| nxmu_reportposition(getposmsg->wnd); |
| } |
| break; |
| |
| case NX_SVRMSG_RAISE: /* Move the window to the top of the display */ |
| { |
| FAR struct nxsvrmsg_raise_s *raisemsg = |
| (FAR struct nxsvrmsg_raise_s *)buffer; |
| nxbe_raise(raisemsg->wnd); |
| } |
| break; |
| |
| case NX_SVRMSG_LOWER: /* Lower the window to the bottom of the display */ |
| { |
| FAR struct nxsvrmsg_lower_s *lowermsg = |
| (FAR struct nxsvrmsg_lower_s *)buffer; |
| nxbe_lower(lowermsg->wnd); |
| } |
| break; |
| |
| case NX_SVRMSG_MODAL: /* Select/De-select window modal state */ |
| { |
| FAR struct nxsvrmsg_modal_s *modalmsg = |
| (FAR struct nxsvrmsg_modal_s *)buffer; |
| nxbe_modal(modalmsg->wnd, modalmsg->modal); |
| } |
| break; |
| |
| case NX_SVRMSG_SETVISIBILITY: /* Show or hide a window */ |
| { |
| FAR struct nxsvrmsg_setvisibility_s *vismsg = |
| (FAR struct nxsvrmsg_setvisibility_s *)buffer; |
| nxbe_setvisibility(vismsg->wnd, vismsg->hide); |
| } |
| break; |
| |
| case NX_SVRMSG_SETPIXEL: /* Set a single pixel in the window with a color */ |
| { |
| FAR struct nxsvrmsg_setpixel_s *setmsg = |
| (FAR struct nxsvrmsg_setpixel_s *)buffer; |
| nxbe_setpixel(setmsg->wnd, &setmsg->pos, setmsg->color); |
| } |
| break; |
| |
| case NX_SVRMSG_FILL: /* Fill a rectangular region in the window with a color */ |
| { |
| FAR struct nxsvrmsg_fill_s *fillmsg = |
| (FAR struct nxsvrmsg_fill_s *)buffer; |
| nxbe_fill(fillmsg->wnd, &fillmsg->rect, fillmsg->color); |
| } |
| break; |
| |
| case NX_SVRMSG_GETRECTANGLE: /* Get a rectangular region from the window */ |
| { |
| FAR struct nxsvrmsg_getrectangle_s *getmsg = |
| (FAR struct nxsvrmsg_getrectangle_s *)buffer; |
| nxbe_getrectangle(getmsg->wnd, &getmsg->rect, getmsg->plane, |
| getmsg->dest, getmsg->deststride); |
| |
| if (getmsg->sem_done) |
| { |
| nxsem_post(getmsg->sem_done); |
| } |
| } |
| break; |
| |
| case NX_SVRMSG_FILLTRAP: /* Fill a trapezoidal region in the window with a color */ |
| { |
| FAR struct nxsvrmsg_filltrapezoid_s *trapmsg = |
| (FAR struct nxsvrmsg_filltrapezoid_s *)buffer; |
| nxbe_filltrapezoid(trapmsg->wnd, &trapmsg->clip, |
| &trapmsg->trap, trapmsg->color); |
| } |
| break; |
| |
| case NX_SVRMSG_MOVE: /* Move a rectangular region within the window */ |
| { |
| FAR struct nxsvrmsg_move_s *movemsg = |
| (FAR struct nxsvrmsg_move_s *)buffer; |
| nxbe_move(movemsg->wnd, &movemsg->rect, &movemsg->offset); |
| } |
| break; |
| |
| case NX_SVRMSG_BITMAP: /* Copy a rectangular bitmap into the window */ |
| { |
| FAR struct nxsvrmsg_bitmap_s *bmpmsg = |
| (FAR struct nxsvrmsg_bitmap_s *)buffer; |
| nxbe_bitmap(bmpmsg->wnd, &bmpmsg->dest, bmpmsg->src, |
| &bmpmsg->origin, bmpmsg->stride); |
| |
| if (bmpmsg->sem_done) |
| { |
| nxsem_post(bmpmsg->sem_done); |
| } |
| } |
| break; |
| |
| case NX_SVRMSG_SETBGCOLOR: /* Set the color of the background */ |
| { |
| FAR struct nxsvrmsg_setbgcolor_s *bgcolormsg = |
| (FAR struct nxsvrmsg_setbgcolor_s *)buffer; |
| |
| /* Has the background color changed? */ |
| |
| if (!nxgl_colorcmp(nxmu.be.bgcolor, bgcolormsg->color)) |
| { |
| /* Yes.. fill the background */ |
| |
| nxgl_colorcopy(nxmu.be.bgcolor, bgcolormsg->color); |
| nxbe_fill(&nxmu.be.bkgd, &nxmu.be.bkgd.bounds, |
| bgcolormsg->color); |
| } |
| } |
| break; |
| |
| #ifdef CONFIG_NX_XYINPUT |
| case NX_SVRMSG_MOUSEIN: /* New mouse report from mouse client */ |
| { |
| FAR struct nxsvrmsg_mousein_s *mousemsg = |
| (FAR struct nxsvrmsg_mousein_s *)buffer; |
| nxmu_mousein(&nxmu, &mousemsg->pt, mousemsg->buttons); |
| } |
| break; |
| #endif |
| #ifdef CONFIG_NX_KBD |
| case NX_SVRMSG_KBDIN: /* New keyboard report from keyboard client */ |
| { |
| FAR struct nxsvrmsg_kbdin_s *kbdmsg = |
| (FAR struct nxsvrmsg_kbdin_s *)buffer; |
| nxmu_kbdin(&nxmu, kbdmsg->nch, kbdmsg->ch); |
| } |
| break; |
| #endif |
| |
| case NX_SVRMSG_REDRAWREQ: /* Request re-drawing of rectangular region */ |
| { |
| FAR struct nxsvrmsg_redrawreq_s *redrawmsg = |
| (FAR struct nxsvrmsg_redrawreq_s *)buffer; |
| nxmu_redraw(redrawmsg->wnd, &redrawmsg->rect); |
| } |
| break; |
| |
| /* Messages sent to the background window *************************/ |
| |
| case NX_CLIMSG_REDRAW: /* Re-draw the background window */ |
| { |
| FAR struct nxclimsg_redraw_s *redraw = |
| (FAR struct nxclimsg_redraw_s *)buffer; |
| DEBUGASSERT(redraw->wnd == &nxmu.be.bkgd); |
| ginfo("Re-draw background rect={(%d,%d),(%d,%d)}\n", |
| redraw->rect.pt1.x, redraw->rect.pt1.y, |
| redraw->rect.pt2.x, redraw->rect.pt2.y); |
| nxbe_fill(&nxmu.be.bkgd, &redraw->rect, nxmu.be.bgcolor); |
| } |
| break; |
| |
| case NX_CLIMSG_MOUSEIN: /* Ignored */ |
| case NX_CLIMSG_KBDIN: |
| break; |
| |
| case NX_CLIMSG_CONNECTED: /* Shouldn't happen */ |
| case NX_CLIMSG_DISCONNECTED: |
| default: |
| gerr("ERROR: Unrecognized command: %" PRId32 "\n", msg->msgid); |
| break; |
| } |
| } |
| |
| nxmu_shutdown(&nxmu); |
| return OK; |
| |
| errout: |
| nxmu_shutdown(&nxmu); |
| return ret; |
| } |
