ArduinoDNSTaskStarter.java

package processing.app.zeroconf.jmdns;

import javax.jmdns.impl.DNSIncoming;
import javax.jmdns.impl.DNSTaskStarter;
import javax.jmdns.impl.JmDNSImpl;
import javax.jmdns.impl.ServiceInfoImpl;
import javax.jmdns.impl.tasks.RecordReaper;
import java.util.Timer;

public class ArduinoDNSTaskStarter implements DNSTaskStarter.Factory.ClassDelegate {

  @Override
  public DNSTaskStarter newDNSTaskStarter(final JmDNSImpl jmDNSImpl) {
    final DNSTaskStarter.DNSTaskStarterImpl delegate = new DNSTaskStarter.DNSTaskStarterImpl(jmDNSImpl);
    final DNSTaskStarter.DNSTaskStarterImpl.StarterTimer timer = new DNSTaskStarter.DNSTaskStarterImpl.StarterTimer("JmDNS(" + jmDNSImpl.getName() + ").Timer", true);

    return new DNSTaskStarter() {

      public void purgeTimer() {
        delegate.purgeTimer();
        timer.purge();
      }

      public void purgeStateTimer() {
        delegate.purgeStateTimer();
      }

      public void cancelTimer() {
        delegate.cancelTimer();
        timer.cancel();
      }

      public void cancelStateTimer() {
        delegate.cancelStateTimer();
      }

      public void startProber() {
        delegate.startProber();
      }

      public void startAnnouncer() {
        delegate.startAnnouncer();
      }

      public void startRenewer() {
        delegate.startRenewer();
      }

      public void startCanceler() {
        delegate.startCanceler();
      }

      public void startReaper() {
        new RecordReaper(jmDNSImpl) {
          @Override
          public void start(Timer timer) {
            if (!this.getDns().isCanceling() && !this.getDns().isCanceled()) {
              timer.schedule(this, 0, 500);
            }
          }
        }.start(timer);
      }

      public void startServiceInfoResolver(ServiceInfoImpl info) {
        delegate.startServiceInfoResolver(info);
      }

      public void startTypeResolver() {
        delegate.startTypeResolver();
      }

      public void startServiceResolver(String type) {
        delegate.startServiceResolver(type);
      }

      public void startResponder(DNSIncoming in, int port) {
        delegate.startResponder(in, port);
      }
    };
  }
}