Optimisation, because tidx is a monotonic sequence.

Signed-off-by: lordnn <lordnn@yahoo.com>

Author: lordnn

src/oapv.c

@@ -931,12 +931,12 @@ static int enc_thread_tile(void *arg)
     oapve_core_t *core = (oapve_core_t *)arg;
     oapve_ctx_t  *ctx = core->ctx;
     oapve_tile_t *tile = ctx->tile;
-    int           ret = OAPV_OK, i;
+    int           ret = OAPV_OK, i = 0;
 
     while(1) {
         // find not encoded tile
         oapv_tpool_enter_cs(ctx->sync_obj);
-        for(i = 0; i < ctx->num_tiles; i++) {
+        for( ; i < ctx->num_tiles; ++i) {
             if(tile[i].stat == ENC_TILE_STAT_NOT_ENCODED) {
                 tile[i].stat = ENC_TILE_STAT_ON_ENCODING;
                 core->tile_idx = i;
@@ -953,6 +953,7 @@ static int enc_thread_tile(void *arg)
 
         oapv_tpool_enter_cs(ctx->sync_obj);
         tile[core->tile_idx].stat = ENC_TILE_STAT_ENCODED;
+        ++i;
         oapv_tpool_leave_cs(ctx->sync_obj);
     }
 ERR:
@@ -1718,7 +1719,7 @@ static int dec_tile(oapvd_core_t *core, oapvd_tile_t *tile)
 static int dec_thread_tile(void *arg)
 {
     oapv_bs_t     bs;
-    int           i, ret, run, tidx = 0, thread_ret = OAPV_OK;
+    int           i = 0, ret, run, tidx = 0, thread_ret = OAPV_OK;
 
     oapvd_core_t *core = (oapvd_core_t *)arg;
     oapvd_ctx_t  *ctx = core->ctx;
@@ -1727,7 +1728,7 @@ static int dec_thread_tile(void *arg)
     while(1) {
         // find not decoded tile
         oapv_tpool_enter_cs(ctx->sync_obj);
-        for(i = 0; i < ctx->num_tiles; i++) {
+        for( ; i < ctx->num_tiles; ++i) {
             if(tile[i].stat == DEC_TILE_STAT_NOT_DECODED) {
                 tile[i].stat = DEC_TILE_STAT_ON_DECODING;
                 tidx = i;
@@ -1775,7 +1776,7 @@ static int dec_thread_tile(void *arg)
             tile[tidx].stat = ret;
             thread_ret = ret;
         }
-        tile[tidx].stat = OAPV_SUCCEEDED(ret) ? DEC_TILE_STAT_DECODED : ret;
+        ++i;
         oapv_tpool_leave_cs(ctx->sync_obj);
     }
     return thread_ret;

src/oapv_rc.c

@@ -60,12 +60,12 @@ int get_tile_cost_thread(void* arg)
     oapve_core_t* core = (oapve_core_t*)arg;
     oapve_ctx_t* ctx = core->ctx;
     oapve_tile_t* tile = ctx->tile;
-    int tidx = 0, ret = OAPV_OK, i;
+    int tidx = 0, ret = OAPV_OK, i = 0;
 
     while (1) {
         // find not processed tile
         oapv_tpool_enter_cs(ctx->sync_obj);
-        for (i = 0; i < ctx->num_tiles; i++) {
+        for ( ; i < ctx->num_tiles; ++i) {
             if (tile[i].stat == ENC_TILE_STAT_NOT_ENCODED) {
                 tile[i].stat = ENC_TILE_STAT_ON_ENCODING;
                 tidx = i;
@@ -82,6 +82,7 @@ int get_tile_cost_thread(void* arg)
 
         oapv_tpool_enter_cs(ctx->sync_obj);
         tile[tidx].stat = ENC_TILE_STAT_ENCODED;
+        ++i;
         oapv_tpool_leave_cs(ctx->sync_obj);
     }
 ERR: