vss: Reduce indentation level in vss_send().

If the current chunk is not due yet, we return from the function.
Reversing the logic of the test allows to reduce indentation by
one level. No semantic change.

diff --git a/vss.c b/vss.c
index 6aac9d59b5107e1a1c4118a961d54f4d500686e7..f1bb57983609ad60c20cb03ba73b3a1e518e9cd3 100644 (file)
--- a/vss.c
+++ b/vss.c
@@ -1034,6 +1034,8 @@ static void vss_send(struct vss_task *vsst)
        bool fec_active = false;
        struct timeval due;
        struct fec_client *fc, *tmp_fc;
        bool fec_active = false;
        struct timeval due;
        struct fec_client *fc, *tmp_fc;

+       char *buf;
+       size_t len;

 
        if (!vsst->map || !vss_playing())
                return;
 
        if (!vsst->map || !vss_playing())
                return;


@@ -1064,35 +1066,31 @@ static void vss_send(struct vss_task *vsst)
        }
        compute_chunk_time(mmd->chunks_sent, &mmd->afd.afhi.chunk_tv,
                &mmd->stream_start, &due);
        }
        compute_chunk_time(mmd->chunks_sent, &mmd->afd.afhi.chunk_tv,
                &mmd->stream_start, &due);

-       if (tv_diff(&due, now, NULL) <= 0) {
-               char *buf;
-               size_t len;
-
-               if (!mmd->chunks_sent) {
-                       mmd->stream_start = *now;
-                       mmd->events++;
-                       set_mmd_offset();
-               }
-               ret = vss_get_chunk(mmd->current_chunk, vsst, &buf, &len);
-               if (ret < 0) {
-                       PARA_ERROR_LOG("could not get chunk %lu: %s\n",
-                               mmd->current_chunk, para_strerror(-ret));
-               } else {
-                       /*
-                        * We call ->send() even if len is zero because senders
-                        * might have data queued which can be sent now.
-                        */
-                       for (i = 0; senders[i].name; i++) {
-                               if (!senders[i].send)
-                                       continue;
-                               senders[i].send(mmd->current_chunk,
-                                       mmd->chunks_sent, buf, len,
-                                       vsst->header_buf, vsst->header_len);
-                       }
+       if (tv_diff(&due, now, NULL) > 0)
+               return;
+       if (!mmd->chunks_sent) {
+               mmd->stream_start = *now;
+               mmd->events++;
+               set_mmd_offset();
+       }
+       ret = vss_get_chunk(mmd->current_chunk, vsst, &buf, &len);
+       if (ret < 0) {
+               PARA_ERROR_LOG("could not get chunk %lu: %s\n",
+                       mmd->current_chunk, para_strerror(-ret));
+       } else {
+               /*
+                * We call ->send() even if len is zero because senders might
+                * have data queued which can be sent now.
+                */
+               for (i = 0; senders[i].name; i++) {
+                       if (!senders[i].send)
+                               continue;
+                       senders[i].send(mmd->current_chunk, mmd->chunks_sent,
+                               buf, len, vsst->header_buf, vsst->header_len);

                }
                }

-               mmd->chunks_sent++;
-               mmd->current_chunk++;

        }
        }

+       mmd->chunks_sent++;
+       mmd->current_chunk++;

 }
 
 static int vss_post_select(struct sched *s, void *context)
 }
 
 static int vss_post_select(struct sched *s, void *context)