(mainServerConn *MainServerConn)
| 199 | } |
| 200 | |
| 201 | func (jm *JobManager) disconnectFromStreamHelper(mainServerConn *MainServerConn) { |
| 202 | jm.lock.Lock() |
| 203 | defer jm.lock.Unlock() |
| 204 | if jm.connectedStreamClient == nil || jm.connectedStreamClient != mainServerConn { |
| 205 | return |
| 206 | } |
| 207 | jm.StreamManager.ClientDisconnected() |
| 208 | jm.connectedStreamClient = nil |
| 209 | } |
| 210 | |
| 211 | func (jm *JobManager) SetAttachedClient(msc *MainServerConn) { |
| 212 | jm.lock.Lock() |
no test coverage detected