/* Chrysalide - Outil d'analyse de fichiers binaires
* collection.c - gestion d'éléments ajoutés par collection
*
* Copyright (C) 2014-2019 Cyrille Bagard
*
* This file is part of Chrysalide.
*
* Chrysalide is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* Chrysalide is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with Chrysalide. If not, see .
*/
#include "collection.h"
#include
#include
#include
#include
#include
#include "collection-int.h"
#include "misc/rlestr.h"
#include "../../common/extstr.h"
#include "../../common/sort.h"
#include "../../glibext/chrysamarshal.h"
/* Initialise la classe des collections génériques d'éléments. */
static void g_db_collection_class_init(GDbCollectionClass *);
/* Initialise une collection générique d'éléments. */
static void g_db_collection_init(GDbCollection *);
/* Supprime toutes les références externes. */
static void g_db_collection_dispose(GDbCollection *);
/* Procède à la libération totale de la mémoire. */
static void g_db_collection_finalize(GDbCollection *);
/* Ajoute un élément dans la liste des éléments actifs. */
static void g_db_collection_set_last_item(GDbCollection *, GDbItem *, bool);
/* Retrouve l'élément correspondant à un horodatage. */
static size_t g_db_collection_find_by_timestamped(GDbCollection *, const GDbItem *);
/* Retire un élément de la liste des éléments courants. */
static void g_db_collection_unset_last_item(GDbCollection *, GDbItem *, size_t);
/* Retrouve le premier élément correspondant à un horodatage. */
static size_t g_db_collection_find_by_timestamp(GDbCollection *, timestamp_t);
/* --------------------- MANIPULATIONS AVEC UNE BASE DE DONNEES --------------------- */
/* Charge et intère un élément dans une collection. */
static bool g_db_collection_load_new_item(const bound_value *, size_t, GDbCollection *);
/* Enregistre un élément de collection dans une base de données. */
static bool g_db_collection_store_item(const GDbCollection *, const GDbItem *, sqlite3 *);
/* Met à jour un élément de collection dans une base de données. */
static bool g_db_collection_store_updated_item(const GDbCollection *, const GDbItem *, sqlite3 *);
/* Indique le type défini pour une collection générique d'éléments. */
G_DEFINE_TYPE(GDbCollection, g_db_collection, G_TYPE_OBJECT);
/******************************************************************************
* *
* Paramètres : klass = classe à initialiser. *
* *
* Description : Initialise la classe des collections génériques d'éléments. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
static void g_db_collection_class_init(GDbCollectionClass *klass)
{
GObjectClass *object; /* Autre version de la classe */
object = G_OBJECT_CLASS(klass);
object->dispose = (GObjectFinalizeFunc/* ! */)g_db_collection_dispose;
object->finalize = (GObjectFinalizeFunc)g_db_collection_finalize;
g_signal_new("content-extended",
G_TYPE_DB_COLLECTION,
G_SIGNAL_RUN_LAST,
G_STRUCT_OFFSET(GDbCollectionClass, content_extended),
NULL, NULL,
g_cclosure_marshal_VOID__OBJECT,
G_TYPE_NONE, 1, G_TYPE_OBJECT);
g_signal_new("state-changed",
G_TYPE_DB_COLLECTION,
G_SIGNAL_RUN_LAST,
G_STRUCT_OFFSET(GDbCollectionClass, state_changed),
NULL, NULL,
g_cclosure_marshal_VOID__OBJECT,
G_TYPE_NONE, 1, G_TYPE_OBJECT);
g_signal_new("active-changed",
G_TYPE_DB_COLLECTION,
G_SIGNAL_RUN_LAST,
G_STRUCT_OFFSET(GDbCollectionClass, active_changed),
NULL, NULL,
g_cclosure_user_marshal_VOID__ENUM_OBJECT,
G_TYPE_NONE, 2, G_TYPE_UINT, G_TYPE_OBJECT);
}
/******************************************************************************
* *
* Paramètres : collec = instance à initialiser. *
* *
* Description : Initialise une collection générique d'éléments. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
static void g_db_collection_init(GDbCollection *collec)
{
collec->binary = NULL;
collec->items = NULL;
collec->count = 0;
collec->last_items = g_hash_table_new_full((GHashFunc)g_db_item_hash_key,
(GEqualFunc)g_db_item_cmp_key,
(GDestroyNotify)g_object_unref,
(GDestroyNotify)g_object_unref);
g_rw_lock_init(&collec->params_access);
}
/******************************************************************************
* *
* Paramètres : collec = instance d'objet GLib à traiter. *
* *
* Description : Supprime toutes les références externes. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
static void g_db_collection_dispose(GDbCollection *collec)
{
size_t i; /* Boucle de parcours */
for (i = 0; i < collec->count; i++)
g_clear_object(&collec->items[i]);
G_OBJECT_CLASS(g_db_collection_parent_class)->dispose(G_OBJECT(collec));
}
/******************************************************************************
* *
* Paramètres : collec = instance d'objet GLib à traiter. *
* *
* Description : Procède à la libération totale de la mémoire. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
static void g_db_collection_finalize(GDbCollection *collec)
{
if (collec->items != NULL)
free(collec->items);
g_rw_lock_clear(&collec->params_access);
G_OBJECT_CLASS(g_db_collection_parent_class)->finalize(G_OBJECT(collec));
}
/******************************************************************************
* *
* Paramètres : id = identifiant réseau des éléments à traiter. *
* type = type GLib des éléments à placer dans la collection. *
* name = indique le nom désignant la table associée. *
* *
* Description : Prépare la mise en place d'une nouvelle collection. *
* *
* Retour : Adresse de l'instance ou NULL en cas d'échec. *
* *
* Remarques : - *
* *
******************************************************************************/
GDbCollection *g_db_collection_new(uint32_t id, GType type, const char *name)
{
GDbCollection *result; /* Adresse à retourner */
result = g_object_new(G_TYPE_DB_COLLECTION, NULL);
result->featuring = id;
result->type = type;
result->name = name;
return result;
}
/******************************************************************************
* *
* Paramètres : collec = collection générique d'éléments à compléter. *
* binary = binaire sur lequel appliquer les éléments. *
* *
* Description : Attache à une collection un binaire pour les éléments listés.*
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
void g_db_collection_link_to_binary(GDbCollection *collec, GLoadedBinary *binary)
{
collec->binary = binary;
}
/******************************************************************************
* *
* Paramètres : collec = collection générique d'éléments à consulter. *
* *
* Description : Décrit le type des éléments rassemblées dans une collection. *
* *
* Retour : Identifiant interne des éléments collectionés. *
* *
* Remarques : - *
* *
******************************************************************************/
uint32_t g_db_collection_get_feature(const GDbCollection *collec)
{
return collec->featuring;
}
/******************************************************************************
* *
* Paramètres : collec = collection générique d'éléments à consulter. *
* *
* Description : Décrit le type de collection manipulée. *
* *
* Retour : Description humaine de la collection. *
* *
* Remarques : - *
* *
******************************************************************************/
const char *g_db_collection_get_name(const GDbCollection *collec)
{
return _(collec->name);
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* pbuf = paquet de données où venir puiser les infos. *
* action = commande de la requête. [OUT] *
* dest = élément de collection ou NULL pour un rejet. [OUT] *
* *
* Description : Réceptionne un élément depuis une requête réseau. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
bool _g_db_collection_unpack(GDbCollection *collec, packed_buffer_t *pbuf, DBAction *action, GDbItem **dest)
{
bool result; /* Bilan à faire remonter */
uint32_t tmp32; /* Valeur sur 32 bits */
GDbItem *item; /* Définition d'élément visé */
result = extract_packed_buffer(pbuf, &tmp32, sizeof(uint32_t), true);
if (!result) goto qck_exit;
*action = tmp32;
result = (*action >= 0 && *action < DBA_COUNT);
if (!result) goto qck_exit;
item = g_object_new(collec->type, NULL);
result = g_db_item_unpack(item, pbuf);
if (!result) goto exit;
if (dest != NULL)
{
g_object_ref(G_OBJECT(item));
*dest = item;
}
exit:
g_object_unref(G_OBJECT(item));
qck_exit:
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* pbuf = paquet de données où venir puiser les infos. *
* db = base de données à mettre à jour. *
* *
* Description : Réceptionne et traite une requête réseau pour collection. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : Cette fonction est uniquement destinée aux appels depuis *
* la fonction g_cdb_archive_process() ; une partie des *
* informations ont déjà été tirées des échanges protocolaires. *
* *
******************************************************************************/
bool g_db_collection_unpack(GDbCollection *collec, packed_buffer_t *pbuf, sqlite3 *db)
{
bool result; /* Bilan à faire remonter */
DBAction action; /* Commande de la requête */
GDbItem *item; /* Définition d'élément visé */
result = _g_db_collection_unpack(collec, pbuf, &action, &item);
if (!result) return false;
switch (action)
{
case DBA_ADD_ITEM:
/* Ecrasement des horodatages par les valeurs communes du serveur */
if (db != NULL)
g_db_item_set_server_side(item);
result = g_db_collection_add_item(collec, item);
if (result)
{
if (collec->binary != NULL && !g_db_item_has_flag(item, DIF_DISABLED))
g_db_item_apply(item, collec->binary);
if (db != NULL)
g_db_collection_store_item(collec, item, db);
}
break;
case DBA_CHANGE_STATE:
if (collec->binary != NULL)
{
result = g_db_collection_update_item_state(collec, item);
if (result)
{
if (g_db_item_has_flag(item, DIF_DISABLED))
g_db_item_cancel(item, collec->binary);
else
g_db_item_apply(item, collec->binary);
}
}
else
{
assert(db != NULL);
result = false;
}
g_object_unref(G_OBJECT(item));
break;
default:
g_object_unref(G_OBJECT(item));
result = false;
break;
}
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* pbuf = paquet de données où venir inscrire les infos. *
* action = avenir de l'élément fourni. *
* item = élément de collection à sérialiser. *
* *
* Description : Envoie pour traitement une requête réseau pour collection. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
bool g_db_collection_pack(GDbCollection *collec, packed_buffer_t *pbuf, DBAction action, const GDbItem *item)
{
bool result; /* Bilan à retourner */
result = extend_packed_buffer(pbuf, (uint32_t []) { DBC_COLLECTION }, sizeof(uint32_t), true);
if (result)
result = extend_packed_buffer(pbuf, (uint32_t []) { collec->featuring }, sizeof(uint32_t), true);
if (result)
result = extend_packed_buffer(pbuf, (uint32_t []) { action }, sizeof(uint32_t), true);
if (result)
result = g_db_item_pack(item, pbuf);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* pbuf = paquet de données où venir inscrire les infos. *
* *
* Description : Envoie pour mise à jour tous les éléments courants. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
bool g_db_collection_pack_all_updates(GDbCollection *collec, packed_buffer_t *pbuf)
{
bool result; /* Bilan à renvoyer */
size_t i; /* Boucle de parcours */
result = true;
/**
* La gestion des accès s'effectue depuis le seul appelant : la fonction
* g_cdb_archive_add_client().
*/
for (i = 0; i < collec->count && result; i++)
result = g_db_collection_pack(collec, pbuf, DBA_ADD_ITEM, G_DB_ITEM(collec->items[i]));
return result;
}
/******************************************************************************
* *
* Paramètres : collec = collection à mettre à jour. *
* write = précise le type d'accès prévu (lecture/écriture). *
* lock = indique le sens du verrouillage à mener. *
* *
* Description : Met à disposition un encadrement des accès aux éléments. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
void g_db_collection_lock_unlock(GDbCollection *collec, bool write, bool lock)
{
if (write)
{
if (lock) g_rw_lock_writer_lock(&collec->params_access);
else g_rw_lock_writer_unlock(&collec->params_access);
}
else
{
if (lock) g_rw_lock_reader_lock(&collec->params_access);
else g_rw_lock_reader_unlock(&collec->params_access);
}
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à consulter. *
* count = taille de la liste constituée. [OUT] *
* *
* Description : Renvoie la liste des éléments rassemblés. *
* *
* Retour : Liste d'éléments à parcourir. *
* *
* Remarques : - *
* *
******************************************************************************/
GDbItem **g_db_collection_get_items(const GDbCollection *collec, size_t *count)
{
GDbItem **result; /* Liste à retourner */
size_t i; /* Boucle de parcours */
/**
* Un verrou doit être posé !
* Il n'y a pas d'assert() possible pour le vérifier...
*/
*count = collec->count;
if (*count == 0)
result = NULL;
else
{
result = malloc(*count * sizeof(GDbItem *));
for (i = 0; i < *count; i++)
{
result[i] = collec->items[i];
g_object_ref(G_OBJECT(result[i]));
}
}
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à consulter. *
* count = taille de la liste constituée. [OUT] *
* *
* Description : Renvoie la liste des éléments actifs. *
* *
* Retour : Liste d'éléments à parcourir. *
* *
* Remarques : - *
* *
******************************************************************************/
GDbItem **g_db_collection_get_last_items(GDbCollection *collec, size_t *count)
{
GDbItem **result; /* Liste à retourner */
GList *list; /* Liste brute des éléments */
GList *iter; /* Boucle de parcours #0 */
size_t i; /* Boucle de parcours #1 */
assert(!g_rw_lock_writer_trylock(&collec->params_access));
list = g_hash_table_get_values(collec->last_items);
*count = g_list_length(list);
if (*count == 0)
result = NULL;
else
{
result = malloc(*count * sizeof(GDbItem *));
for (iter = g_list_first(list), i = 0; iter != NULL; iter = g_list_next(iter), i++)
{
result[i] = iter->data;
g_object_ref(G_OBJECT(result[i]));
}
}
g_list_free(list);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à manipuler. *
* new = précise la nature de l'élément à insérer. *
* *
* Description : Ajoute un élément dans la liste des éléments actifs. *
* *
* Retour : - *
* *
* Remarques : *
* *
******************************************************************************/
static void g_db_collection_set_last_item(GDbCollection *collec, GDbItem *item, bool new)
{
GDbItem *prev; /* Elément similaire précédent */
timestamp_t its; /* Horodatage #0 */
timestamp_t pts; /* Horodatage #1 */
assert(!g_db_item_has_flag(item, DIF_DISABLED));
prev = g_hash_table_lookup(collec->last_items, item);
if (prev != NULL)
{
/**
* Dans le cas où le changement intervient sans contexte particulier,
* on s'assure de le pas remplacer un élément plus récent déjà en place
* par un élément nouvellement actif mais dépassé.
*
* Le code de g_db_collection_disable_at(), aux conséquences portant
* dans le serveur et le client, procède de manière à éviter cette
* situation par un ordre de parcours choisi.
*
* On insère néanmoins une petite sécurité.
*/
its = g_db_item_get_timestamp(item);
pts = g_db_item_get_timestamp(prev);
if (timestamp_is_younger(its, pts))
goto already_up_to_date;
g_object_ref(G_OBJECT(prev));
if (g_db_item_get_flags(item) & DIF_ERASER)
{
g_signal_emit_by_name(collec, "active-changed", AIC_REMOVED, prev);
g_hash_table_remove(collec->last_items, prev);
}
else
{
if (!new)
g_db_item_add_flag(item, DIF_UPDATED);
g_object_ref(G_OBJECT(item));
g_object_ref(G_OBJECT(item));
g_signal_emit_by_name(collec, "active-changed", AIC_UPDATED, item);
g_hash_table_replace(collec->last_items, item, item);
}
g_object_unref(G_OBJECT(prev));
}
else
{
if ((g_db_item_get_flags(item) & DIF_ERASER) == 0)
{
g_object_ref(G_OBJECT(item));
g_object_ref(G_OBJECT(item));
g_signal_emit_by_name(collec, "active-changed", AIC_ADDED, item);
g_hash_table_add(collec->last_items, item);
}
}
already_up_to_date:
;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à manipuler. *
* *
* Description : Procède à l'ajout d'un nouvel élément dans la collection. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : L'appelant perd la propriété de l'object transféré. *
* *
******************************************************************************/
bool g_db_collection_add_item(GDbCollection *collec, GDbItem *item)
{
bool result; /* Bilan à faire remonter */
result = true;
g_db_collection_wlock(collec);
collec->items = realloc(collec->items, ++collec->count * sizeof(GDbItem *));
collec->items[collec->count - 1] = item;
g_db_collection_set_last_item(collec, item, true);
g_signal_emit_by_name(collec, "content-extended", item);
g_db_collection_wunlock(collec);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* pbuf = paquet de données où venir inscrire les infos. *
* *
* Description : Procède au retrait des éléments désactivés de la collection. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : *
* *
******************************************************************************/
bool g_db_collection_drop_disabled_items(GDbCollection *collec, packed_buffer_t *pbuf)
{
bool result; /* Bilan à retourner */
size_t i; /* Boucle de parcours */
GDbItem *item; /* Elément désactivé */
#ifndef NDEBUG
GDbItem *enabled; /* Eventuel similarité active */
#endif
/**
* Voie de suppression d'un élément côté serveur.
*/
result = true;
g_db_collection_wlock(collec);
for (i = collec->count; i > 0 && result; i--)
{
item = collec->items[i - 1];
if (!g_db_item_has_flag(item, DIF_DISABLED))
break;
#ifndef NDEBUG
enabled = g_hash_table_lookup(collec->last_items, item);
assert(enabled != item);
#endif
collec->items = realloc(collec->items, --collec->count * sizeof(GDbItem *));
result = g_db_collection_pack(collec, pbuf, DBA_REM_ITEM, item);
g_object_unref(G_OBJECT(item));
}
g_db_collection_wunlock(collec);
return result;
}
/******************************************************************************
* *
* Paramètres : binary = élément binaire à consulter. *
* item = définition de l'élément à retrouver. *
* *
* Description : Retrouve l'élément correspondant à un horodatage. *
* *
* Retour : Indice valide pour un élément retrouvé, invalide sinon. *
* *
* Remarques : - *
* *
******************************************************************************/
static size_t g_db_collection_find_by_timestamped(GDbCollection *collec, const GDbItem *item)
{
size_t result; /* Indice à retourner */
GDbItem **found; /* Emplacement de la trouvaille*/
found = bsearch(&item, collec->items, collec->count, sizeof(GDbItem *),
(__compar_fn_t)g_db_item_cmp_timestamp);
if (found == NULL)
result = collec->count;
else
result = found - collec->items;
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à manipuler. *
* *
* Description : Procède au retrait d'un élément dans la collection. *
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : L'appelant reste le propriétaire de l'object transféré. *
* *
******************************************************************************/
bool g_db_collection_remove_item(GDbCollection *collec, const GDbItem *item)
{
bool result; /* Bilan à faire remonter */
size_t found; /* Indice de l'élément concerné*/
GDbItem *disabled; /* Elément désactivé */
#ifndef NDEBUG
GDbItem *enabled; /* Eventuel similarité active */
#endif
/**
* Voie de suppression d'un élément côté serveur.
*/
g_db_collection_wlock(collec);
found = g_db_collection_find_by_timestamped(collec, item);
result = (found < collec->count);
assert(result);
if (result)
{
disabled = collec->items[found];
assert(g_db_item_has_flag(disabled, DIF_DISABLED));
#ifndef NDEBUG
enabled = g_hash_table_lookup(collec->last_items, disabled);
assert(enabled != disabled);
#endif
memmove(collec->items + found, collec->items + found + 1,
(collec->count - found - 1) * sizeof(GDbItem *));
collec->items = realloc(collec->items, --collec->count * sizeof(GDbItem *));
g_object_unref(G_OBJECT(disabled));
}
g_db_collection_wunlock(collec);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à manipuler. *
* count = décompte des éléments actifs. *
* *
* Description : Retire un élément de la liste des éléments courants. *
* *
* Retour : - *
* *
* Remarques : *
* *
******************************************************************************/
static void g_db_collection_unset_last_item(GDbCollection *collec, GDbItem *item, size_t count)
{
GDbItem *prev; /* Elément similaire précédent */
GDbItem *old; /* Ancien élément similaire */
size_t i; /* Boucle de parcours */
assert(g_db_item_has_flag(item, DIF_DISABLED));
prev = g_hash_table_lookup(collec->last_items, item);
if (prev == item)
{
old = NULL;
for (i = count; i > 0; i++)
if (g_db_item_cmp_key(collec->items[i - 1], item))
break;
else
old = collec->items[i - 1];
if (old == NULL || g_db_item_get_flags(old) & DIF_ERASER)
{
g_signal_emit_by_name(collec, "active-changed", AIC_REMOVED, item);
g_hash_table_remove(collec->last_items, item);
}
else
{
g_object_ref(G_OBJECT(old));
g_object_ref(G_OBJECT(old));
g_signal_emit_by_name(collec, "active-changed", AIC_UPDATED, old);
g_hash_table_replace(collec->last_items, old, old);
}
}
}
/******************************************************************************
* *
* Paramètres : binary = élément binaire à consulter. *
* timestamp = date du dernier élément à garder comme actif. *
* *
* Description : Retrouve le premier élément correspondant à un horodatage. *
* *
* Retour : Indice valide pour un élément retrouvé, invalide sinon. *
* *
* Remarques : - *
* *
******************************************************************************/
static size_t g_db_collection_find_by_timestamp(GDbCollection *collec, timestamp_t timestamp)
{
size_t result; /* Indice à retourner */
timestamp_t prev_ts; /* Horodatage précédent */
bsearch_index(×tamp, collec->items, collec->count, sizeof(GDbItem *),
(__compar_fn_t)g_db_item_cmp_with_timestamp, &result);
while (result > 0)
{
prev_ts = g_db_item_get_timestamp(collec->items[result - 1]);
if (cmp_timestamp(&prev_ts, ×tamp) != 0)
break;
result--;
}
return result;
}
/******************************************************************************
* *
* Paramètres : binary = élément binaire à consulter. *
* timestamp = date du dernier élément à garder comme actif. *
* db = base de données à mettre à jour. *
* pbuf = paquet de données où venir inscrire les infos. *
* *
* Description : Désactive les éléments en aval d'un horodatage donné. *
* *
* Retour : true si la commande a bien été envoyée, false sinon. *
* *
* Remarques : - *
* *
******************************************************************************/
bool g_db_collection_disable_at(GDbCollection *collec, timestamp_t timestamp, sqlite3 *db, packed_buffer_t *pbuf)
{
bool result; /* Bilan à retourner */
size_t start; /* Début de la zone à changer */
size_t back; /* Début de restauration */
size_t i; /* Boucle de parcours */
GDbItem *item; /* Elément à traiter */
result = true;
g_db_collection_wlock(collec);
start = g_db_collection_find_by_timestamp(collec, timestamp);
/* Réactivation d'éléments ? */
if (start > 0)
{
back = start;
for (i = start; i > 0; i--)
if (!g_db_item_has_flag(collec->items[i - 1], DIF_DISABLED))
break;
else
back--;
for (i = back; i < start && result; i++)
{
item = collec->items[i];
g_db_item_remove_flag(item, DIF_DISABLED);
g_db_collection_store_updated_item(collec, item, db);
g_db_collection_set_last_item(collec, item, false);
result = g_db_collection_pack(collec, pbuf, DBA_CHANGE_STATE, item);
}
}
/* Désactivation des éléments en queue */
for (i = start; i < collec->count && result; i++)
{
item = collec->items[i];
if (g_db_item_has_flag(item, DIF_DISABLED))
break;
g_db_item_add_flag(item, DIF_DISABLED);
g_db_collection_store_updated_item(collec, item, db);
g_db_collection_unset_last_item(collec, item, start);
result = g_db_collection_pack(collec, pbuf, DBA_CHANGE_STATE, item);
}
g_db_collection_wunlock(collec);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à manipuler. *
* *
* Description : Prend acte d'un changement d'état d'un élément de collection.*
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : L'appelant reste le propriétaire de l'object transféré. *
* *
******************************************************************************/
bool g_db_collection_update_item_state(GDbCollection *collec, const GDbItem *item)
{
bool result; /* Bilan à faire remonter */
size_t index; /* Indice de l'élément visé */
GDbItem *changed; /* Elément à basculer */
DbItemFlags new; /* Nouvelles propriétés */
result = false;
g_db_collection_wlock(collec);
index = g_db_collection_find_by_timestamped(collec, item);
result = (index < collec->count);
if (result)
{
changed = collec->items[index];
new = g_db_item_get_flags(item);
g_db_item_set_flags(changed, new);
if (new & DIF_DISABLED)
g_db_collection_unset_last_item(collec, changed, index);
else
g_db_collection_set_last_item(collec, changed, false);
g_signal_emit_by_name(collec, "state-changed", changed);
}
g_db_collection_wunlock(collec);
return result;
}
/* ---------------------------------------------------------------------------------- */
/* MANIPULATIONS AVEC UNE BASE DE DONNEES */
/* ---------------------------------------------------------------------------------- */
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments spectateur des opérations. *
* db = accès à la base de données. *
* *
* Description : Crée la table d'élément dans une base de données. *
* *
* Retour : Bilan de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
bool g_db_collection_create_db_table(const GDbCollection *collec, sqlite3 *db)
{
return G_DB_COLLECTION_GET_CLASS(collec)->create_table(collec, db);
}
/******************************************************************************
* *
* Paramètres : values = couples de champs et de valeurs à lier. *
* count = nombre de ces couples. *
* collec = collection à manipuler. *
* *
* Description : Charge et intère un élément dans une collection. *
* *
* Retour : Bilan de l'opération : succès ou non. *
* *
* Remarques : - *
* *
******************************************************************************/
static bool g_db_collection_load_new_item(const bound_value *values, size_t count, GDbCollection *collec)
{
bool result; /* Bilan à retourner */
GDbItem *new; /* Nouvel élément à insérer */
new = g_object_new(G_DB_COLLECTION(collec)->type, NULL);
result = g_db_item_load(new, values, count);
if (result)
result = g_db_collection_add_item(G_DB_COLLECTION(collec), new);
else
g_object_unref(G_OBJECT(new));
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à peupler. *
* db = base de données repondant aux requêtes. *
* *
* Description : Charge un ensemble d'éléments à partir d'une base de données.*
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
bool g_db_collection_load_all_items(GDbCollection *collec, sqlite3 *db)
{
bool result; /* Conclusion à faire remonter */
GDbItem *dummy; /* Interface vide */
bound_value *values; /* Champs de table à inclure */
size_t count; /* Nombre de ces champs */
dummy = g_object_new(collec->type, NULL);
result = g_db_item_setup_load(dummy, &values, &count);
g_object_unref(G_OBJECT(dummy));
if (result)
result = load_db_values(db, collec->name, values, count, (db_load_cb)g_db_collection_load_new_item, collec);
free_all_bound_values(values, count);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à enregistrer. *
* db = base de données à mettre à jour. *
* *
* Description : Enregistre un élément de collection dans une base de données.*
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
static bool g_db_collection_store_item(const GDbCollection *collec, const GDbItem *item, sqlite3 *db)
{
bool result; /* Conclusion à faire remonter */
bound_value *values; /* Champs de table à inclure */
size_t count; /* Nombre de ces champs */
result = g_db_item_store(item, &values, &count);
if (result)
result = store_db_values(db, collec->name, values, count);
free_all_bound_values(values, count);
return result;
}
/******************************************************************************
* *
* Paramètres : collec = ensemble d'éléments à considérer. *
* item = élément de collection à enregistrer. *
* db = base de données à mettre à jour. *
* *
* Description : Met à jour un élément de collection dans une base de données.*
* *
* Retour : Bilan de l'exécution de l'opération. *
* *
* Remarques : - *
* *
******************************************************************************/
static bool g_db_collection_store_updated_item(const GDbCollection *collec, const GDbItem *item, sqlite3 *db)
{
bool result; /* Conclusion à faire remonter */
bound_value *values; /* Champs de table à inclure */
size_t count; /* Nombre de ces champs */
bound_value *updates; /* Champs à mettre à jour */
size_t ucount; /* Nombre de ces champs */
bound_value *conds; /* Champs de condition */
size_t ccount; /* Nombre de ces champs */
const bound_value *flags_ptr; /* Emplacement des fanions */
size_t i; /* Boucle de parcours */
result = false;
if (!g_db_item_store(item, &values, &count))
goto building_values;
updates = malloc(1 * sizeof(bound_value));
ucount = 0;
conds = malloc((count - 1) * sizeof(bound_value));
ccount = 0;
flags_ptr = find_bound_value(values, count, "flags");
for (i = 0; i < count; i++)
{
if (&values[i] == flags_ptr)
{
assert(ucount < 1);
memcpy(&updates[ucount++], &values[i], sizeof(bound_value));
}
else
{
assert(ccount < (count - 1));
memcpy(&conds[ccount++], &values[i], sizeof(bound_value));
}
}
result = update_db_values(db, collec->name, updates, ucount, conds, ccount);
building_values:
free_all_bound_values(values, count);
return result;
}
/* ---------------------------------------------------------------------------------- */
/* CREATION DE L'ABSTRACTION POUR COLLECTIONS */
/* ---------------------------------------------------------------------------------- */
/******************************************************************************
* *
* Paramètres : list = ensemble de collectons à parcourir. *
* binary = binaire sur lequel appliquer les éléments. *
* *
* Description : Attache un binaire à une série de collections. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
void attach_binary_to_collections(GList *list, GLoadedBinary *binary)
{
GList *iter; /* Boucle de parcours */
GDbCollection *collec; /* Collection visée manipulée */
for (iter = g_list_first(list);
iter != NULL;
iter = g_list_next(iter))
{
collec = G_DB_COLLECTION(iter->data);
g_db_collection_link_to_binary(collec, binary);
}
}
/******************************************************************************
* *
* Paramètres : list = ensemble de collectons à parcourir. *
* id = identifiant interne du type d'éléments groupés. *
* *
* Description : Recherche une collection correspondant à un type donné. *
* *
* Retour : Collection trouvée ou NULL en cas d'échec. *
* *
* Remarques : - *
* *
******************************************************************************/
GDbCollection *find_collection_in_list(GList *list, uint32_t id)
{
GDbCollection *result; /* Collection trouvée renvoyée */
GList *iter; /* Boucle de parcours */
result = NULL;
for (iter = g_list_first(list);
iter != NULL;
iter = g_list_next(iter))
{
result = G_DB_COLLECTION(iter->data);
if (g_db_collection_get_feature(result) == id)
break;
}
return (iter != NULL ? result : NULL);
}
/******************************************************************************
* *
* Paramètres : list = ensemble de collectons à parcourir. *
* write = précise le type d'accès prévu (lecture/écriture). *
* lock = indique le sens du verrouillage à mener. *
* *
* Description : Met à disposition un encadrement des accès aux éléments. *
* *
* Retour : - *
* *
* Remarques : - *
* *
******************************************************************************/
void lock_unlock_collections(GList *list, bool write, bool lock)
{
GList *iter; /* Boucle de parcours */
GDbCollection *collec; /* Collection visée manipulée */
for (iter = g_list_first(list);
iter != NULL;
iter = g_list_next(iter))
{
collec = G_DB_COLLECTION(iter->data);
g_db_collection_lock_unlock(collec, write, lock);
}
}
/******************************************************************************
* *
* Paramètres : list = ensemble de collectons à traiter. *
* pbuf = paquet de données où venir inscrire des infos. *
* *
* Description : Collecte les informations utiles pour un nouvel arrivant. *
* *
* Retour : Bilan du déroulement des opérations. *
* *
* Remarques : - *
* *
******************************************************************************/
bool pack_all_collection_updates(GList *list, packed_buffer_t *pbuf)
{
bool result; /* Bilan à retourner */
GList *iter; /* Boucle de parcours */
GDbCollection *collec; /* Collection visée manipulée */
result = true;
/**
* Cette procédure n'est appelée que depuis g_cdb_archive_process(),
* qui bloque son exécution jusqu'à la fin des opérations.
*
* On a donc l'assurance d'un récupérer tous les éléments d'un coup,
* sans activité parallèle.
*/
for (iter = g_list_first(list);
iter != NULL && result;
iter = g_list_next(iter))
{
collec = G_DB_COLLECTION(iter->data);
result = g_db_collection_pack_all_updates(collec, pbuf);
}
return result;
}
/******************************************************************************
* *
* Paramètres : list = ensemble de collectons à traiter. *
* inbuf = paquet de données où venir puiser les infos. *
* outbuf = paquet de données où inscrire les mises à jour. *
* db = base de données à mettre à jour. *
* *
* Description : Met à jour les statuts d'activité des éléments. *
* *
* Retour : Bilan du déroulement des opérations. *
* *
* Remarques : - *
* *
******************************************************************************/
bool update_activity_in_collections(GList *list, packed_buffer_t *inbuf, packed_buffer_t *outbuf, sqlite3 *db)
{
bool result; /* Résultat global à renvoyer */
bool status; /* Bilan de lecture initiale */
timestamp_t timestamp; /* Horodatage de limite */
GList *iter; /* Boucle de parcours */
GDbCollection *collec; /* Collection visée manipulée */
result = true;
/**
* Cette procédure n'est appelée que depuis g_cdb_archive_process(),
* qui bloque son exécution jusqu'à la fin des opérations.
*
* On a donc l'assurance d'un traitement global homgène des horodatages.
*/
status = unpack_timestamp(×tamp, inbuf);
if (!status) return false;
for (iter = g_list_first(list);
iter != NULL && result;
iter = g_list_next(iter))
{
collec = G_DB_COLLECTION(iter->data);
result = g_db_collection_disable_at(collec, timestamp, db, outbuf);
}
return result;
}