GitHub-Mirror/NeoStats
Archived
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

FIRSTKEY and NEXTKEY on perl interface for namedvars fixed (NEO-373 NEO-375 and NEO-372)

Browse source
This commit is contained in:
Fish 2007-07-23 04:04:54 +00:00
parent 62f2d1ff78
commit 13691332f4
4 changed files with 35 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
include/namedvars.h
View file

@ -110,6 +110,7 @@ typedef struct nv_list {
struct hscan_t hscan;
struct lnode_t *node;
} iter;
int itercount;
} nv_list;
extern hash_t *namedvars;

20
modules/perltest/test.pl
View file

@ -117,15 +117,23 @@ sub event_pong {
# NeoStats::debug("$key => $value");
# }
#
my $hostserv = new NeoStats::NV("HostServ");
# my $hashtest = $hostserv->{1};
# Dump($hostserv);
while ( my ($key, $value) = each(%$hostserv)) {
NeoStats::debug("Hostserv Key => $value");
while ( my ($key1, $value1) = each(%$key)) {
my $servers = new NeoStats::NV("Servers");
while ( my ($key, $value) = each(%$servers)) {
NeoStats::debug("Hostserv Key => $value, $key");
while ( my ($key1, $value1) = each(%$value)) {
NeoStats::debug("HS: $key: $key1 => $value1");
}
}
my $hostserv = new NeoStats::NV("HostServ");
# my $hashtest = $hostserv->{1};
while ( my ($key, $value) = each(%$hostserv)) {
NeoStats::debug("Hostserv Key => $value, $key");
while ( my ($key1, $value1) = each(%$value)) {
NeoStats::debug("HS: $key: $key1 => $value1");
}
}
# Dump($hostserv);
# NeoStats::debug("Debug HostServ: ".$hostserv." Ok");
# Dump($hostserv);
# NeoStats::debug("Var: HostServ".$hostserv->{0}."Fin");

40
src/NV.xs
View file

@ -174,9 +174,7 @@ CODE:
lnode = list_first((list_t *)nv->data);;
for (i = 0; i == pos; i++) {
lnode = list_next((list_t *)nv->data, lnode);
printf("iter\n");
}
printf("%d %d\n", i, pos);
if (lnode) {
RETVAL = perl_encode_namedvars(nv, lnode_get(lnode));
} else
@ -212,7 +210,7 @@ CODE:
/* make sure its a hash, not a list */
if (nv->type == NV_TYPE_HASH) {
nlog(LOG_WARNING, "NamedVars is not a hash?!?!");
} else {
} else if (nv->type == NV_TYPE_LIST) {
k = SvPV(key, klen);
perl_store_namedvars(nv, k, value);
}
@ -263,7 +261,7 @@ OUTPUT:
#/* get the first entry from a hash */
HV*
SV*
FIRSTKEY(self)
SV *self;
PREINIT:
@ -272,7 +270,7 @@ PREINIT:
nv_list *nv;
hnode_t *node;
CODE:
RETVAL = (HV *)-1;
RETVAL = &PL_sv_undef;
hash = (HV*)SvRV(self);
mg = mg_find(SvRV(self),'~');
if(!mg) { croak("lost ~ magic"); }
@ -281,14 +279,16 @@ CODE:
if (nv->type == NV_TYPE_HASH) {
hash_scan_begin( &nv->iter.hscan, (hash_t *)nv->data);
node = hash_scan_next(&nv->iter.hscan);
nv->itercount = 0;
if (!node) {
RETVAL = (HV *)-1;
RETVAL = &PL_sv_undef;
} else {
RETVAL = perl_encode_namedvars(nv, hnode_get(node));
RETVAL = newSVpv(hnode_getkey(node), 0);
}
} else if (nv->type == NV_TYPE_LIST) {
nv->iter.node = list_first((list_t *)nv->data);
RETVAL = perl_encode_namedvars(nv, lnode_get(nv->iter.node));
nv->itercount = 0;
RETVAL = newSVpv("0", 0);
}
POSTCALL:
RETURN_UNDEF_IF_FAIL;
@ -297,7 +297,7 @@ OUTPUT:
#/* get the next entry from a cache */
HV*
SV*
NEXTKEY(self, lastkey)
SV *self;
PREINIT:
@ -305,8 +305,9 @@ PREINIT:
MAGIC *mg;
hnode_t *node;
nv_list *nv;
char tmpstr[BUFSIZE];
CODE:
RETVAL = (HV *)-1;
RETVAL = &PL_sv_undef;
hash = (HV*)SvRV(self);
mg = mg_find(SvRV(self),'~');
if(!mg) { croak("lost ~ magic"); }
@ -314,21 +315,20 @@ CODE:
/* make sure its a hash, not a list */
if (nv->type == NV_TYPE_HASH) {
node = hash_scan_next(&nv->iter.hscan);
nv->itercount++;
if (!node) {
RETVAL = (HV *)-1;
RETVAL = &PL_sv_undef;
} else {
RETVAL = perl_encode_namedvars(nv, hnode_get(node));
RETVAL = newSVpv(hnode_getkey(node), 0);
}
} else if (nv->type == NV_TYPE_LIST) {
if (nv->iter.node) {
nv->iter.node = list_next((list_t *)nv->data, nv->iter.node);
if (nv->iter.node)
RETVAL = perl_encode_namedvars(nv, lnode_get(nv->iter.node));
else
RETVAL = (HV *)-1;
nv->itercount++;
if (nv->itercount >= list_count((list_t *)nv->data)) {
RETVAL = &PL_sv_undef;
} else {
RETVAL = (HV *)-1;
}
ircsnprintf(tmpstr, BUFSIZE, "%d", nv->itercount);
RETVAL =newSVpv(tmpstr,0);
}
}
POSTCALL:
RETURN_UNDEF_IF_FAIL;

1
src/namedvars.c
View file

@ -301,7 +301,6 @@ void nv_printstruct(void *data, nv_list *item) {
}
}
int nv_update_structure (nv_list *data, nv_item *item, nv_write_action action) {
int i, j;
/* first, determine if the structure allows updates */