~drizzle-trunk/drizzle/development

/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-

 *  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:

 *

 *  Copyright (C) 2008 Sun Microsystems

 *

 *  This program is free software; you can redistribute it and/or modify

 *  it under the terms of the GNU General Public License as published by

 *  the Free Software Foundation; version 2 of the License.

 *

 *  This program is distributed in the hope that it will be useful,

 *  but WITHOUT ANY WARRANTY; without even the implied warranty of

 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 *  GNU General Public License for more details.

 *

 *  You should have received a copy of the GNU General Public License

 *  along with this program; if not, write to the Free Software

 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA

 */

#ifndef DRIZZLE_SERVER_SCHEDULER_H

#define DRIZZLE_SERVER_SCHEDULER_H

/*

  Classes for the thread scheduler

*/

/* Forward declarations */

class Session;

struct event;

/* Functions used when manipulating threads */

class scheduler_functions

{

public:

  uint32_t max_threads;

  bool (*init)(void);

  bool (*init_new_connection_thread)(void);

  void (*add_connection)(Session *session);

  void (*post_kill_notification)(Session *session);

  bool (*end_thread)(Session *session, bool cache_thread);

  void (*end)(void);

  scheduler_functions();

};

enum scheduler_types

{

  SCHEDULER_POOL_OF_THREADS

};

void one_thread_per_connection_scheduler(scheduler_functions* func);

void one_thread_scheduler(scheduler_functions* func);

#define HAVE_POOL_OF_THREADS 1

class session_scheduler

{

public:

  bool logged_in;

  struct event* io_event;

  LIST list;

  bool thread_attached;  /* Indicates if Session is attached to the OS thread */

  session_scheduler();

  ~session_scheduler();

  session_scheduler(const session_scheduler&);

  void operator=(const session_scheduler&);

  bool init(Session* parent_session);

  bool thread_attach();

  void thread_detach();

};

void pool_of_threads_scheduler(scheduler_functions* func);

#endif /* DRIZZLE_SERVER_SCHEDULER_H */