From: Ramakrishnan Muthukrishnan <ram@rkrishnan.org>
Date: Sun, 22 Oct 2023 10:07:51 +0000 (+0530)
Subject: clang-format pulseaudio.c
X-Git-Url: https://git.rkrishnan.org/specifications/components//%22%3C?a=commitdiff_plain;h=6832acd1a833b5d449570ce036abd20362be7700;p=pihpsdr.git

clang-format pulseaudio.c
---

diff --git a/pulseaudio.c b/pulseaudio.c
index 7bd4f1b..18f2d25 100644
--- a/pulseaudio.c
+++ b/pulseaudio.c
@@ -1,15 +1,15 @@
 #include <gtk/gtk.h>
-#include <pulse/pulseaudio.h>
 #include <pulse/glib-mainloop.h>
+#include <pulse/pulseaudio.h>
 #include <pulse/simple.h>
 
-#include "radio.h"
-#include "receiver.h"
-#include "transmitter.h"
 #include "audio.h"
 #include "mode.h"
 #include "new_protocol.h"
 #include "old_protocol.h"
+#include "radio.h"
+#include "receiver.h"
+#include "transmitter.h"
 
 int n_input_devices;
 AUDIO_DEVICE input_devices[MAX_AUDIO_DEVICES];
@@ -22,289 +22,301 @@ AUDIO_DEVICE output_devices[MAX_AUDIO_DEVICES];
 //       samples in large chunks if fed from digimode programs.
 //
 #define MICRINGLEN 6000
-static float  *mic_ring_buffer=NULL;
-static int     mic_ring_read_pt=0;
-static int     mic_ring_write_pt=0;
+static float *mic_ring_buffer = NULL;
+static int mic_ring_read_pt = 0;
+static int mic_ring_write_pt = 0;
 
 static pa_glib_mainloop *main_loop;
 static pa_mainloop_api *main_loop_api;
 static pa_operation *op;
 static pa_context *pa_ctx;
-static pa_simple* microphone_stream;
+static pa_simple *microphone_stream;
 static gint local_microphone_buffer_offset;
 static float *local_microphone_buffer;
 static GThread *mic_read_thread_id;
 static gboolean running;
 
-gint local_microphone_buffer_size=720;
+gint local_microphone_buffer_size = 720;
 GMutex audio_mutex;
 
