Mercurial > pidgin
view src/protocols/icq/timeout.c @ 6928:6ed0a1c045b4
[gaim-migrate @ 7475]
Added support for invisible plugins.
committer: Tailor Script <tailor@pidgin.im>
author | Christian Hammond <chipx86@chipx86.com> |
---|---|
date | Wed, 24 Sep 2003 01:28:33 +0000 |
parents | 424a40f12a6c |
children |
line wrap: on
line source
/* -*- Mode: C; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ /* * $Id: timeout.c 2096 2001-07-31 01:00:39Z warmenhoven $ * * Copyright (C) 1998-2001, Denis V. Dmitrienko <denis@null.net> and * Bill Soudan <soudan@kde.org> * * This program 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 of the License, or * (at your option) any later version. * * This program 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 this program; if not, write to the Free Software * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. * */ #include <stdlib.h> #include "timeout.h" icq_Timeout *icq_CurrentTimeout = NULL; icq_List *icq_TimeoutList = NULL; void (*icq_SetTimeout)(long length); int icq_TimeoutCompare(icq_Timeout *t1, icq_Timeout *t2) { return (t1->expire_time - t2->expire_time); } icq_Timeout *icq_TimeoutNew(int length, icq_TimeoutHandler handler, void *data) { icq_Timeout *t = (icq_Timeout *)malloc(sizeof(icq_Timeout)); if (t) { int count = icq_TimeoutList->count; t->length = length; t->handler = handler; t->data = data; t->expire_time = time(NULL) + length; t->single_shot = 1; icq_ListInsertSorted(icq_TimeoutList, t); if (count == 0) icq_TimeoutDoNotify(); } return t; } void icq_TimeoutDelete(icq_Timeout *timeout) { icq_ListRemove(icq_TimeoutList, timeout); /* if this was the timeout we were currently waiting on, move on * to the next */ if (icq_CurrentTimeout == timeout) { icq_CurrentTimeout = NULL; icq_TimeoutDoNotify(); } free(timeout); } int _icq_HandleTimeout1(void *p, va_list data) { icq_Timeout *t = p; int complete = 0; time_t current_time = va_arg(data, time_t); icq_List *expired_timeouts = va_arg(data, icq_List *); (void)data; if (t->expire_time <= current_time) icq_ListEnqueue(expired_timeouts, t); else /* traversal is complete when we reach an expire time in the future */ complete = 1; return complete; } int _icq_HandleTimeout2(void *p, va_list data) { icq_Timeout *t = p; (void)data; /* maybe a previously executed timeout caused us to be deleted, so * make sure we're still around */ if (icq_ListFind(icq_TimeoutList, t)) (t->handler)(t->data); return 0; /* traverse entire list */ } int _icq_HandleTimeout3(void *p, va_list data) { icq_Timeout *t = p; int complete = 0; time_t current_time = va_arg(data, time_t); if (t->expire_time <= current_time) { if (t->single_shot) icq_TimeoutDelete(t); else t->expire_time = current_time + t->length; } else /* traversal is complete when we reach an expire time in the future */ complete = 1; return complete; } void icq_HandleTimeout() { time_t current_time = time(NULL); icq_List *expired_timeouts = icq_ListNew(); icq_CurrentTimeout = NULL; /* these three operations must be split up for the case where a * timeout function causes timers to be deleted - this ensures * we don't try to free any timers that have already been removed * or corrupt the list traversal process */ /* determine which timeouts that have expired */ icq_ListTraverse(icq_TimeoutList, _icq_HandleTimeout1, current_time, expired_timeouts); /* call handler function for expired timeouts */ icq_ListTraverse(expired_timeouts, _icq_HandleTimeout2); /* delete any expired timeouts */ icq_ListTraverse(icq_TimeoutList, _icq_HandleTimeout3, current_time); /* if there's any timeouts left, notify the library client */ if (icq_TimeoutList->count) icq_TimeoutDoNotify(); icq_ListDelete(expired_timeouts, NULL); } void icq_TimeoutDoNotify() { time_t length, current_time = time(NULL); if (!icq_TimeoutList->count) { if (icq_SetTimeout) (*icq_SetTimeout)(0); return; } icq_CurrentTimeout = (icq_Timeout *)icq_ListFirst(icq_TimeoutList); length = icq_CurrentTimeout->expire_time - current_time; if (icq_SetTimeout) (*icq_SetTimeout)(length); }