index_db.c File Reference

#include "config.h"
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include "log.h"
#include "index_db.h"

Include dependency graph for index_db.c:

Go to the source code of this file.

Defines
#define	MAX_WAIT_DATABASE   (30)
Functions
int	db_open_global (db_state_t *db_state, const gchar *directory)
void	db_close (db_state_t *db_state)
int	db_start_transaction (db_state_t *db_state)
int	db_end_transaction (db_state_t *db_state)
void	db_update_entry (db_state_t *db_state, const db_entry_t *entry)
void	db_update_shortcut_entry (db_state_t *db_state, const db_entry_t *entry, const char *display_name, const char *author)
void	db_add_entry (db_state_t *db_state, const db_entry_t *entry, const char *tag, const char *display_name, const char *author)
int	db_delete_entry (db_state_t *db_state, const db_entry_t *entry)
static db_entry_t *	row2entry (const metadata_cell *row)
GSList *	db_get_model (const gchar *dir)

---

Define Documentation

#define MAX_WAIT_DATABASE   (30)

Copyright (C) 2009 iRex Technologies B.V. All rights reserved.

Definition at line 37 of file index_db.c.

Referenced by db_start_transaction().

---

Function Documentation

void db_add_entry	(	db_state_t *	db_state,
		const db_entry_t *	entry,
		const char *	tag,
		const char *	display_name,
		const char *	author
	)

Definition at line 133 of file index_db.c.

References ermetadb_global_add_file(), ermetadb_global_add_folder(), db_entry_t::filename, db_entry_t::filepath, db_entry_t::filesize, db_entry_t::is_dir, db_entry_t::last_modified, and db_state_t::mdb.

Referenced by handle_changes().

