(frontendAddress string)
| 321 | } |
| 322 | |
| 323 | func (s *Scheduler) frontendDisconnected(frontendAddress string) { |
| 324 | s.connectedFrontendsMu.Lock() |
| 325 | defer s.connectedFrontendsMu.Unlock() |
| 326 | |
| 327 | cf := s.connectedFrontends[frontendAddress] |
| 328 | cf.connections-- |
| 329 | if cf.connections == 0 { |
| 330 | delete(s.connectedFrontends, frontendAddress) |
| 331 | cf.cancel() |
| 332 | } |
| 333 | } |
| 334 | |
| 335 | func updatePlanInHTTPRequest(fragment plan_fragments.Fragment) ([]byte, error) { |
| 336 | byteLP, err := logicalplan.Marshal(fragment.Node) |