obj manager, id:3, get lowest slave failed !!!

[tp111222]

trafficstars

hi,@debugger999,When I test gat1400 protocol with postman,The following error occurred:

ERR : FILE -> work.cpp, LINE -> 216, mqOpen, mq open 172.17.0.2:5672 failed obj manager, id:3, get lowest slave failed

the postman info:

http://172.17.0.2:11706/system/init { "masterIp": "172.17.0.2", "msgOutParams": [ { "type": "mq", "host": "172.17.0.2", "port": 5672, "userName": "guest", "passWord": "guest", "exchange": "aiotc.exchange.message", "routingKey": "" } ],

"gat1400Params": {
    "localGatHostIp": "34010000002000000001",
    "localGatServerId": "32020200002000000002",
    "localGatPort": 7100,
    "platform": [
        {
            "id": "32020200002000000001",
            "ip": "172.17.0.2",
            "port": 7200,
            "username": "admin",
            "password": "admin",
            "extra": {
                "manufactor": "hik"
            }
        }
    ]
}

}

http://172.17.0.2:11706/obj/add/gat1400 { "name":"test", "type":"camera", "id":3, "data":{ "subType":"gat1400", "deviceId": "32020200002000000003", "mode": 0, "slaveIp": "172.17.2.0", "platformId": "32020200002000000001" } }

[tp111222]

http://172.17.0.2:11706/system/slave/add { "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764, "internetIp": "8.8.8.8" }

[debugger999]

关于“mq open 172.17.0.2:5672 failed”，应该是你没有初始化rabiitmq服务器导致，这个不影响测试，只是无法通过mq接收抓拍信息。 关于“get lowest slave failed”，我的理解，可能是没有严格按照"https://debugger999.github.io/2020/06/29/js-version/"中的步骤，漏了“添加slave”这一步。 仅作参考。

[tp111222]

我刚刚又做了测试的，还是报 “get lowest slave failed“错误,终端打印印象如下：

WARRING : FILE -> work.cpp, LINE -> 194, mqOpen, please system init first DEBUG : FILE -> rest.cpp, LINE -> 287, request_cb, pid:2118, /system/init:{ "masterIp": "172.17.0.2", "msgOutParams": [ { "type": "mq", "host": "172.17.0.2", "port": 5672, "userName": "guest", "passWord": "guest", "exchange": "aiotc.exchange.message", "routingKey": "" } ],

"gat1400Params": {
    "localGatHostIp": "34010000002000000001",
    "localGatServerId": "32020200002000000002",
    "localGatPort": 7100,
    "platform": [
        {
            "id": "32020200002000000001",
            "ip": "172.17.0.2",
            "port": 7200,
            "username": "admin",
            "password": "admin",
            "extra": {
                "manufactor": "hik"
            }
        }
    ]
}

}

delet failed, original.msgOutParams.type, No suitable servers found (serverSelectionTryOnce set): [connection refused calling ismaster on '192.168.0.99:27017'] ERR : FILE -> db.cpp, LINE -> 273, dbWrite, insert failed, {"original":{ "masterIp": "172.17.0.2", "msgOutParams": [ { "type": "mq", "host": "172.17.0.2", "port": 5672, "userName": "guest", "passWord": "guest", "exchange": "aiotc.exchange.message", "routingKey": "" } ],

"gat1400Params": {
    "localGatHostIp": "34010000002000000001",
    "localGatServerId": "32020200002000000002",
    "localGatPort": 7100,
    "platform": [
        {
            "id": "32020200002000000001",
            "ip": "172.17.0.2",
            "port": 7200,
            "username": "admin",
            "password": "admin",
            "extra": {
                "manufactor": "hik"
            }
        }
    ]
}

} }, No servers yet eligible for rescan

DEBUG : FILE -> rest.cpp, LINE -> 287, request_cb, pid:2118, /system/slave/add:{ "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764 delet failed, original.slaveIp, No suitable servers found (serverSelectionTryOnce set): [connection refused calling ismaster on '192.168.0.99:27017'] ERR : FILE -> db.cpp, LINE -> 273, dbWrite, insert failed, {"original":{ "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764

}}, No servers yet eligible for rescan

DEBUG : FILE -> rest.cpp, LINE -> 287, request_cb, pid:2118, /obj/add/gat1400:{ "name":"test", "type":"camera", "id":3, "data":{ "subType":"gat1400", "deviceId": "32020200002000000003", "mode": 0, "slaveIp": "172.17.0.2", "platformId": "32020200002000000001" } } obj manager, id:3, get lowest slave failed delet failed, original.id, No suitable servers found (serverSelectionTryOnce set): [connection refused calling ismaster on '192.168.0.99:27017'] ERR : FILE -> db.cpp, LINE -> 273, dbWrite, insert failed, {"original":{ "name":"test", "type":"camera", "id":3, "data":{ "subType":"gat1400", "deviceId": "32020200002000000003", "mode": 0, "slaveIp": "172.17.0.2", "platformId": "32020200002000000001" } }}, No servers yet eligible for rescan

obj manager, id:3, get lowest slave failed obj manager, id:3, get lowest slave failed obj manager, id:3, get lowest slave failed obj manager, id:3, get lowest slave failed obj manager, id:3, get lowest slave failed obj manager, id:3, get lowest slave failed

[debugger999]

从你的信息，没有看到“添加slave”命令

[tp111222]

DEBUG : FILE -> rest.cpp, LINE -> 287, request_cb, pid:2118, /system/slave/add:{ "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764 delet failed, original.slaveIp, No suitable servers found (serverSelectionTryOnce set): [connection refused calling ismaster on '192.168.0.99:27017'] ERR : FILE -> db.cpp, LINE -> 273, dbWrite, insert failed, {"original":{ "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764

}}, No servers yet eligible for rescan

这个就是的吧？

[tp111222]

http://172.17.0.2:11706/system/slave/add { "slaveIp":"172.17.0.2", "restPort":11762, "streamPort":11764

} 这个是我用postman 发的，初始化完了后，就发的增加slave设备这条命令

[debugger999]

我觉得，你需要在函数_getlowestLoadSlave里面加几条调试信息，看哪个条件导致的异常。参考如下： static int _getlowestLoadSlave(node_common *p, void *arg) { slaveParam **ppLowestSlave = (slaveParam **)arg; slaveParam *pSlaveParam = (slaveParam *)p->name;

printf("##test, %d, %d,%d,%d,%d\n", __LINE__,
        pSlaveParam->online, pSlaveParam->systemInit, pSlaveParam->load,
        pSlaveLast->load);
if(*ppLowestSlave == NULL) {
    printf("##test, %d\n", __LINE__);
    if(pSlaveParam->online && pSlaveParam->systemInit && pSlaveParam->load < SLAVE_LOAD_MAX) {
        printf("##test, %d\n", __LINE__);
        *ppLowestSlave = pSlaveParam;
    }
}
else {
    slaveParam *pSlaveLast = *ppLowestSlave;
    printf("##test, %d\n", __LINE__);
    if(pSlaveParam->load < pSlaveLast->load && pSlaveParam->online && pSlaveParam->systemInit) {
        printf("##test, %d\n", __LINE__);
        *ppLowestSlave = pSlaveParam;
    }
}
printf("##test, %d\n", __LINE__);

return 0;

}