hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Added trace log to event handling.

Browse Source
This commit is contained in:
vraatikka
2013-08-15 22:45:11 +03:00
parent a1b05359ac
commit 7c0ed171a0
2 changed files with 46 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
server/core/dcb.c
View File

@ -425,6 +425,19 @@ pthread_t tid = pthread_self();
saved_errno = errno; saved_errno = errno;
if (w < 0) if (w < 0)
{ {
skygw_log_write(
LOGFILE_ERROR,
"%lu [dcb_write] Write to %d failed, errno %d",
tid,
dcb->fd,
saved_errno);
skygw_log_write(
LOGFILE_TRACE,
"%lu [dcb_write] Write to %d failed, errno %d",
tid,
dcb->fd,
saved_errno);
break; break;
} }
@ -476,6 +489,7 @@ dcb_drain_writeq(DCB *dcb)
int n = 0; int n = 0;
int w; int w;
int saved_errno = 0; int saved_errno = 0;
pthread_t tid = pthread_self();
spinlock_acquire(&dcb->writeqlock); spinlock_acquire(&dcb->writeqlock);
if (dcb->writeq) if (dcb->writeq)
@ -494,6 +508,19 @@ int saved_errno = 0;
saved_errno = errno; saved_errno = errno;
if (w < 0) if (w < 0)
{ {
skygw_log_write(
LOGFILE_ERROR,
"%lu [dcb_drain_writeq] Write to %d failed, errno %d",
tid,
dcb->fd,
saved_errno);
skygw_log_write(
LOGFILE_TRACE,
"%lu [dcb_drain_writeq] Write to %d failed, errno %d",
tid,
dcb->fd,
saved_errno);
break; break;
} }
@ -506,6 +533,12 @@ int saved_errno = 0;
{ {
/* We didn't write all the data */ /* We didn't write all the data */
} }
skygw_log_write(
LOGFILE_TRACE,
"%lu [dcb_drain_writeq] Wrote %d Bytes to %d",
tid,
w,
dcb->fd);
n += w; n += w;
} }
} }

11
server/core/poll.c
View File

@ -194,8 +194,19 @@ bool no_op = FALSE;
DCB *dcb = (DCB *)events[i].data.ptr; DCB *dcb = (DCB *)events[i].data.ptr;
__uint32_t ev = events[i].events; __uint32_t ev = events[i].events;
skygw_log_write(
LOGFILE_TRACE,
"%lu [poll_waitevents] event %d",
tid,
ev);
if (DCB_ISZOMBIE(dcb)) if (DCB_ISZOMBIE(dcb))
{
skygw_log_write(
LOGFILE_TRACE,
"%lu [poll_waitevents] dcb is zombie",
tid);
continue; continue;
}
if (ev & EPOLLERR) if (ev & EPOLLERR)
{ {