* [ANN] posix_mq 2.2.0 - POSIX Message Queues for Ruby
@ 2015-01-16 20:32 6% Eric Wong
0 siblings, 0 replies; 2+ results
From: Eric Wong @ 2015-01-16 20:32 UTC (permalink / raw)
To: ruby-talk, ruby-posix-mq; +Cc: Christopher Lord
POSIX message queues allow local processes to exchange data in the form
of messages. This API is distinct from that provided by System V
message queues, but provides similar functionality.
* Homepage: http://bogomips.org/ruby_posix_mq/
* public-inbox: ruby-posix-mq@bogomips.org
* git clone git://bogomips.org/ruby_posix_mq.git
* Atom feed: http://bogomips.org/ruby_posix_mq/NEWS.atom.xml
* Mailing list archives: http://bogomips.org/ruby-posix-mq/
Changes:
The major feature of this release is the POSIX_MQ.for_fd class
method thanks to Christopher Lord. The addition of the
POSIX_MQ#autoclose? and POSIX_MQ#autoclose= round out the new
feature set. All of the new methods are analogous to their
counterparts in the core IO class.
The mailing list is also moved to ruby-posix-mq@bogomips.org
and no longer requires subscription. Existing librelist
subscribers will need to resubscribe manually (as I have no
way of doing so automatically):
ruby-posix-mq+subscribe@bogomips.org
HTTP archives and instructions for extracting the mail archives
via git are available at:
http://bogomips.org/ruby-posix-mq/
Christopher Lord (1):
Ability to adopt file descriptors
Eric Wong (16):
for_fd: delay assigning to mq->des until after mq_getattr
test_posix_mq: rewrite test to not depend on DL or alarm
support autoclose= and autoclose?
pack rw_args struct
change mailing list to ruby-posix-mq@bogomips.org
doc: remove --sanitize-html option for pandoc
switch documentation to olddoc
LICENSE: allow all future versions of LGPLv3+
favor comparisons against zero instead of -1
pkg.mk: misc tweaks and updates
gemspec: remove rdoc_options setting
.gitignore: add placeholder
gemspec: use SPDX license abbreviation
misc doc updates
POSIX_MQ#autoclose= propagates to IO
GNUmakefile: ordering fix for building gem
--
EW
^ permalink raw reply [relevance 6%]
* [PATCH] support autoclose= and autoclose?
@ 2015-01-09 7:37 7% Eric Wong
0 siblings, 0 replies; 2+ results
From: Eric Wong @ 2015-01-09 7:37 UTC (permalink / raw)
To: ruby.posix.mq
These are analogous to the identically-named IO methods and useful
when we're inheriting descriptors (or writing tests for inheriting
descriptors).
---
ext/posix_mq/posix_mq.c | 36 +++++++++++++++++++++++++++++++++++-
test/test_posix_mq.rb | 11 +++++++++++
2 files changed, 46 insertions(+), 1 deletion(-)
diff --git a/ext/posix_mq/posix_mq.c b/ext/posix_mq/posix_mq.c
index 93e3913..1b56608 100644
--- a/ext/posix_mq/posix_mq.c
+++ b/ext/posix_mq/posix_mq.c
@@ -38,6 +38,7 @@
struct posix_mq {
mqd_t des;
+ unsigned autoclose:1;
struct mq_attr attr;
VALUE name;
VALUE thread;
@@ -300,7 +301,8 @@ static void _free(void *ptr)
if (mq->des != MQD_INVALID && MQ_IO_NIL_P(mq)) {
/* we ignore errors when gc-ing */
- mq_close(mq->des);
+ if (mq->autoclose)
+ mq_close(mq->des);
errno = 0;
}
xfree(ptr);
@@ -313,6 +315,7 @@ static VALUE alloc(VALUE klass)
VALUE rv = Data_Make_Struct(klass, struct posix_mq, mark, _free, mq);
mq->des = MQD_INVALID;
+ mq->autoclose = 1;
mq->attr.mq_flags = 0;
mq->attr.mq_maxmsg = 0;
mq->attr.mq_msgsize = -1;
@@ -1066,6 +1069,35 @@ static VALUE setnonblock(VALUE self, VALUE nb)
/*
* call-seq:
+ * mq.autoclose = boolean => boolean
+ *
+ * Determines whether or not the _mq_ will be closed automatically
+ * at finalization.
+ */
+static VALUE setautoclose(VALUE self, VALUE autoclose)
+{
+ struct posix_mq *mq = get(self, 1);
+
+ mq->autoclose = RTEST(autoclose) ? 1 : 0;
+ return autoclose;
+}
+
+/*
+ * call-seq:
+ * mq.autoclose? => boolean
+ *
+ * Returns whether or not the _mq_ will be closed automatically
+ * at finalization.
+ */
+static VALUE autoclose_p(VALUE self)
+{
+ struct posix_mq *mq = get(self, 1);
+
+ return mq->autoclose ? Qtrue : Qfalse;
+}
+
+/*
+ * call-seq:
* mq.trysend(string [,priority[, timeout]]) => +true+ or +false+
*
* Exactly like POSIX_MQ#send, except it returns +false+ instead of raising
@@ -1155,6 +1187,8 @@ void Init_posix_mq_ext(void)
rb_define_private_method(cPOSIX_MQ, "notify_exec", setnotify_exec, 2);
rb_define_private_method(cPOSIX_MQ, "notify_cleanup", notify_cleanup, 0);
rb_define_method(cPOSIX_MQ, "nonblock?", nonblock_p, 0);
+ rb_define_method(cPOSIX_MQ, "autoclose?", autoclose_p, 0);
+ rb_define_method(cPOSIX_MQ, "autoclose=", setautoclose, 1);
#ifdef MQD_TO_FD
rb_define_method(cPOSIX_MQ, "to_io", to_io, 0);
#endif
diff --git a/test/test_posix_mq.rb b/test/test_posix_mq.rb
index 3583022..a4fc407 100644
--- a/test/test_posix_mq.rb
+++ b/test/test_posix_mq.rb
@@ -245,6 +245,17 @@ class Test_POSIX_MQ < Test::Unit::TestCase
assert_equal @mq.to_io.to_i, @alt.to_io.to_i
assert_raises(ArgumentError) { @alt.name }
assert_raises(Errno::EBADF) { POSIX_MQ.for_fd(1) }
+ @alt.autoclose = false
+ assert_equal false, @alt.autoclose?
+
+ # iterate a bunch and hope GC kicks in
+ fd = @mq.to_io.fileno
+ 10_000.times do
+ mq = POSIX_MQ.for_fd(fd)
+ assert_equal true, mq.autoclose?
+ mq.autoclose = false
+ assert_equal false, mq.autoclose?
+ end
end if POSIX_MQ.respond_to?(:for_fd) && POSIX_MQ.method_defined?(:to_io)
def test_notify
--
EW
^ permalink raw reply related [relevance 7%]
Results 1-2 of 2 | reverse | options above
-- pct% links below jump to the message on this page, permalinks otherwise --
2015-01-09 7:37 7% [PATCH] support autoclose= and autoclose? Eric Wong
2015-01-16 20:32 6% [ANN] posix_mq 2.2.0 - POSIX Message Queues for Ruby Eric Wong
Code repositories for project(s) associated with this public inbox
https://yhbt.net/ruby_posix_mq.git/
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).