serialize_io.c File Reference

#include <rz_util/rz_serialize.h>
#include <rz_io.h>
#include <errno.h>

Go to the source code of this file.

Classes
struct	RzIODescasd
struct	PCacheSaveCtx

Macros
#define	SUB(ns, call)   RZ_SERIALIZE_SUB_DO(db, subdb, res, ns, call, goto beach;)

Functions
static bool	pcache_save_cb (void *user, const ut64 k, const void *v)
static bool	file_save_cb (void *user, void *data, ut32 id)
RZ_API void	rz_serialize_io_files_save (RZ_NONNULL Sdb *db, RZ_NONNULL RzIO *io)
RZ_API bool	rz_serialize_io_files_load (RZ_NONNULL Sdb *db, RZ_NONNULL RzIO *io, RZ_NULLABLE RzSerializeResultInfo *res)
RZ_API void	rz_serialize_io_save (RZ_NONNULL Sdb *db, RZ_NONNULL RzIO *io)
RZ_API bool	rz_serialize_io_load (RZ_NONNULL Sdb *db, RZ_NONNULL RzIO *io, RZ_NULLABLE RzSerializeResultInfo *res)

Macro Definition Documentation

SUB

#define SUB	(		ns,
			call
	)		RZ_SERIALIZE_SUB_DO(db, subdb, res, ns, call, goto beach;)

Function Documentation

file_save_cb()

static bool file_save_cb ( void *  user, void *  data, ut32  id  )

static

Definition at line 49 of file serialize_io.c.

                                                          {
    Sdb *db = user;
    RzIODesc *desc = (RzIODesc *)data;
 
    char key[0x20];
    if (snprintf(key, sizeof(key), "%d", desc->fd) < 0) {
        return false;
    }
 
    PJ *j = pj_new();
    if (!j) {
        return false;
    }
    pj_o(j);
 
    pj_ki(j, "perm", desc->perm);
    // obsz is irrelevant (never written, always 0)
    pj_ks(j, "uri", desc->uri);
    pj_ks(j, "name", desc->name);
    if (desc->referer) {
        pj_ks(j, "referer", desc->referer);
    }
    // TODO: plugin
 
    pj_end(j);
    sdb_set(db, key, pj_string(j), 0);
    pj_free(j);
 
    if (desc->cache->count) {
        PCacheSaveCtx ctx = {
            .fd = desc->fd,
            .db = sdb_ns(db, "pcache", true)
        };
        ht_up_foreach(desc->cache, pcache_save_cb, &ctx);
    }
    return true;
}

References desc, key, pcache_save_cb(), pj_end(), pj_free(), pj_ki(), pj_ks(), pj_new(), pj_o(), pj_string(), sdb_ns(), sdb_set(), and snprintf.

Referenced by rz_serialize_io_files_save().

pcache_save_cb()

static bool pcache_save_cb ( void *  user, const ut64  k, const void *  v  )

static

Definition at line 37 of file serialize_io.c.

                                                                    {
    PCacheSaveCtx *ctx = user;
    const RzIODescCache *cache = v;
    char key[0x30];
    if (snprintf(key, sizeof(key), "%d.0x%" PFMT64x, ctx->fd, k) < 0) {
        return false;
    }
    char val[RZ_IO_DESC_CACHE_SIZE * 4 + 1];
    rz_base64_encode(val, cache->cdata, RZ_IO_DESC_CACHE_SIZE);
    return true;
}

References rz_io_desc_cache_t::cdata, k, key, PFMT64x, rz_base64_encode(), RZ_IO_DESC_CACHE_SIZE, snprintf, v, and val.

Referenced by file_save_cb().

rz_serialize_io_files_load()

RZ_API bool rz_serialize_io_files_load	(	RZ_NONNULL Sdb *	db,
		RZ_NONNULL RzIO *	io,
		RZ_NULLABLE RzSerializeResultInfo *	res
	)

Definition at line 92 of file serialize_io.c.

                                                                                                                        {
    // TODO
    return true;
}

Referenced by rz_serialize_io_load().

rz_serialize_io_files_save()

RZ_API void rz_serialize_io_files_save	(	RZ_NONNULL Sdb *	db,
		RZ_NONNULL RzIO *	io
	)

Definition at line 87 of file serialize_io.c.

                                                                                {
    sdb_ns(db, "pcache", true);
    rz_id_storage_foreach(io->files, file_save_cb, db);
}

References file_save_cb(), rz_id_storage_foreach(), and sdb_ns().

Referenced by rz_serialize_io_save().

rz_serialize_io_load()

RZ_API bool rz_serialize_io_load	(	RZ_NONNULL Sdb *	db,
		RZ_NONNULL RzIO *	io,
		RZ_NULLABLE RzSerializeResultInfo *	res
	)

Definition at line 101 of file serialize_io.c.

                                                                                                                  {
    // TODO: purge RzIO?
    bool ret = false;
    Sdb *subdb;
#define SUB(ns, call) RZ_SERIALIZE_SUB_DO(db, subdb, res, ns, call, goto beach;)
    SUB("files", rz_serialize_io_files_load(subdb, io, res));
#undef SUB
    ret = true;
beach:
    return ret;
}

References rz_serialize_io_files_load(), and SUB.

rz_serialize_io_save()

RZ_API void rz_serialize_io_save	(	RZ_NONNULL Sdb *	db,
		RZ_NONNULL RzIO *	io
	)

Definition at line 97 of file serialize_io.c.

                                                                          {
    rz_serialize_io_files_save(sdb_ns(db, "files", true), io);
}

References rz_serialize_io_files_save(), and sdb_ns().