-CrossThreadChannel::drop_ios ()
-{
- delete _ios;
- _ios = 0;
-}
-
-void
-CrossThreadChannel::drain ()
-{
- drain (fds[0]);
-}
-
-void
-CrossThreadChannel::drain (int fd)
-{
- /* drain selectable fd */
- char buf[64];
- while (::read (fd, buf, sizeof (buf)) > 0) {};
-}
-
-int
-CrossThreadChannel::deliver (char msg)
-{
- return ::write (fds[1], &msg, 1);
-}
-
-int
-CrossThreadChannel::receive (char& msg)