-static void source_list_cb(pa_context *context,const pa_source_info *s,int eol,void *data) {
-  int i;
-  if(eol>0) {
-    for(i=0;i<n_input_devices;i++) {
-      g_print("Input: %d: %s (%s)\n",input_devices[i].index,input_devices[i].name,input_devices[i].description);
+static void source_list_cb(pa_context *context, const pa_source_info *s,
+                           int eol, void *data) {
+    int i;
+    if (eol > 0) {
+        for (i = 0; i < n_input_devices; i++) {
+            g_print("Input: %d: %s (%s)\n", input_devices[i].index,
+                    input_devices[i].name, input_devices[i].description);
+        }
+        g_mutex_unlock(&audio_mutex);
+    } else if (n_input_devices < MAX_AUDIO_DEVICES) {
+        input_devices[n_input_devices].name = g_new0(char, strlen(s->name) + 1);
+        strncpy(input_devices[n_input_devices].name, s->name, strlen(s->name));
+        input_devices[n_input_devices].description =
+            g_new0(char, strlen(s->description) + 1);
+        strncpy(input_devices[n_input_devices].description, s->description,
+                strlen(s->description));
+        input_devices[n_input_devices].index = s->index;
+        n_input_devices++;
     }
-    g_mutex_unlock(&audio_mutex);
-  } else if(n_input_devices<MAX_AUDIO_DEVICES) {
-    input_devices[n_input_devices].name=g_new0(char,strlen(s->name)+1);
-    strncpy(input_devices[n_input_devices].name,s->name,strlen(s->name));
-    input_devices[n_input_devices].description=g_new0(char,strlen(s->description)+1);
-    strncpy(input_devices[n_input_devices].description,s->description,strlen(s->description));
-    input_devices[n_input_devices].index=s->index;
-    n_input_devices++;
-  }
 }
 
-static void sink_list_cb(pa_context *context,const pa_sink_info *s,int eol,void *data) {
-  int i;
-  if(eol>0) {
-    for(i=0;i<n_output_devices;i++) {
-      g_print("Output: %d: %s (%s)\n",output_devices[i].index,output_devices[i].name,output_devices[i].description);
+static void sink_list_cb(pa_context *context, const pa_sink_info *s, int eol,
+                         void *data) {
+    int i;
+    if (eol > 0) {
+        for (i = 0; i < n_output_devices; i++) {
+            g_print("Output: %d: %s (%s)\n", output_devices[i].index,
+                    output_devices[i].name, output_devices[i].description);
+        }
+        op = pa_context_get_source_info_list(pa_ctx, source_list_cb, NULL);
+    } else if (n_output_devices < MAX_AUDIO_DEVICES) {
+        output_devices[n_output_devices].name =
+            g_new0(char, strlen(s->name) + 1);
+        strncpy(output_devices[n_output_devices].name, s->name,
+                strlen(s->name));
+        output_devices[n_output_devices].description =
+            g_new0(char, strlen(s->description) + 1);
+        strncpy(output_devices[n_output_devices].description, s->description,
+                strlen(s->description));
+        output_devices[n_output_devices].index = s->index;
+        n_output_devices++;
     }
-    op=pa_context_get_source_info_list(pa_ctx,source_list_cb,NULL);
-  } else if(n_output_devices<MAX_AUDIO_DEVICES) {
-    output_devices[n_output_devices].name=g_new0(char,strlen(s->name)+1);
-    strncpy(output_devices[n_output_devices].name,s->name,strlen(s->name));
-    output_devices[n_output_devices].description=g_new0(char,strlen(s->description)+1);
-    strncpy(output_devices[n_output_devices].description,s->description,strlen(s->description));
-    output_devices[n_output_devices].index=s->index;
-    n_output_devices++;
-  }
 }
 
 static void state_cb(pa_context *c, void *userdata) {
-  pa_context_state_t state;
+    pa_context_state_t state;
 
-  state = pa_context_get_state(c);
+    state = pa_context_get_state(c);
 
-g_print("%s: %d\n",__FUNCTION__,state);
-  switch  (state) {
+    g_print("%s: %d\n", __FUNCTION__, state);
+    switch (state) {
     // There are just here for reference
     case PA_CONTEXT_UNCONNECTED:
-g_print("audio: state_cb: PA_CONTEXT_UNCONNECTED\n");
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_UNCONNECTED\n");
+        break;
     case PA_CONTEXT_CONNECTING:
-g_print("audio: state_cb: PA_CONTEXT_CONNECTING\n");
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_CONNECTING\n");
+        break;
     case PA_CONTEXT_AUTHORIZING:
-g_print("audio: state_cb: PA_CONTEXT_AUTHORIZING\n");
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_AUTHORIZING\n");
+        break;
     case PA_CONTEXT_SETTING_NAME:
-g_print("audio: state_cb: PA_CONTEXT_SETTING_NAME\n");
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_SETTING_NAME\n");
+        break;
     case PA_CONTEXT_FAILED:
-g_print("audio: state_cb: PA_CONTEXT_FAILED\n");
-      g_mutex_unlock(&audio_mutex);
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_FAILED\n");
+        g_mutex_unlock(&audio_mutex);
+        break;
     case PA_CONTEXT_TERMINATED:
-g_print("audio: state_cb: PA_CONTEXT_TERMINATED\n");
-      g_mutex_unlock(&audio_mutex);
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_TERMINATED\n");
+        g_mutex_unlock(&audio_mutex);
+        break;
     case PA_CONTEXT_READY:
-g_print("audio: state_cb: PA_CONTEXT_READY\n");
-// get a list of the output devices
-      n_input_devices=0;
-      n_output_devices=0;
-      op = pa_context_get_sink_info_list(pa_ctx,sink_list_cb,NULL);
-      break;
+        g_print("audio: state_cb: PA_CONTEXT_READY\n");
+        // get a list of the output devices
+        n_input_devices = 0;
+        n_output_devices = 0;
+        op = pa_context_get_sink_info_list(pa_ctx, sink_list_cb, NULL);
+        break;
     default:
-      g_print("audio: state_cb: unknown state %d\n",state);
-      break;
-  }
+        g_print("audio: state_cb: unknown state %d\n", state);
+        break;
+    }
 }
 
 void audio_get_cards() {
-  g_mutex_init(&audio_mutex);
-  g_mutex_lock(&audio_mutex);
-  main_loop=pa_glib_mainloop_new(NULL);
-  main_loop_api=pa_glib_mainloop_get_api(main_loop);
-  pa_ctx=pa_context_new(main_loop_api,"linhpsdr");
-  pa_context_connect(pa_ctx,NULL,0,NULL);
-  pa_context_set_state_callback(pa_ctx, state_cb, NULL);
+    g_mutex_init(&audio_mutex);
+    g_mutex_lock(&audio_mutex);
+    main_loop = pa_glib_mainloop_new(NULL);
+    main_loop_api = pa_glib_mainloop_get_api(main_loop);
+    pa_ctx = pa_context_new(main_loop_api, "linhpsdr");
+    pa_context_connect(pa_ctx, NULL, 0, NULL);
+    pa_context_set_state_callback(pa_ctx, state_cb, NULL);
 }
 
 int audio_open_output(RECEIVER *rx) {
-  int result=0;
-  pa_sample_spec sample_spec;
-  int err;
+    int result = 0;
+    pa_sample_spec sample_spec;
+    int err;
 
-  if(rx->audio_name==NULL) {
-    result=-1;
-  } else {
-    g_mutex_lock(&rx->local_audio_mutex);
-    sample_spec.rate=48000;
-    sample_spec.channels=2;
-    sample_spec.format=PA_SAMPLE_FLOAT32NE;
-   
-
-    char stream_id[16];
-    sprintf(stream_id,"RX-%d",rx->id);
-
-    rx->playstream=pa_simple_new(NULL,               // Use the default server.
-                    "piHPSDR",           // Our application's name.
-                    PA_STREAM_PLAYBACK,
-                    rx->audio_name,
-                    stream_id,            // Description of our stream.
-                    &sample_spec,                // Our sample format.
-                    NULL,               // Use default channel map
-                    NULL,               // Use default buffering attributes.
-                    &err               // error code if returns NULL
-                    );
-
-    if(rx->playstream!=NULL) {
-      rx->local_audio_buffer_offset=0;
-      rx->local_audio_buffer=g_new0(float,2*rx->local_audio_buffer_size);
-      g_print("%s: allocated local_audio_buffer %p size %ld bytes\n",__FUNCTION__,rx->local_audio_buffer,2*rx->local_audio_buffer_size*sizeof(float));
+    if (rx->audio_name == NULL) {
+        result = -1;
     } else {
-      result=-1;
-      g_print("%s: pa-simple_new failed: err=%d\n",__FUNCTION__,err);
+        g_mutex_lock(&rx->local_audio_mutex);
+        sample_spec.rate = 48000;
+        sample_spec.channels = 2;
+        sample_spec.format = PA_SAMPLE_FLOAT32NE;
+
+        char stream_id[16];
+        sprintf(stream_id, "RX-%d", rx->id);
+
+        rx->playstream =
+            pa_simple_new(NULL,      // Use the default server.
+                          "piHPSDR", // Our application's name.
+                          PA_STREAM_PLAYBACK, rx->audio_name,
+                          stream_id,    // Description of our stream.
+                          &sample_spec, // Our sample format.
+                          NULL,         // Use default channel map
+                          NULL,         // Use default buffering attributes.
+                          &err          // error code if returns NULL
+            );
+
+        if (rx->playstream != NULL) {
+            rx->local_audio_buffer_offset = 0;
+            rx->local_audio_buffer =
+                g_new0(float, 2 * rx->local_audio_buffer_size);
+            g_print("%s: allocated local_audio_buffer %p size %ld bytes\n",
+                    __FUNCTION__, rx->local_audio_buffer,
+                    2 * rx->local_audio_buffer_size * sizeof(float));
+        } else {
+            result = -1;
+            g_print("%s: pa-simple_new failed: err=%d\n", __FUNCTION__, err);
+        }
+        g_mutex_unlock(&rx->local_audio_mutex);
     }
-    g_mutex_unlock(&rx->local_audio_mutex);
-  }
 
-  return result;
+    return result;
 }
 
 static void *mic_read_thread(gpointer arg) {
-  int rc;
-  int err;
-
-  g_print("%s: running=%d\n",__FUNCTION__,running);
-  while(running) {
-    g_mutex_lock(&audio_mutex);
-    if(local_microphone_buffer==NULL) {
-      running=0;
-    } else {
-      rc=pa_simple_read(microphone_stream,
-            local_microphone_buffer,
-            local_microphone_buffer_size*sizeof(float),
-            &err);
-      if(rc<0) {
-        running=0;
-        g_print("%s: returned %d error=%d (%s)\n",__FUNCTION__,rc,err,pa_strerror(err));
-      } else {
-	gint newpt;
-	for(gint i=0;i<local_microphone_buffer_size;i++) {
-          gfloat sample=local_microphone_buffer[i];
-          switch(protocol) {
-            case ORIGINAL_PROTOCOL:
-            case NEW_PROTOCOL:
-              //
-              // put sample into ring buffer
-              //
-              if (mic_ring_buffer != NULL) {
-                // the "existence" of the ring buffer is now guaranteed for 1 msec,
-                // see audio_close_input().
-                newpt=mic_ring_write_pt +1;
-                if (newpt == MICRINGLEN) newpt=0;
-                if (newpt != mic_ring_read_pt) {
-                  // buffer space available, do the write
-                  mic_ring_buffer[mic_ring_write_pt]=sample;
-                  // atomic update of mic_ring_write_pt
-                  mic_ring_write_pt=newpt;
+    int rc;
+    int err;
+
+    g_print("%s: running=%d\n", __FUNCTION__, running);
+    while (running) {
+        g_mutex_lock(&audio_mutex);
+        if (local_microphone_buffer == NULL) {
+            running = 0;
+        } else {
+            rc = pa_simple_read(microphone_stream, local_microphone_buffer,
+                                local_microphone_buffer_size * sizeof(float),
+                                &err);
+            if (rc < 0) {
+                running = 0;
+                g_print("%s: returned %d error=%d (%s)\n", __FUNCTION__, rc,
+                        err, pa_strerror(err));
+            } else {
+                gint newpt;
+                for (gint i = 0; i < local_microphone_buffer_size; i++) {
+                    gfloat sample = local_microphone_buffer[i];
+                    switch (protocol) {
+                    case ORIGINAL_PROTOCOL:
+                    case NEW_PROTOCOL:
+                        //
+                        // put sample into ring buffer
+                        //
+                        if (mic_ring_buffer != NULL) {
+                            // the "existence" of the ring buffer is now
+                            // guaranteed for 1 msec, see audio_close_input().
+                            newpt = mic_ring_write_pt + 1;
+                            if (newpt == MICRINGLEN)
+                                newpt = 0;
+                            if (newpt != mic_ring_read_pt) {
+                                // buffer space available, do the write
+                                mic_ring_buffer[mic_ring_write_pt] = sample;
+                                // atomic update of mic_ring_write_pt
+                                mic_ring_write_pt = newpt;
+                            }
+                        }
+                        break;
+                    default:
+                        break;
+                    }
                 }
-              }
-              break;
-            default:
-              break;
-          }
+            }
         }
-      }
+        g_mutex_unlock(&audio_mutex);
     }
-    g_mutex_unlock(&audio_mutex);
-  }
-  g_print("%s: exit\n",__FUNCTION__);
-  return NULL;
+    g_print("%s: exit\n", __FUNCTION__);
+    return NULL;
 }
 
 int audio_open_input() {
-  pa_sample_spec sample_spec;
-  int result=0;
-
-  if(transmitter->microphone_name==NULL) {
-    return -1;
-  }
-
-  g_mutex_lock(&audio_mutex);
-
-
-  pa_buffer_attr attr;
-  attr.maxlength = (uint32_t) -1;
-  attr.tlength = (uint32_t) -1;
-  attr.prebuf = (uint32_t) -1;
-  attr.minreq = (uint32_t) -1;
-  attr.fragsize = 512;
-
-
-  sample_spec.rate=48000;
-  sample_spec.channels=1;
-  sample_spec.format=PA_SAMPLE_FLOAT32NE;
-
-  microphone_stream=pa_simple_new(NULL,               // Use the default server.
-                  "piHPSDR",           // Our application's name.
-                  PA_STREAM_RECORD,
-                  transmitter->microphone_name,
-                  "TX",            // Description of our stream.
-                  &sample_spec,                // Our sample format.
-                  NULL,               // Use default channel map
-                  //NULL,
-                  &attr,               // Use default buffering attributes.
-                  NULL               // Ignore error code.
-                  );
-
-  if(microphone_stream!=NULL) {
-    local_microphone_buffer_offset=0;
-    local_microphone_buffer=g_new0(float,local_microphone_buffer_size);
-
-    g_print("%s: allocating ring buffer\n",__FUNCTION__);
-    mic_ring_buffer=(float *) g_new(float,MICRINGLEN);
-    mic_ring_read_pt = mic_ring_write_pt=0;
-    if (mic_ring_buffer == NULL) {
-      audio_close_input();
-      return -1;
+    pa_sample_spec sample_spec;
+    int result = 0;
+
+    if (transmitter->microphone_name == NULL) {
+        return -1;
     }
 
-    running=TRUE;
-    g_print("%s: PULSEAUDIO mic_read_thread\n",__FUNCTION__);
-    mic_read_thread_id=g_thread_new("mic_thread",mic_read_thread,NULL);
-    if(!mic_read_thread_id ) {
-      g_print("%s: g_thread_new failed on mic_read_thread\n",__FUNCTION__);
-      g_free(local_microphone_buffer);
-      local_microphone_buffer=NULL;
-      running=FALSE;
-      result=-1;
+    g_mutex_lock(&audio_mutex);
+
+    pa_buffer_attr attr;
+    attr.maxlength = (uint32_t)-1;
+    attr.tlength = (uint32_t)-1;
+    attr.prebuf = (uint32_t)-1;
+    attr.minreq = (uint32_t)-1;
+    attr.fragsize = 512;
+
+    sample_spec.rate = 48000;
+    sample_spec.channels = 1;
+    sample_spec.format = PA_SAMPLE_FLOAT32NE;
+
+    microphone_stream =
+        pa_simple_new(NULL,      // Use the default server.
+                      "piHPSDR", // Our application's name.
+                      PA_STREAM_RECORD, transmitter->microphone_name,
+                      "TX",         // Description of our stream.
+                      &sample_spec, // Our sample format.
+                      NULL,         // Use default channel map
+                      // NULL,
+                      &attr, // Use default buffering attributes.
+                      NULL   // Ignore error code.
+        );
+
+    if (microphone_stream != NULL) {
+        local_microphone_buffer_offset = 0;
+        local_microphone_buffer = g_new0(float, local_microphone_buffer_size);
+
+        g_print("%s: allocating ring buffer\n", __FUNCTION__);
+        mic_ring_buffer = (float *)g_new(float, MICRINGLEN);
+        mic_ring_read_pt = mic_ring_write_pt = 0;
+        if (mic_ring_buffer == NULL) {
+            audio_close_input();
+            return -1;
+        }
+
+        running = TRUE;
+        g_print("%s: PULSEAUDIO mic_read_thread\n", __FUNCTION__);
+        mic_read_thread_id = g_thread_new("mic_thread", mic_read_thread, NULL);
+        if (!mic_read_thread_id) {
+            g_print("%s: g_thread_new failed on mic_read_thread\n",
+                    __FUNCTION__);
+            g_free(local_microphone_buffer);
+            local_microphone_buffer = NULL;
+            running = FALSE;
+            result = -1;
+        }
+    } else {
+        result = -1;
     }
-  } else {
-    result=-1;
-  }
-  g_mutex_unlock(&audio_mutex);
+    g_mutex_unlock(&audio_mutex);
 
-  return result;
+    return result;
 }
 
 void audio_close_output(RECEIVER *rx) {
-  g_mutex_lock(&rx->local_audio_mutex);
-  if(rx->playstream!=NULL) {
-    pa_simple_free(rx->playstream);
-    rx->playstream=NULL;
-  }
-  if(rx->local_audio_buffer!=NULL) {
-    g_free(rx->local_audio_buffer);
-    rx->local_audio_buffer=NULL;
-  }
-  g_mutex_unlock(&rx->local_audio_mutex);
+    g_mutex_lock(&rx->local_audio_mutex);
+    if (rx->playstream != NULL) {
+        pa_simple_free(rx->playstream);
+        rx->playstream = NULL;
+    }
+    if (rx->local_audio_buffer != NULL) {
+        g_free(rx->local_audio_buffer);
+        rx->local_audio_buffer = NULL;
+    }
+    g_mutex_unlock(&rx->local_audio_mutex);
 }
 
 void audio_close_input() {
-  g_mutex_lock(&audio_mutex);
-  if(microphone_stream!=NULL) {
-    pa_simple_free(microphone_stream);
-    microphone_stream=NULL;
-    g_free(local_microphone_buffer);
-    local_microphone_buffer=NULL;
-  }
-  g_mutex_unlock(&audio_mutex);
+    g_mutex_lock(&audio_mutex);
+    if (microphone_stream != NULL) {
+        pa_simple_free(microphone_stream);
+        microphone_stream = NULL;
+        g_free(local_microphone_buffer);
+        local_microphone_buffer = NULL;
+    }
+    g_mutex_unlock(&audio_mutex);
 }
 
 //
@@ -312,80 +324,79 @@ void audio_close_input() {
 // from ring buffer
 //
 float audio_get_next_mic_sample() {
-  int newpt;
-  float sample;
-
-  if ((mic_ring_buffer == NULL) || (mic_ring_read_pt == mic_ring_write_pt)) {
-    // no buffer, or nothing in buffer: insert silence
-    //g_print("%s: no samples\n",__FUNCTION__);
-    sample=0.0;
-  } else {
-    // the "existence" of the ring buffer is now guaranteed for 1 msec,
-    // see audio_close_input(),
-    newpt = mic_ring_read_pt+1;
-    if (newpt == MICRINGLEN) newpt=0;
-    sample=mic_ring_buffer[mic_ring_read_pt];
-    // atomic update of read pointer
-    mic_ring_read_pt=newpt;
-  }
-  return sample;
+    int newpt;
+    float sample;
+
+    if ((mic_ring_buffer == NULL) || (mic_ring_read_pt == mic_ring_write_pt)) {
+        // no buffer, or nothing in buffer: insert silence
+        // g_print("%s: no samples\n",__FUNCTION__);
+        sample = 0.0;
+    } else {
+        // the "existence" of the ring buffer is now guaranteed for 1 msec,
+        // see audio_close_input(),
+        newpt = mic_ring_read_pt + 1;
+        if (newpt == MICRINGLEN)
+            newpt = 0;
+        sample = mic_ring_buffer[mic_ring_read_pt];
+        // atomic update of read pointer
+        mic_ring_read_pt = newpt;
+    }
+    return sample;
 }
 
-int cw_audio_write(RECEIVER *rx,float sample) {
-  int result=0;
-  int rc;
-  int err;
-
-  g_mutex_lock(&rx->local_audio_mutex);
-  if(rx->local_audio_buffer==NULL) {
-    rx->local_audio_buffer_offset=0;
-    rx->local_audio_buffer=g_new0(float,2*rx->local_audio_buffer_size);
-  }
-
-  rx->local_audio_buffer[rx->local_audio_buffer_offset*2]=sample;
-  rx->local_audio_buffer[(rx->local_audio_buffer_offset*2)+1]=sample;
-  rx->local_audio_buffer_offset++;
-  if(rx->local_audio_buffer_offset>=rx->local_audio_buffer_size) {
-    rc=pa_simple_write(rx->playstream,
-                       rx->local_audio_buffer,
-                       rx->local_audio_buffer_size*sizeof(float)*2,
-                       &err);
-    if(rc!=0) {
-      fprintf(stderr,"audio_write failed err=%d\n",err);
+int cw_audio_write(RECEIVER *rx, float sample) {
+    int result = 0;
+    int rc;
+    int err;
+
+    g_mutex_lock(&rx->local_audio_mutex);
+    if (rx->local_audio_buffer == NULL) {
+        rx->local_audio_buffer_offset = 0;
+        rx->local_audio_buffer = g_new0(float, 2 * rx->local_audio_buffer_size);
+    }
+
+    rx->local_audio_buffer[rx->local_audio_buffer_offset * 2] = sample;
+    rx->local_audio_buffer[(rx->local_audio_buffer_offset * 2) + 1] = sample;
+    rx->local_audio_buffer_offset++;
+    if (rx->local_audio_buffer_offset >= rx->local_audio_buffer_size) {
+        rc = pa_simple_write(rx->playstream, rx->local_audio_buffer,
+                             rx->local_audio_buffer_size * sizeof(float) * 2,
+                             &err);
+        if (rc != 0) {
+            fprintf(stderr, "audio_write failed err=%d\n", err);
+        }
+        rx->local_audio_buffer_offset = 0;
     }
-    rx->local_audio_buffer_offset=0;
-  }
-  g_mutex_unlock(&rx->local_audio_mutex);
+    g_mutex_unlock(&rx->local_audio_mutex);
 
-  return result;
+    return result;
 }
 
-int audio_write(RECEIVER *rx,float left_sample,float right_sample) {
-  int result=0;
-  int rc;
-  int err;
-
-  g_mutex_lock(&rx->local_audio_mutex);
-  if(rx->local_audio_buffer==NULL) {
-    rx->local_audio_buffer_offset=0;
-    rx->local_audio_buffer=g_new0(float,2*rx->local_audio_buffer_size);
-  }
-
-  rx->local_audio_buffer[rx->local_audio_buffer_offset*2]=left_sample;
-  rx->local_audio_buffer[(rx->local_audio_buffer_offset*2)+1]=right_sample;
-  rx->local_audio_buffer_offset++;
-  if(rx->local_audio_buffer_offset>=rx->local_audio_buffer_size) {
-    rc=pa_simple_write(rx->playstream,
-                       rx->local_audio_buffer,
-                       rx->local_audio_buffer_size*sizeof(float)*2,
-                       &err);
-    if(rc!=0) {
-      fprintf(stderr,"audio_write failed err=%d\n",err);
+int audio_write(RECEIVER *rx, float left_sample, float right_sample) {
+    int result = 0;
+    int rc;
+    int err;
+
+    g_mutex_lock(&rx->local_audio_mutex);
+    if (rx->local_audio_buffer == NULL) {
+        rx->local_audio_buffer_offset = 0;
+        rx->local_audio_buffer = g_new0(float, 2 * rx->local_audio_buffer_size);
     }
-    rx->local_audio_buffer_offset=0;
-  }
-  g_mutex_unlock(&rx->local_audio_mutex);
 
-  return result;
-}
+    rx->local_audio_buffer[rx->local_audio_buffer_offset * 2] = left_sample;
+    rx->local_audio_buffer[(rx->local_audio_buffer_offset * 2) + 1] =
+        right_sample;
+    rx->local_audio_buffer_offset++;
+    if (rx->local_audio_buffer_offset >= rx->local_audio_buffer_size) {
+        rc = pa_simple_write(rx->playstream, rx->local_audio_buffer,
+                             rx->local_audio_buffer_size * sizeof(float) * 2,
+                             &err);
+        if (rc != 0) {
+            fprintf(stderr, "audio_write failed err=%d\n", err);
+        }
+        rx->local_audio_buffer_offset = 0;
+    }
+    g_mutex_unlock(&rx->local_audio_mutex);
 
+    return result;
+}