X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=src%2Feventl.c;h=9e446119b4fa24c31b3b83083dc6f2f525b702e9;hb=ed886db22397360898fa5ef764543237e99b1774;hp=cc8a6b98c452f35ba5c5f142c8ff925dbcd2fd1a;hpb=235995289021a11b33312c91a55ccfbca605348b;p=pazpar2-moved-to-github.git diff --git a/src/eventl.c b/src/eventl.c index cc8a6b9..9e44611 100644 --- a/src/eventl.c +++ b/src/eventl.c @@ -1,12 +1,32 @@ +/* $Id: eventl.c,v 1.6 2007-04-20 11:43:43 adam Exp $ + Copyright (c) 2006-2007, Index Data. + +This file is part of Pazpar2. + +Pazpar2 is free software; you can redistribute it and/or modify it under +the terms of the GNU General Public License as published by the Free +Software Foundation; either version 2, or (at your option) any later +version. + +Pazpar2 is distributed in the hope that it will be useful, but WITHOUT ANY +WARRANTY; without even the implied warranty of MERCHANTABILITY or +FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License +for more details. + +You should have received a copy of the GNU General Public License +along with Pazpar2; see the file LICENSE. If not, write to the +Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA +02111-1307, USA. + */ + /* - * ParaZ - a simple tool for harvesting performance data for parallel - * operations using Z39.50. + * Based on ParaZ - a simple tool for harvesting performance data for + * parallel operations using Z39.50. * Copyright (c) 2000-2004 Index Data ApS * See LICENSE file for details. */ /* - * $Id: eventl.c,v 1.3 2007-03-28 12:05:18 marc Exp $ * Based on revision YAZ' server/eventl.c 1.29. */ @@ -17,7 +37,11 @@ #include #endif - +#ifdef WIN32 +#include +#else +#include +#endif #include #include #include @@ -26,13 +50,10 @@ #include #include #include -#include - #include "eventl.h" +#include - -IOCHAN iochan_create(int fd, struct sockaddr_in *addr_in, - IOC_CALLBACK cb, int flags) +IOCHAN iochan_create(int fd, IOC_CALLBACK cb, int flags) { IOCHAN new_iochan; @@ -40,14 +61,6 @@ IOCHAN iochan_create(int fd, struct sockaddr_in *addr_in, return 0; new_iochan->destroyed = 0; new_iochan->fd = fd; - - if(addr_in){ - new_iochan->addr_in.sin_family = addr_in->sin_family; - new_iochan->addr_in.sin_port = addr_in->sin_port; - new_iochan->addr_in.sin_addr = addr_in->sin_addr; - strncpy(new_iochan->addr_str, inet_ntoa(addr_in->sin_addr), 64); - } - new_iochan->flags = flags; new_iochan->fun = cb; new_iochan->force_event = 0; @@ -87,6 +100,8 @@ int event_loop(IOCHAN *iochans) FD_SET(p->fd, &except); if (p->fd > max) max = p->fd; + if (p->max_idle && p->max_idle < to.tv_sec) + to.tv_sec = p->max_idle; } if ((res = select(max + 1, &in, &out, &except, timeout)) < 0) {