diff options
Diffstat (limited to 'src/analysis/db')
| -rw-r--r-- | src/analysis/db/admin.c | 10 | ||||
| -rw-r--r-- | src/analysis/db/analyst.c | 30 | ||||
| -rw-r--r-- | src/analysis/db/cdb.c | 22 | ||||
| -rw-r--r-- | src/analysis/db/client.c | 4 | ||||
| -rw-r--r-- | src/analysis/db/collection.c | 16 | ||||
| -rw-r--r-- | src/analysis/db/collection.h | 16 | ||||
| -rw-r--r-- | src/analysis/db/item-int.h | 4 | ||||
| -rw-r--r-- | src/analysis/db/item.c | 12 | ||||
| -rw-r--r-- | src/analysis/db/item.h | 4 | ||||
| -rw-r--r-- | src/analysis/db/items/bookmark.c | 8 | ||||
| -rw-r--r-- | src/analysis/db/items/comment.c | 8 | ||||
| -rw-r--r-- | src/analysis/db/items/move.c | 8 | ||||
| -rw-r--r-- | src/analysis/db/items/switcher.c | 8 | ||||
| -rw-r--r-- | src/analysis/db/misc/rlestr.c | 4 | ||||
| -rw-r--r-- | src/analysis/db/misc/rlestr.h | 4 | ||||
| -rw-r--r-- | src/analysis/db/misc/snapshot.c | 8 | ||||
| -rw-r--r-- | src/analysis/db/misc/snapshot.h | 8 | ||||
| -rw-r--r-- | src/analysis/db/misc/timestamp.c | 4 | ||||
| -rw-r--r-- | src/analysis/db/misc/timestamp.h | 4 | ||||
| -rw-r--r-- | src/analysis/db/server.c | 12 | ||||
| -rw-r--r-- | src/analysis/db/snapshot.c | 14 | ||||
| -rw-r--r-- | src/analysis/db/snapshot.h | 10 |
22 files changed, 109 insertions, 109 deletions
diff --git a/src/analysis/db/admin.c b/src/analysis/db/admin.c index 771a912..024cbed 100644 --- a/src/analysis/db/admin.c +++ b/src/analysis/db/admin.c @@ -75,7 +75,7 @@ static void g_admin_client_finalize(GAdminClient *); static void *g_admin_client_update(GAdminClient *); /* Met à jour la liste des binaires existants. */ -static bool g_admin_client_update_existing_binaries(GAdminClient *, packed_buffer *); +static bool g_admin_client_update_existing_binaries(GAdminClient *, packed_buffer_t *); @@ -234,11 +234,11 @@ static void *g_admin_client_update(GAdminClient *client) { GHubClient *base; /* Base de l'instance */ struct pollfd fds[2]; /* Surveillance des flux */ - packed_buffer in_pbuf; /* Tampon de réception */ + packed_buffer_t in_pbuf; /* Tampon de réception */ int ret; /* Bilan d'un appel */ bool status; /* Bilan d'une opération */ uint32_t command; /* Commande de la requête */ - //packed_buffer out_pbuf; /* Tampon d'émission */ + //packed_buffer_t out_pbuf; /* Tampon d'émission */ char *msg; /* Message d'erreur à imprimer */ base = G_HUB_CLIENT(client); @@ -350,7 +350,7 @@ static void *g_admin_client_update(GAdminClient *client) bool g_admin_client_request_existing_binaries(GAdminClient *client) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -391,7 +391,7 @@ bool g_admin_client_request_existing_binaries(GAdminClient *client) * * ******************************************************************************/ -static bool g_admin_client_update_existing_binaries(GAdminClient *client, packed_buffer *pbuf) +static bool g_admin_client_update_existing_binaries(GAdminClient *client, packed_buffer_t *pbuf) { bool result; /* Validité à retourner */ size_t i; /* Boucle de parcours */ diff --git a/src/analysis/db/analyst.c b/src/analysis/db/analyst.c index a828c11..87a60d3 100644 --- a/src/analysis/db/analyst.c +++ b/src/analysis/db/analyst.c @@ -82,10 +82,10 @@ static void g_analyst_client_finalize(GAnalystClient *); static void *g_analyst_client_update(GAnalystClient *); /* Met à jour la liste des instantanés courants. */ -static bool g_analyst_client_update_snapshots(GAnalystClient *, packed_buffer *); +static bool g_analyst_client_update_snapshots(GAnalystClient *, packed_buffer_t *); /* Met à jour l'identifiant de l'instantané courant. */ -static bool g_analyst_client_update_current_snapshot(GAnalystClient *, packed_buffer *); +static bool g_analyst_client_update_current_snapshot(GAnalystClient *, packed_buffer_t *); @@ -268,10 +268,10 @@ GAnalystClient *g_analyst_client_new(const char *hash, GList *collections) static void *g_analyst_client_update(GAnalystClient *client) { GHubClient *base; /* Base de l'instance */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ bool status; /* Bilan d'une opération */ struct pollfd fds[2]; /* Surveillance des flux */ - packed_buffer in_pbuf; /* Tampon de réception */ + packed_buffer_t in_pbuf; /* Tampon de réception */ int ret; /* Bilan d'un appel */ uint32_t tmp32; /* Valeur sur 32 bits */ uint32_t command; /* Commande de la requête */ @@ -499,7 +499,7 @@ static void *g_analyst_client_update(GAnalystClient *client) * * ******************************************************************************/ -static bool g_analyst_client_update_snapshots(GAnalystClient *client, packed_buffer *pbuf) +static bool g_analyst_client_update_snapshots(GAnalystClient *client, packed_buffer_t *pbuf) { bool result; /* Validité à retourner */ size_t i; /* Boucle de parcours */ @@ -578,7 +578,7 @@ static bool g_analyst_client_update_snapshots(GAnalystClient *client, packed_buf * * ******************************************************************************/ -static bool g_analyst_client_update_current_snapshot(GAnalystClient *client, packed_buffer *pbuf) +static bool g_analyst_client_update_current_snapshot(GAnalystClient *client, packed_buffer_t *pbuf) { bool result; /* Validité à retourner */ snapshot_id_t id; /* Identifiant d'instantané */ @@ -620,7 +620,7 @@ static bool g_analyst_client_update_current_snapshot(GAnalystClient *client, pac bool g_analyst_client_save(GAnalystClient *client) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -664,7 +664,7 @@ bool g_analyst_client_save(GAnalystClient *client) bool g_analyst_client_add_item(GAnalystClient *client, const GDbItem *item) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ DBFeatures feature; /* Domaine de fonctionnalité */ GDbCollection *collec; /* Collection visée au final */ @@ -721,7 +721,7 @@ bool g_analyst_client_add_item(GAnalystClient *client, const GDbItem *item) bool g_analyst_client_set_last_active(GAnalystClient *client, timestamp_t timestamp) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -846,7 +846,7 @@ bool g_analyst_client_get_current_snapshot(GAnalystClient *client, snapshot_id_t bool g_analyst_client_set_current_snapshot(GAnalystClient *client, const snapshot_id_t *id) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -894,7 +894,7 @@ bool g_analyst_client_set_current_snapshot(GAnalystClient *client, const snapsho bool g_analyst_client_set_snapshot_name(GAnalystClient *client, const snapshot_id_t *id, const char *name) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ rle_string string; /* Chaîne à transmettre */ @@ -953,7 +953,7 @@ bool g_analyst_client_set_snapshot_name(GAnalystClient *client, const snapshot_i bool g_analyst_client_set_snapshot_desc(GAnalystClient *client, const snapshot_id_t *id, const char *desc) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ rle_string string; /* Chaîne à transmettre */ @@ -1011,7 +1011,7 @@ bool g_analyst_client_set_snapshot_desc(GAnalystClient *client, const snapshot_i bool g_analyst_client_restore_snapshot(GAnalystClient *client, const snapshot_id_t *id) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -1057,7 +1057,7 @@ bool g_analyst_client_restore_snapshot(GAnalystClient *client, const snapshot_id bool g_analyst_client_create_snapshot(GAnalystClient *client) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); @@ -1102,7 +1102,7 @@ bool g_analyst_client_create_snapshot(GAnalystClient *client) bool g_analyst_client_remove_snapshot(GAnalystClient *client, const snapshot_id_t *id, bool rec) { bool result; /* Bilan partiel à remonter */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ SSL *tls_fd; /* Canal de communication SSL */ init_packed_buffer(&out_pbuf); diff --git a/src/analysis/db/cdb.c b/src/analysis/db/cdb.c index 8d589b3..d2997c7 100644 --- a/src/analysis/db/cdb.c +++ b/src/analysis/db/cdb.c @@ -153,13 +153,13 @@ static void _g_cdb_archive_remove_client(GCdbArchive *, size_t); static void g_cdb_archive_remove_client(GCdbArchive *, size_t); /* Envoie un paquet de données constitué à tous les clients. */ -static void g_cdb_archive_send_reply_to_all_clients(GCdbArchive *, packed_buffer *); +static void g_cdb_archive_send_reply_to_all_clients(GCdbArchive *, packed_buffer_t *); /* Envoie à tous les clients la nouvelle liste d'instantanés. */ -static bool g_cdb_archive_send_snapshot_update(GCdbArchive *, packed_buffer *); +static bool g_cdb_archive_send_snapshot_update(GCdbArchive *, packed_buffer_t *); /* Envoie à tous les clients le nouvel instantané courant. */ -static bool g_cdb_archive_send_snapshot_change(GCdbArchive *, packed_buffer *); +static bool g_cdb_archive_send_snapshot_change(GCdbArchive *, packed_buffer_t *); @@ -797,7 +797,7 @@ static void g_cdb_archive_register_signals(GCdbArchive *archive) static void on_collection_extended(GDbCollection *collec, GDbItem *item, GCdbArchive *archive) { - packed_buffer pbuf; /* Tampon d'émission */ + packed_buffer_t pbuf; /* Tampon d'émission */ size_t i; /* Boucle de parcours */ bool status; /* Bilan d'un envoi de retour */ @@ -842,12 +842,12 @@ static void *g_cdb_archive_process(GCdbArchive *archive) nfds_t nfds; /* Quantité de ces flux */ nfds_t i; /* Boucle de parcours */ int ret; /* Bilan d'un appel */ - packed_buffer in_pbuf; /* Tampon de réception */ + packed_buffer_t in_pbuf; /* Tampon de réception */ uint32_t tmp32; /* Valeur sur 32 bits */ bool status; /* Bilan de lecture initiale */ uint32_t command; /* Commande de la requête */ DBError error; /* Bilan d'une opération */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ GDbCollection *collec; /* Collection visée au final */ bool reload; /* Besoin de rechargement */ char *msg; /* Erreur à faire remonter */ @@ -1327,7 +1327,7 @@ static void g_cdb_archive_remove_client(GCdbArchive *archive, size_t index) * * ******************************************************************************/ -static void g_cdb_archive_send_reply_to_all_clients(GCdbArchive *archive, packed_buffer *pbuf) +static void g_cdb_archive_send_reply_to_all_clients(GCdbArchive *archive, packed_buffer_t *pbuf) { size_t i; /* Boucle de parcours */ bool status; /* Bilan d'une émission */ @@ -1366,11 +1366,11 @@ static void g_cdb_archive_send_reply_to_all_clients(GCdbArchive *archive, packed * * ******************************************************************************/ -static bool g_cdb_archive_send_snapshot_update(GCdbArchive *archive, packed_buffer *pbuf) +static bool g_cdb_archive_send_snapshot_update(GCdbArchive *archive, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ bool do_send; /* Réalisation de l'émission */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ do_send = (pbuf == NULL); @@ -1415,11 +1415,11 @@ static bool g_cdb_archive_send_snapshot_update(GCdbArchive *archive, packed_buff * * ******************************************************************************/ -static bool g_cdb_archive_send_snapshot_change(GCdbArchive *archive, packed_buffer *pbuf) +static bool g_cdb_archive_send_snapshot_change(GCdbArchive *archive, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ bool do_send; /* Réalisation de l'émission */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ snapshot_id_t id; /* Identifiant d'instantané */ do_send = (pbuf == NULL); diff --git a/src/analysis/db/client.c b/src/analysis/db/client.c index 1f47eea..aa1407c 100644 --- a/src/analysis/db/client.c +++ b/src/analysis/db/client.c @@ -393,9 +393,9 @@ static bool g_hub_client_start_common(GHubClient *client, char *desc) int ret; /* Bilan d'un appel */ char *rootdir; /* Racine pour le client */ GHubClientClass *class; /* Classe du client connecté */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ bool status; /* Bilan d'une opération */ - packed_buffer in_pbuf; /* Tampon de réception */ + packed_buffer_t in_pbuf; /* Tampon de réception */ uint32_t data; /* Mot de données lues */ DBError error; /* Validation de la connexion */ diff --git a/src/analysis/db/collection.c b/src/analysis/db/collection.c index dcab73e..52476dd 100644 --- a/src/analysis/db/collection.c +++ b/src/analysis/db/collection.c @@ -324,7 +324,7 @@ const char *g_db_collection_get_name(const GDbCollection *collec) * * ******************************************************************************/ -bool _g_db_collection_unpack(GDbCollection *collec, packed_buffer *pbuf, DBAction *action, GDbItem **dest) +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 */ @@ -376,7 +376,7 @@ bool _g_db_collection_unpack(GDbCollection *collec, packed_buffer *pbuf, DBActio * * ******************************************************************************/ -bool g_db_collection_unpack(GDbCollection *collec, packed_buffer *pbuf, sqlite3 *db) +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 */ @@ -460,7 +460,7 @@ bool g_db_collection_unpack(GDbCollection *collec, packed_buffer *pbuf, sqlite3 * * ******************************************************************************/ -bool g_db_collection_pack(GDbCollection *collec, packed_buffer *pbuf, DBAction action, const GDbItem *item) +bool g_db_collection_pack(GDbCollection *collec, packed_buffer_t *pbuf, DBAction action, const GDbItem *item) { bool result; /* Bilan à retourner */ @@ -493,7 +493,7 @@ bool g_db_collection_pack(GDbCollection *collec, packed_buffer *pbuf, DBAction a * * ******************************************************************************/ -bool g_db_collection_pack_all_updates(GDbCollection *collec, packed_buffer *pbuf) +bool g_db_collection_pack_all_updates(GDbCollection *collec, packed_buffer_t *pbuf) { bool result; /* Bilan à renvoyer */ size_t i; /* Boucle de parcours */ @@ -779,7 +779,7 @@ bool g_db_collection_add_item(GDbCollection *collec, GDbItem *item) * * ******************************************************************************/ -bool g_db_collection_drop_disabled_items(GDbCollection *collec, packed_buffer *pbuf) +bool g_db_collection_drop_disabled_items(GDbCollection *collec, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ size_t i; /* Boucle de parcours */ @@ -1021,7 +1021,7 @@ static size_t g_db_collection_find_by_timestamp(GDbCollection *collec, timestamp * * ******************************************************************************/ -bool g_db_collection_disable_at(GDbCollection *collec, timestamp_t timestamp, sqlite3 *db, packed_buffer *pbuf) +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 */ @@ -1450,7 +1450,7 @@ void lock_unlock_collections(GList *list, bool write, bool lock) * * ******************************************************************************/ -bool pack_all_collection_updates(GList *list, packed_buffer *pbuf) +bool pack_all_collection_updates(GList *list, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ GList *iter; /* Boucle de parcours */ @@ -1496,7 +1496,7 @@ bool pack_all_collection_updates(GList *list, packed_buffer *pbuf) * * ******************************************************************************/ -bool update_activity_in_collections(GList *list, packed_buffer *inbuf, packed_buffer *outbuf, sqlite3 *db) +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 */ diff --git a/src/analysis/db/collection.h b/src/analysis/db/collection.h index 6c14624..6d7b369 100644 --- a/src/analysis/db/collection.h +++ b/src/analysis/db/collection.h @@ -69,16 +69,16 @@ const char *g_db_collection_get_name(const GDbCollection *); /* Réceptionne un élément depuis une requête réseau. */ -bool _g_db_collection_unpack(GDbCollection *, packed_buffer *, DBAction *, GDbItem **); +bool _g_db_collection_unpack(GDbCollection *, packed_buffer_t *, DBAction *, GDbItem **); /* Réceptionne et traite une requête réseau pour collection. */ -bool g_db_collection_unpack(GDbCollection *, packed_buffer *, sqlite3 *); +bool g_db_collection_unpack(GDbCollection *, packed_buffer_t *, sqlite3 *); /* Envoie pour traitement une requête réseau pour collection. */ -bool g_db_collection_pack(GDbCollection *, packed_buffer *, DBAction, const GDbItem *); +bool g_db_collection_pack(GDbCollection *, packed_buffer_t *, DBAction, const GDbItem *); /* Envoie pour mise à jour tous les éléments courants. */ -bool g_db_collection_pack_all_updates(GDbCollection *, packed_buffer *); +bool g_db_collection_pack_all_updates(GDbCollection *, packed_buffer_t *); @@ -111,13 +111,13 @@ typedef enum _ActiveItemChange bool g_db_collection_add_item(GDbCollection *, GDbItem *); /* Procède au retrait des éléments désactivés de la collection. */ -bool g_db_collection_drop_disabled_items(GDbCollection *, packed_buffer *); +bool g_db_collection_drop_disabled_items(GDbCollection *, packed_buffer_t *); /* Procède au retrait d'un élément dans la collection. */ bool g_db_collection_remove_item(GDbCollection *, const GDbItem *); /* Désactive les éléments en aval d'un horodatage donné. */ -bool g_db_collection_disable_at(GDbCollection *, timestamp_t, sqlite3 *, packed_buffer *); +bool g_db_collection_disable_at(GDbCollection *, timestamp_t, sqlite3 *, packed_buffer_t *); /* Prend acte d'un changement d'état d'un élément de collection. */ bool g_db_collection_update_item_state(GDbCollection *, const GDbItem *); @@ -154,10 +154,10 @@ void lock_unlock_collections(GList *, bool, bool); #define runlock_collections(lst) lock_unlock_collections(lst, false, false); /* Collecte les informations utiles pour un nouvel arrivant. */ -bool pack_all_collection_updates(GList *, packed_buffer *); +bool pack_all_collection_updates(GList *, packed_buffer_t *); /* Met à jour les statuts d'activité des éléments. */ -bool update_activity_in_collections(GList *, packed_buffer *, packed_buffer *, sqlite3 *); +bool update_activity_in_collections(GList *, packed_buffer_t *, packed_buffer_t *, sqlite3 *); diff --git a/src/analysis/db/item-int.h b/src/analysis/db/item-int.h index 4b37844..871a65e 100644 --- a/src/analysis/db/item-int.h +++ b/src/analysis/db/item-int.h @@ -46,10 +46,10 @@ typedef gboolean (* cmp_db_item_key_fc) (const GDbItem *, const GDbItem *); typedef gint (* cmp_db_item_fc) (const GDbItem *, const GDbItem *); /* Importe la définition d'une base d'éléments pour collection. */ -typedef bool (* unpack_db_item_fc) (GDbItem *, packed_buffer *); +typedef bool (* unpack_db_item_fc) (GDbItem *, packed_buffer_t *); /* Exporte la définition d'une base d'éléments pour collection. */ -typedef bool (* pack_db_item_fc) (const GDbItem *, packed_buffer *); +typedef bool (* pack_db_item_fc) (const GDbItem *, packed_buffer_t *); /* Construit la description humaine d'un signet sur un tampon. */ typedef char * (* build_item_label_fc) (const GDbItem *); diff --git a/src/analysis/db/item.c b/src/analysis/db/item.c index 16866ab..6ee59a7 100644 --- a/src/analysis/db/item.c +++ b/src/analysis/db/item.c @@ -49,10 +49,10 @@ static void g_db_item_dispose(GDbItem *); static void g_db_item_finalize(GDbItem *); /* Importe la définition d'une base d'éléments pour collection. */ -static bool _g_db_item_unpack(GDbItem *, packed_buffer *); +static bool _g_db_item_unpack(GDbItem *, packed_buffer_t *); /* Exporte la définition d'une base d'éléments pour collection. */ -static bool _g_db_item_pack(const GDbItem *, packed_buffer *); +static bool _g_db_item_pack(const GDbItem *, packed_buffer_t *); @@ -376,7 +376,7 @@ gint g_db_item_cmp(const GDbItem *a, const GDbItem *b) * * ******************************************************************************/ -static bool _g_db_item_unpack(GDbItem *item, packed_buffer *pbuf) +static bool _g_db_item_unpack(GDbItem *item, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ uint32_t flags; /* Propriétés de l'élément */ @@ -410,7 +410,7 @@ static bool _g_db_item_unpack(GDbItem *item, packed_buffer *pbuf) * * ******************************************************************************/ -bool g_db_item_unpack(GDbItem *item, packed_buffer *pbuf) +bool g_db_item_unpack(GDbItem *item, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -434,7 +434,7 @@ bool g_db_item_unpack(GDbItem *item, packed_buffer *pbuf) * * ******************************************************************************/ -static bool _g_db_item_pack(const GDbItem *item, packed_buffer *pbuf) +static bool _g_db_item_pack(const GDbItem *item, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ DbItemFlags flags; /* Propriétés de l'élément */ @@ -468,7 +468,7 @@ static bool _g_db_item_pack(const GDbItem *item, packed_buffer *pbuf) * * ******************************************************************************/ -bool g_db_item_pack(const GDbItem *item, packed_buffer *pbuf) +bool g_db_item_pack(const GDbItem *item, packed_buffer_t *pbuf) { return G_DB_ITEM_GET_CLASS(item)->pack(item, pbuf); diff --git a/src/analysis/db/item.h b/src/analysis/db/item.h index a4eaffa..e34523c 100644 --- a/src/analysis/db/item.h +++ b/src/analysis/db/item.h @@ -93,10 +93,10 @@ int g_db_item_cmp_with_timestamp(const timestamp_t *, const GDbItem **); gint g_db_item_cmp(const GDbItem *, const GDbItem *); /* Importe la définition d'une base d'éléments pour collection. */ -bool g_db_item_unpack(GDbItem *, packed_buffer *); +bool g_db_item_unpack(GDbItem *, packed_buffer_t *); /* Exporte la définition d'une base d'éléments pour collection. */ -bool g_db_item_pack(const GDbItem *, packed_buffer *); +bool g_db_item_pack(const GDbItem *, packed_buffer_t *); /* Applique un élément de collection sur un binaire. */ bool g_db_item_apply(GDbItem *, GLoadedBinary *); diff --git a/src/analysis/db/items/bookmark.c b/src/analysis/db/items/bookmark.c index 0a64c89..3610d96 100644 --- a/src/analysis/db/items/bookmark.c +++ b/src/analysis/db/items/bookmark.c @@ -81,10 +81,10 @@ static gboolean g_db_bookmark_cmp_key(const GDbBookmark *, const GDbBookmark *); static gint g_db_bookmark_cmp(const GDbBookmark *, const GDbBookmark *); /* Importe la définition d'un signet dans un flux réseau. */ -static bool g_db_bookmark_unpack(GDbBookmark *, packed_buffer *); +static bool g_db_bookmark_unpack(GDbBookmark *, packed_buffer_t *); /* Exporte la définition d'un signet dans un flux réseau. */ -static bool g_db_bookmark_pack(const GDbBookmark *, packed_buffer *); +static bool g_db_bookmark_pack(const GDbBookmark *, packed_buffer_t *); /* Construit la description humaine d'un signet sur un tampon. */ static char *g_db_bookmark_build_label(const GDbBookmark *); @@ -412,7 +412,7 @@ static gint g_db_bookmark_cmp(const GDbBookmark *a, const GDbBookmark *b) * * ******************************************************************************/ -static bool g_db_bookmark_unpack(GDbBookmark *bookmark, packed_buffer *pbuf) +static bool g_db_bookmark_unpack(GDbBookmark *bookmark, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -442,7 +442,7 @@ static bool g_db_bookmark_unpack(GDbBookmark *bookmark, packed_buffer *pbuf) * * ******************************************************************************/ -static bool g_db_bookmark_pack(const GDbBookmark *bookmark, packed_buffer *pbuf) +static bool g_db_bookmark_pack(const GDbBookmark *bookmark, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ diff --git a/src/analysis/db/items/comment.c b/src/analysis/db/items/comment.c index bdff3a6..da7a4c0 100644 --- a/src/analysis/db/items/comment.c +++ b/src/analysis/db/items/comment.c @@ -94,10 +94,10 @@ static gboolean g_db_comment_cmp_key(const GDbComment *, const GDbComment *); static gint g_db_comment_cmp(const GDbComment *, const GDbComment *); /* Importe la définition d'un commentaire dans un flux réseau. */ -static bool g_db_comment_unpack(GDbComment *, packed_buffer *); +static bool g_db_comment_unpack(GDbComment *, packed_buffer_t *); /* Exporte la définition d'un commentaire dans un flux réseau. */ -static bool g_db_comment_pack(GDbComment *, packed_buffer *); +static bool g_db_comment_pack(GDbComment *, packed_buffer_t *); /* Construit la description humaine d'un commentaire. */ static char *g_db_comment_build_label(GDbComment *); @@ -570,7 +570,7 @@ static gint g_db_comment_cmp(const GDbComment *a, const GDbComment *b) * * ******************************************************************************/ -static bool g_db_comment_unpack(GDbComment *comment, packed_buffer *pbuf) +static bool g_db_comment_unpack(GDbComment *comment, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ uint8_t tmp8; /* Valeur sur 8 bits */ @@ -623,7 +623,7 @@ static bool g_db_comment_unpack(GDbComment *comment, packed_buffer *pbuf) * * ******************************************************************************/ -static bool g_db_comment_pack(GDbComment *comment, packed_buffer *pbuf) +static bool g_db_comment_pack(GDbComment *comment, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ rle_string text; /* Texte brut récupéré */ diff --git a/src/analysis/db/items/move.c b/src/analysis/db/items/move.c index f70de6f..af1c8c1 100644 --- a/src/analysis/db/items/move.c +++ b/src/analysis/db/items/move.c @@ -78,10 +78,10 @@ static void g_db_move_finalize(GDbMove *); static gint g_db_move_cmp(const GDbMove *, const GDbMove *); /* Importe la définition d'un déplacement depuis un flux réseau. */ -static bool g_db_move_unpack(GDbMove *, packed_buffer *); +static bool g_db_move_unpack(GDbMove *, packed_buffer_t *); /* Exporte la définition d'un déplacement dans un flux réseau. */ -static bool g_db_move_pack(const GDbMove *, packed_buffer *); +static bool g_db_move_pack(const GDbMove *, packed_buffer_t *); /* Construit la description humaine d'un déplacement. */ static char *g_db_move_build_label(GDbMove *); @@ -314,7 +314,7 @@ static gint g_db_move_cmp(const GDbMove *a, const GDbMove *b) * * ******************************************************************************/ -static bool g_db_move_unpack(GDbMove *move, packed_buffer *pbuf) +static bool g_db_move_unpack(GDbMove *move, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -347,7 +347,7 @@ static bool g_db_move_unpack(GDbMove *move, packed_buffer *pbuf) * * ******************************************************************************/ -static bool g_db_move_pack(const GDbMove *move, packed_buffer *pbuf) +static bool g_db_move_pack(const GDbMove *move, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ diff --git a/src/analysis/db/items/switcher.c b/src/analysis/db/items/switcher.c index 090b8ce..885406c 100644 --- a/src/analysis/db/items/switcher.c +++ b/src/analysis/db/items/switcher.c @@ -84,10 +84,10 @@ static gboolean g_db_switcher_cmp_key(const GDbSwitcher *, const GDbSwitcher *); static gint g_db_switcher_cmp(const GDbSwitcher *, const GDbSwitcher *); /* Importe la définition d'un signet depuis un flux réseau. */ -static bool g_db_switcher_unpack(GDbSwitcher *, packed_buffer *); +static bool g_db_switcher_unpack(GDbSwitcher *, packed_buffer_t *); /* Exporte la définition d'un signet dans un flux réseau. */ -static bool g_db_switcher_pack(const GDbSwitcher *, packed_buffer *); +static bool g_db_switcher_pack(const GDbSwitcher *, packed_buffer_t *); /* Construit la description humaine d'un signet sur un tampon. */ static char *g_db_switcher_build_label(GDbSwitcher *); @@ -448,7 +448,7 @@ static gint g_db_switcher_cmp(const GDbSwitcher *a, const GDbSwitcher *b) * * ******************************************************************************/ -static bool g_db_switcher_unpack(GDbSwitcher *switcher, packed_buffer *pbuf) +static bool g_db_switcher_unpack(GDbSwitcher *switcher, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ uint32_t tmp32; /* Valeur sur 32 bits */ @@ -489,7 +489,7 @@ static bool g_db_switcher_unpack(GDbSwitcher *switcher, packed_buffer *pbuf) * * ******************************************************************************/ -static bool g_db_switcher_pack(const GDbSwitcher *switcher, packed_buffer *pbuf) +static bool g_db_switcher_pack(const GDbSwitcher *switcher, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ diff --git a/src/analysis/db/misc/rlestr.c b/src/analysis/db/misc/rlestr.c index 7b1e705..bb81b55 100644 --- a/src/analysis/db/misc/rlestr.c +++ b/src/analysis/db/misc/rlestr.c @@ -273,7 +273,7 @@ int cmp_rle_string(const rle_string *s1, const rle_string *s2) * * ******************************************************************************/ -bool unpack_rle_string(rle_string *str, packed_buffer *pbuf) +bool unpack_rle_string(rle_string *str, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ uint32_t tmp32; /* Valeur sur 32 bits */ @@ -317,7 +317,7 @@ bool unpack_rle_string(rle_string *str, packed_buffer *pbuf) * * ******************************************************************************/ -bool pack_rle_string(const rle_string *str, packed_buffer *pbuf) +bool pack_rle_string(const rle_string *str, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ diff --git a/src/analysis/db/misc/rlestr.h b/src/analysis/db/misc/rlestr.h index 63effda..aa2aa73 100644 --- a/src/analysis/db/misc/rlestr.h +++ b/src/analysis/db/misc/rlestr.h @@ -83,10 +83,10 @@ void unset_rle_string(rle_string *); int cmp_rle_string(const rle_string *, const rle_string *); /* Importe la définition d'une chaîne de caractères. */ -bool unpack_rle_string(rle_string *, packed_buffer *); +bool unpack_rle_string(rle_string *, packed_buffer_t *); /* Exporte la définition d'une chaîne de caractères. */ -bool pack_rle_string(const rle_string *, packed_buffer *); +bool pack_rle_string(const rle_string *, packed_buffer_t *); diff --git a/src/analysis/db/misc/snapshot.c b/src/analysis/db/misc/snapshot.c index 23fe15c..b116b3c 100644 --- a/src/analysis/db/misc/snapshot.c +++ b/src/analysis/db/misc/snapshot.c @@ -188,7 +188,7 @@ int cmp_snapshot_id(const snapshot_id_t *id1, const snapshot_id_t *id2) * * ******************************************************************************/ -bool unpack_snapshot_id(snapshot_id_t *id, packed_buffer *pbuf) +bool unpack_snapshot_id(snapshot_id_t *id, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -212,7 +212,7 @@ bool unpack_snapshot_id(snapshot_id_t *id, packed_buffer *pbuf) * * ******************************************************************************/ -bool pack_snapshot_id(const snapshot_id_t *id, packed_buffer *pbuf) +bool pack_snapshot_id(const snapshot_id_t *id, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -411,7 +411,7 @@ void copy_snapshot_info(snapshot_info_t *dest, const snapshot_info_t *src) * * ******************************************************************************/ -bool unpack_snapshot_info(snapshot_info_t *info, packed_buffer *pbuf) +bool unpack_snapshot_info(snapshot_info_t *info, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ rle_string string; /* Chaîne à transmettre */ @@ -473,7 +473,7 @@ bool unpack_snapshot_info(snapshot_info_t *info, packed_buffer *pbuf) * * ******************************************************************************/ -bool pack_snapshot_info(const snapshot_info_t *info, packed_buffer *pbuf) +bool pack_snapshot_info(const snapshot_info_t *info, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ rle_string string; /* Chaîne à transmettre */ diff --git a/src/analysis/db/misc/snapshot.h b/src/analysis/db/misc/snapshot.h index 3f55b50..f6a84f1 100644 --- a/src/analysis/db/misc/snapshot.h +++ b/src/analysis/db/misc/snapshot.h @@ -71,10 +71,10 @@ void copy_snapshot_id(snapshot_id_t *, const snapshot_id_t *); int cmp_snapshot_id(const snapshot_id_t *, const snapshot_id_t *); /* Importe la définition d'un identifiant d'instantané. */ -bool unpack_snapshot_id(snapshot_id_t *, packed_buffer *); +bool unpack_snapshot_id(snapshot_id_t *, packed_buffer_t *); /* Exporte la définition d'un identifiant d'instantané. */ -bool pack_snapshot_id(const snapshot_id_t *, packed_buffer *); +bool pack_snapshot_id(const snapshot_id_t *, packed_buffer_t *); @@ -117,10 +117,10 @@ void exit_snapshot_info(snapshot_info_t *); void copy_snapshot_info(snapshot_info_t *, const snapshot_info_t *); /* Importe la description d'un identifiant d'instantané. */ -bool unpack_snapshot_info(snapshot_info_t *, packed_buffer *); +bool unpack_snapshot_info(snapshot_info_t *, packed_buffer_t *); /* Exporte la description d'un identifiant d'instantané. */ -bool pack_snapshot_info(const snapshot_info_t *, packed_buffer *); +bool pack_snapshot_info(const snapshot_info_t *, packed_buffer_t *); /* Change la désignation dans les informations d'un instantané. */ void set_snapshot_info_name(snapshot_info_t *, const char *); diff --git a/src/analysis/db/misc/timestamp.c b/src/analysis/db/misc/timestamp.c index 5f49997..1790e2b 100644 --- a/src/analysis/db/misc/timestamp.c +++ b/src/analysis/db/misc/timestamp.c @@ -203,7 +203,7 @@ int cmp_timestamp(const timestamp_t *t1, const timestamp_t *t2) * * ******************************************************************************/ -bool unpack_timestamp(timestamp_t *timestamp, packed_buffer *pbuf) +bool unpack_timestamp(timestamp_t *timestamp, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -227,7 +227,7 @@ bool unpack_timestamp(timestamp_t *timestamp, packed_buffer *pbuf) * * ******************************************************************************/ -bool pack_timestamp(const timestamp_t *timestamp, packed_buffer *pbuf) +bool pack_timestamp(const timestamp_t *timestamp, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ diff --git a/src/analysis/db/misc/timestamp.h b/src/analysis/db/misc/timestamp.h index f41a529..bdb9d3e 100644 --- a/src/analysis/db/misc/timestamp.h +++ b/src/analysis/db/misc/timestamp.h @@ -57,10 +57,10 @@ void copy_timestamp(timestamp_t *, const timestamp_t *); int cmp_timestamp(const timestamp_t *, const timestamp_t *); /* Importe la définition d'un horodatage. */ -bool unpack_timestamp(timestamp_t *, packed_buffer *); +bool unpack_timestamp(timestamp_t *, packed_buffer_t *); /* Exporte la définition d'un horodatage. */ -bool pack_timestamp(const timestamp_t *, packed_buffer *); +bool pack_timestamp(const timestamp_t *, packed_buffer_t *); diff --git a/src/analysis/db/server.c b/src/analysis/db/server.c index ad7929f..f324c74 100644 --- a/src/analysis/db/server.c +++ b/src/analysis/db/server.c @@ -141,10 +141,10 @@ static int g_hub_server_verify(int, X509_STORE_CTX *); static void *g_hub_server_listener(GHubServer *); /* Assure l'accueil des nouveaux clients administrateurs. */ -static GServerBackend *g_hub_server_handle_admin(GHubServer *, packed_buffer *, const char *, DBError *, bool *); +static GServerBackend *g_hub_server_handle_admin(GHubServer *, packed_buffer_t *, const char *, DBError *, bool *); /* Assure l'accueil des nouveaux clients analystes. */ -static GServerBackend *g_hub_server_handle_analyst(GHubServer *, packed_buffer *, const char *, DBError *, bool *); +static GServerBackend *g_hub_server_handle_analyst(GHubServer *, packed_buffer_t *, const char *, DBError *, bool *); /* Enregistre dans une liste interne un support de suivi. */ static void g_hub_server_register_backend(GHubServer *, GServerBackend *); @@ -752,13 +752,13 @@ static void *g_hub_server_listener(GHubServer *server) const char *ip; /* Statut de la conversion */ char *peer_name; /* Désignation du correspondant*/ DBError error; /* Validation de la connexion */ - packed_buffer in_pbuf; /* Tampon de réception */ + packed_buffer_t in_pbuf; /* Tampon de réception */ bool status; /* Bilan d'une opération */ uint32_t cmd; /* Commande initiale lue */ uint32_t version; /* Version du client lue */ uint32_t role; /* Rôle visé par le client */ bool new; /* Besoin d'ajout à une liste */ - packed_buffer out_pbuf; /* Tampon d'émission */ + packed_buffer_t out_pbuf; /* Tampon d'émission */ fds.fd = server->fd; fds.events = POLLIN | POLLPRI; @@ -1021,7 +1021,7 @@ static void *g_hub_server_listener(GHubServer *server) * * ******************************************************************************/ -static GServerBackend *g_hub_server_handle_admin(GHubServer *server, packed_buffer *in_pbuf, const char *peer_name, DBError *error, bool *new) +static GServerBackend *g_hub_server_handle_admin(GHubServer *server, packed_buffer_t *in_pbuf, const char *peer_name, DBError *error, bool *new) { GCdbController *result; /* Support de suivi à retourner*/ char *basedir; /* Répertoire de stockage */ @@ -1070,7 +1070,7 @@ static GServerBackend *g_hub_server_handle_admin(GHubServer *server, packed_buff * * ******************************************************************************/ -static GServerBackend *g_hub_server_handle_analyst(GHubServer *server, packed_buffer *in_pbuf, const char *peer_name, DBError *error, bool *new) +static GServerBackend *g_hub_server_handle_analyst(GHubServer *server, packed_buffer_t *in_pbuf, const char *peer_name, DBError *error, bool *new) { GCdbArchive *result; /* Support de suivi à retourner*/ rle_string hash; /* Empreinte du binaire visé */ diff --git a/src/analysis/db/snapshot.c b/src/analysis/db/snapshot.c index e07129e..1a92a34 100644 --- a/src/analysis/db/snapshot.c +++ b/src/analysis/db/snapshot.c @@ -90,7 +90,7 @@ static void add_snapshot_node(snapshot_node_t *, snapshot_node_t *); static void remove_snapshot_node(snapshot_node_t *, bool); /* Collecte les descriptions d'une arborescence d'instantanés. */ -static bool pack_snapshot_node(const snapshot_node_t *, packed_buffer *); +static bool pack_snapshot_node(const snapshot_node_t *, packed_buffer_t *); @@ -639,7 +639,7 @@ static void remove_snapshot_node(snapshot_node_t *node, bool rec) * * ******************************************************************************/ -static bool pack_snapshot_node(const snapshot_node_t *node, packed_buffer *pbuf) +static bool pack_snapshot_node(const snapshot_node_t *node, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ size_t i; /* Boucle de parcours */ @@ -1263,7 +1263,7 @@ sqlite3 *g_db_snapshot_get_database(const GDbSnapshot *snap) * * ******************************************************************************/ -bool g_db_snapshot_pack_all(const GDbSnapshot *snap, packed_buffer *pbuf) +bool g_db_snapshot_pack_all(const GDbSnapshot *snap, packed_buffer_t *pbuf) { bool result; /* Bilan à retourner */ @@ -1287,7 +1287,7 @@ bool g_db_snapshot_pack_all(const GDbSnapshot *snap, packed_buffer *pbuf) * * ******************************************************************************/ -DBError g_db_snapshot_set_name(const GDbSnapshot *snap, packed_buffer *pbuf) +DBError g_db_snapshot_set_name(const GDbSnapshot *snap, packed_buffer_t *pbuf) { DBError result; /* Conclusion à retourner */ snapshot_id_t id; /* Identifiant d'instantané */ @@ -1352,7 +1352,7 @@ DBError g_db_snapshot_set_name(const GDbSnapshot *snap, packed_buffer *pbuf) * * ******************************************************************************/ -DBError g_db_snapshot_set_desc(const GDbSnapshot *snap, packed_buffer *pbuf) +DBError g_db_snapshot_set_desc(const GDbSnapshot *snap, packed_buffer_t *pbuf) { DBError result; /* Conclusion à retourner */ snapshot_id_t id; /* Identifiant d'instantané */ @@ -1418,7 +1418,7 @@ DBError g_db_snapshot_set_desc(const GDbSnapshot *snap, packed_buffer *pbuf) * * ******************************************************************************/ -DBError g_db_snapshot_restore(GDbSnapshot *snap, packed_buffer *pbuf, bool *reload) +DBError g_db_snapshot_restore(GDbSnapshot *snap, packed_buffer_t *pbuf, bool *reload) { DBError result; /* Conclusion à retourner */ snapshot_id_t id; /* Identifiant d'instantané */ @@ -1544,7 +1544,7 @@ DBError g_db_snapshot_create(GDbSnapshot *snap, sqlite3 *db) * * ******************************************************************************/ -DBError g_db_snapshot_remove(GDbSnapshot *snap, packed_buffer *pbuf, bool *changed) +DBError g_db_snapshot_remove(GDbSnapshot *snap, packed_buffer_t *pbuf, bool *changed) { DBError result; /* Conclusion à retourner */ snapshot_id_t id; /* Identifiant d'instantané */ diff --git a/src/analysis/db/snapshot.h b/src/analysis/db/snapshot.h index 8737f8c..7f8a82a 100644 --- a/src/analysis/db/snapshot.h +++ b/src/analysis/db/snapshot.h @@ -75,22 +75,22 @@ bool g_db_snapshot_get_current_id(const GDbSnapshot *, snapshot_id_t *); sqlite3 *g_db_snapshot_get_database(const GDbSnapshot *); /* Collecte les descriptions de l'ensemble des instantanés. */ -bool g_db_snapshot_pack_all(const GDbSnapshot *, packed_buffer *); +bool g_db_snapshot_pack_all(const GDbSnapshot *, packed_buffer_t *); /* Actualise la désignation d'un instantané donné. */ -DBError g_db_snapshot_set_name(const GDbSnapshot *, packed_buffer *); +DBError g_db_snapshot_set_name(const GDbSnapshot *, packed_buffer_t *); /* Actualise la description d'un instantané donné. */ -DBError g_db_snapshot_set_desc(const GDbSnapshot *, packed_buffer *); +DBError g_db_snapshot_set_desc(const GDbSnapshot *, packed_buffer_t *); /* Restaure un instantané de l'arborescence. */ -DBError g_db_snapshot_restore(GDbSnapshot *, packed_buffer *, bool *); +DBError g_db_snapshot_restore(GDbSnapshot *, packed_buffer_t *, bool *); /* Crée un nouvel instantanés dans l'arborescence. */ DBError g_db_snapshot_create(GDbSnapshot *, sqlite3 *); /* Supprime un instantané dans l'arborescence. */ -DBError g_db_snapshot_remove(GDbSnapshot *, packed_buffer *, bool *); +DBError g_db_snapshot_remove(GDbSnapshot *, packed_buffer_t *, bool *); |