/* following line is 174 */
        final synchronized void copy (QueueFile[] dst, QueueFile src[])
        {
                dst[] = src;
        }

        final void watchdog ()
        {       
            
                auto len = queueList.length;
                auto list = (cast(QueueFile*) alloca(len * QueueFile.sizeof))[0..len];

                // clone the list of queues to avoid stalling everything
                copy (list, queueList);

        /*
                synchronized (this)
                        memcpy (list.ptr, queueList.ptr, len * (QueueFile*).sizeof);
                        list[] = queueList;
        */

                foreach (q; list)
                        {
                        if (q.size)
                            publish (q.channel);

                        if (q.isDirty)
                           {
                           q.flush;
                           log.info ("flushed "~q.channel.name~" to disk");
                           }
                        }

        }