← Back to branch summary

~stewart/percona-playback/cassert-header

« back to all changes in this revision

Viewing changes to src/worker.cc

  • Committer: Oleg Tsarev
  • Date: 2011-05-11 15:10:00 UTC
  • Revision ID: oleg.tsarev@percona.com-20110511151000-pcpxyuii1x5l7qvm
fix "quit", "shutdown", "commit", "end" processing

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/worker.cc
27
27
  //std::cout << "WORKER TASK START\n" << std::flush;
28
28
  while(a_task->pop(a_query))
29
29
  {
30
 
    if (::is_quit(a_query))
 
30
    if (::is_connection_end(a_query))
31
31
    {
32
32
      a_client= MySQL_Client(::get_mysql_client_options());
 
33
      continue;
33
34
    }
34
35
    if (a_query.type == eQuery_Type_Unknown)
35
36
    {