← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to plugin/pbms/src/mysql_ms.cc

  • Committer: Monty Taylor
  • Date: 2010-07-04 20:02:43 UTC
  • mfrom: (1548.2.40 drizzle_pbms)
  • mto: This revision was merged to the branch mainline in revision 1644.
  • Revision ID: mordred@inaugust.com-20100704200243-2vkq9gi6ysauj2tb
Merge PBMS from Barry.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin/pbms/src/mysql_ms.cc
 
1
/* Copyright (c) 2008 PrimeBase Technologies GmbH, Germany
 
2
 *
 
3
 * PrimeBase Media Stream for MySQL
 
4
 *
 
5
 * This program is free software; you can redistribute it and/or modify
 
6
 * it under the terms of the GNU General Public License as published by
 
7
 * the Free Software Foundation; either version 2 of the License, or
 
8
 * (at your option) any later version.
 
9
 *
 
10
 * This program is distributed in the hope that it will be useful,
 
11
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 
12
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
13
 * GNU General Public License for more details.
 
14
 *
 
15
 * You should have received a copy of the GNU General Public License
 
16
 * along with this program; if not, write to the Free Software
 
17
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 
18
 *
 
19
 * Original author: Paul McCullagh
 
20
 * Continued development: Barry Leslie
 
21
 *
 
22
 * 2007-05-25
 
23
 *
 
24
 * H&G2JCtL
 
25
 *
 
26
 * MySQL interface.
 
27
 *
 
28
 */
 
29
 
 
30
 
 
31
#ifdef DRIZZLED
 
32
#include "config.h"
 
33
#include <drizzled/common.h>
 
34
#include <drizzled/data_home.h>
 
35
#include <drizzled/current_session.h>
 
36
#include <drizzled/session.h>
 
37
#else
 
38
#include "cslib/CSConfig.h"
 
39
#endif
 
40
 
 
41
#include "cslib/CSGlobal.h"
 
42
#include "cslib/CSException.h"
 
43
#include "defs_ms.h"
 
44
#include "defs_ms.h"
 
45
#include "mysql_ms.h"
 
46
 
 
47
/* Note: 'new' used here is NOT CSObject::new which is a DEBUG define*/
 
48
#ifdef new
 
49
#undef new
 
50
#endif
 
51
 
 
52
void *ms_my_get_thread()
 
53
{
 
54
        THD *thd = current_thd;
 
55
 
 
56
        return (void *) thd;
 
57
}
 
58
 
 
59
#ifdef DRIZZLED
 
60
const char *ms_my_get_mysql_home_path()
 
61
{
 
62
        return drizzled::data_home;
 
63
}
 
64
 
 
65
bool ms_is_autocommit()
 
66
{
 
67
        return (session_test_options(current_thd, (OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN))) == 0;
 
68
}
 
69
 
 
70
#else
 
71
const char *ms_my_get_mysql_home_path()
 
72
{
 
73
        return mysql_real_data_home;
 
74
}
 
75
 
 
76
bool ms_is_autocommit()
 
77
{
 
78
        return (thd_test_options(current_thd, (OPTION_NOT_AUTOCOMMIT | OPTION_BEGIN))) == 0;
 
79
}
 
80
#endif
 
81
 
 
82
/* YYYYMMDDHHMMSS */
 
83
uint64_t        ms_my_1970_to_mysql_time(time_t t)
 
84
{
 
85
        struct tm       details;
 
86
        uint64_t                sec;
 
87
        uint64_t                min;
 
88
        uint64_t                hour;
 
89
        uint64_t                day;
 
90
        uint64_t                mon;
 
91
        uint64_t                year;
 
92
 
 
93
        gmtime_r(&t, &details);
 
94
        sec = (uint64_t) details.tm_sec;
 
95
        min = (uint64_t) details.tm_min * 100LL;
 
96
        hour = (uint64_t) details.tm_hour * 10000LL;
 
97
        day = (uint64_t) details.tm_mday * 1000000LL;
 
98
        mon = (uint64_t) (details.tm_mon+1) * 100000000LL;
 
99
        year = (uint64_t) (details.tm_year+1900) * 10000000000LL;
 
100
        
 
101
        return year + mon + day + hour + min + sec;
 
102
}
 
103
 
 
104