| 39 | bool RowlockNodeImpl::Exit() { return true; } |
| 40 | |
| 41 | void RowlockNodeImpl::TryLock(const RowlockRequest* request, RowlockResponse* response, |
| 42 | google::protobuf::Closure* done) { |
| 43 | uint64_t rowlock_key = GetRowlockKey(request->table_name(), request->row()); |
| 44 | if (rowlock_db_.TryLock(rowlock_key)) { |
| 45 | response->set_lock_status(kLockSucc); |
| 46 | VLOG(12) << "Lock success: " << request->row(); |
| 47 | } else { |
| 48 | response->set_lock_status(kLockFail); |
| 49 | LOG(WARNING) << " table name: " << request->table_name() << " row :" << request->row(); |
| 50 | } |
| 51 | |
| 52 | done->Run(); |
| 53 | } |
| 54 | |
| 55 | void RowlockNodeImpl::UnLock(const RowlockRequest* request, RowlockResponse* response, |
| 56 | google::protobuf::Closure* done) { |
no test coverage detected