| | |
|---|
| | | |
|---|
| | | const ( |
|---|
| | | // 共享内存发送/接收失败shmMaxTryCount次重新创建通道尝试 |
|---|
| | | shmMaxTryCount = 7 |
|---|
| | | ShmMaxTryCount = 7 |
|---|
| | | // 不论共享内存/mangos发送/接收失败最大次数,认为当前通道不再使用, 关闭 |
|---|
| | | // 有问题,摄像机长时间断网后重连,但是通道关闭 |
|---|
| | | tooLongFailed = 300 |
|---|
| | |
|---|
| | | |
|---|
| | | func MaybeRestartSocket(socket SocketContext, tryCnt *int) SocketContext { |
|---|
| | | if socket.UseSHM { |
|---|
| | | if *tryCnt > shmMaxTryCount { |
|---|
| | | logger.Info("SDK SEND SHM TRY :", shmMaxTryCount, " RESTART IT") |
|---|
| | | if *tryCnt > ShmMaxTryCount { |
|---|
| | | logger.Info("SDK SEND SHM TRY :", ShmMaxTryCount, " RESTART IT") |
|---|
| | | |
|---|
| | | socket.Sock.Close() |
|---|
| | | newSocket, err := NewSocketListen(socket.Mode, socket.URL, socket.UseSHM) |
|---|
