head 1.31; access; symbols PTH_2_0_7:1.30 PTH_2_0_6:1.29 PTH_2_0_5:1.29 PTH_2_0_4:1.29 PTH_2_0_3:1.28 PTH_2_0_2:1.27 PTH_2_0_1:1.27 PTH_2_0_0:1.26 PTH_2_0b2:1.25 PTH_2_0b1:1.25 PTH_2_0b0:1.25 PTH_1_4:1.22.0.2 PTH_1_4_1:1.22 PTH_1_4_0:1.21 PTH_1_3_7:1.19 PTH_1_4a3:1.20 PTH_1_3_6:1.19 PTH_1_4a2:1.20 PTH_1_3_5:1.19 PTH_1_4a1:1.20 PTH_1_3_4:1.19 PTH_1_3:1.19.0.2 PTH_1_3_3:1.19 PTH_1_3_2:1.19 PTH_1_3_1:1.19 PTH_1_3_0:1.19 PTH_1_3b3:1.19 PTH_1_2_3:1.16.2.1 PTH_1_3b2:1.19 PTH_1_3b1:1.19 PTH_1_3a5:1.19 PTH_1_3a4:1.19 PTH_1_3a3:1.19 PTH_1_2_2:1.16.2.1 PTH_1_3a2:1.19 PTH_1_2_1:1.16.2.1 PTH_1_3a1:1.17 PTH_1_2:1.16.0.2 PTH_1_2_0:1.16 PTH_1_2b8:1.15 PTH_1_2b7:1.15 PTH_1_1_6:1.14 PTH_1_2b6:1.15 PTH_1_2b5:1.15 PTH_1_2b4:1.15 PTH_1_2b3:1.15 PTH_1_2b2:1.14 PTH_1_2b1:1.14 PTH_1_1_5:1.14 PTH_1_0_6:1.11.2.1 PTH_1_0_5:1.11.2.1 PTH_1_0:1.11.0.2 PTH_1_1:1.14.0.2 PTH_1_1_4:1.14 PTH_1_1_3:1.14 PTH_1_1_2:1.14 PTH_1_1_1:1.14 PTH_1_1_0:1.14 PTH_1_1b7:1.13 PTH_1_1b6:1.13 PTH_1_1b5:1.13 PTH_1_1b4:1.12 PTH_1_1b3:1.12 PTH_1_1b2:1.12 PTH_1_1b1:1.11 PTH_1_0_4:1.11 PTH_1_0_3:1.11 PTH_1_0_2:1.11 PTH_1_0_1:1.11 PTH_1_0_0:1.11 PTH_1_0b8:1.11 PTH_1_0b7:1.11 PTH_1_0b6:1.11 PTH_1_0b5:1.11 PTH_1_0b4:1.11 PTH_1_0b3:1.9 PTH_1_0b2:1.9 PTH_1_0b1:1.8 PTH_0_9_21:1.8 PTH_0_9_20:1.7 PTH_0_9_19:1.6 PTH_0_9_18:1.6 PTH_0_9_17:1.6 PTH_0_9_16:1.6 PTH_0_9_15:1.6 PTH_0_9_14:1.6 PTH_0_9_13:1.6 PTH_0_9_12:1.5 PTH_0_9_11:1.5 PTH_0_9_10:1.5 PTH_0_9_9:1.4 PTH_0_9_8:1.4 PTH_0_9_7:1.3 PTH_0_9_6:1.3 PTH_0_9_5:1.2 PTH_0_9_4:1.1; locks; strict; comment @ * @; 1.31 date 2007.01.01.18.23.53; author rse; state Exp; branches; next 1.30; commitid 9DhdiirNzQPBIP0s; 1.30 date 2006.06.08.17.54.53; author rse; state Exp; branches; next 1.29; commitid x8N3mLVdQgkbdeAr; 1.29 date 2004.12.31.19.34.45; author rse; state Exp; branches; next 1.28; 1.28 date 2004.10.18.19.35.45; author rse; state Exp; branches; next 1.27; 1.27 date 2004.07.13.10.50.49; author rse; state Exp; branches; next 1.26; 1.26 date 2003.01.01.15.49.12; author rse; state Exp; branches; next 1.25; 1.25 date 2002.10.24.15.21.14; author rse; state Exp; branches; next 1.24; 1.24 date 2002.10.24.09.39.01; author rse; state Exp; branches; next 1.23; 1.23 date 2002.10.23.13.55.49; author rse; state Exp; branches; next 1.22; 1.22 date 2002.01.27.11.03.40; author rse; state Exp; branches; next 1.21; 1.21 date 2001.03.24.14.51.04; author rse; state Exp; branches; next 1.20; 1.20 date 2000.03.12.16.43.16; author rse; state Exp; branches; next 1.19; 1.19 date 99.12.30.21.59.00; author rse; state Exp; branches; next 1.18; 1.18 date 99.11.09.08.11.31; author rse; state Exp; branches; next 1.17; 1.17 date 99.11.01.10.27.19; author rse; state Exp; branches; next 1.16; 1.16 date 99.10.31.11.46.13; author rse; state Exp; branches 1.16.2.1; next 1.15; 1.15 date 99.09.17.08.01.55; author rse; state Exp; branches; next 1.14; 1.14 date 99.08.19.15.08.52; author rse; state Exp; branches; next 1.13; 1.13 date 99.08.17.08.08.36; author rse; state Exp; branches; next 1.12; 1.12 date 99.08.10.07.48.42; author rse; state Exp; branches; next 1.11; 1.11 date 99.07.08.10.34.01; author rse; state Exp; branches 1.11.2.1; next 1.10; 1.10 date 99.07.08.10.19.11; author rse; state Exp; branches; next 1.9; 1.9 date 99.07.04.12.05.35; author rse; state Exp; branches; next 1.8; 1.8 date 99.06.26.12.30.55; author rse; state Exp; branches; next 1.7; 1.7 date 99.06.25.09.03.35; author rse; state Exp; branches; next 1.6; 1.6 date 99.06.01.09.55.26; author rse; state Exp; branches; next 1.5; 1.5 date 99.05.28.09.05.12; author rse; state Exp; branches; next 1.4; 1.4 date 99.05.24.07.58.13; author rse; state Exp; branches; next 1.3; 1.3 date 99.05.22.14.37.53; author rse; state Exp; branches; next 1.2; 1.2 date 99.05.21.15.22.32; author rse; state Exp; branches; next 1.1; 1.1 date 99.05.21.09.44.10; author rse; state Exp; branches; next ; 1.16.2.1 date 99.11.01.10.25.00; author rse; state Exp; branches; next ; 1.11.2.1 date 99.08.31.08.30.29; author rse; state Exp; branches; next ; desc @@ 1.31 log @Adjusted all copyright messages for new year 2007. @ text @/* ** GNU Pth - The GNU Portable Threads ** Copyright (c) 1999-2007 Ralf S. Engelschall ** ** This file is part of GNU Pth, a non-preemptive thread scheduling ** library which can be found at http://www.gnu.org/software/pth/. ** ** This library is free software; you can redistribute it and/or ** modify it under the terms of the GNU Lesser General Public ** License as published by the Free Software Foundation; either ** version 2.1 of the License, or (at your option) any later version. ** ** This library 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 ** Lesser General Public License for more details. ** ** You should have received a copy of the GNU Lesser General Public ** License along with this library; if not, write to the Free Software ** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 ** USA, or contact Ralf S. Engelschall . ** ** pth_msg.c: Pth message port facility */ /* ``Those who do not understand Unix are condemned to reinvent it, poorly.'' -- Henry Spencer */ #include "pth_p.h" #if cpp /* message port structure */ struct pth_msgport_st { pth_ringnode_t mp_node; /* maintainance node handle */ const char *mp_name; /* optional name of message port */ pth_t mp_tid; /* corresponding thread */ pth_ring_t mp_queue; /* queue of messages pending on port */ }; #endif /* cpp */ static pth_ring_t pth_msgport = PTH_RING_INIT; /* create a new message port */ pth_msgport_t pth_msgport_create(const char *name) { pth_msgport_t mp; /* Notice: "name" is allowed to be NULL */ /* allocate message port structure */ if ((mp = (pth_msgport_t)malloc(sizeof(struct pth_msgport_st))) == NULL) return pth_error((pth_msgport_t)NULL, ENOMEM); /* initialize structure */ mp->mp_name = name; mp->mp_tid = pth_current; pth_ring_init(&mp->mp_queue); /* insert into list of existing message ports */ pth_ring_append(&pth_msgport, &mp->mp_node); return mp; } /* delete a message port */ void pth_msgport_destroy(pth_msgport_t mp) { pth_message_t *m; /* check input */ if (mp == NULL) return; /* first reply to all pending messages */ while ((m = pth_msgport_get(mp)) != NULL) pth_msgport_reply(m); /* remove from list of existing message ports */ pth_ring_delete(&pth_msgport, &mp->mp_node); /* deallocate message port structure */ free(mp); return; } /* find a known message port through name */ pth_msgport_t pth_msgport_find(const char *name) { pth_msgport_t mp, mpf; /* check input */ if (name == NULL) return pth_error((pth_msgport_t)NULL, EINVAL); /* iterate over message ports */ mp = mpf = (pth_msgport_t)pth_ring_first(&pth_msgport); while (mp != NULL) { if (mp->mp_name != NULL) if (strcmp(mp->mp_name, name) == 0) break; mp = (pth_msgport_t)pth_ring_next(&pth_msgport, (pth_ringnode_t *)mp); if (mp == mpf) { mp = NULL; break; } } return mp; } /* number of messages on a port */ int pth_msgport_pending(pth_msgport_t mp) { if (mp == NULL) return pth_error(-1, EINVAL); return pth_ring_elements(&mp->mp_queue); } /* put a message on a port */ int pth_msgport_put(pth_msgport_t mp, pth_message_t *m) { if (mp == NULL) return pth_error(FALSE, EINVAL); pth_ring_append(&mp->mp_queue, (pth_ringnode_t *)m); return TRUE; } /* get top message from a port */ pth_message_t *pth_msgport_get(pth_msgport_t mp) { pth_message_t *m; if (mp == NULL) return pth_error((pth_message_t *)NULL, EINVAL); m = (pth_message_t *)pth_ring_pop(&mp->mp_queue); return m; } /* reply message to sender */ int pth_msgport_reply(pth_message_t *m) { if (m == NULL) return pth_error(FALSE, EINVAL); return pth_msgport_put(m->m_replyport, m); } @ 1.30 log @Adjusted all copyright messages for new year 2006 @ text @d3 1 a3 1 ** Copyright (c) 1999-2006 Ralf S. Engelschall @ 1.29 log @Adjusted all copyright messages for new year 2005. @ text @d3 1 a3 1 ** Copyright (c) 1999-2005 Ralf S. Engelschall @ 1.28 log @Do not break in pth_msgport_find() if a message port was created with a NULL name. @ text @d3 1 a3 1 ** Copyright (c) 1999-2004 Ralf S. Engelschall @ 1.27 log @Adjusted all copyright messages for new year 2004. @ text @d100 3 a102 2 if (strcmp(mp->mp_name, name) == 0) break; d112 1 a112 1 /* number of message on a port */ @ 1.26 log @Adjusted all copyright messages for new year 2003. @ text @d3 1 a3 1 ** Copyright (c) 1999-2003 Ralf S. Engelschall @ 1.25 log @Internally switch from "errno_shield {...}" to "pth_shield {...}" and from "return_errno(..)" to "return pth_error(...)" in order to make the internal error handling a little bit more consistent. @ text @d3 1 a3 1 ** Copyright (c) 1999-2002 Ralf S. Engelschall @ 1.24 log @fix type @ text @d53 1 a53 1 return_errno(NULL, ENOMEM); d95 1 a95 1 return_errno(NULL, EINVAL); d115 1 a115 1 return_errno(-1, EINVAL); d123 1 a123 1 return_errno(FALSE, EINVAL); d134 1 a134 1 return_errno(NULL, EINVAL); d143 1 a143 1 return_errno(FALSE, EINVAL); @ 1.23 log @Matthew Mondor wrote: > I noticed that pth_msgport_create(), although inspired from the AmigaOS > API, does not support NULL for port identifyer, which would be very > useful for thread-specific private message ports (mmftpd uses those and > unfortunately currently has to generate unique strings to create ports). > AmigaOS had this functionality... So, make him happy and allow NULL from now on, too. @ text @d134 1 a134 1 return_errno(FALSE, EINVAL); @ 1.22 log @bump copyright year @ text @d49 1 a49 3 /* check input */ if (name == NULL) return_errno(NULL, EINVAL); @ 1.21 log @*** empty log message *** @ text @d3 1 a3 1 ** Copyright (c) 1999-2001 Ralf S. Engelschall @ 1.20 log @*** empty log message *** @ text @d3 1 a3 1 ** Copyright (c) 1999-2000 Ralf S. Engelschall @ 1.19 log @*** empty log message *** @ text @d60 1 a60 1 pth_ring_init(&mp->mp_queue, NULL); d82 1 a82 1 pth_ring_remove(&pth_msgport, &mp->mp_node); @ 1.18 log @*** empty log message *** @ text @d3 1 a3 1 ** Copyright (c) 1999 Ralf S. Engelschall @ 1.17 log @*** empty log message *** @ text @d25 1 a25 1 /* ``Those who do not understand Unix d64 1 a64 1 d134 1 a134 1 @ 1.16 log @*** empty log message *** @ text @d2 1 a2 2 ** pth_msg.c -- Pth message port facility ** d22 2 @ 1.16.2.1 log @*** empty log message *** @ text @d2 2 a3 1 ** GNU Pth - The GNU Portable Threads a22 2 ** ** pth_msg.c: Pth message port facility @ 1.15 log @*** empty log message *** @ text @d12 1 a12 1 ** version 2 of the License, or (at your option) any later version. @ 1.14 log @*** empty log message *** @ text @d10 1 a10 1 ** modify it under the terms of the GNU Library General Public d17 1 a17 1 ** Library General Public License for more details. d19 1 a19 1 ** You should have received a copy of the GNU Library General Public @ 1.13 log @*** empty log message *** @ text @d24 3 a26 1 @ 1.12 log @*** empty log message *** @ text @d51 1 a51 1 if ((mp = malloc(sizeof(struct pth_msgport_st))) == NULL) @ 1.11 log @*** empty log message *** @ text @d90 1 a90 1 pth_msgport_t mp; d97 1 a97 1 mp = (pth_msgport_t)pth_ring_first(&pth_msgport); d102 4 @ 1.11.2.1 log @*** empty log message *** @ text @d90 1 a90 1 pth_msgport_t mp, mpf; d97 1 a97 1 mp = mpf = (pth_msgport_t)pth_ring_first(&pth_msgport); a101 4 if (mp == mpf) { mp = NULL; break; } @ 1.10 log @*** empty log message *** @ text @d2 1 a2 1 ** pth_msg.c -- PTH message port facility @ 1.9 log @*** empty log message *** @ text @d6 2 a7 2 ** This file is part of PTH, a non-preemptive thread scheduling library ** which can be found at http://www.gnu.org/software/pth/. @ 1.8 log @*** empty log message *** @ text @d7 1 a7 1 ** which can be found at http://www.engelschall.com/sw/pth/. @ 1.7 log @*** empty log message *** @ text @d51 1 a51 1 if ((mp = (pth_msgport_t)malloc(sizeof(struct pth_msgport_st))) == NULL) @ 1.6 log @*** empty log message *** @ text @d46 4 d52 1 a52 1 return NULL; d70 4 d92 1 d94 3 a96 1 return NULL; d110 1 a110 1 return -1; d118 1 a118 1 return FALSE; d129 1 a129 1 return NULL; d138 1 a138 1 return FALSE; @ 1.5 log @*** empty log message *** @ text @d20 1 a20 1 ** License along with this library; if not, write to the Free @ 1.4 log @*** empty log message *** @ text @d27 12 @ 1.3 log @*** empty log message *** @ text @d6 1 a6 1 ** This file is part of PTH, a non-preemtive thread scheduling library @ 1.2 log @*** empty log message *** @ text @a0 40 /* ==================================================================== * Copyright (c) 1999 Ralf S. Engelschall. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * 3. All advertising materials mentioning features or use of this * software must display the following acknowledgment: * "This product includes software developed by * Ralf S. Engelschall ." * * 4. Redistributions of any form whatsoever must retain the following * acknowledgment: * "This product includes software developed by * Ralf S. Engelschall ." * * THIS SOFTWARE IS PROVIDED BY RALF S. ENGELSCHALL ``AS IS'' AND ANY * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL RALF S. ENGELSCHALL OR * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED * OF THE POSSIBILITY OF SUCH DAMAGE. * ==================================================================== */ d2 21 a22 2 ** Non-Preemtive Scheduler Library (PTH) ** pth_msg.c -- message port handling @ 1.1 log @*** empty log message *** @ text @d76 2 a77 2 while ((m = pth_message_get(mp)) != NULL) pth_message_reply(m); d105 1 a105 1 int pth_message_pending(pth_msgport_t mp) d113 1 a113 1 int pth_message_put(pth_msgport_t mp, pth_message_t *m) d122 1 a122 1 pth_message_t *pth_message_get(pth_msgport_t mp) d133 1 a133 1 int pth_message_reply(pth_message_t *m) d137 1 a137 1 return pth_message_put(m->m_replyport, m); @