import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * Create an instance of JmDNS and bind it to a specific network interface given its IP-address.
 *
 * @param address
 *            IP address to bind to.
 * @param name
 *            name of the newly created JmDNS
 * @exception IOException
 */
public JmDNSImpl(InetAddress address, String name) throws IOException {
    super();
    if (logger.isLoggable(Level.FINER)) {
        logger.finer("JmDNS instance created");
    }
    _cache = new DNSCache(100);

    _listeners = Collections.synchronizedList(new ArrayList<DNSListener>());
    _serviceListeners = new ConcurrentHashMap<String, List<ServiceListenerStatus>>();
    _typeListeners = Collections.synchronizedSet(new HashSet<ServiceTypeListenerStatus>());
    _serviceCollectors = new ConcurrentHashMap<String, ServiceCollector>();

    _services = new ConcurrentHashMap<String, ServiceInfo>(20);
    _serviceTypes = new ConcurrentHashMap<String, ServiceTypeEntry>(20);

    _localHost = HostInfo.newHostInfo(address, this, name);
    _name = (name != null ? name : _localHost.getName());

    // _cancelerTimer = new Timer("JmDNS.cancelerTimer");

    // (ldeck 2.1.1) preventing shutdown blocking thread
    // -------------------------------------------------
    // _shutdown = new Thread(new Shutdown(), "JmDNS.Shutdown");
    // Runtime.getRuntime().addShutdownHook(_shutdown);

    // -------------------------------------------------

    // Bind to multicast socket
    this.openMulticastSocket(this.getLocalHost());
    this.start(this.getServices().values());

    this.startReaper();
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void addServiceTypeListener(ServiceTypeListener listener) throws IOException {
    ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener, ListenerStatus.ASYNCHONEOUS);
    _typeListeners.add(status);

    // report cached service types
    for (String type : _serviceTypes.keySet()) {
        status.serviceTypeAdded(new ServiceEventImpl(this, type, "", null));
    }

    this.startTypeResolver();
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * Create an instance of JmDNS and bind it to a specific network interface given its IP-address.
 *
 * @param address
 *            IP address to bind to.
 * @param name
 *            name of the newly created JmDNS
 * @exception IOException
 */
public JmDNSImpl(InetAddress address, String name) throws IOException {
    super();
    Log.i("mDNS","JmDNSImpl");
    
    if (logger.isLoggable(Level.FINER)) {
        logger.finer("JmDNS instance created");
    }
    _cache = new DNSCache(100);
    
    _listeners = Collections.synchronizedList(new ArrayList<DNSListener>());
    _serviceListeners = new ConcurrentHashMap<String, List<ServiceListenerStatus>>();
    _typeListeners = Collections.synchronizedSet(new HashSet<ServiceTypeListenerStatus>());
    _serviceCollectors = new ConcurrentHashMap<String, ServiceCollector>();

    _services = new ConcurrentHashMap<String, ServiceInfo>(20);
    _serviceTypes = new ConcurrentHashMap<String, ServiceTypeEntry>(20);
    
    _localHost = HostInfo.newHostInfo(address, this, name);
    
    _name = (name != null ? name : _localHost.getName());
   
    // _cancelerTimer = new Timer("JmDNS.cancelerTimer");

    // (ldeck 2.1.1) preventing shutdown blocking thread
    // -------------------------------------------------
    // _shutdown = new Thread(new Shutdown(), "JmDNS.Shutdown");
    // Runtime.getRuntime().addShutdownHook(_shutdown);

    // -------------------------------------------------

    // Bind to multicast socket
    this.openMulticastSocket(this.getLocalHost());
    this.start(this.getServices().values());

    this.startReaper();
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * Create an instance of JmDNS and bind it to a specific network interface given its IP-address.
 *
 * @param address
 *            IP address to bind to.
 * @param name
 *            name of the newly created JmDNS
 * @throws java.io.IOException
 */
public JmDNSImpl(InetAddress address, String name) throws IOException
{
    super();
    if (logger.isLoggable(Level.FINER))
    {
        logger.finer("JmDNS instance created");
    }
    _cache = new DNSCache(100);

    _listeners = Collections.synchronizedList(new ArrayList<DNSListener>());
    _serviceListeners = new ConcurrentHashMap<String, List<ServiceListenerStatus>>();
    _typeListeners = Collections.synchronizedSet(new HashSet<ServiceTypeListenerStatus>());
    _serviceCollectors = new ConcurrentHashMap<String, ServiceCollector>();

    _services = new ConcurrentHashMap<String, ServiceInfo>(20);
    _serviceTypes = new ConcurrentHashMap<String, Set<String>>(20);

    _localHost = HostInfo.newHostInfo(address, this);
    _name = (name != null ? name : _localHost.getName());

    _timer = new Timer("JmDNS(" + _name + ").Timer", true);
    _stateTimer = new Timer("JmDNS(" + _name + ").State.Timer", false);
    // _cancelerTimer = new Timer("JmDNS.cancelerTimer");

    // (ldeck 2.1.1) preventing shutdown blocking thread
    // -------------------------------------------------
    // _shutdown = new Thread(new Shutdown(), "JmDNS.Shutdown");
    // Runtime.getRuntime().addShutdownHook(_shutdown);

    // -------------------------------------------------

    // Bind to multicast socket
    this.openMulticastSocket(this.getLocalHost());
    this.start(this.getServices().values());

    new RecordReaper(this).start(_timer);
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void addServiceTypeListener(ServiceTypeListener listener) throws IOException
{
    ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener);
    _typeListeners.add(status);

    // report cached service types
    for (String type : _serviceTypes.keySet())
    {
        status.serviceTypeAdded(new ServiceEventImpl(this, type, "", null));
    }

    new TypeResolver(this).start(_timer);
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void removeServiceTypeListener(ServiceTypeListener listener)
{
    ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener);
    _typeListeners.remove(status);
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * Create an instance of JmDNS and bind it to a specific network interface given its IP-address.
 * 
 * @param address
 *            IP address to bind to.
 * @param name
 *            name of the newly created JmDNS
 * @exception IOException
 */
public JmDNSImpl(final InetAddress address, final String name) throws IOException {
    super();
    if (logger.isLoggable(Level.FINER)) {
        logger.finer("JmDNS instance created");
    }
    this._cache = new DNSCache(100);

    this._listeners = Collections.synchronizedList(new ArrayList<DNSListener>());
    this._serviceListeners = new ConcurrentHashMap<String, List<ServiceListenerStatus>>();
    this._typeListeners = Collections.synchronizedSet(new HashSet<ServiceTypeListenerStatus>());
    this._serviceCollectors = new ConcurrentHashMap<String, ServiceCollector>();

    this._services = new ConcurrentHashMap<String, ServiceInfo>(20);
    this._serviceTypes = new ConcurrentHashMap<String, ServiceTypeEntry>(20);

    this._localHost = HostInfo.newHostInfo(address, this, name);
    this._name = (name != null ? name : this._localHost.getName());

    // _cancelerTimer = new Timer("JmDNS.cancelerTimer");

    // (ldeck 2.1.1) preventing shutdown blocking thread
    // -------------------------------------------------
    // _shutdown = new Thread(new Shutdown(), "JmDNS.Shutdown");
    // Runtime.getRuntime().addShutdownHook(_shutdown);

    // -------------------------------------------------

    // Bind to multicast socket
    this.openMulticastSocket(this.getLocalHost());
    this.start(this.getServices().values());

    this.startReaper();
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void addServiceTypeListener(final ServiceTypeListener listener) throws IOException {
    final ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener, ListenerStatus.ASYNCHONEOUS);
    this._typeListeners.add(status);

    // report cached service types
    for (final String type : this._serviceTypes.keySet()) {
        status.serviceTypeAdded(new ServiceEventImpl(this, type, "", null));
    }

    this.startTypeResolver();
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void removeServiceTypeListener(ServiceTypeListener listener) {
    ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener, ListenerStatus.ASYNCHONEOUS);
    _typeListeners.remove(status);
}
 

import javax.jmdns.impl.ListenerStatus.ServiceTypeListenerStatus; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public void removeServiceTypeListener(final ServiceTypeListener listener) {
    final ServiceTypeListenerStatus status = new ServiceTypeListenerStatus(listener, ListenerStatus.ASYNCHONEOUS);
    this._typeListeners.remove(status);
}