Fprintf removed
This commit is contained in:
@ -277,8 +277,6 @@ gw_MySQLWrite_backend(DCB *dcb, GWBUF *queue)
|
|||||||
|
|
||||||
spinlock_acquire(&dcb->authlock);
|
spinlock_acquire(&dcb->authlock);
|
||||||
|
|
||||||
fprintf(stderr, ">>>> Backend %i: command %i, queue command %i\n", dcb->fd, dcb->command, queue->command);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Now put the incoming data to the delay queue unless backend is connected with auth ok
|
* Now put the incoming data to the delay queue unless backend is connected with auth ok
|
||||||
*/
|
*/
|
||||||
|
@ -23,8 +23,10 @@
|
|||||||
|
|
||||||
#include <stdlib.h>
|
#include <stdlib.h>
|
||||||
#include <mysql.h>
|
#include <mysql.h>
|
||||||
|
#if defined(SS_DEBUG)
|
||||||
#include <skygw_utils.h>
|
#include <skygw_utils.h>
|
||||||
#include <log_manager.h>
|
#include <log_manager.h>
|
||||||
|
#endif
|
||||||
#include <query_classifier.h>
|
#include <query_classifier.h>
|
||||||
#include <dcb.h>
|
#include <dcb.h>
|
||||||
#include <spinlock.h>
|
#include <spinlock.h>
|
||||||
@ -304,7 +306,7 @@ static void* newSession(
|
|||||||
* by which a router may cleanup data structure etc.
|
* by which a router may cleanup data structure etc.
|
||||||
*
|
*
|
||||||
* @param instance The router instance data
|
* @param instance The router instance data
|
||||||
* @param router_session The session being closed
|
* @param session The session being closed
|
||||||
*/
|
*/
|
||||||
static void closeSession(
|
static void closeSession(
|
||||||
ROUTER* instance,
|
ROUTER* instance,
|
||||||
@ -360,7 +362,7 @@ static void closeSession(
|
|||||||
* contain the remainder, or part thereof of the query.
|
* contain the remainder, or part thereof of the query.
|
||||||
*
|
*
|
||||||
* @param instance The query router instance
|
* @param instance The query router instance
|
||||||
* @param router_session The session associated with the client
|
* @param session The session associated with the client
|
||||||
* @param queue Gateway buffer queue with the packets received
|
* @param queue Gateway buffer queue with the packets received
|
||||||
*
|
*
|
||||||
* @return The number of queries forwarded
|
* @return The number of queries forwarded
|
||||||
@ -546,10 +548,10 @@ int i = 0;
|
|||||||
static void
|
static void
|
||||||
clientReply(ROUTER* instance, void* router_session, GWBUF* queue, DCB *backend_dcb)
|
clientReply(ROUTER* instance, void* router_session, GWBUF* queue, DCB *backend_dcb)
|
||||||
{
|
{
|
||||||
INSTANCE* inst = NULL;
|
INSTANCE* inst = NULL;
|
||||||
DCB *master = NULL;
|
DCB *master = NULL;
|
||||||
DCB *client = NULL;
|
DCB *client = NULL;
|
||||||
CLIENT_SESSION* session = NULL;
|
CLIENT_SESSION* session = NULL;
|
||||||
|
|
||||||
inst = (INSTANCE *)instance;
|
inst = (INSTANCE *)instance;
|
||||||
session = (CLIENT_SESSION *)router_session;
|
session = (CLIENT_SESSION *)router_session;
|
||||||
|
Reference in New Issue
Block a user