迭代优化代码

air720u/air720u.go

@@ -54,7 +54,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 			air720U_Repower() // 重新上电
 			bExists = false   // 等待复位, 标记设备已不存在
 		case -99: // 模块型号不匹配, 不是合宙的 "Air720U"
-			air720U_ComExit()
 			return false
 		}
 	} else { // 设备不存在, 或调用该函数时明确要求强制重启/
@@ -64,7 +63,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 
 	for range 6 {
 		if baseapp.IsExit1() {
-			air720U_ComExit()
 			return false
 		}
 		if !bExists {
@@ -78,7 +76,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 	}
 
 	if err != nil {
-		air720U_ComExit()
 		baseapp.Logger.Errorf("[%s] 错误: %v!!", MODULE_NAME, err)
 		return false
 	}

ec200u/en200u.go

@@ -54,7 +54,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 			ec200U_Repower() // 重新上电
 			bExists = false  // 等待复位, 标记设备已不存在
 		case -99: // 模块型号不匹配, 不是移远的 "EC200U"
-			ec200U_ComExit()
 			return false
 		}
 	} else { ///// 设备不存在, 或调用该函数时明确要求强制重启 ////
@@ -64,7 +63,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 
 	for range 6 {
 		if baseapp.IsExit1() {
-			ec200U_ComExit()
 			return false
 		}
 		if !bExists {
@@ -78,7 +76,6 @@ func ModuleInit(bForceRepower bool /*是否强制重启*/) bool {
 	}
 
 	if err != nil {
-		ec200U_ComExit()
 		baseapp.Logger.Errorf("[%s] 错误: %v!!", MODULE_NAME, err)
 		return false
 	}

netmgrd/modem.go

@@ -34,15 +34,11 @@ func ModemInit() bool {
 	if modem1.ModuleInit(false) {
 		curModemType = Air720U
 		return true
-	} else {
-		modem1.ModuleExit()
 	}
 
 	if modem2.ModuleInit(false) {
 		curModemType = EC200U
 		return true
-	} else {
-		modem2.ModuleExit()
 	}
 
 	return false

swapi/subjects/serial/serial.c

@@ -174,7 +174,13 @@ char *serial_get_log_prefix(const void *hSerial)
 int serial_send_data(const void *hSerial, const unsigned char *data, int len)
 {
     struct serial_t *pSerial = (struct serial_t *)hSerial;
-    if(pSerial && pSerial->fd != -1) return write(pSerial->fd, data, len);
+    if(pSerial && pSerial->fd != -1)
+    {
+        int ret = write(pSerial->fd, data, len);
+        if(ret < 0) sw_log_error("write error(ret=%d, errno=%d, %s), \"%s\" serial port send failed!!", 
+                                 ret, errno, strerror(errno), pSerial->name);
+        return ret;
+    }
     else return -1;
 }
 
@@ -293,7 +299,7 @@ NoneP:
         else if(nRet == 0 && errno == ETIMEDOUT) goto NoneP; // 读数据超时
         else
         { // 读一个字节错误
-            sw_log_fatal("read one byte error(ret=%d, errno=%d), \"%s\" serial port receiving thread abort!!!",
+            sw_log_error("read one byte error(ret=%d, errno=%d), \"%s\" serial port receiving thread abort!!",
                          nRet, errno, pSerial->name);
             return -1;
         }
@@ -308,7 +314,7 @@ NoneP:
     }
     else if(nRet < 0 && errno != EINTR)
     { // 有错误发生
-        sw_log_fatal("select error(%s), \"%s\" serial port receiving thread abort!!!", strerror(errno), pSerial->name);
+        sw_log_error("select error(%s), \"%s\" serial port receiving thread abort!!", strerror(errno), pSerial->name);
         return -1;
     }
     else nInterval = 1; // 不满足上述组合判断条件时

swapi/swmem.c

@@ -269,7 +269,7 @@ void *sw_mem_alloc(void *hMem, int size, const char *filename, int line)
 			return ptr; // return a void pointer to the allocated space
 		}
 
-		sw_log_fatal("sorry, alloc memory fail, because %p memory container is full!!!", xm);
+		sw_log_error("sorry, alloc memory fail, because %p memory container is full!!", xm);
 		sw_mutex_unlock(xm->hMutex); // unlock
 		return NULL;
 	}

swapi/swthrdpool.c

@@ -151,7 +151,7 @@ void *sw_thrdpool_alloc(void *hPool, PThrdProc proc, unsigned long wParam, unsig
 	//4, 没有分配到
 	if(hThrd == NULL)
 	{
-		sw_log_fatal("sorry, alloc thread fail, because %p thread pool is full!!!", tp);
+		sw_log_error("sorry, alloc thread fail, because %p thread pool is full!!", tp);
 		sw_thrdpool_printf(tp);
 	}