--- pth_msg.c 2002/10/24 09:39:01 1.24
+++ pth_msg.c 2002/10/24 15:21:14 1.25
@@ -50,7 +50,7 @@
/* allocate message port structure */
if ((mp = (pth_msgport_t)malloc(sizeof(struct pth_msgport_st))) == NULL)
- return_errno(NULL, ENOMEM);
+ return pth_error((pth_msgport_t)NULL, ENOMEM);
/* initialize structure */
mp->mp_name = name;
@@ -92,7 +92,7 @@
/* check input */
if (name == NULL)
- return_errno(NULL, EINVAL);
+ return pth_error((pth_msgport_t)NULL, EINVAL);
/* iterate over message ports */
mp = mpf = (pth_msgport_t)pth_ring_first(&pth_msgport);
@@ -112,7 +112,7 @@
int pth_msgport_pending(pth_msgport_t mp)
{
if (mp == NULL)
- return_errno(-1, EINVAL);
+ return pth_error(-1, EINVAL);
return pth_ring_elements(&mp->mp_queue);
}
@@ -120,7 +120,7 @@
int pth_msgport_put(pth_msgport_t mp, pth_message_t *m)
{
if (mp == NULL)
- return_errno(FALSE, EINVAL);
+ return pth_error(FALSE, EINVAL);
pth_ring_append(&mp->mp_queue, (pth_ringnode_t *)m);
return TRUE;
}
@@ -131,7 +131,7 @@
pth_message_t *m;
if (mp == NULL)
- return_errno(NULL, EINVAL);
+ return pth_error((pth_message_t *)NULL, EINVAL);
m = (pth_message_t *)pth_ring_pop(&mp->mp_queue);
return m;
}
@@ -140,7 +140,7 @@
int pth_msgport_reply(pth_message_t *m)
{
if (m == NULL)
- return_errno(FALSE, EINVAL);
+ return pth_error(FALSE, EINVAL);
return pth_msgport_put(m->m_replyport, m);
}
|
