#include "IRCEvents.h"
static struct ChanNode **chanList;
+#ifdef HAVE_THREADS
+pthread_mutex_t cache_sync;
+#endif
void init_ChanNode() {
+ THREAD_MUTEX_INIT(cache_sync);
/*
len pos chars
26 0 a-z
}
void free_ChanNode() {
+ SYNCHRONIZE(cache_sync);
//kamikaze free all channels and chanusers
int i;
struct ChanNode *chan, *next;
}
}
free(chanList);
+ DESYNCHRONIZE(cache_sync);
}
int is_valid_chan(const char *name) {
cindex++;
if(cindex >= CHANNEL_LIST_SIZE) return NULL;
return chanList[cindex];
- } else
+ } else {
return last->next;
+ }
}
struct ChanNode* getChanByName(const char *name) { //case insensitive
chan->modes = createModeNode(chan);
chan->trigger = NULL;
+ SYNCHRONIZE(cache_sync);
chan->next = chanList[chanListIndex];
chanList[chanListIndex] = chan;
+ DESYNCHRONIZE(cache_sync);
return chan;
}
void delChannel(struct ChanNode* chan, int freeChan) {
int chanListIndex = get_chanlist_entry(chan->name[1]);
if(chanListIndex == -1) return;
+ SYNCHRONIZE(cache_sync);
struct ChanNode *cchan, *last_chan = NULL;
for(cchan = chanList[chanListIndex]; cchan; cchan = cchan->next) {
if(cchan == chan) {
freeChanNode(chan);
else
chan->next = NULL;
+ DESYNCHRONIZE(cache_sync);
}
void freeChanNode(struct ChanNode* chan) {
}
}
//free the channel...
+ SYNCHRONIZE(cache_sync);
for(chanuser = getChannelUsers(chan, NULL); chanuser; chanuser = next) {
next = getChannelUsers(chan, chanuser);
//remove the channel from the user's channel-list
}
chan->user = NULL;
delChannel(chan, 1);
+ DESYNCHRONIZE(cache_sync);
return 0;
}