void KqueueFDMultiplexer::addFD(callbackmap_t& cbmap, int fd, callbackfunc_t toDo, const boost::any& parameter)
{
- cerr<<"called\n";
accountingAddFD(cbmap, fd, toDo, parameter);
struct kevent kqevent;
return 0;
}
+#if 0
void acceptData(int fd, boost::any& parameter)
{
cout<<"Have data on fd "<<fd<<endl;
cout<<"Received "<<packet.size()<<" bytes!\n";
}
-#if 0
int main()
{
Socket s(InterNetwork, Datagram);
len=recvfrom(fd, data, sizeof(data), 0, (sockaddr *)&fromaddr, &addrlen);
-
if(len < (int)sizeof(dnsheader)) {
if(len < 0)
- cerr<<"Error on fd "<<fd<<": "<<stringerror()<<"\n";
+ ; // cerr<<"Error on fd "<<fd<<": "<<stringerror()<<"\n";
else {
g_stats.serverParseError++;
if(g_logCommonErrors)
}
}
}
+ else
+ g_udpclientsocks.returnSocket(fd);
}
else
L<<Logger::Warning<<"Ignoring question on outgoing socket from "<< sockAddrToString((struct sockaddr_in*) &fromaddr, addrlen) <<endl;