| | |
|---|
| | | |
|---|
| | | ////////////////////////////////////////////////////////////////// |
|---|
| | | const ( |
|---|
| | | cacheFrameNum = 3 |
|---|
| | | trackChnTimeout = time.Duration(10) |
|---|
| | | ) |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | func (f *face) run(ctx context.Context, in <-chan []byte, out chan<- sdkstruct.MsgSDK) { |
|---|
| | | |
|---|
| | | chMsg := make(chan protomsg.SdkMessage) |
|---|
| | | chMsg := make(chan protomsg.SdkMessage, f.maxChannel) |
|---|
| | | go sdkhelper.UnserilizeProto(ctx, in, chMsg, f.fnLogger) |
|---|
| | | |
|---|
| | | for { |
|---|
| | |
|---|
| | | f.ftrackChans[rMsg.Cid] <- rMsg |
|---|
| | | } else { |
|---|
| | | |
|---|
| | | f.ftrackChans[rMsg.Cid] = make(chan protomsg.SdkMessage, cacheFrameNum) |
|---|
| | | f.ftrackChans[rMsg.Cid] = make(chan protomsg.SdkMessage, f.maxChannel) |
|---|
| | | chn := f.getAvailableChn() |
|---|
| | | if chn < 0 { |
|---|
| | | f.fnLogger("TOO MUCH CHANNEL") |
|---|
