clearlinux/uwsgi
2
0
Fork 0
mirror of https://github.com/clearlinux/uwsgi.git synced 2026-09-07 22:21:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

added lock/unlock to rack plugin

Browse Source
This commit is contained in:
roberto@debian32
2011-11-12 11:31:22 +01:00
parent 90fda2b4bb
commit 6800d2ac95
1 changed files with 42 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/rack/rack_api.c
+42
View File
@@ -27,6 +27,44 @@ VALUE rack_uwsgi_mem(VALUE *class) {
}
VALUE rack_uwsgi_lock(int argc, VALUE *argv, VALUE *class) {
int lock_num = 0;
if (argc > 0) {
Check_Type(argv[0], T_FIXNUM);
lock_num = NUM2INT(argv[0]);
}
if (lock_num < 0 || lock_num > uwsgi.locks) {
rb_raise(rb_eRuntimeError, "Invalid lock number");
return Qnil;
}
uwsgi_lock(uwsgi.user_lock[lock_num]);
return Qnil;
}
VALUE rack_uwsgi_unlock(int argc, VALUE *argv, VALUE *class) {
int lock_num = 0;
if (argc > 0) {
Check_Type(argv[0], T_FIXNUM);
lock_num = NUM2INT(argv[0]);
}
if (lock_num < 0 || lock_num > uwsgi.locks) {
rb_raise(rb_eRuntimeError, "Invalid lock number");
return Qnil;
}
uwsgi_unlock(uwsgi.user_lock[lock_num]);
return Qnil;
}
VALUE rack_uwsgi_cache_set(VALUE *class, VALUE rbkey, VALUE rbvalue) {
@@ -470,6 +508,10 @@ void uwsgi_rack_init_api() {
rb_define_module_function(rb_uwsgi_embedded, "setprocname", rack_uwsgi_setprocname, 1);
rb_define_module_function(rb_uwsgi_embedded, "mem", rack_uwsgi_mem, 0);
rb_define_module_function(rb_uwsgi_embedded, "lock", rack_uwsgi_lock, -1);
rb_define_module_function(rb_uwsgi_embedded, "unlock", rack_uwsgi_unlock, -1);
if (uwsgi.cache_max_items > 0) {
rb_define_module_function(rb_uwsgi_embedded, "cache_get", rack_uwsgi_cache_get, 1);
rb_define_module_function(rb_uwsgi_embedded, "cache_get!", rack_uwsgi_cache_get_exc, 1);