Commit f0379da8 authored by kevin-montrose's avatar kevin-montrose

merge

parents ad868210 f4208759
...@@ -786,6 +786,7 @@ public bool LockExtend(RedisKey key, RedisValue value, TimeSpan expiry, CommandF ...@@ -786,6 +786,7 @@ public bool LockExtend(RedisKey key, RedisValue value, TimeSpan expiry, CommandF
{ {
if (value.IsNull) throw new ArgumentNullException("value"); if (value.IsNull) throw new ArgumentNullException("value");
var tran = GetLockExtendTransaction(key, value, expiry); var tran = GetLockExtendTransaction(key, value, expiry);
if (tran != null) return tran.Execute(flags); if (tran != null) return tran.Execute(flags);
// without transactions (twemproxy etc), we can't enforce the "value" part // without transactions (twemproxy etc), we can't enforce the "value" part
...@@ -863,6 +864,7 @@ public RedisResult ScriptEvaluate(string script, RedisKey[] keys = null, RedisVa ...@@ -863,6 +864,7 @@ public RedisResult ScriptEvaluate(string script, RedisKey[] keys = null, RedisVa
try try
{ {
return ExecuteSync(msg, ResultProcessor.ScriptResult); return ExecuteSync(msg, ResultProcessor.ScriptResult);
} }
catch (RedisServerException) catch (RedisServerException)
{ {
...@@ -876,6 +878,7 @@ public RedisResult ScriptEvaluate(byte[] hash, RedisKey[] keys = null, RedisValu ...@@ -876,6 +878,7 @@ public RedisResult ScriptEvaluate(byte[] hash, RedisKey[] keys = null, RedisValu
var msg = new ScriptEvalMessage(Db, flags, hash, keys, values); var msg = new ScriptEvalMessage(Db, flags, hash, keys, values);
return ExecuteSync(msg, ResultProcessor.ScriptResult); return ExecuteSync(msg, ResultProcessor.ScriptResult);
} }
public RedisResult ScriptEvaluate(LuaScript script, object parameters = null, CommandFlags flags = CommandFlags.None) public RedisResult ScriptEvaluate(LuaScript script, object parameters = null, CommandFlags flags = CommandFlags.None)
{ {
return script.Evaluate(this, parameters, null, flags); return script.Evaluate(this, parameters, null, flags);
...@@ -885,6 +888,7 @@ public RedisResult ScriptEvaluate(LoadedLuaScript script, object parameters = nu ...@@ -885,6 +888,7 @@ public RedisResult ScriptEvaluate(LoadedLuaScript script, object parameters = nu
return script.Evaluate(this, parameters, null, flags); return script.Evaluate(this, parameters, null, flags);
} }
public Task<RedisResult> ScriptEvaluateAsync(string script, RedisKey[] keys = null, RedisValue[] values = null, CommandFlags flags = CommandFlags.None) public Task<RedisResult> ScriptEvaluateAsync(string script, RedisKey[] keys = null, RedisValue[] values = null, CommandFlags flags = CommandFlags.None)
{ {
var msg = new ScriptEvalMessage(Db, flags, script, keys, values); var msg = new ScriptEvalMessage(Db, flags, script, keys, values);
...@@ -895,6 +899,7 @@ public Task<RedisResult> ScriptEvaluateAsync(byte[] hash, RedisKey[] keys = null ...@@ -895,6 +899,7 @@ public Task<RedisResult> ScriptEvaluateAsync(byte[] hash, RedisKey[] keys = null
var msg = new ScriptEvalMessage(Db, flags, hash, keys, values); var msg = new ScriptEvalMessage(Db, flags, hash, keys, values);
return ExecuteAsync(msg, ResultProcessor.ScriptResult); return ExecuteAsync(msg, ResultProcessor.ScriptResult);
} }
public Task<RedisResult> ScriptEvaluateAsync(LuaScript script, object parameters = null, CommandFlags flags = CommandFlags.None) public Task<RedisResult> ScriptEvaluateAsync(LuaScript script, object parameters = null, CommandFlags flags = CommandFlags.None)
{ {
return script.EvaluateAsync(this, parameters, null, flags); return script.EvaluateAsync(this, parameters, null, flags);
...@@ -2407,4 +2412,4 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes ...@@ -2407,4 +2412,4 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
} }
} }
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment