Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
M
MariaDB
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
nexedi
MariaDB
Commits
2c7505b2
Commit
2c7505b2
authored
Oct 09, 2005
by
konstantin@mysql.com
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Remove protocol_cursor.cpp (no longer used) from sources
Fix a compile failure
parent
ba169f81
Changes
4
Show whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
1 addition
and
157 deletions
+1
-157
VC++Files/libmysqld/libmysqld.dsp
VC++Files/libmysqld/libmysqld.dsp
+0
-4
VC++Files/sql/mysqld.dsp
VC++Files/sql/mysqld.dsp
+0
-4
sql/mysqld.cc
sql/mysqld.cc
+1
-1
sql/protocol_cursor.cc
sql/protocol_cursor.cc
+0
-148
No files found.
VC++Files/libmysqld/libmysqld.dsp
View file @
2c7505b2
...
...
@@ -396,10 +396,6 @@ SOURCE=..\sql\protocol.cpp
# End Source File
# Begin Source File
SOURCE=..\sql\protocol_cursor.cpp
# End Source File
# Begin Source File
SOURCE=..\sql\records.cpp
# End Source File
# Begin Source File
...
...
VC++Files/sql/mysqld.dsp
View file @
2c7505b2
...
...
@@ -1283,10 +1283,6 @@ SOURCE=.\protocol.cpp
# End Source File
# Begin Source File
SOURCE=.\protocol_cursor.cpp
# End Source File
# Begin Source File
SOURCE=.\records.cpp
!IF "$(CFG)" == "mysqld - Win32 Release"
...
...
sql/mysqld.cc
View file @
2c7505b2
...
...
@@ -2167,7 +2167,7 @@ static void start_signal_handler(void)
/* This threads handles all signals and alarms */
/* ARGSUSED */
static
void
*
signal_hand
(
void
*
arg
__attribute__
((
unused
)))
pthread_handler_t
signal_hand
(
void
*
arg
__attribute__
((
unused
)))
{
sigset_t
set
;
int
sig
;
...
...
sql/protocol_cursor.cc
deleted
100644 → 0
View file @
ba169f81
/* Copyright (C) 2000-2003 MySQL AB
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; either version 2 of the License, or
(at your option) any later version.
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
/*
Low level functions for storing data to be send to the MySQL client
The actual communction is handled by the net_xxx functions in net_serv.cc
*/
#ifdef USE_PRAGMA_IMPLEMENTATION
#pragma implementation // gcc: Class implementation
#endif
#include "mysql_priv.h"
#include <mysql.h>
bool
Protocol_cursor
::
send_fields
(
List
<
Item
>
*
list
,
uint
flags
)
{
List_iterator_fast
<
Item
>
it
(
*
list
);
Item
*
item
;
MYSQL_FIELD
*
client_field
;
DBUG_ENTER
(
"Protocol_cursor::send_fields"
);
if
(
prepare_for_send
(
list
))
return
FALSE
;
fields
=
(
MYSQL_FIELD
*
)
alloc_root
(
alloc
,
sizeof
(
MYSQL_FIELD
)
*
field_count
);
if
(
!
fields
)
goto
err
;
for
(
client_field
=
fields
;
(
item
=
it
++
)
;
client_field
++
)
{
Send_field
server_field
;
item
->
make_field
(
&
server_field
);
client_field
->
db
=
strdup_root
(
alloc
,
server_field
.
db_name
);
client_field
->
table
=
strdup_root
(
alloc
,
server_field
.
table_name
);
client_field
->
name
=
strdup_root
(
alloc
,
server_field
.
col_name
);
client_field
->
org_table
=
strdup_root
(
alloc
,
server_field
.
org_table_name
);
client_field
->
org_name
=
strdup_root
(
alloc
,
server_field
.
org_col_name
);
client_field
->
catalog
=
strdup_root
(
alloc
,
""
);
client_field
->
length
=
server_field
.
length
;
client_field
->
type
=
server_field
.
type
;
client_field
->
flags
=
server_field
.
flags
;
client_field
->
decimals
=
server_field
.
decimals
;
client_field
->
db_length
=
strlen
(
client_field
->
db
);
client_field
->
table_length
=
strlen
(
client_field
->
table
);
client_field
->
name_length
=
strlen
(
client_field
->
name
);
client_field
->
org_name_length
=
strlen
(
client_field
->
org_name
);
client_field
->
org_table_length
=
strlen
(
client_field
->
org_table
);
client_field
->
catalog_length
=
0
;
client_field
->
charsetnr
=
server_field
.
charsetnr
;
if
(
INTERNAL_NUM_FIELD
(
client_field
))
client_field
->
flags
|=
NUM_FLAG
;
if
(
flags
&
(
uint
)
Protocol
::
SEND_DEFAULTS
)
{
char
buff
[
80
];
String
tmp
(
buff
,
sizeof
(
buff
),
default_charset_info
),
*
res
;
if
(
!
(
res
=
item
->
val_str
(
&
tmp
)))
client_field
->
def
=
(
char
*
)
""
;
else
client_field
->
def
=
strmake_root
(
alloc
,
res
->
ptr
(),
res
->
length
());
}
else
client_field
->
def
=
0
;
client_field
->
max_length
=
0
;
}
DBUG_RETURN
(
FALSE
);
err:
my_message
(
ER_OUT_OF_RESOURCES
,
ER
(
ER_OUT_OF_RESOURCES
),
MYF
(
0
));
/* purecov: inspected */
DBUG_RETURN
(
TRUE
);
/* purecov: inspected */
}
/* Get the length of next field. Change parameter to point at fieldstart */
bool
Protocol_cursor
::
write
()
{
byte
*
cp
=
(
byte
*
)
packet
->
ptr
();
byte
*
end_pos
=
(
byte
*
)
packet
->
ptr
()
+
packet
->
length
();
ulong
len
;
MYSQL_FIELD
*
cur_field
=
fields
;
MYSQL_FIELD
*
fields_end
=
fields
+
field_count
;
MYSQL_ROWS
*
new_record
;
byte
**
data_tmp
;
byte
*
to
;
new_record
=
(
MYSQL_ROWS
*
)
alloc_root
(
alloc
,
sizeof
(
MYSQL_ROWS
)
+
(
field_count
+
2
)
*
sizeof
(
char
*
)
+
packet
->
length
());
if
(
!
new_record
)
goto
err
;
data_tmp
=
(
byte
**
)(
new_record
+
1
);
new_record
->
data
=
(
char
**
)
data_tmp
;
to
=
(
byte
*
)
data_tmp
+
(
field_count
+
2
)
*
sizeof
(
char
*
);
for
(;
cur_field
<
fields_end
;
cur_field
++
,
data_tmp
++
)
{
if
((
len
=
net_field_length
((
uchar
**
)
&
cp
))
==
NULL_LENGTH
)
{
*
data_tmp
=
0
;
}
else
{
if
((
long
)
len
>
(
end_pos
-
cp
))
{
// TODO error signal send_error(thd, CR_MALFORMED_PACKET);
return
TRUE
;
}
*
data_tmp
=
to
;
memcpy
(
to
,(
char
*
)
cp
,
len
);
to
[
len
]
=
0
;
to
+=
len
+
1
;
cp
+=
len
;
if
(
cur_field
->
max_length
<
len
)
cur_field
->
max_length
=
len
;
}
}
data_tmp
[
0
]
=
to
;
// Pointer to last used byte
data_tmp
[
1
]
=
0
;
*
prev_record
=
new_record
;
prev_record
=
&
new_record
->
next
;
new_record
->
next
=
NULL
;
row_count
++
;
return
FALSE
;
err:
// TODO error signal send_error(thd, ER_OUT_OF_RESOURCES);
return
TRUE
;
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment