diff options
| author | Eric Wong <normalperson@yhbt.net> | 2010-01-03 05:26:00 +0000 |
|---|---|---|
| committer | Eric Wong <normalperson@yhbt.net> | 2010-01-02 23:24:43 -0800 |
| commit | d8c8fb4155c1feea454abc3ed3f0a4b26e90be68 (patch) | |
| tree | 757cd08a4c6ff526c8b66c8b84b08a0ffe3985cc /ext/posix_mq/posix_mq.c | |
| parent | dbe5ed46e07b853e79e44141924a0166016e3e44 (diff) | |
| download | ruby_posix_mq-d8c8fb4155c1feea454abc3ed3f0a4b26e90be68.tar.gz | |
The POSIX manpages specify the return values of all mq_* functions besides mq_open(3) to be "int", not "mqd_t".
Diffstat (limited to 'ext/posix_mq/posix_mq.c')
| -rw-r--r-- | ext/posix_mq/posix_mq.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/ext/posix_mq/posix_mq.c b/ext/posix_mq/posix_mq.c index 26e7b65..883aa45 100644 --- a/ext/posix_mq/posix_mq.c +++ b/ext/posix_mq/posix_mq.c @@ -497,7 +497,7 @@ static void get_msgsize(struct posix_mq *mq) { struct mq_attr attr; - if (mq_getattr(mq->des, &attr) == MQD_INVALID) + if (mq_getattr(mq->des, &attr) < 0) rb_sys_fail("mq_getattr"); mq->msgsize = attr.mq_msgsize; @@ -569,7 +569,7 @@ static VALUE getattr(VALUE self) VALUE astruct; VALUE *ptr; - if (mq_getattr(mq->des, &attr) == MQD_INVALID) + if (mq_getattr(mq->des, &attr) < 0) rb_sys_fail("mq_getattr"); astruct = rb_struct_alloc_noinit(cAttr); @@ -599,7 +599,7 @@ static VALUE setattr(VALUE self, VALUE astruct) attr_from_struct(&newattr, astruct, 0); - if (mq_setattr(mq->des, &newattr, NULL) == MQD_INVALID) + if (mq_setattr(mq->des, &newattr, NULL) < 0) rb_sys_fail("mq_setattr"); return astruct; @@ -619,7 +619,7 @@ static VALUE _close(VALUE self) { struct posix_mq *mq = get(self, 1); - if (mq_close(mq->des) == MQD_INVALID) + if (mq_close(mq->des) < 0) rb_sys_fail("mq_close"); mq->des = MQD_INVALID; @@ -730,7 +730,7 @@ static VALUE setnotify(VALUE self, VALUE arg) rb_raise(rb_eArgError, "must be a signal or nil"); } - if (mq_notify(mq->des, notification) == MQD_INVALID) + if (mq_notify(mq->des, notification) < 0) rb_sys_fail("mq_notify"); return rv; @@ -747,7 +747,7 @@ static VALUE getnonblock(VALUE self) struct mq_attr attr; struct posix_mq *mq = get(self, 1); - if (mq_getattr(mq->des, &attr) == MQD_INVALID) + if (mq_getattr(mq->des, &attr) < 0) rb_sys_fail("mq_getattr"); mq->msgsize = attr.mq_msgsize; /* optimization */ @@ -776,7 +776,7 @@ static VALUE setnonblock(VALUE self, VALUE nb) else rb_raise(rb_eArgError, "must be true or false"); - if (mq_setattr(mq->des, &newattr, &oldattr) == MQD_INVALID) + if (mq_setattr(mq->des, &newattr, &oldattr) < 0) rb_sys_fail("mq_setattr"); mq->msgsize = oldattr.mq_msgsize; /* optimization */ |