Dotaz: select a jak ho vzbudit

[Deleted [8409]]

Chtěl bych se zeptat, jakým způsobem se dá vzbudit select(), který čeká na X11.

Mám následující kód:

void EventPumpX11::waitForWork()
{
  UISystemX11* uiSystem = UI_SYSTEM();

  int fd = uiSystem->_fd;
  int fdSize = fd + 1;
  fd_set fdSet;

  struct timeval tval;
  FD_ZERO(&fdSet);
  FD_SET(fd, &fdSet);

  TimeDelta delay = _delayedWorkTime - Time::now();
  if (delay > TimeDelta())
  {
    // Go to sleep. X11 will wake us to process X events. We also set interval
    // to wake up if there are planned tasks to specific time (Timers).
    int64_t udelay = delay.inMicroseconds();
    tval.tv_sec = (int)(udelay / 1000000);
    tval.tv_usec = (int)(udelay % 1000000);
    if (tval.tv_usec <= 100) tval.tv_usec = 100;

    int ret = ::select(fdSize, &fdSet, NULL, NULL, &tval);
    // TODO: Check for select result
  }
  else
  {
    // It looks like delayedWorkTime indicates a time in the past, so we
    // need to call doDelayedWork now.
    _delayedWorkTime = Time();
  }
}

kde fd je deskriptor, který jsem obdržel pomocí ConnectionNumber(Display*) (Xlib). O co mi jde, potřeboval bych probudit event loop, když chci z jiného vlákna poslat událost do toho hlavního, které čeká buď na událost z X11 nebo na vypršení časového limitu potřebného pro jiné úkoly (delay).

Myslím, že správná cesta bude vytvořit vlastní file descriptor, na který pošlu 1 byte v případě, že budu chtít probudit event loop, ale nějak nevím jak přesně na to (toto jsem ještě nikdy nedělal). Použít fd_set a do masky dát vlastní fd?

Stačí mi nakopnutí správným směrem ;)

Odpovědi

[joe]

Přesně tak, jen přidáš ten další deskriptor (nejlépe asi z pipe()) pomocí FD_SET(fd2, fdSet) a fdSize upravíš na max(fd, fd2) + 1 a po tom selectu otestuješ, na kterých deskriptorech jsou data pomocí FD_ISSET (i ten druhý deskriptor musíš vyprazdňovat). Samozřejmě se to dá přerušit třeba signálem, ale musí člověk přesně vědět, co všechno to může udělat. Přidání dalšího deskriptoru je nejčistší.

[Deleted [8409]]

díky, dopracoval jsem se k něčemu takovému:

void EventPumpX11::waitForWork()
{
  UISystemX11* uiSystem = UI_SYSTEM();

  int fd = uiSystem->_fd;
  int fdSize = fog_max(fd, uiSystem->_wakeUpPipe[0]) + 1;
  fd_set fdSet;

  struct timeval tval;
  struct timeval* ptval = NULL;
  FD_ZERO(&fdSet);
  FD_SET(fd, &fdSet);
  FD_SET(uiSystem->_wakeUpPipe[0], &fdSet);

  if (_delayedWorkTime.isNull())
  {
    // There are no scheduled tasks, so ptval is NULL and this tells to select()
    // that it should wait infitine time.
  }
  else
  {
    TimeDelta delay = _delayedWorkTime - Time::now();

    if (delay > TimeDelta())
    {
      // Go to sleep. X11 will wake us to process X events and we also set
      // interval to wake up to run planned tasks (usually Timers).
      int64_t udelay = delay.inMicroseconds();
      tval.tv_sec = (int)(udelay / 1000000);
      tval.tv_usec = (int)(udelay % 1000000);
      if (tval.tv_usec <= 100) tval.tv_usec = 100;
      ptval = &tval;
    }
    else
    {
      // It looks like delayedWorkTime indicates a time in the past, so we
      // need to call doDelayedWork now.
      _delayedWorkTime = Time();
      return;
    }
  }

  int ret = ::select(fdSize, &fdSet, NULL, NULL, ptval);

  if (ret < 0)
  {
    fog_debug("Fog::EventPumpX11::waitForWork() - select() failed (errno=%d).", errno);
  }

  if (ret > 0)
  {
    if (FD_ISSET(uiSystem->_wakeUpPipe[0], &fdSet))
    {
      // Dummy c, the actual value is out of our interest.
      uint8_t c;
      read(uiSystem->_wakeUpPipe[0], &c, 1);
      _wakeUpSent.cmpXchg(1, 0);
    }
  }
}

a Kód pro probuzen9 z jiiného vlákna vypadá takto:

void EventPumpX11::sendWakeUp()
{
  if (_wakeUpSent.cmpXchg(0, 1))
  {
    UISystemX11* uiSystem = UI_SYSTEM();
    uint8_t c = 'W';

    write(uiSystem->_wakeUpPipe[1], &c, 1);
  }
}

požil jsem atomické operace k tomu, abych do pipe neposílal příliš moc, teď tam je normálně jen ten 1 BYTE, který probudí select. Funguje to, ale samořejmě to může obsahovat chyby (zase tak moc jsem to neotestoval)...

Ke kompletnosti ještě vytvoření pipe:

  // Create wakeup pipe.
  if (pipe(_wakeUpPipe) < 0)
  {
    fog_debug("Fog::UISystemX11::Can't create wakeup pipe");
    goto fail;
  }

K zápisu používám _wakeUpPipe[1] a ke čtení _wakeUpPipe[0], doufám, že jsem to pochopil správně...:)