(runtimeID, requestID string, store LogStatStore)
| 237 | } |
| 238 | |
| 239 | func (s *DispatchServerV2) StartRecvLog(runtimeID, requestID string, store LogStatStore) { |
| 240 | st := s.statsMap.get(runtimeID) |
| 241 | if st != nil { |
| 242 | store.SetMemUsed(st.memused) |
| 243 | } |
| 244 | s.storeMap.set(runtimeID, requestID, store) |
| 245 | } |
| 246 | |
| 247 | func (s *DispatchServerV2) StopRecvLog(runtimeID, requestID string, store LogStatStore) { |
| 248 | s.storeMap.del(runtimeID, requestID, store) |