#include "class.h"
#include "client.h"
#include "ircd.h"
+#include "ircd_alloc.h"
#include "ircd_reply.h"
#include "list.h"
#include "numeric.h"
#include "s_conf.h"
#include "s_debug.h"
#include "send.h"
-#include "struct.h"
#include <assert.h>
#define BAD_PING ((unsigned int)-2)
#define BAD_CLIENT_CLASS ((unsigned int)-3)
-struct ConfClass *classes;
+static struct ConnectionClass* connClassList;
+static unsigned int connClassAllocCount;
+
+const struct ConnectionClass* get_class_list(void)
+{
+ return connClassList;
+}
+
+struct ConnectionClass* make_class(void)
+{
+ struct ConnectionClass *tmp;
+
+ tmp = (struct ConnectionClass*) MyMalloc(sizeof(struct ConnectionClass));
+ assert(0 != tmp);
+ ++connClassAllocCount;
+ return tmp;
+}
+
+void free_class(struct ConnectionClass* p)
+{
+ if (p) {
+ assert(0 == p->valid);
+ MyFree(p);
+ --connClassAllocCount;
+ }
+}
+
+/*
+ * init_class - initialize the class list
+ */
+void init_class(void)
+{
+ connClassList = (struct ConnectionClass*) make_class();
+
+ ConClass(connClassList) = 0;
+ PingFreq(connClassList) = PINGFREQUENCY;
+ ConFreq(connClassList) = CONNECTFREQUENCY;
+ MaxLinks(connClassList) = MAXIMUM_LINKS;
+ MaxSendq(connClassList) = DEFAULTMAXSENDQLENGTH;
+ connClassList->valid = 1;
+ Links(connClassList) = 0;
+ connClassList->next = 0;
+}
+
+/*
+ * class_mark_delete - mark classes for delete
+ * We don't delete the class table, rather mark all entries
+ * for deletion. The table is cleaned up by class_delete_marked(). - avalon
+ * XXX - This destroys data
+ */
+void class_mark_delete(void)
+{
+ struct ConnectionClass* p;
+ assert(0 != connClassList);
+
+ for (p = connClassList->next; p; p = p->next)
+ p->valid = 0;
+}
+
+/*
+ * class_delete_marked
+ * delete classes marked for deletion
+ * XXX - memory leak, no one deletes classes that become unused
+ * later
+ */
+void class_delete_marked(void)
+{
+ struct ConnectionClass* cl;
+ struct ConnectionClass* prev;
+
+ Debug((DEBUG_DEBUG, "Class check:"));
+
+ for (prev = cl = connClassList; cl; cl = prev->next) {
+ Debug((DEBUG_DEBUG, "Class %d : CF: %d PF: %d ML: %d LI: %d SQ: %d",
+ ConClass(cl), ConFreq(cl), PingFreq(cl), MaxLinks(cl), Links(cl), MaxSendq(cl)));
+ /*
+ * unlink marked classes, delete unreferenced ones
+ */
+ if (cl->valid)
+ prev = cl;
+ else {
+ prev->next = cl->next;
+ if (0 == cl->ref_count)
+ free_class(cl);
+ }
+ }
+}
unsigned int get_conf_class(const struct ConfItem* aconf)
{
- if ((aconf) && (aconf->confClass))
+ if ((aconf) && (aconf->conn_class))
return (ConfClass(aconf));
Debug((DEBUG_DEBUG, "No Class For %s", (aconf) ? aconf->name : "*No Conf*"));
return (BAD_CONF_CLASS);
}
-unsigned int get_conf_ping(struct ConfItem *aconf)
+int get_conf_ping(const struct ConfItem* aconf)
{
- if ((aconf) && (aconf->confClass))
+ assert(0 != aconf);
+ if (aconf->conn_class)
return (ConfPingFreq(aconf));
- Debug((DEBUG_DEBUG, "No Ping For %s", (aconf) ? aconf->name : "*No Conf*"));
+ Debug((DEBUG_DEBUG, "No Ping For %s", aconf->name));
- return (BAD_PING);
+ return -1;
}
unsigned int get_client_class(struct Client *acptr)
{
struct SLink *tmp;
- struct ConfClass *cl;
+ struct ConnectionClass *cl;
unsigned int retc = BAD_CLIENT_CLASS;
if (acptr && !IsMe(acptr) && (acptr->confs))
for (tmp = acptr->confs; tmp; tmp = tmp->next)
{
- if (!tmp->value.aconf || !(cl = tmp->value.aconf->confClass))
+ if (!tmp->value.aconf || !(cl = tmp->value.aconf->conn_class))
continue;
if (ConClass(cl) > retc || retc == BAD_CLIENT_CLASS)
retc = ConClass(cl);
return (ping);
}
-unsigned int get_con_freq(struct ConfClass * clptr)
+unsigned int get_con_freq(struct ConnectionClass * clptr)
{
if (clptr)
return (ConFreq(clptr));
* immeadiately after the first one (class 0).
*/
void add_class(unsigned int conClass, unsigned int ping, unsigned int confreq,
- unsigned int maxli, unsigned int sendq)
+ unsigned int maxli, unsigned int sendq)
{
- struct ConfClass *t, *p;
+ struct ConnectionClass* t;
+ struct ConnectionClass* p;
t = find_class(conClass);
- if ((t == classes) && (conClass != 0))
+ if ((t == connClassList) && (conClass != 0))
{
- p = (struct ConfClass *) make_class();
- NextClass(p) = NextClass(t);
- NextClass(t) = p;
+ p = (struct ConnectionClass *) make_class();
+ p->next = t->next;
+ t->next = p;
}
else
p = t;
- Debug((DEBUG_DEBUG, "Add Class %u: p %p t %p - cf: %u pf: %u ml: %u sq: %d",
- conClass, p, t, confreq, ping, maxli, sendq));
+ Debug((DEBUG_DEBUG, "Add Class %u: cf: %u pf: %u ml: %u sq: %d",
+ conClass, confreq, ping, maxli, sendq));
ConClass(p) = conClass;
ConFreq(p) = confreq;
PingFreq(p) = ping;
MaxLinks(p) = maxli;
MaxSendq(p) = (sendq > 0) ? sendq : DEFAULTMAXSENDQLENGTH;
+ p->valid = 1;
if (p != t)
Links(p) = 0;
}
-struct ConfClass *find_class(unsigned int cclass)
+struct ConnectionClass* find_class(unsigned int cclass)
{
- struct ConfClass *cltmp;
+ struct ConnectionClass *cltmp;
- for (cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp))
+ for (cltmp = connClassList; cltmp; cltmp = cltmp->next) {
if (ConClass(cltmp) == cclass)
return cltmp;
- return classes;
-}
-
-void check_class(void)
-{
- struct ConfClass *cltmp, *cltmp2;
-
- Debug((DEBUG_DEBUG, "Class check:"));
-
- for (cltmp2 = cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp2))
- {
- Debug((DEBUG_DEBUG,
- "Class %d : CF: %d PF: %d ML: %d LI: %d SQ: %d",
- ConClass(cltmp), ConFreq(cltmp), PingFreq(cltmp),
- MaxLinks(cltmp), Links(cltmp), MaxSendq(cltmp)));
- if (IsMarkedDelete(cltmp))
- {
- NextClass(cltmp2) = NextClass(cltmp);
- if (Links(cltmp) == 0)
- free_class(cltmp);
- }
- else
- cltmp2 = cltmp;
}
-}
-
-void initclass(void)
-{
- classes = (struct ConfClass *) make_class();
-
- ConClass(FirstClass()) = 0;
- ConFreq(FirstClass()) = CONNECTFREQUENCY;
- PingFreq(FirstClass()) = PINGFREQUENCY;
- MaxLinks(FirstClass()) = MAXIMUM_LINKS;
- MaxSendq(FirstClass()) = DEFAULTMAXSENDQLENGTH;
- Links(FirstClass()) = 0;
- NextClass(FirstClass()) = NULL;
+ return connClassList;
}
void report_classes(struct Client *sptr)
{
- struct ConfClass *cltmp;
+ struct ConnectionClass *cltmp;
- for (cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp))
+ for (cltmp = connClassList; cltmp; cltmp = cltmp->next)
send_reply(sptr, RPL_STATSYLINE, 'Y', ConClass(cltmp), PingFreq(cltmp),
- ConFreq(cltmp), MaxLinks(cltmp), MaxSendq(cltmp));
+ ConFreq(cltmp), MaxLinks(cltmp), MaxSendq(cltmp),
+ Links(cltmp));
}
unsigned int get_sendq(struct Client *cptr)
else if (cptr->confs) {
struct SLink* tmp;
- struct ConfClass* cl;
+ struct ConnectionClass* cl;
for (tmp = cptr->confs; tmp; tmp = tmp->next) {
- if (!tmp->value.aconf || !(cl = tmp->value.aconf->confClass))
+ if (!tmp->value.aconf || !(cl = tmp->value.aconf->conn_class))
continue;
if (ConClass(cl) != BAD_CLIENT_CLASS) {
cptr->max_sendq = MaxSendq(cl);
return DEFAULTMAXSENDQLENGTH;
}
+void class_send_meminfo(struct Client* cptr)
+{
+ send_reply(cptr, SND_EXPLICIT | RPL_STATSDEBUG, ":Classes: inuse: %d(%d)",
+ connClassAllocCount, connClassAllocCount * sizeof(struct ConnectionClass));
+}
+
+
projects / ircu2.10.12-pk.git / blobdiff