| | |
| | | File []byte |
| | | Id string |
| | | Result []*protomsg.ResultFaceDetect |
| | | DeadTime time.Duration |
| | | } |
| | | |
| | | const ( |
| | |
| | | Url_Service_PULL = Ipc_Url_Pre + Virtual_FaceSdkId + Ipc_Pull_Ext |
| | | ) |
| | | |
| | | func GetFaceFeaFromSdk(fileBytes []byte) ([]*protomsg.ResultFaceDetect,error,*protomsg.Image){ |
| | | s := NewFaceSdkService(fileBytes) |
| | | func GetFaceFeaFromSdk(fileBytes []byte,deadTime time.Duration) ([]*protomsg.ResultFaceDetect,error,*protomsg.Image){ |
| | | s := NewFaceSdkService(fileBytes, deadTime) |
| | | i, err := s.ReadFromUploadImg() |
| | | if err !=nil{ |
| | | logger.Debug("readFromUploadImg err:",err) |
| | |
| | | } |
| | | } |
| | | |
| | | func NewFaceSdkService(fileBytes []byte) FaceSdkService{ |
| | | func NewFaceSdkService(fileBytes []byte, deadTime time.Duration) FaceSdkService{ |
| | | return FaceSdkService{ |
| | | File:fileBytes, |
| | | Id:uuid.NewV4().String(), |
| | | DeadTime:deadTime, |
| | | } |
| | | } |
| | | |
| | |
| | | func (s *FaceSdkService) GetFaceFea(){ |
| | | var wg sync.WaitGroup |
| | | wg.Add(1) |
| | | ticker := time.NewTicker(time.Second * 3) |
| | | ticker := time.NewTicker(s.DeadTime) |
| | | go func(ticker *time.Ticker, s *FaceSdkService) { |
| | | defer ticker.Stop() |
| | | defer wg.Done() |