| 226 | } |
| 227 | |
| 228 | void srt::CSndUList::update(const CUDT* u, EReschedule reschedule, sync::steady_clock::time_point ts) |
| 229 | { |
| 230 | ScopedLock listguard(m_ListLock); |
| 231 | |
| 232 | CSNode* n = u->m_pSNode; |
| 233 | |
| 234 | if (n->m_iHeapLoc >= 0) |
| 235 | { |
| 236 | if (reschedule == DONT_RESCHEDULE) |
| 237 | return; |
| 238 | |
| 239 | if (n->m_tsTimeStamp <= ts) |
| 240 | return; |
| 241 | |
| 242 | if (n->m_iHeapLoc == 0) |
| 243 | { |
| 244 | n->m_tsTimeStamp = ts; |
| 245 | m_pTimer->interrupt(); |
| 246 | return; |
| 247 | } |
| 248 | |
| 249 | remove_(u); |
| 250 | insert_norealloc_(ts, u); |
| 251 | return; |
| 252 | } |
| 253 | |
| 254 | insert_(ts, u); |
| 255 | } |
| 256 | |
| 257 | srt::CUDT* srt::CSndUList::pop() |
| 258 | { |