← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/user_locks/get_lock.cc

Refactor

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/user_locks/get_lock.cc
47
47
  if (list) // To be compatible with MySQL, we will now release all other locks we might have.
48
48
    list->erase_all();
49
49
 
50
 
  bool result;
51
50
  drizzled::identifier::User::const_shared_ptr user_identifier(getSession().user());
52
51
  {
53
52
    boost::this_thread::restore_interruption dl(getSession().getThreadInterupt());
54
53
 
55
 
    try {
56
 
      result= user_locks::Locks::getInstance().lock(getSession().getSessionId(), Key(*user_identifier, res->c_str()), wait_time);
 
54
    try 
 
55
    {
 
56
      if (not user_locks::Locks::getInstance().lock(getSession().getSessionId(), Key(*user_identifier, res->c_str()), wait_time))
 
57
        return 0;
57
58
    }
58
 
    catch(boost::thread_interrupted const& error)
 
59
    catch (boost::thread_interrupted const&)
59
60
    {
60
61
      my_error(drizzled::ER_QUERY_INTERRUPTED, MYF(0));
61
62
      null_value= true;
62
 
 
63
63
      return 0;
64
64
    }
65
65
  }
66
 
 
67
 
  if (result)
68
 
  {
69
 
    if (not list)
70
 
      list= getSession().setProperty("user_locks", new user_locks::Storable(getSession().getSessionId()));
71
 
 
72
 
    list->insert(Key(*user_identifier, res->c_str()));
73
 
 
74
 
    return 1;
75
 
  }
76
 
 
77
 
  return 0;
 
66
  if (not list)
 
67
    getSession().setProperty("user_locks", new user_locks::Storable(getSession().getSessionId()));
 
68
  list->insert(Key(*user_identifier, res->c_str()));
 
69
  return 1;
78
70
}
79
71
 
80
72
} /* namespace user_locks */