package com.seewo.remote.f;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.vman.R;
import e.c.d.k;
import java.io.IOException;
import org.snmp4j.MessageDispatcherImpl;
import org.snmp4j.Snmp;
import org.snmp4j.mp.MPv1;
import org.snmp4j.mp.MPv2c;
import org.snmp4j.smi.UdpAddress;
import org.snmp4j.transport.DefaultUdpTransportMapping;
import org.snmp4j.util.MultiThreadedMessageDispatcher;
import org.snmp4j.util.ThreadPool;

/* JADX INFO: compiled from: SnmpAgent.java */
/* JADX INFO: loaded from: classes.dex */
public class b {
    private Context a;
    private Snmp b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private BroadcastReceiver f272c;

    /* JADX INFO: compiled from: SnmpAgent.java */
    class a extends BroadcastReceiver {
        a() {
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            String strD = k.a.d();
            e.c.b.b.b.a("SnmpAgent", "getIp:" + strD);
            if (b.this.e(strD)) {
                b.this.f(strD);
            } else {
                b.this.c();
            }
        }
    }

    public b(Context context) {
        a aVar = new a();
        this.f272c = aVar;
        this.a = context;
        context.registerReceiver(aVar, new IntentFilter("android.net.conn.CONNECTIVITY_CHANGE"));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void c() {
        try {
            if (this.b != null) {
                this.b.close();
                this.b = null;
            }
        } catch (IOException e2) {
            e.c.b.b.b.d("SnmpAgent", e2);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public boolean e(String str) {
        return (TextUtils.isEmpty(str) || "0.0.0.0".equals(str)) ? false : true;
    }

    public void d() {
        try {
            if (this.b != null) {
                this.b.close();
                this.b = null;
            }
        } catch (IOException e2) {
            e.c.b.b.b.d("SnmpAgent", e2);
        }
        this.a.unregisterReceiver(this.f272c);
    }

    public void f(String str) {
        if (!e(str)) {
            Log.d("SnmpAgent", "ip is empty");
            return;
        }
        c();
        MultiThreadedMessageDispatcher multiThreadedMessageDispatcher = new MultiThreadedMessageDispatcher(ThreadPool.create("seewo_thread_pool", 3), new MessageDispatcherImpl());
        DefaultUdpTransportMapping defaultUdpTransportMapping = null;
        try {
            defaultUdpTransportMapping = new DefaultUdpTransportMapping(new UdpAddress(str + "/" + this.a.getResources().getInteger(R.integer.snmp_port)));
        } catch (IOException e2) {
            e.c.b.b.b.d("SnmpAgent", e2);
        }
        com.seewo.remote.f.a aVar = new com.seewo.remote.f.a(this.a);
        Snmp snmp = new Snmp(multiThreadedMessageDispatcher, defaultUdpTransportMapping);
        this.b = snmp;
        snmp.getMessageDispatcher().addMessageProcessingModel(new MPv2c());
        this.b.getMessageDispatcher().addMessageProcessingModel(new MPv1());
        this.b.addCommandResponder(aVar);
        if (defaultUdpTransportMapping != null) {
            try {
                defaultUdpTransportMapping.listen();
            } catch (IOException e3) {
                e.c.b.b.b.d("SnmpAgent", e3);
            }
        }
    }
}