kc3-lang/kc3/libkc3/facts_with_cursor.c

Tag - branch -callablemasterconfigurefnfractionsfractions-rebaselinuxratio-rebasev0.1- tag -v0.1.9v0.1.8v0.1.7v0.1.6v0.1.5v0.1.4v0.1.3v0.1.2v0.1.13v0.1.12v0.1.11v0.1.10v0.1.1v0.1.0v0HTTPd-v0.1.1HTTPd-v0.1.0

• Show log

  Commit

• Hash : 1ae6ad0e
  Author : Thomas de Grivel
  Date : 2024-07-15T19:59:52
  

  rename c3 to kc3, fix update_source, configure, build

Download

• libkc3/facts_with_cursor.c

• /* kc3
   * Copyright 2022,2023,2024 kmx.io <contact@kmx.io>
   *
   * Permission is hereby granted to use this software granted the above
   * copyright notice and this permission paragraph are included in all
   * copies and substantial portions of this software.
   *
   * THIS SOFTWARE IS PROVIDED "AS-IS" WITHOUT ANY GUARANTEE OF
   * PURPOSE AND PERFORMANCE. IN NO EVENT WHATSOEVER SHALL THE
   * AUTHOR BE CONSIDERED LIABLE FOR THE USE AND PERFORMANCE OF
   * THIS SOFTWARE.
   */
  #include "assert.h"
  #include "buf.h"
  #include "buf_inspect.h"
  #include "env.h"
  #include "facts_cursor.h"
  #include "facts_spec.h"
  #include "facts_with.h"
  #include "facts_with_cursor.h"
  
  void facts_with_cursor_clean (s_facts_with_cursor *cursor)
  {
    uw i = 0;
    assert(cursor);
    while (i < cursor->facts_count) {
      if (cursor->levels[i].spec) {
        free(cursor->levels[i].spec);
        facts_cursor_clean(&cursor->levels[i].cursor);
      }
      i++;
    }
    free(cursor->levels);
    free(cursor->spec);
    if (pthread_mutex_destroy(&cursor->mutex)) {
      err_puts("facts_with_cursor_clean: pthread_mutex_destroy");
      assert(! "facts_with_cursor_clean: pthread_mutex_destroy");
      exit(1);
    }
  }
  
  const s_fact ** facts_with_cursor_next (s_facts_with_cursor *cursor,
                                          const s_fact **dest)
  {
    const s_fact *fact = NULL;
    s_facts_with_cursor_level *level;
    p_facts_spec parent_spec;
    assert(cursor);
    if (pthread_mutex_lock(&cursor->mutex)) {
      err_puts("facts_with_cursor_next: pthread_mutex_lock");
      assert(! "facts_with_cursor_next: pthread_mutex_lock");
      exit(1);
      return NULL;
    }
    if (! cursor->facts_count)
      goto not_found;
    if (cursor->level == cursor->facts_count) {
      level = &cursor->levels[cursor->facts_count - 1];
  #ifdef DEBUG_FACTS
      err_write_1("[debug] cursor->level=");
      err_inspect_uw(&cursor->level);
      err_write_1(" level->spec=");
      err_inspect_facts_spec(level->spec);
      err_write_1(" ");
      err_inspect_fact(level->fact);
  #endif
      if (! facts_cursor_next(&level->cursor, &level->fact))
        goto ko;
  #ifdef DEBUG_FACTS
      err_write_1(" -> ");
      err_inspect_fact(level->fact);
      err_write_1("\n");
      err_flush(err);
  #endif
      if (level->fact) {
        if (pthread_mutex_unlock(&cursor->mutex)) {
          err_puts("facts_with_cursor_next: pthread_mutex_unlock");
          assert(! "facts_with_cursor_next: pthread_mutex_unlock");
          exit(1);
        }
        *dest = level->fact;
        return dest;
      }
      free(level->spec);
      level->spec = NULL;
      cursor->level--;
      if (! cursor->level) {
        cursor->facts_count = 0;
        goto not_found;
      }
      cursor->level--;
    }
    while (cursor->level < cursor->facts_count) {
      level = &cursor->levels[cursor->level];
      if (! level->spec) {
        if (cursor->level)
          parent_spec = cursor->levels[cursor->level - 1].spec + 4;
        else
          parent_spec = cursor->spec;
        level->spec = facts_spec_new_expand(parent_spec);
        if (! facts_with_tags(cursor->facts, &level->cursor,
                              level->spec[0], level->spec[1],
                              level->spec[2]))
          goto ko;
      }
  #ifdef DEBUG_FACTS
      buf_write_1(&g_c3_env.err, "[debug] cursor->level=");
      buf_inspect_uw(&g_c3_env.err, &cursor->level);
      buf_write_1(&g_c3_env.err, " level->spec=");
      buf_inspect_facts_spec(&g_c3_env.err, level->spec);
      buf_write_1(&g_c3_env.err, " ");
      buf_inspect_fact(&g_c3_env.err, level->fact);
  #endif
      if (! facts_cursor_next(&level->cursor, &fact))
        goto ko;
      level->fact = fact;
  #ifdef DEBUG_FACTS
      buf_write_1(&g_c3_env.err, " -> ");
      buf_inspect_fact(&g_c3_env.err, level->fact);
      buf_write_1(&g_c3_env.err, "\n");
      buf_flush(&g_c3_env.err);
  #endif    
      if (fact) {
        cursor->level++;
        continue;
      }
      free(level->spec);
      level->spec = NULL;
      if (! cursor->level) {
        cursor->facts_count = 0;
        goto not_found;
      }
      cursor->level--;
    }
    if (pthread_mutex_unlock(&cursor->mutex)) {
      err_puts("facts_with_cursor_next: pthread_mutex_unlock");
      assert(! "facts_with_cursor_next: pthread_mutex_unlock");
      exit(1);
    }
    *dest = fact;
    return dest;
   not_found:
    if (pthread_mutex_unlock(&cursor->mutex)) {
      err_puts("facts_with_cursor_next: pthread_mutex_unlock");
      assert(! "facts_with_cursor_next: pthread_mutex_unlock");
      exit(1);
    }
    *dest = NULL;
    return dest;
   ko:
    if (pthread_mutex_unlock(&cursor->mutex)) {
      err_puts("facts_with_cursor_next: pthread_mutex_unlock");
      assert(! "facts_with_cursor_next: pthread_mutex_unlock");
      exit(1);
    }
    return NULL;
  }
  

Download