Function _hx_std_socket_poll_prepare

src/hx/libs/std/Socket.cpp:1171–1215

socket_poll_prepare : 'poll -> read:'socket array -> write:'socket array -> int array array Prepare a poll for scanning events on sets of sockets. **/

   </doc>
**/
Array<Dynamic> _hx_std_socket_poll_prepare( Dynamic pdata, Array<Dynamic> rsocks, Array<Dynamic> wsocks )
{
   polldata *p = val_poll(pdata);

   int len = rsocks.mPtr ? rsocks->length : 0;
   int wlen = wsocks.mPtr ? wsocks->length : 0;
   if( len + wlen > p->max )
      hx::Throw(HX_CSTRING("Too many sockets in poll"));

   #ifdef NEKO_WINDOWS
   for(int i=0;i<len;i++)
      p->fdr->fd_array[i] = val_sock( rsocks[i] );
   p->fdr->fd_count = len;

   len = wlen;
   for(int i=0;i<len;i++)
      p->fdw->fd_array[i] = val_sock( wsocks[i]);
   p->fdw->fd_count = len;

   #else

   for(int i=0;i<len;i++)
   {
      p->fds[i].fd = val_sock( rsocks[i] );
      p->fds[i].events = POLLIN;
      p->fds[i].revents = 0;
   }
   p->rcount = len;
   len = wlen;
   for(int i=0;i<len;i++)
   {
      int k = i + p->rcount;
      p->fds[k].fd = val_sock(wsocks[i]);
      p->fds[k].events = POLLOUT;
      p->fds[k].revents = 0;
   }
   p->wcount = len;

   #endif

   Array<Dynamic> a = Array_obj<Dynamic>::__new(2,2);
   a[0] = p->ridx;
   a[1] = p->widx;
   return a;
}


/**