rrdp
rrdp_publish_file(struct rrdp *s, struct publish_xml *pxml,
static struct rrdp *
struct rrdp *s;
rrdp_free(struct rrdp *s)
rrdp_finished(struct rrdp *s)
rrdp_data_handler(struct rrdp *s)
struct rrdp *s = NULL;
TAILQ_ENTRY(rrdp) entry;
rp->rrdp = rrdp_get(notify);
if (rp->rrdp == NULL)
} else if (rp->rrdp) {
path = rrdp_filename(rp->rrdp, rp->repouri, 0);
!(rp->rrdp == NULL && rp->rsync == NULL && rp->ta == NULL))
if (rp->rrdp != NULL)
else if (rp->rrdp)
rrdp_finish(rp->rrdp->id, 0);
} else if (rp->rrdp) {
rrdp_abort(rp->rrdp->id);
if (rp->rrdp == NULL)
rr = (struct rrdprepo *)rp->rrdp;
if (rp != NULL && rp->rrdp != NULL)
return rp->rrdp->state == REPO_DONE ? rp->rrdp : NULL;
if (rp->rrdp)
return rp->rrdp->state;
if (vp != rp->ta && vp != rp->rsync && vp != rp->rrdp)
if (vp == rp->rrdp && !ok && !nofetch) {
rp->rrdp = NULL;
if (rp->rrdp == NULL)
if (strcmp(dir, rp->rrdp->basedir) == 0)
if (rp->rrdp != rr)
const struct rrdprepo *rrdp;
rrdp_state_send(struct rrdp *s)
rrdp_clear_repo(struct rrdp *s)
rrdp_publish_file(struct rrdp *s, struct publish_xml *pxml,
struct rrdp *s;
rrdp_free(struct rrdp *s)
static struct rrdp *
struct rrdp *s;
rrdp_failed(struct rrdp *s)
rrdp_finished(struct rrdp *s)
rrdp_abort_req(struct rrdp *s)
struct rrdp *s;
rrdp_data_handler(struct rrdp *s)
TAILQ_ENTRY(rrdp) entry;
struct rrdp *s, *ns;
static TAILQ_HEAD(, rrdp) states = TAILQ_HEAD_INITIALIZER(states);
struct rrdp;
void rrdp_publish_file(struct rrdp *, struct publish_xml *,
int publish_done(struct rrdp *, struct publish_xml *);
struct rrdp *);
struct rrdp *);
if (publish_done(dxml->rrdp, dxml->pxml) != 0)
new_delta_xml(XML_Parser p, struct rrdp_session *rs, struct rrdp *r)
dxml->rrdp = r;
struct rrdp *rrdp;
if (publish_done(sxml->rrdp, sxml->pxml) != 0)
new_snapshot_xml(XML_Parser p, struct rrdp_session *rs, struct rrdp *r)
sxml->rrdp = r;
struct rrdp *rrdp;
publish_done(struct rrdp *s, struct publish_xml *pxml)