Skip to content
GitLab
Menu
Projects
Groups
Snippets
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
Menu
Open sidebar
ruanhaishen
redis
Commits
2cb68284
Commit
2cb68284
authored
Jun 30, 2011
by
antirez
Browse files
Added an unique ID field to every slow log entry.
parent
de32c37c
Changes
3
Hide whitespace changes
Inline
Side-by-side
src/redis.h
View file @
2cb68284
...
@@ -528,6 +528,7 @@ struct redisServer {
...
@@ -528,6 +528,7 @@ struct redisServer {
size_t
stat_peak_memory
;
/* max used memory record */
size_t
stat_peak_memory
;
/* max used memory record */
long
long
stat_fork_time
;
/* time needed to perform latets fork() */
long
long
stat_fork_time
;
/* time needed to perform latets fork() */
list
*
slowlog
;
list
*
slowlog
;
long
long
slowlog_entry_id
;
long
long
slowlog_log_slower_than
;
long
long
slowlog_log_slower_than
;
unsigned
long
slowlog_max_len
;
unsigned
long
slowlog_max_len
;
/* Configuration */
/* Configuration */
...
...
src/slowlog.c
View file @
2cb68284
...
@@ -26,6 +26,7 @@ slowlogEntry *slowlogCreateEntry(robj **argv, int argc, long long duration) {
...
@@ -26,6 +26,7 @@ slowlogEntry *slowlogCreateEntry(robj **argv, int argc, long long duration) {
}
}
se
->
time
=
time
(
NULL
);
se
->
time
=
time
(
NULL
);
se
->
duration
=
duration
;
se
->
duration
=
duration
;
se
->
id
=
server
.
slowlog_entry_id
++
;
return
se
;
return
se
;
}
}
...
@@ -47,6 +48,7 @@ void slowlogFreeEntry(void *septr) {
...
@@ -47,6 +48,7 @@ void slowlogFreeEntry(void *septr) {
* at server startup. */
* at server startup. */
void
slowlogInit
(
void
)
{
void
slowlogInit
(
void
)
{
server
.
slowlog
=
listCreate
();
server
.
slowlog
=
listCreate
();
server
.
slowlog_entry_id
=
0
;
listSetFreeMethod
(
server
.
slowlog
,
slowlogFreeEntry
);
listSetFreeMethod
(
server
.
slowlog
,
slowlogFreeEntry
);
}
}
...
@@ -96,7 +98,8 @@ void slowlogCommand(redisClient *c) {
...
@@ -96,7 +98,8 @@ void slowlogCommand(redisClient *c) {
int
j
;
int
j
;
se
=
ln
->
value
;
se
=
ln
->
value
;
addReplyMultiBulkLen
(
c
,
3
);
addReplyMultiBulkLen
(
c
,
4
);
addReplyLongLong
(
c
,
se
->
id
);
addReplyLongLong
(
c
,
se
->
time
);
addReplyLongLong
(
c
,
se
->
time
);
addReplyLongLong
(
c
,
se
->
duration
);
addReplyLongLong
(
c
,
se
->
duration
);
addReplyMultiBulkLen
(
c
,
se
->
argc
);
addReplyMultiBulkLen
(
c
,
se
->
argc
);
...
...
src/slowlog.h
View file @
2cb68284
...
@@ -2,6 +2,7 @@
...
@@ -2,6 +2,7 @@
typedef
struct
slowlogEntry
{
typedef
struct
slowlogEntry
{
robj
**
argv
;
robj
**
argv
;
int
argc
;
int
argc
;
long
long
id
;
/* Unique entry identifier. */
long
long
duration
;
/* Time spent by the query, in nanoseconds. */
long
long
duration
;
/* Time spent by the query, in nanoseconds. */
time_t
time
;
/* Unix time at which the query was executed. */
time_t
time
;
/* Unix time at which the query was executed. */
}
slowlogEntry
;
}
slowlogEntry
;
...
...
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