| | |
|---|
| | | |
|---|
| | | const ( |
|---|
| | | // 共享内存发送/接收失败shmMaxTryCount次重新创建通道尝试 |
|---|
| | | shmMaxTryCount = 7 |
|---|
| | | ShmMaxTryCount = 7 |
|---|
| | | // 不论共享内存/mangos发送/接收失败最大次数,认为当前通道不再使用, 关闭 |
|---|
| | | // 有问题,摄像机长时间断网后重连,但是通道关闭 |
|---|
| | | tooLongFailed = 300 |
|---|
| | | |
|---|
| | | File_Img_Id_Pre = "img_" |
|---|
| | | File_Img_Id_Pre = "img_" |
|---|
| | | File_Video_Id_Pre = "video_" |
|---|
| | | File_Audio_Id_Pre = "audio_" |
|---|
| | | ) |
|---|
| | |
|---|
| | | |
|---|
| | | // create server |
|---|
| | | func NewSocketListen(mode int, url string, shm bool) (socket SocketContext, err error) { |
|---|
| | | logger.Info("url is: ", url) |
|---|
| | | ctx, cancel := context.WithCancel(context.Background()) |
|---|
| | | |
|---|
| | | socket.Context = ctx |
|---|
| | |
|---|
| | | |
|---|
| | | 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) |
|---|
