proxmox-mirrors/mirror_frr
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_frr synced 2025-08-07 11:25:41 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #15769 from raja-rajasekar/rajasekarr/backpressure_display_i_o_buf

Browse Source 
zebra: Actually display I/O buffer sizes (part-2)
This commit is contained in:
Mark Stapp 2024-04-23 13:01:35 -04:00 committed by GitHub
commit 1c49f93b5f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/stream.c
View File

@ -1241,9 +1241,7 @@ void stream_fifo_init(struct stream_fifo *fifo)
/* Add new stream to fifo. */ /* Add new stream to fifo. */
void stream_fifo_push(struct stream_fifo *fifo, struct stream *s) void stream_fifo_push(struct stream_fifo *fifo, struct stream *s)
{ {
#if defined DEV_BUILD
size_t max, curmax; size_t max, curmax;
#endif
if (fifo->tail) if (fifo->tail)
fifo->tail->next = s; fifo->tail->next = s;
@ -1252,15 +1250,11 @@ void stream_fifo_push(struct stream_fifo *fifo, struct stream *s)
fifo->tail = s; fifo->tail = s;
fifo->tail->next = NULL; fifo->tail->next = NULL;
#if !defined DEV_BUILD
atomic_fetch_add_explicit(&fifo->count, 1, memory_order_release);
#else
max = atomic_fetch_add_explicit(&fifo->count, 1, memory_order_release); max = atomic_fetch_add_explicit(&fifo->count, 1, memory_order_release);
curmax = atomic_load_explicit(&fifo->max_count, memory_order_relaxed); curmax = atomic_load_explicit(&fifo->max_count, memory_order_relaxed);
if (max > curmax) if (max > curmax)
atomic_store_explicit(&fifo->max_count, max, atomic_store_explicit(&fifo->max_count, max,
memory_order_relaxed); memory_order_relaxed);
#endif
} }
void stream_fifo_push_safe(struct stream_fifo *fifo, struct stream *s) void stream_fifo_push_safe(struct stream_fifo *fifo, struct stream *s)