| | |
|---|
| | | assert("t_value.size()"); |
|---|
| | | } |
|---|
| | | appPref.setIntData("RpcFSPort", atoi(argv[1])); |
|---|
| | | appPref.setIntData("thread.max", atoi(argv[2]));//线程池大小 |
|---|
| | | appPref.setIntData("ErlNodePort", atoi(argv[2])); |
|---|
| | | appPref.setIntData("thread.max", atoi(argv[3]));//线程池大小 |
|---|
| | | |
|---|
| | | appPref.setStringData("ipAdd", appConfig.getStringProperty("ES_IP")); |
|---|
| | | appPref.setIntData("ipPort", appConfig.getIntProperty("ES_PORT")); |
|---|
| | |
|---|
| | | av_init_packet(&p_this->pkt); |
|---|
| | | |
|---|
| | | p_this->frame = av_frame_alloc(); |
|---|
| | | unsigned int usleepTime = (1000 / p_this->m_fps) - 12; |
|---|
| | | usleepTime *= 1000; |
|---|
| | | // unsigned int usleepTime = (1000 / p_this->m_fps) - 12; |
|---|
| | | // usleepTime *= 1000; |
|---|
| | | DBG("===open ok, camid: " << p_this->m_camIdx); |
|---|
| | | while (p_this->m_running) { |
|---|
| | | #ifdef TestCode |
|---|
