--- parser3/src/classes/memcached.C 2012/03/23 22:33:23 1.2 +++ parser3/src/classes/memcached.C 2012/04/24 22:41:09 1.4 @@ -12,9 +12,10 @@ #include "pa_request.h" #include "pa_vstring.h" #include "pa_vtable.h" +#include "pa_vbool.h" #include "pa_vmemcached.h" -volatile const char * IDENT_MEMCACHED_C="$Id: memcached.C,v 1.2 2012/03/23 22:33:23 moko Exp $"; +volatile const char * IDENT_MEMCACHED_C="$Id: memcached.C,v 1.4 2012/04/24 22:41:09 moko Exp $"; class MMemcached: public Methoded { public: // VStateless_class @@ -26,14 +27,27 @@ public: DECLARE_CLASS_VAR(memcached, new MMemcached, 0); static void _open(Request& r, MethodParams& params) { - const String& connect_string=params.as_string(0, "connection string must be string"); + Value& param_value=params.as_no_junction(0, PARAM_MUST_NOT_BE_CODE); + VMemcached& self=GET_SELF(r, VMemcached); + int ttl=0; if(params.count()>1) ttl=params.as_int(1, "default expiration must be int", r); - VMemcached& self=GET_SELF(r, VMemcached); - self.open(connect_string, ttl); + if(HashStringValue* options=param_value.get_hash()){ + String result; + for(HashStringValue::Iterator i(*options); i; i.next()){ + result << (result.is_empty() ? "--" : " --") << i.key(); + const String& value=i.value()->as_string(); + if(!value.is_empty()) + result << "=" << value; + } + self.open(result, ttl); + } else { + const String& connect_string=params.as_string(0, "param must be connection string or options hash"); + self.open_parse(connect_string, ttl); + } } static void _flush(Request& r, MethodParams& params) { @@ -76,6 +90,13 @@ static void _mget(Request& r, MethodPara } } +static void _add(Request& r, MethodParams& params) { + const String& key=params.as_string(0, "key must be string"); + + VMemcached& self=GET_SELF(r, VMemcached); + r.write_no_lang(VBool::get(self.add(key, params.get(1)))); +} + static void _delete(Request& r, MethodParams& params) { const String& key=params.as_string(0, "key must be string"); @@ -87,5 +108,6 @@ MMemcached::MMemcached() : Methoded("mem add_native_method("open", Method::CT_DYNAMIC, _open, 1, 2); add_native_method("flush", Method::CT_DYNAMIC, _flush, 1, 1); add_native_method("mget", Method::CT_DYNAMIC, _mget, 1, 1000); + add_native_method("add", Method::CT_DYNAMIC, _add, 2, 2); add_native_method("delete", Method::CT_DYNAMIC, _delete, 1, 1); }