← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/drizzled.cc

Moved service stuff into plugin/

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/drizzled.cc
41
41
#include <drizzled/item/create.h>
42
42
#include <drizzled/unireg.h>
43
43
#include "drizzled/temporal_format.h" /* For init_temporal_formats() */
44
 
#include "drizzled/service/listen.h"
45
 
#include "drizzled/service/error_message.h"
 
44
#include "drizzled/plugin/listen.h"
 
45
#include "drizzled/plugin/error_message.h"
46
46
#include "drizzled/plugin/client.h"
47
47
#include "drizzled/plugin/scheduler.h"
48
48
#include "drizzled/probes.h"
395
395
drizzled::atomic<uint32_t> refresh_version;  /* Increments on each reload */
396
396
 
397
397
/* Function declarations */
398
 
bool drizzle_rm_tmp_tables(drizzled::service::Listen &listen);
 
398
bool drizzle_rm_tmp_tables();
399
399
 
400
400
extern "C" pthread_handler_t signal_hand(void *arg);
401
401
static void drizzle_init_variables(void);
419
419
 
420
420
void close_connections(void)
421
421
{
422
 
  plugin::Registry &plugins= plugin::Registry::singleton();
423
 
 
424
422
  /* Abort listening to new connections */
425
 
  plugins.listen.shutdown();
 
423
  plugin::Listen::shutdown();
426
424
 
427
425
  /* kill connection thread */
428
426
  (void) pthread_mutex_lock(&LOCK_thread_count);
1391
1389
    scheduler_name= opt_scheduler_default;
1392
1390
  }
1393
1391
 
1394
 
  if (plugins.scheduler.setFactory(scheduler_name))
 
1392
  if (plugin::SchedulerFactory::setFactory(scheduler_name))
1395
1393
  {
1396
1394
      errmsg_printf(ERRMSG_LVL_ERROR,
1397
1395
                   _("No scheduler found, cannot continue!\n"));
1539
1537
 
1540
1538
  set_default_port();
1541
1539
 
1542
 
  if (plugins.listen.setup())
 
1540
  if (plugin::Listen::setup())
1543
1541
    unireg_abort(1);
1544
1542
 
1545
1543
  /*
1548
1546
  */
1549
1547
  error_handler_hook= my_message_sql;
1550
1548
 
1551
 
  if (drizzle_rm_tmp_tables(plugins.listen) ||
 
1549
  if (drizzle_rm_tmp_tables() ||
1552
1550
      my_tz_init((Session *)0, default_tz_name))
1553
1551
  {
1554
1552
    abort_loop= true;
1569
1567
  /* Listen for new connections and start new session for each connection
1570
1568
     accepted. The listen.getClient() method will return NULL when the server
1571
1569
     should be shutdown. */
1572
 
  while ((client= plugins.listen.getClient()) != NULL)
 
1570
  while ((client= plugin::Listen::getClient()) != NULL)
1573
1571
  {
1574
1572
    if (!(session= new Session(client)))
1575
1573
    {
2403
2401
 
2404
2402
void option_error_reporter(enum loglevel level, const char *format, ...)
2405
2403
{
2406
 
  plugin::Registry &plugins= plugin::Registry::singleton();
2407
 
 
2408
2404
  va_list args;
2409
2405
  va_start(args, format);
2410
2406
 
2411
2407
  /* Don't print warnings for --loose options during bootstrap */
2412
2408
  if (level == ERROR_LEVEL || global_system_variables.log_warnings)
2413
2409
  {
2414
 
    plugins.error_message.vprintf(current_session, ERROR_LEVEL, format, args);
 
2410
    plugin::ErrorMessage::vprintf(current_session, ERROR_LEVEL, format, args);
2415
2411
  }
2416
2412
  va_end(args);
2417
2413
}