{
    if (entry->is_dir) {
        ermetadb_global_add_folder(db_state->mdb,
                                   entry->filepath,
                                   entry->filename,
                                   entry->last_modified);
    } else {
        if (display_name == NULL) display_name = entry->filename;
        ermetadb_global_add_file(db_state->mdb,
                                 entry->filepath,
                                 entry->filename,
                                 entry->filesize,
                                 entry->last_modified,
                                 display_name,
                                 author,
                                 tag);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void db_close

(

db_state_t *

db_state

)

Definition at line 63 of file index_db.c.

References ermetadb_close(), LOGPRINTF, and db_state_t::mdb.

Referenced by db_get_model(), handle_changes(), and index_full().

{
    LOGPRINTF("entry");

    if (db_state->mdb)
    {
        ermetadb_close(db_state->mdb);
        db_state->mdb = NULL;
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

int db_delete_entry	(	db_state_t *	db_state,
		const db_entry_t *	entry
	)

Definition at line 154 of file index_db.c.

References ermetadb_global_remove_entry(), db_entry_t::file_id, db_entry_t::filename, db_entry_t::filepath, db_entry_t::is_dir, and db_state_t::mdb.

Referenced by handle_changes().

{
    // NOTE: only need to delete entry itself, not subdirs/files
    return ermetadb_global_remove_entry(db_state->mdb,
                                        entry->file_id,
                                        entry->filepath,
                                        entry->filename,
                                        entry->is_dir);
}

Here is the call graph for this function:

Here is the caller graph for this function:

int db_end_transaction

(

db_state_t *

db_state

)

Definition at line 105 of file index_db.c.

References ER_OK, ermetadb_end_transaction(), LOGPRINTF, db_state_t::mdb, and db_state_t::transaction_started.

Referenced by handle_changes().

{
    int  ret = ER_OK;    // return code

    LOGPRINTF("entry");

    if (db_state->transaction_started && db_state->mdb)
    {
        ret = ermetadb_end_transaction(db_state->mdb);
        db_state->transaction_started = FALSE;
    }

    return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

GSList* db_get_model

(

const gchar *

dir

)

Definition at line 199 of file index_db.c.

References metadata_table::cell_data, db_close(), db_open_global(), ER_OK, ermetadb_global_select_all(), ERRORPRINTF, db_state_t::mdb, metadata_table_n_columns, metadata_table_n_rows, and row2entry().

Referenced by index_full().

{
    db_state_t db_state;
    GSList* model = 0;

    if (db_open_global(&db_state, dir) != ER_OK) {
        ERRORPRINTF("error opening db");
        return NULL;
    }

    metadata_table *values = NULL;

    int ret = ermetadb_global_select_all(db_state.mdb, &values);
    if (ret != ER_OK) {
        ERRORPRINTF("error [%d]", ret);
        goto out;
    }

    int n_rows = metadata_table_n_rows(values);
    int n_cols = metadata_table_n_columns(values);

    const metadata_cell *row = (const metadata_cell*) (values->cell_data->data);
    for (int i=0; i<n_rows; i++) {
        db_entry_t* entry = row2entry(row);
        model = g_slist_prepend(model, entry);
        row += n_cols; 
    }

    model = g_slist_reverse(model);
    
    // DONT FREE, strings are used
    //metadata_table_free(values);
out:
    db_close(&db_state);
    return model;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int db_open_global	(	db_state_t *	db_state,
		const gchar *	directory
	)

Definition at line 40 of file index_db.c.

References db_state_t::db, ER_FAIL, ER_OK, ermetadb_global_open(), ERRORPRINTF, LOGPRINTF, db_state_t::mdb, db_state_t::num_cols, db_state_t::num_rows, db_state_t::row, db_state_t::transaction_started, and db_state_t::values.

Referenced by db_get_model(), handle_changes(), and index_full().

{
    LOGPRINTF("entry: dir [%s]", directory);
    
    db_state->mdb = NULL;
    db_state->transaction_started = FALSE;
    db_state->values = NULL;
    db_state->db = NULL;
    db_state->num_rows = 0;
    db_state->num_cols = 0;
    db_state->row = 0;

    erMetadb db = ermetadb_global_open(directory, FALSE);
    if (db == NULL) {
        ERRORPRINTF("failed to open database in %s.", directory);
        return ER_FAIL;
    }
    
    db_state->mdb = db;
    return ER_OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int db_start_transaction

(

db_state_t *

db_state

)

Definition at line 75 of file index_db.c.

References ER_OK, ermetadb_begin_transaction(), ERMETADB_DATABASE_BUSY, LOGPRINTF, MAX_WAIT_DATABASE, db_state_t::mdb, db_state_t::transaction_started, and WARNPRINTF.

Referenced by handle_changes().

{
    int           ret = ER_OK;    // return code
    const time_t  start = time(NULL);

    LOGPRINTF("entry");

    if (db_state->mdb)
    {
        if (db_state->transaction_started)
            WARNPRINTF("transaction already started");
        ret = ermetadb_begin_transaction(db_state->mdb);
        if (ret == ERMETADB_DATABASE_BUSY)
        {
            // database locked, wait till database becomes available
            while ((ret == ERMETADB_DATABASE_BUSY) &&
                   (time(NULL) - start) <= MAX_WAIT_DATABASE )
            {
                WARNPRINTF("database locked");
                ret = ermetadb_begin_transaction(db_state->mdb);
            }
        }
    }

    db_state->transaction_started = TRUE;

    return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void db_update_entry	(	db_state_t *	db_state,
		const db_entry_t *	entry
	)

Definition at line 121 of file index_db.c.

References ermetadb_global_update_size(), db_entry_t::file_id, db_entry_t::filesize, db_entry_t::last_modified, and db_state_t::mdb.

Referenced by handle_changes().

{
    ermetadb_global_update_size(db_state->mdb, entry->file_id, entry->last_modified, entry->filesize);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void db_update_shortcut_entry	(	db_state_t *	db_state,
		const db_entry_t *	entry,
		const char *	display_name,
		const char *	author
	)

Definition at line 127 of file index_db.c.

References ermetadb_global_update_title(), db_entry_t::file_id, and db_state_t::mdb.

Referenced by handle_changes().

{
    ermetadb_global_update_title(db_state->mdb, entry->file_id, display_name, author);
}

Here is the call graph for this function:

Here is the caller graph for this function:

static db_entry_t* row2entry

(

const metadata_cell *

row

)

[static]

Definition at line 165 of file index_db.c.

References db_entry_t::file_id, db_entry_t::filename, filename, db_entry_t::filepath, db_entry_t::filesize, db_entry_t::is_dir, db_entry_t::last_modified, metadata_cell::v_int64, metadata_cell::v_text, and metadata_cell::value.

Referenced by db_get_model().

{
    // SQL result: file_id, filename, dirpath, isdir, size, date
    db_entry_t* entry = g_malloc(sizeof(db_entry_t));
    memset(entry, 0, sizeof(db_entry_t));

    const metadata_cell *cell = row;
    gint64 file_id = cell->value.v_int64;
    entry->file_id = file_id;

    cell++;
    char* filename = cell->value.v_text->str;
    entry->filename = filename;

    cell++;
    char* filepath = cell->value.v_text->str;
    entry->filepath = filepath;

    cell++;
    gboolean is_dir = cell->value.v_int64;
    entry->is_dir = is_dir;

    cell++;
    gint64 size = cell->value.v_int64;
    entry->filesize = size;

    cell++;
    gint64 filedate = cell->value.v_int64;
    entry->last_modified = filedate;

    return entry;
}

Here is the caller graph for this function: