summaryrefslogtreecommitdiff
path: root/server
diff options
context:
space:
mode:
authorGravatar Jeffrey Hutzelman <jhutz@cmu.edu>2013-01-04 16:33:59 -0500
committerGravatar Jeffrey Hutzelman <jhutz@cmu.edu>2013-02-17 22:34:40 -0500
commit3923d414d0408e2f33dff220c5964b36e28565ba (patch)
tree43c7518b25eb340cc1a41e6c4d017507ac893046 /server
parent854948b8a897cfc2791c8823922b4600668445b1 (diff)
Make otherrealms be an array of pointers
The server keeps pointers to realms in non-ephemeral data structures, such as triplet subscriber lists. Thus, we cannot move existing realms around in memory without causing data corruption. However, dynamic reloading of the realm.list means new realms can appear, which sooner or later will mean reallocating the otherrealms array to make room for more realms. Therefore, to allow otherrealms to be reallocated without changing the addresses of existing realms, otherrealms is converted from an array of realms to an array of pointers to realms.
Diffstat (limited to 'server')
-rw-r--r--server/realm.c94
-rw-r--r--server/server.c3
-rw-r--r--server/zserver.h4
3 files changed, 54 insertions, 47 deletions
diff --git a/server/realm.c b/server/realm.c
index 68502d6..6b84e05 100644
--- a/server/realm.c
+++ b/server/realm.c
@@ -3,7 +3,7 @@
Unacked *rlm_nacklist = NULL; /* not acked list for realm-realm
packets */
-ZRealm *otherrealms; /* points to an array of the known
+ZRealm **otherrealms; /* points to an array of the known
servers */
int nrealms = 0; /* number of other realms */
@@ -127,7 +127,6 @@ realm_next_idx_by_idx(realm, idx)
const char *
realm_expand_realm(char *realmname)
{
- ZRealm *realm;
int a;
/* First, look for an exact match (case insensitive) */
@@ -136,9 +135,9 @@ realm_expand_realm(char *realmname)
return(ZGetRealm());
#endif
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (!strcasecmp(realm->name, realmname))
- return(realm->name);
+ for (a = 0; a < nrealms; a++)
+ if (!strcasecmp(otherrealms[a]->name, realmname))
+ return(otherrealms[a]->name);
/* No exact match. See if there's a partial match */
#if defined(HAVE_KRB4) || defined(HAVE_KRB5)
@@ -146,21 +145,20 @@ realm_expand_realm(char *realmname)
return(ZGetRealm());
#endif
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (!strncasecmp(realm->name, realmname, strlen(realmname)))
- return(realm->name);
+ for (a = 0; a < nrealms; a++)
+ if (!strncasecmp(otherrealms[a]->name, realmname, strlen(realmname)))
+ return(otherrealms[a]->name);
return(realmname);
}
ZRealm *
realm_get_realm_by_pid(int pid)
{
- ZRealm *realm;
int a;
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (realm->child_pid == pid)
- return(realm);
+ for (a = 0; a < nrealms; a++)
+ if (otherrealms[a]->child_pid == pid)
+ return(otherrealms[a]);
return 0;
}
@@ -168,12 +166,11 @@ realm_get_realm_by_pid(int pid)
void
kill_realm_pids(void)
{
- ZRealm *realm;
int a;
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (realm->child_pid != 0)
- kill(realm->child_pid, 9);
+ for (a = 0; a < nrealms; a++)
+ if (otherrealms[a]->child_pid != 0)
+ kill(otherrealms[a]->child_pid, 9);
return;
}
@@ -279,7 +276,7 @@ realm_send_realms(void)
{
int cnt, retval;
for (cnt = 0; cnt < nrealms; cnt++) {
- retval = subscr_send_realm_subs(&otherrealms[cnt]);
+ retval = subscr_send_realm_subs(otherrealms[cnt]);
if (retval != ZERR_NONE)
return(retval);
}
@@ -325,7 +322,6 @@ realm_sender_in_realm(const char *realm, char *sender)
ZRealm *
realm_which_realm(struct sockaddr_in *who)
{
- ZRealm *realm;
ZRealm_server *srvr;
int a, b;
@@ -333,13 +329,15 @@ realm_which_realm(struct sockaddr_in *who)
return 0;
/* loop through the realms */
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
+ for (a = 0; a < nrealms; a++)
/* loop through the addresses for the realm */
- for (srvr = realm->srvrs, b = 0; b < realm->count; b++, srvr++) {
+ for (srvr = otherrealms[a]->srvrs, b = 0;
+ b < otherrealms[a]->count;
+ b++, srvr++) {
if (!srvr->usable)
continue;
if (srvr->addr.sin_addr.s_addr == who->sin_addr.s_addr)
- return(realm);
+ return(otherrealms[a]);
}
return 0;
@@ -349,17 +347,16 @@ ZRealm *
realm_get_realm_by_name(char *name)
{
int a;
- ZRealm *realm;
/* First, look for an exact match (case insensitive) */
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (!strcasecmp(realm->name, name))
- return(realm);
+ for (a = 0; a < nrealms; a++)
+ if (!strcasecmp(otherrealms[a]->name, name))
+ return(otherrealms[a]);
/* Failing that, look for an inexact match */
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (!strncasecmp(realm->name, name, strlen(name)))
- return(realm);
+ for (a = 0; a < nrealms; a++)
+ if (!strncasecmp(otherrealms[a]->name, name, strlen(name)))
+ return(otherrealms[a]);
return 0;
}
@@ -368,10 +365,10 @@ ZRealm *
realm_get_realm_by_name_string(String *z)
{
int a;
- ZRealm *realm;
- for (realm = otherrealms, a = 0; a < nrealms; a++, realm++)
- if (realm->namestr == z) return realm;
+ for (a = 0; a < nrealms; a++)
+ if (otherrealms[a]->namestr == z)
+ return otherrealms[a];
return 0;
}
@@ -393,7 +390,7 @@ rlm_nack_cancel(register ZNotice_t *notice,
}
for (nacked = rlm_nacklist; nacked; nacked = nacked->next) {
- if (&otherrealms[nacked->dest.rlm.rlm_idx] == which) {
+ if (nacked->dest.rlm.realm == which) {
/* First, note the realm appears to be up */
which->state = REALM_UP;
if (ZCompareUID(&nacked->uid, &notice->z_uid)) {
@@ -532,15 +529,22 @@ realm_init(void)
for (nrealms = 0; rlmnames[nrealms].name; nrealms++);
- otherrealms = (ZRealm *)malloc(nrealms * sizeof(ZRealm));
+ otherrealms = (ZRealm **)malloc(nrealms * sizeof(ZRealm *));
if (!otherrealms) {
syslog(LOG_CRIT, "malloc failed in realm_init");
abort();
}
- memset(otherrealms, 0, (nrealms * sizeof(ZRealm)));
+ memset(otherrealms, 0, (nrealms * sizeof(ZRealm *)));
for (ii = 0; ii < nrealms; ii++) {
- rlm = &otherrealms[ii];
+ rlm = (ZRealm *) malloc(sizeof(ZRealm));
+ if (!rlm) {
+ syslog(LOG_CRIT, "malloc failed in realm_init");
+ abort();
+ }
+ memset(rlm, 0, sizeof(ZRealm));
+ otherrealms[ii] = rlm;
+
rlm->namestr = rlmnames[ii].name;
rlm->name = rlm->namestr->string;
@@ -604,12 +608,13 @@ realm_deathgram(Server *server)
int jj = 0;
/* Get it out once, and assume foreign servers will share */
- for (realm = otherrealms, jj = 0; jj < nrealms; jj++, realm++) {
+ for (jj = 0; jj < nrealms; jj++) {
ZNotice_t snotice;
char *pack;
char rlm_recipient[REALM_SZ + 1];
int packlen, retval;
+ realm = otherrealms[jj];
memset (&snotice, 0, sizeof (snotice));
snotice.z_kind = ACKED;
@@ -671,12 +676,13 @@ realm_wakeup(void)
if (nservers < 2 || !found) {
/* if we're the only server up, send a REALM_BOOT to one of their
servers here */
- for (realm = otherrealms, jj = 0; jj < nrealms; jj++, realm++) {
+ for (jj = 0; jj < nrealms; jj++) {
ZNotice_t snotice;
char *pack;
char rlm_recipient[REALM_SZ + 1];
int packlen, retval;
+ realm = otherrealms[jj];
memset (&snotice, 0, sizeof (snotice));
snotice.z_opcode = REALM_BOOT;
@@ -979,7 +985,7 @@ realm_sendit(ZNotice_t *notice,
memset(nacked, 0, sizeof(Unacked));
nacked->packet = pack;
- nacked->dest.rlm.rlm_idx = realm - otherrealms;
+ nacked->dest.rlm.realm = realm;
nacked->dest.rlm.rlm_srv_idx = realm->idx;
nacked->packsz = packlen;
nacked->uid = notice->z_uid;
@@ -1018,7 +1024,7 @@ rlm_rexmit(void *arg)
zdbug((LOG_DEBUG,"rlm_rexmit"));
- realm = &otherrealms[nackpacket->dest.rlm.rlm_idx];
+ realm = nackpacket->dest.rlm.realm;
zdbug((LOG_DEBUG, "rlm_rexmit: sending to %s:%d (%d)",
realm->name, realm->idx, nackpacket->rexmits));
@@ -1094,13 +1100,13 @@ realm_dump_realms(FILE *fp)
register int ii, jj;
for (ii = 0; ii < nrealms; ii++) {
- (void) fprintf(fp, "%d:%s\n", ii, otherrealms[ii].name);
- for (jj = 0; jj < otherrealms[ii].count; jj++) {
+ (void) fprintf(fp, "%d:%s\n", ii, otherrealms[ii]->name);
+ for (jj = 0; jj < otherrealms[ii]->count; jj++) {
(void) fprintf(fp, "\t%s\n",
- inet_ntoa(otherrealms[ii].srvrs[jj].addr.sin_addr));
+ inet_ntoa(otherrealms[ii]->srvrs[jj].addr.sin_addr));
}
/* dump the subs */
- subscr_dump_subs(fp, otherrealms[ii].subs);
+ subscr_dump_subs(fp, otherrealms[ii]->subs);
}
}
@@ -1119,7 +1125,7 @@ realm_auth_sendit_nacked(char *buffer, int packlen, ZRealm *realm,
memset(nacked, 0, sizeof(Unacked));
nacked->packet = buffer;
- nacked->dest.rlm.rlm_idx = realm - otherrealms;
+ nacked->dest.rlm.realm = realm;
nacked->dest.rlm.rlm_srv_idx = realm->idx;
nacked->packsz = packlen;
nacked->uid = uid;
diff --git a/server/server.c b/server/server.c
index 88d2555..2983cf6 100644
--- a/server/server.c
+++ b/server/server.c
@@ -760,7 +760,8 @@ send_stats(struct sockaddr_in *who)
otherservers[i].dumping ? " (DUMPING)" : "");
responses[num_resp++] = strsave(buf);
}
- for (realm = otherrealms, i = 0; i < nrealms ; i++, realm++) {
+ for (i = 0; i < nrealms ; i++) {
+ realm = otherrealms[i];
sprintf(buf, "%s(%s)/%s", realm->name,
inet_ntoa((realm->srvrs[realm->idx].addr).sin_addr),
rlm_states[(int) realm->state]);
diff --git a/server/zserver.h b/server/zserver.h
index 6cefe5d..fc6f847 100644
--- a/server/zserver.h
+++ b/server/zserver.h
@@ -176,7 +176,7 @@ struct _Unacked {
struct sockaddr_in addr; /* client address */
int srv_idx; /* index of server */
struct {
- int rlm_idx; /* index of realm */
+ ZRealm *realm; /* pointer to realm */
int rlm_srv_idx; /* index of server in realm */
} rlm;
} dest;
@@ -442,7 +442,7 @@ extern int nservers; /* number of other servers*/
extern String *empty;
extern String *wildcard_instance;
-extern ZRealm *otherrealms;
+extern ZRealm **otherrealms;
extern int nrealms;