← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/multi_thread/multi_thread.h

  • Committer: Brian Aker
  • Date: 2011-02-22 06:12:02 UTC
  • mfrom: (2190.1.6 drizzle-build)
  • Revision ID: brian@tangent.org-20110222061202-k03czxykqy4x9hjs
List update, header fixes, multiple symbols, and David deletes some code.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/multi_thread/multi_thread.h
 
1
/* Copyright (C) 2009 Sun Microsystems, Inc.
 
2
 
 
3
  This program is free software; you can redistribute it and/or modify
 
4
  it under the terms of the GNU General Public License as published by
 
5
  the Free Software Foundation; version 2 of the License.
 
6
 
 
7
  This program is distributed in the hope that it will be useful,
 
8
  but WITHOUT ANY WARRANTY; without even the implied warranty of
 
9
  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
10
  GNU General Public License for more details.
 
11
 
 
12
  You should have received a copy of the GNU General Public License
 
13
  along with this program; if not, write to the Free Software
 
14
  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA */
 
15
 
 
16
#ifndef PLUGIN_MULTI_THREAD_MULTI_THREAD_H
 
17
#define PLUGIN_MULTI_THREAD_MULTI_THREAD_H
 
18
 
 
19
#include <drizzled/atomics.h>
 
20
#include <drizzled/gettext.h>
 
21
#include <drizzled/error.h>
 
22
#include <drizzled/plugin/scheduler.h>
 
23
#include <drizzled/internal/my_sys.h>
 
24
#include <drizzled/sql_parse.h>
 
25
#include <string>
 
26
 
 
27
namespace drizzled {
 
28
class Session;
 
29
}
 
30
 
 
31
namespace multi_thread {
 
32
 
 
33
class MultiThreadScheduler: public drizzled::plugin::Scheduler
 
34
{
 
35
private:
 
36
  drizzled::atomic<uint32_t> thread_count;
 
37
 
 
38
public:
 
39
  MultiThreadScheduler(const char *name_arg): 
 
40
    Scheduler(name_arg)
 
41
  {
 
42
    setStackSize();
 
43
    thread_count= 0;
 
44
  }
 
45
 
 
46
  ~MultiThreadScheduler();
 
47
  bool addSession(drizzled::Session::shared_ptr &session);
 
48
  void killSessionNow(drizzled::Session::shared_ptr &session);
 
49
  void killSession(drizzled::Session*);
 
50
  
 
51
  void runSession(drizzled::session_id_t);
 
52
private:
 
53
  void setStackSize();
 
54
};
 
55
 
 
56
} // namespace multi_thread
 
57
 
 
58
#endif /* PLUGIN_MULTI_THREAD_MULTI_THREAD_H */