@@ -180,23 +180,22 @@ func (c *RemoteClient) Lock(info *statemgr.LockInfo) (string, error) {
180180 },
181181 }
182182
183- log .Printf ("[DEBUG] Recording state lock in tablestore: %#v" , putParams )
183+ log .Printf ("[DEBUG] Recording state lock in tablestore: %#v; LOCKID:%s " , putParams , c . lockPath () )
184184
185185 _ , err := c .otsClient .PutRow (& tablestore.PutRowRequest {
186186 PutRowChange : putParams ,
187187 })
188188 if err != nil {
189- log . Printf ( "[WARN] Error storing state lock in tablestore : %#v" , err )
189+ err = fmt . Errorf ( "invoking PutRow got an error : %#v" , err )
190190 lockInfo , infoErr := c .getLockInfo ()
191191 if infoErr != nil {
192- log .Printf ("[WARN] Error getting lock info: %#v" , err )
193- err = multierror .Append (err , infoErr )
192+ err = multierror .Append (err , fmt .Errorf ("\n getting lock info got an error: %#v" , infoErr ))
194193 }
195194 lockErr := & statemgr.LockError {
196195 Err : err ,
197196 Info : lockInfo ,
198197 }
199- log .Printf ("[WARN ] state lock error: %#v " , lockErr )
198+ log .Printf ("[ERROR ] state lock error: %s " , lockErr . Error () )
200199 return "" , lockErr
201200 }
202201
@@ -386,13 +385,11 @@ func (c *RemoteClient) Unlock(id string) error {
386385 },
387386 },
388387 Condition : & tablestore.RowCondition {
389- RowExistenceExpectation : tablestore .RowExistenceExpectation_EXPECT_EXIST ,
388+ RowExistenceExpectation : tablestore .RowExistenceExpectation_IGNORE ,
390389 },
391390 },
392391 }
393392
394- log .Printf ("[DEBUG] Deleting state lock from tablestore: %#v" , params )
395-
396393 _ , err = c .otsClient .DeleteRow (params )
397394
398395 if err != nil {
0 commit comments