rec.c

Go to the documentation of this file.

 
/*************************************************************************
 * Copyright (c) 2011 AT&T Intellectual Property 
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * https://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors: Details at https://graphviz.org
 *************************************************************************/
 
#include        <cgraph/cghdr.h>
#include        <stdbool.h>
#include        <stdlib.h>
#include        <util/streq.h>
#include        <util/alloc.h>
#include        <util/unreachable.h>
 
/*
 * run time records
 */
 
static void set_data(Agobj_t * obj, Agrec_t * data, bool mtflock)
{
    Agedge_t *e;
 
    obj->data = data;
    obj->tag.mtflock = mtflock;
    if (AGTYPE(obj) == AGINEDGE || AGTYPE(obj) == AGOUTEDGE) {
        e = agopp((Agedge_t *) obj);
        AGDATA(e) = data;
        e->base.tag.mtflock = mtflock;
    }
}
 
/* find record in circular list and do optional move-to-front */
Agrec_t *aggetrec(void *obj, const char *name, int mtf)
{
    Agobj_t *hdr;
    Agrec_t *d, *first;
 
    hdr = obj;
    first = d = hdr->data;
    while (d && !streq(name, d->name)) {
        d = d->next;
        if (d == first)
            return NULL;
    }
    if (!d)
        return NULL;
 
    if (hdr->tag.mtflock) {
        if (mtf && hdr->data != d)
            agerrorf("move to front lock inconsistency");
    } else if (d != first || mtf != 0) {
        set_data(hdr, d, mtf != 0);     /* Always optimize */
    }
    return d;
}
 
/* insert the record in data list of this object (only) */
static void objputrec(Agobj_t * obj, void *arg)
{
    Agrec_t *firstrec, *newrec;
 
    newrec = arg;
    firstrec = obj->data;
    if (firstrec == NULL)
        newrec->next = newrec;  /* 0 elts */
    else {
        if (firstrec->next == firstrec) {
            firstrec->next = newrec;    /* 1 elt */
            newrec->next = firstrec;
        } else {
            newrec->next = firstrec->next;
            firstrec->next = newrec;
        }
    }
    if (!obj->tag.mtflock)
        set_data(obj, newrec, false);
}
 
/* attach a new record of the given size to the object.
 */
void *agbindrec(void *arg_obj, const char *recname, unsigned int recsize,
                int move_to_front)
{
    Agraph_t *g;
    Agobj_t *obj;
 
    obj = arg_obj;
    g = agraphof(obj);
    Agrec_t *rec = aggetrec(obj, recname, 0);
    if (rec == NULL && recsize > 0) {
        rec = gv_calloc(recsize, sizeof(char));
        rec->name = agstrdup(g, recname);
        objputrec(obj, rec);
    }
    if (move_to_front)
        aggetrec(arg_obj, recname, 1);
    return rec;
}
 
 
/* if obj points to rec, move its data pointer. break any mtf lock(?) */
static void objdelrec(Agraph_t * g, Agobj_t * obj, void *arg_rec)
{
    (void)g;
    Agrec_t *rec = arg_rec, *newrec;
    if (obj->data == rec) {
        if (rec->next == rec)
            newrec = NULL;
        else
            newrec = rec->next;
        set_data(obj, newrec, false);
    }
}
 
/* delete a record from a circular data list */
static void listdelrec(Agobj_t * obj, Agrec_t * rec)
{
    Agrec_t *prev;
 
    prev = obj->data;
    while (prev->next != rec) {
        prev = prev->next;
        assert(prev != obj->data);
    }
    /* following is a harmless no-op if the list is trivial */
    prev->next = rec->next;
}
 
int agdelrec(void *arg_obj, const char *name)
{
    Agobj_t *obj = arg_obj;
    Agraph_t *g = agraphof(obj);
    Agrec_t *rec = aggetrec(obj, name, 0);
    if (!rec)
        return FAILURE;
 
    listdelrec(obj, rec);       /* zap it from the circular list */
    switch (obj->tag.objtype) { /* refresh any stale pointers */
    case AGRAPH:
        objdelrec(g, obj, rec);
        break;
    case AGNODE:
    case AGINEDGE:
    case AGOUTEDGE:
        agapply(agroot(g), obj, objdelrec, rec, false);
        break;
    default:
        UNREACHABLE();
    }
    agstrfree(g, rec->name);
    free(rec);
 
    return SUCCESS;
}
 
static void simple_delrec(Agraph_t * g, Agobj_t * obj, void *rec_name)
{
    (void)g;
    agdelrec(obj, rec_name);
}
 
void aginit(Agraph_t * g, int kind, const char *rec_name, int arg_rec_size,
            int mtf) {
    Agnode_t *n;
    Agedge_t *e;
    Agraph_t *s;
    unsigned int rec_size;
    bool recur = arg_rec_size < 0; /* if recursive on subgraphs */
 
    rec_size = (unsigned int) abs(arg_rec_size);
    switch (kind) {
    case AGRAPH:
        agbindrec(g, rec_name, rec_size, mtf);
        if (recur)
                for (s = agfstsubg(g); s; s = agnxtsubg(s))
                        aginit(s,kind,rec_name,arg_rec_size,mtf);
        break;
    case AGNODE:
    case AGOUTEDGE:
    case AGINEDGE:
        for (n = agfstnode(g); n; n = agnxtnode(g, n))
            if (kind == AGNODE)
                agbindrec(n, rec_name, rec_size, mtf);
            else {
                for (e = agfstout(g, n); e; e = agnxtout(g, e))
                    agbindrec(e, rec_name, rec_size, mtf);
            }
        break;
    default:
        break;
    }
}
 
void agclean(Agraph_t * g, int kind, char *rec_name)
{
    Agnode_t *n;
    Agedge_t *e;
 
    switch (kind) {
    case AGRAPH:
        agapply(g, (Agobj_t *)g, simple_delrec, rec_name, true);
        break;
    case AGNODE:
    case AGOUTEDGE:
    case AGINEDGE:
        for (n = agfstnode(g); n; n = agnxtnode(g, n))
            if (kind == AGNODE)
                agdelrec(n, rec_name);
            else {
                for (e = agfstout(g, n); e; e = agnxtout(g, e))
                    agdelrec(e, rec_name);
            }
        break;
    default:
        break;
    }
}
 
void agrecclose(Agobj_t * obj)
{
    Agraph_t *g;
    Agrec_t *rec, *nrec;
 
    g = agraphof(obj);
    if ((rec = obj->data)) {
        do {
            nrec = rec->next;
            agstrfree(g, rec->name);
            free(rec);
            rec = nrec;
        } while (rec != obj->data);
    }
    obj->data = NULL;
}