| | |
|---|
| | | "time" |
|---|
| | | "unsafe" |
|---|
| | | |
|---|
| | | "basic.com/libgowrapper/sdkhelper.git" |
|---|
| | | "reid/common" |
|---|
| | | |
|---|
| | | "basic.com/valib/gogpu.git" |
|---|
| | | |
|---|
| | | "basic.com/pubsub/protomsg.git" |
|---|
| | |
|---|
| | | // Create Reid |
|---|
| | | func Create(config string, typ, id string, gpu int, shm bool, ipc2Rule string, ruleMaxSize int, fn func(...interface{}), reserved map[string]interface{}) interface{} { |
|---|
| | | |
|---|
| | | cfg, err := sdkhelper.ReadConfig(config) |
|---|
| | | cfg, err := common.ReadConfig(config) |
|---|
| | | if err != nil { |
|---|
| | | fn("Reid SDK Create Error When Read Config: ", err) |
|---|
| | | return nil |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | gpuM := sdkhelper.Atoi(cfg.Param[sGPU]) |
|---|
| | | gpuM := common.Atoi(cfg.Param[sGPU]) |
|---|
| | | |
|---|
| | | rGPU := gpu |
|---|
| | | |
|---|
| | |
|---|
| | | if p >= 0 { |
|---|
| | | file := s.ipc[p+len(string(suf)):] |
|---|
| | | os.Remove(file) |
|---|
| | | s.fnLogger("remove:", file) |
|---|
| | | s.fnLogger("remove:", file) |
|---|
| | | } |
|---|
| | | s.fnLogger("can't listen on rep socket: ", err) |
|---|
| | | time.Sleep(5 * time.Millisecond) |
|---|
