nuttx/graphics/nxmu/nxmu_server.c

/****************************************************************************
 * 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;
}