summaryrefslogtreecommitdiffstats
path: root/zebra/zserv.c
diff options
context:
space:
mode:
Diffstat (limited to 'zebra/zserv.c')
-rw-r--r--zebra/zserv.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/zebra/zserv.c b/zebra/zserv.c
index 403f6c0d9..f76b29def 100644
--- a/zebra/zserv.c
+++ b/zebra/zserv.c
@@ -239,7 +239,7 @@ static void zserv_write(struct thread *thread)
cache = stream_fifo_new();
- frr_with_mutex(&client->obuf_mtx) {
+ frr_with_mutex (&client->obuf_mtx) {
while (stream_fifo_head(client->obuf_fifo))
stream_fifo_push(cache,
stream_fifo_pop(client->obuf_fifo));
@@ -432,7 +432,7 @@ static void zserv_read(struct thread *thread)
memory_order_relaxed);
/* publish read packets on client's input queue */
- frr_with_mutex(&client->ibuf_mtx) {
+ frr_with_mutex (&client->ibuf_mtx) {
while (cache->head)
stream_fifo_push(client->ibuf_fifo,
stream_fifo_pop(cache));
@@ -501,7 +501,7 @@ static void zserv_process_messages(struct thread *thread)
uint32_t p2p = zrouter.packets_to_process;
bool need_resched = false;
- frr_with_mutex(&client->ibuf_mtx) {
+ frr_with_mutex (&client->ibuf_mtx) {
uint32_t i;
for (i = 0; i < p2p && stream_fifo_head(client->ibuf_fifo);
++i) {
@@ -531,7 +531,7 @@ static void zserv_process_messages(struct thread *thread)
int zserv_send_message(struct zserv *client, struct stream *msg)
{
- frr_with_mutex(&client->obuf_mtx) {
+ frr_with_mutex (&client->obuf_mtx) {
stream_fifo_push(client->obuf_fifo, msg);
}
@@ -547,7 +547,7 @@ int zserv_send_batch(struct zserv *client, struct stream_fifo *fifo)
{
struct stream *msg;
- frr_with_mutex(&client->obuf_mtx) {
+ frr_with_mutex (&client->obuf_mtx) {
msg = stream_fifo_pop(fifo);
while (msg) {
stream_fifo_push(client->obuf_fifo, msg);
@@ -684,7 +684,7 @@ void zserv_close_client(struct zserv *client)
* Final check in case the client struct is in use in another
* pthread: if not in-use, continue and free the client
*/
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
if (client->busy_count <= 0) {
/* remove from client list */
listnode_delete(zrouter.client_list, client);
@@ -761,7 +761,7 @@ static struct zserv *zserv_client_create(int sock)
}
/* Add this client to linked list. */
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
listnode_add(zrouter.client_list, client);
}
@@ -797,7 +797,7 @@ struct zserv *zserv_acquire_client(uint8_t proto, unsigned short instance,
{
struct zserv *client = NULL;
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
client = find_client_internal(proto, instance, session_id);
if (client) {
/* Don't return a dead/closed client object */
@@ -823,7 +823,7 @@ void zserv_release_client(struct zserv *client)
* for it to be deleted as soon as we release the lock, so we won't
* touch the object again.
*/
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
client->busy_count--;
if (client->busy_count <= 0) {
@@ -1229,7 +1229,7 @@ struct zserv *zserv_find_client(uint8_t proto, unsigned short instance)
{
struct zserv *client;
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
client = find_client_internal(proto, instance, 0);
}
@@ -1244,7 +1244,7 @@ struct zserv *zserv_find_client_session(uint8_t proto, unsigned short instance,
{
struct zserv *client;
- frr_with_mutex(&client_mutex) {
+ frr_with_mutex (&client_mutex) {
client = find_client_internal(proto, instance, session_id);
}