merkle_sync: ms_outq_drain_cb — сохранять e->len до etcp_send (UAF); документировать ownership etcp_send
This commit is contained in:
1 parent
1f8ccabdbf
commit
da329d0479
2 files changed
+7
-3
No files matched your search
@@ -316,10 +316,11 @@ static void ms_outq_drain_cb(struct ll_queue* q, void* arg) {
|
||||
if (e->dgram) u_free(e->dgram);
|
||||
queue_entry_free(e);
|
||||
} else {
|
||||
uint16_t len = e->len; /* etcp_send может синхронно освободить e (ownership переходит в очередь) */
|
||||
int r = etcp_send(conn, e);
|
||||
if (r != 0) { if (e->dgram) u_free(e->dgram); queue_entry_free(e); }
|
||||
DEBUG_DEBUG(DEBUG_CATEGORY_MEMBER_SYNC, "%s: outq drain peer=%016llx len=%u rc=%d left=%d",
|
||||
MS_ID, (unsigned long long)s->peer, e->len, r, queue_entry_count(s->out_q));
|
||||
MS_ID, (unsigned long long)s->peer, len, r, queue_entry_count(s->out_q));
|
||||
}
|
||||
if (queue_entry_count(s->out_q) > 0 && conn && conn->send_input_q)
|
||||
queue_waiter_wait(conn->send_input_q, &s->waiter, ms_outq_drain_cb, s);
|
||||
|
||||
@@ -162,8 +162,11 @@ struct ETCP_BINDINGS {
|
||||
* @param entry Элемент очереди с данными для отправки
|
||||
* @return 0 при успехе, -1 при ошибке
|
||||
*
|
||||
* @note Функция забирает ownership entry - вызывающий код не должен
|
||||
* освобождать entry после вызова
|
||||
* @note Функция забирает ownership entry — вызывающий код не должен
|
||||
* ни освобождать, ни читать entry после вызова: если очередь
|
||||
* normalizer'а пуста, entry освобождается СИНХРОННО внутри этого
|
||||
* вызова (queue_data_put → callback → queue_entry_free). Любые
|
||||
* нужные поля entry надо сохранять до etcp_send().
|
||||
*/
|
||||
int etcp_send(struct ETCP_CONN* conn, struct ll_entry* entry);
|
||||
|
||||
|
||||
Reference in new issue
Block a user