@@ -444,13 +444,13 @@ public IConcatOperationResult ExecutePrepend(string key, ulong cas, ArraySegment
444
444
/// <returns>true if the item was successfully removed from the cache; false otherwise.</returns>
445
445
public IRemoveOperationResult ExecuteRemove ( string key )
446
446
{
447
- // var hashedKey = this.keyTransformer.Transform(key);
448
- var node = this . pool . Locate ( key ) ;
447
+ var hashedKey = this . keyTransformer . Transform ( key ) ;
448
+ var node = this . pool . Locate ( hashedKey ) ;
449
449
var result = RemoveOperationResultFactory . Create ( ) ;
450
450
451
451
if ( node != null )
452
452
{
453
- var command = this . pool . OperationFactory . Delete ( key , 0 ) ;
453
+ var command = this . pool . OperationFactory . Delete ( hashedKey , 0 ) ;
454
454
var commandResult = node . Execute ( command ) ;
455
455
456
456
if ( commandResult . Success )
@@ -472,12 +472,13 @@ public IRemoveOperationResult ExecuteRemove(string key)
472
472
473
473
public async Task < IRemoveOperationResult > ExecuteRemoveAsync ( string key )
474
474
{
475
- var node = this . pool . Locate ( key ) ;
475
+ var hashedKey = this . keyTransformer . Transform ( key ) ;
476
+ var node = this . pool . Locate ( hashedKey ) ;
476
477
var result = RemoveOperationResultFactory . Create ( ) ;
477
478
478
479
if ( node != null )
479
480
{
480
- var command = this . pool . OperationFactory . Delete ( key , 0 ) ;
481
+ var command = this . pool . OperationFactory . Delete ( hashedKey , 0 ) ;
481
482
var commandResult = await node . ExecuteAsync ( command ) ;
482
483
483
484
if ( commandResult . Success )
0 commit comments