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

Merge branch 'release-1.0GA' of https://github.com/mariadb-corporation/MaxScale into release-1.0GA

Browse Source
This commit is contained in:
Mark Riddoch
2014-12-03 09:53:42 +00:00
parent fdb9c5e6dc 33f77303f7
commit 3230eab37c
6 changed files with 182 additions and 71 deletions
Download Patch File Download Diff File Expand all files Collapse all files

164
log_manager/log_manager.cc
View File

@ -94,7 +94,9 @@ char* syslog_ident_str = NULL;
*/ */
static int lmlock; static int lmlock;
static logmanager_t* lm; static logmanager_t* lm;
static bool flushall_flag;
static bool flushall_started_flag;
static bool flushall_done_flag;
/** Writer thread structure */ /** Writer thread structure */
struct filewriter_st { struct filewriter_st {
@ -286,12 +288,14 @@ static char* add_slash(char* str);
static bool check_file_and_path( static bool check_file_and_path(
char* filename, char* filename,
bool* writable); bool* writable,
bool do_log);
static bool file_is_symlink(char* filename); static bool file_is_symlink(char* filename);
static int skygw_log_disable_raw(logfile_id_t id, bool emergency); /*< no locking */ static int skygw_log_disable_raw(logfile_id_t id, bool emergency); /*< no locking */
static int find_last_seqno(strpart_t* parts, int seqno, int seqnoidx); static int find_last_seqno(strpart_t* parts, int seqno, int seqnoidx);
void flushall_logfiles(bool flush);
bool thr_flushall_check();
const char* get_suffix_default(void) const char* get_suffix_default(void)
{ {
@ -441,17 +445,6 @@ static bool logmanager_init_nomutex(
return_succp: return_succp:
if (err != 0) if (err != 0)
{ {
if (lm != NULL)
{
if (lm->lm_clientmes != NULL)
{
skygw_message_done(lm->lm_clientmes);
}
if (lm->lm_logmes != NULL)
{
skygw_message_done(lm->lm_logmes);
}
}
/** This releases memory of all created objects */ /** This releases memory of all created objects */
logmanager_done_nomutex(); logmanager_done_nomutex();
fprintf(stderr, "*\n* Error : Initializing log manager failed.\n*\n"); fprintf(stderr, "*\n* Error : Initializing log manager failed.\n*\n");
@ -2053,7 +2046,7 @@ static bool logfile_create(
* If file exists but is different type, create fails and * If file exists but is different type, create fails and
* new, increased sequence number is added to file name. * new, increased sequence number is added to file name.
*/ */
if (check_file_and_path(lf->lf_full_file_name, &writable)) if (check_file_and_path(lf->lf_full_file_name, &writable, true))
{ {
/** Found similarly named file which isn't writable */ /** Found similarly named file which isn't writable */
if (!writable || file_is_symlink(lf->lf_full_file_name)) if (!writable || file_is_symlink(lf->lf_full_file_name))
@ -2077,13 +2070,11 @@ static bool logfile_create(
if (store_shmem) if (store_shmem)
{ {
if (check_file_and_path(lf->lf_full_file_name, &writable)) if (check_file_and_path(lf->lf_full_link_name, &writable, true))
{ {
/** Found similarly named file which isn't writable */ /** Found similarly named link which isn't writable */
if (!writable || if (!writable)
file_is_symlink(lf->lf_full_file_name))
{ {
unlink(lf->lf_full_file_name);
nameconflicts = true; nameconflicts = true;
} }
} }
@ -2214,7 +2205,6 @@ return_succp:
* *
* @return Pointer to filename, of NULL if failed. * @return Pointer to filename, of NULL if failed.
* *
*
*/ */
static char* form_full_file_name( static char* form_full_file_name(
strpart_t* parts, strpart_t* parts,
@ -2231,9 +2221,21 @@ static char* form_full_file_name(
if (lf->lf_name_seqno != -1) if (lf->lf_name_seqno != -1)
{ {
lf->lf_name_seqno = find_last_seqno(parts, int file_sn;
lf->lf_name_seqno, int link_sn = 0;
seqnoidx); char* tmp = parts[0].sp_string;
file_sn = find_last_seqno(parts, lf->lf_name_seqno, seqnoidx);
if (lf->lf_linkpath != NULL)
{
tmp = parts[0].sp_string;
parts[0].sp_string = lf->lf_linkpath;
link_sn = find_last_seqno(parts, lf->lf_name_seqno, seqnoidx);
parts[0].sp_string = tmp;
}
lf->lf_name_seqno = MAX(file_sn, link_sn);
seqno = lf->lf_name_seqno; seqno = lf->lf_name_seqno;
s = UINTLEN(seqno); s = UINTLEN(seqno);
seqnostr = (char *)malloc((int)s+1); seqnostr = (char *)malloc((int)s+1);
@ -2354,7 +2356,8 @@ static char* add_slash(
*/ */
static bool check_file_and_path( static bool check_file_and_path(
char* filename, char* filename,
bool* writable) bool* writable,
bool do_log)
{ {
int fd; int fd;
bool exists; bool exists;
@ -2381,12 +2384,24 @@ static bool check_file_and_path(
fd = open(filename, O_CREAT|O_RDWR, S_IRWXU|S_IRWXG); fd = open(filename, O_CREAT|O_RDWR, S_IRWXU|S_IRWXG);
if (fd == -1) if (fd == -1)
{
if (do_log && file_is_symlink(filename))
{
fprintf(stderr,
"*\n* Error : Can't access "
"file pointed to by %s due "
"to %s.\n",
filename,
strerror(errno));
}
else if (do_log)
{ {
fprintf(stderr, fprintf(stderr,
"*\n* Error : Can't access %s due " "*\n* Error : Can't access %s due "
"to %s.\n", "to %s.\n",
filename, filename,
strerror(errno)); strerror(errno));
}
if (writable) if (writable)
{ {
*writable = false; *writable = false;
@ -2402,12 +2417,25 @@ static bool check_file_and_path(
*writable = true; *writable = true;
} }
else else
{
if (do_log &&
file_is_symlink(filename))
{
fprintf(stderr,
"*\n* Error : Can't write to "
"file pointed to by %s due to "
"%s.\n",
filename,
strerror(errno));
}
else if (do_log)
{ {
fprintf(stderr, fprintf(stderr,
"*\n* Error : Can't write to " "*\n* Error : Can't write to "
"%s due to %s.\n", "%s due to %s.\n",
filename, filename,
strerror(errno)); strerror(errno));
}
*writable = false; *writable = false;
} }
} }
@ -2416,11 +2444,22 @@ static bool check_file_and_path(
exists = true; exists = true;
} }
else else
{
if (do_log && file_is_symlink(filename))
{
fprintf(stderr,
"*\n* Error : Can't access the file "
"pointed to by %s due to %s.\n",
filename,
strerror(errno));
}
else if (do_log)
{ {
fprintf(stderr, fprintf(stderr,
"*\n* Error : Can't access %s due to %s.\n", "*\n* Error : Can't access %s due to %s.\n",
filename, filename,
strerror(errno)); strerror(errno));
}
exists = false; exists = false;
if (writable) if (writable)
@ -2572,7 +2611,7 @@ static bool logfile_init(
logfile_free_memory(logfile); logfile_free_memory(logfile);
goto return_with_succp; goto return_with_succp;
} }
#if defined(SS_DEBUG)
if (store_shmem) if (store_shmem)
{ {
fprintf(stderr, "%s\t: %s->%s\n", fprintf(stderr, "%s\t: %s->%s\n",
@ -2586,7 +2625,6 @@ static bool logfile_init(
STRLOGNAME(logfile_id), STRLOGNAME(logfile_id),
logfile->lf_full_file_name); logfile->lf_full_file_name);
} }
#endif
succp = true; succp = true;
logfile->lf_state = RUN; logfile->lf_state = RUN;
CHK_LOGFILE(logfile); CHK_LOGFILE(logfile);
@ -2802,13 +2840,15 @@ static void* thr_filewriter_fun(
int i; int i;
blockbuf_state_t flush_blockbuf; /**< flush single block buffer. */ blockbuf_state_t flush_blockbuf; /**< flush single block buffer. */
bool flush_logfile; /**< flush logfile */ bool flush_logfile; /**< flush logfile */
bool flushall_logfiles;/**< flush all logfiles */ bool do_flushall = false;
bool rotate_logfile; /*< close current and open new file */ bool rotate_logfile; /*< close current and open new file */
size_t vn1; size_t vn1;
size_t vn2; size_t vn2;
thr = (skygw_thread_t *)data; thr = (skygw_thread_t *)data;
fwr = (filewriter_t *)skygw_thread_get_data(thr); fwr = (filewriter_t *)skygw_thread_get_data(thr);
flushall_logfiles(false);
CHK_FILEWRITER(fwr); CHK_FILEWRITER(fwr);
ss_debug(skygw_thread_set_state(thr, THR_RUNNING)); ss_debug(skygw_thread_set_state(thr, THR_RUNNING));
@ -2821,8 +2861,9 @@ static void* thr_filewriter_fun(
* Reset message to avoid redundant calls. * Reset message to avoid redundant calls.
*/ */
skygw_message_wait(fwr->fwr_logmes); skygw_message_wait(fwr->fwr_logmes);
if(skygw_thread_must_exit(thr)){
flushall_logfiles = skygw_thread_must_exit(thr); flushall_logfiles(true);
}
/** Process all logfiles which have buffered writes. */ /** Process all logfiles which have buffered writes. */
for (i=LOGFILE_FIRST; i<=LOGFILE_LAST; i <<= 1) for (i=LOGFILE_FIRST; i<=LOGFILE_LAST; i <<= 1)
@ -2831,6 +2872,10 @@ static void* thr_filewriter_fun(
/** /**
* Get file pointer of current logfile. * Get file pointer of current logfile.
*/ */
do_flushall = thr_flushall_check();
file = fwr->fwr_file[i]; file = fwr->fwr_file[i];
lf = &lm->lm_logfile[(logfile_id_t)i]; lf = &lm->lm_logfile[(logfile_id_t)i];
@ -2901,7 +2946,7 @@ static void* thr_filewriter_fun(
if (bb->bb_buf_used != 0 && if (bb->bb_buf_used != 0 &&
(flush_blockbuf == BB_FULL || (flush_blockbuf == BB_FULL ||
flush_logfile || flush_logfile ||
flushall_logfiles)) do_flushall))
{ {
/** /**
* buffer is at least half-full * buffer is at least half-full
@ -2920,7 +2965,7 @@ static void* thr_filewriter_fun(
(void *)bb->bb_buf, (void *)bb->bb_buf,
bb->bb_buf_used, bb->bb_buf_used,
(flush_logfile || (flush_logfile ||
flushall_logfiles)); do_flushall));
if (err) if (err)
{ {
fprintf(stderr, fprintf(stderr,
@ -2967,13 +3012,28 @@ static void* thr_filewriter_fun(
* Loop is restarted to ensure that all logfiles are * Loop is restarted to ensure that all logfiles are
* flushed. * flushed.
*/ */
if (!flushall_logfiles && skygw_thread_must_exit(thr))
{ if(flushall_started_flag){
flushall_logfiles = true; flushall_started_flag = false;
flushall_done_flag = true;
i = LOGFILE_FIRST; i = LOGFILE_FIRST;
goto retry_flush_on_exit; goto retry_flush_on_exit;
} }
} /* for */
if (!thr_flushall_check() && skygw_thread_must_exit(thr))
{
flushall_logfiles(true);
i = LOGFILE_FIRST;
goto retry_flush_on_exit;
}
}/* for */
if(flushall_done_flag){
flushall_done_flag = false;
flushall_logfiles(false);
skygw_message_send(fwr->fwr_clientmes);
}
} /* while (!skygw_thread_must_exit) */ } /* while (!skygw_thread_must_exit) */
ss_debug(skygw_thread_set_state(thr, THR_STOPPED)); ss_debug(skygw_thread_set_state(thr, THR_STOPPED));
@ -3061,7 +3121,7 @@ static int find_last_seqno(
} }
} }
if (check_file_and_path(filename, NULL)) if (check_file_and_path(filename, NULL, false))
{ {
seqno++; seqno++;
} }
@ -3074,3 +3134,33 @@ static int find_last_seqno(
return seqno; return seqno;
} }
bool thr_flushall_check()
{
bool rval = false;
simple_mutex_lock(&lm->lm_mutex,true);
rval = flushall_flag;
if(rval && !flushall_started_flag && !flushall_done_flag){
flushall_started_flag = true;
}
simple_mutex_unlock(&lm->lm_mutex);
return rval;
}
void flushall_logfiles(bool flush)
{
simple_mutex_lock(&lm->lm_mutex,true);
flushall_flag = flush;
simple_mutex_unlock(&lm->lm_mutex);
}
/**
* Flush all log files synchronously
*/
void skygw_log_sync_all(void)
{
skygw_log_write(LOGFILE_TRACE,"Starting log flushing to disk.");
flushall_logfiles(true);
skygw_message_send(lm->lm_logmes);
skygw_message_wait(lm->lm_clientmes);
}

10
server/MaxScale_template.cnf
View File

@ -31,7 +31,7 @@ threads=4
# backend_write_timeout=<timeout in seconds> # backend_write_timeout=<timeout in seconds>
# backend_read_timeout=<timeout in seconds> # backend_read_timeout=<timeout in seconds>
# #
## mysql_monitor specific options: ## MySQL monitor-specific options:
# #
# Enable detection of replication slaves lag via replication_heartbeat # Enable detection of replication slaves lag via replication_heartbeat
# table - optional. # table - optional.
@ -43,6 +43,13 @@ threads=4
# #
# detect_stale_master=[1|0] (default 0) # detect_stale_master=[1|0] (default 0)
# #
## Galera monitor-specific options:
#
# If disable_master_failback is not set, recovery of previously failed master
# causes mastership to be switched back to it. Enabling the option prevents it.
#
# disable_master_failback=[0|1] (default 0)
#
## Examples: ## Examples:
[MySQL Monitor] [MySQL Monitor]
@ -65,6 +72,7 @@ servers=server1,server2,server3
user=myuser user=myuser
passwd=mypwd passwd=mypwd
monitor_interval=10000 monitor_interval=10000
#disable_master_failback=
## Filter definition ## Filter definition
# #

1
server/modules/include/mysql_client_server_protocol.h
View File

@ -95,6 +95,7 @@ typedef enum {
MYSQL_AUTH_SENT, MYSQL_AUTH_SENT,
MYSQL_AUTH_RECV, MYSQL_AUTH_RECV,
MYSQL_AUTH_FAILED, MYSQL_AUTH_FAILED,
MYSQL_HANDSHAKE_FAILED,
MYSQL_IDLE MYSQL_IDLE
} mysql_auth_state_t; } mysql_auth_state_t;

17
server/modules/protocol/mysql_backend.c
View File

@ -211,12 +211,13 @@ static int gw_read_backend_event(DCB *dcb) {
/** Read cached backend handshake */ /** Read cached backend handshake */
if (gw_read_backend_handshake(backend_protocol) != 0) if (gw_read_backend_handshake(backend_protocol) != 0)
{ {
backend_protocol->protocol_auth_state = MYSQL_AUTH_FAILED; backend_protocol->protocol_auth_state = MYSQL_HANDSHAKE_FAILED;
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
"%lu [gw_read_backend_event] after " "%lu [gw_read_backend_event] after "
"gw_read_backend_handshake, fd %d, " "gw_read_backend_handshake, fd %d, "
"state = MYSQL_AUTH_FAILED.", "state = MYSQL_HANDSHAKE_FAILED.",
pthread_self(), pthread_self(),
backend_protocol->owner_dcb->fd))); backend_protocol->owner_dcb->fd)));
} }
@ -256,6 +257,7 @@ static int gw_read_backend_event(DCB *dcb) {
* -- handle a previous handshake error * -- handle a previous handshake error
*/ */
if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV || if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV ||
backend_protocol->protocol_auth_state == MYSQL_HANDSHAKE_FAILED ||
backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED) backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED)
{ {
spinlock_acquire(&dcb->authlock); spinlock_acquire(&dcb->authlock);
@ -264,6 +266,7 @@ static int gw_read_backend_event(DCB *dcb) {
CHK_PROTOCOL(backend_protocol); CHK_PROTOCOL(backend_protocol);
if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV || if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV ||
backend_protocol->protocol_auth_state == MYSQL_HANDSHAKE_FAILED ||
backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED) backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED)
{ {
ROUTER_OBJECT *router = NULL; ROUTER_OBJECT *router = NULL;
@ -286,7 +289,7 @@ static int gw_read_backend_event(DCB *dcb) {
if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV) if (backend_protocol->protocol_auth_state == MYSQL_AUTH_RECV)
{ {
/** /**
* Read backed's reply to authentication message * Read backend's reply to authentication message
*/ */
receive_rc = receive_rc =
gw_receive_backend_auth(backend_protocol); gw_receive_backend_auth(backend_protocol);
@ -340,7 +343,8 @@ static int gw_read_backend_event(DCB *dcb) {
} /* switch */ } /* switch */
} }
if (backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED) if (backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED ||
backend_protocol->protocol_auth_state == MYSQL_HANDSHAKE_FAILED)
{ {
/** /**
* protocol state won't change anymore, * protocol state won't change anymore,
@ -362,7 +366,9 @@ static int gw_read_backend_event(DCB *dcb) {
bool succp; bool succp;
/* try reload users' table for next connection */ /* try reload users' table for next connection */
if (backend_protocol->protocol_auth_state == MYSQL_AUTH_FAILED) {
service_refresh_users(dcb->session->service); service_refresh_users(dcb->session->service);
}
#if defined(SS_DEBUG) #if defined(SS_DEBUG)
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
@ -428,7 +434,7 @@ static int gw_read_backend_event(DCB *dcb) {
spinlock_release(&dcb->authlock); spinlock_release(&dcb->authlock);
} /* MYSQL_AUTH_RECV || MYSQL_AUTH_FAILED */ } /* MYSQL_AUTH_RECV || MYSQL_AUTH_FAILED || MYSQL_HANDSHAKE_FAILED */
/* reading MySQL command output from backend and writing to the client */ /* reading MySQL command output from backend and writing to the client */
{ {
@ -693,6 +699,7 @@ gw_MySQLWrite_backend(DCB *dcb, GWBUF *queue)
* return 1. * return 1.
*/ */
switch (backend_protocol->protocol_auth_state) { switch (backend_protocol->protocol_auth_state) {
case MYSQL_HANDSHAKE_FAILED:
case MYSQL_AUTH_FAILED: case MYSQL_AUTH_FAILED:
{ {
size_t len; size_t len;

21
server/modules/protocol/mysql_common.c
View File

@ -214,12 +214,12 @@ int gw_read_backend_handshake(
if (h_len <= 4) { if (h_len <= 4) {
/* log error this exit point */ /* log error this exit point */
conn->protocol_auth_state = MYSQL_AUTH_FAILED; conn->protocol_auth_state = MYSQL_HANDSHAKE_FAILED;
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
"%lu [gw_read_backend_handshake] after " "%lu [gw_read_backend_handshake] after "
"dcb_read, fd %d, " "dcb_read, fd %d, "
"state = MYSQL_AUTH_FAILED.", "state = MYSQL_HANDSHAKE_FAILED.",
dcb->fd, dcb->fd,
pthread_self()))); pthread_self())));
@ -232,6 +232,8 @@ int gw_read_backend_handshake(
uint16_t errcode = MYSQL_GET_ERRCODE(payload); uint16_t errcode = MYSQL_GET_ERRCODE(payload);
char* bufstr = strndup(&((char *)payload)[7], len-3); char* bufstr = strndup(&((char *)payload)[7], len-3);
conn->protocol_auth_state = MYSQL_HANDSHAKE_FAILED;
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
"%lu [gw_receive_backend_auth] Invalid " "%lu [gw_receive_backend_auth] Invalid "
@ -261,12 +263,14 @@ int gw_read_backend_handshake(
* data in buffer less than expected in the * data in buffer less than expected in the
* packet. Log error this exit point * packet. Log error this exit point
*/ */
conn->protocol_auth_state = MYSQL_AUTH_FAILED;
conn->protocol_auth_state = MYSQL_HANDSHAKE_FAILED;
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
"%lu [gw_read_backend_handshake] after " "%lu [gw_read_backend_handshake] after "
"gw_mysql_get_byte3, fd %d, " "gw_mysql_get_byte3, fd %d, "
"state = MYSQL_AUTH_FAILED.", "state = MYSQL_HANDSHAKE_FAILED.",
pthread_self(), pthread_self(),
dcb->fd, dcb->fd,
pthread_self()))); pthread_self())));
@ -285,12 +289,13 @@ int gw_read_backend_handshake(
* we cannot continue * we cannot continue
* log error this exit point * log error this exit point
*/ */
conn->protocol_auth_state = MYSQL_AUTH_FAILED; conn->protocol_auth_state = MYSQL_HANDSHAKE_FAILED;
LOGIF(LD, (skygw_log_write( LOGIF(LD, (skygw_log_write(
LOGFILE_DEBUG, LOGFILE_DEBUG,
"%lu [gw_read_backend_handshake] after " "%lu [gw_read_backend_handshake] after "
"gw_decode_mysql_server_handshake, fd %d, " "gw_decode_mysql_server_handshake, fd %d, "
"state = MYSQL_AUTH_FAILED.", "state = MYSQL_HANDSHAKE_FAILED.",
pthread_self(), pthread_self(),
conn->owner_dcb->fd, conn->owner_dcb->fd,
pthread_self()))); pthread_self())));
@ -577,8 +582,8 @@ int gw_send_authentication_to_backend(
dcb = conn->owner_dcb; dcb = conn->owner_dcb;
final_capabilities = gw_mysql_get_byte4((uint8_t *)&server_capabilities); final_capabilities = gw_mysql_get_byte4((uint8_t *)&server_capabilities);
/** Copy client's flags to backend */ /** Copy client's flags to backend but with the known capabilities mask */
final_capabilities |= conn->client_capabilities; final_capabilities |= (conn->client_capabilities & GW_MYSQL_CAPABILITIES_CLIENT);
/* get charset the client sent and use it for connection auth */ /* get charset the client sent and use it for connection auth */
charset = conn->charset; charset = conn->charset;

10
utils/skygw_utils.cc
View File

@ -1680,12 +1680,12 @@ static bool file_write_header(
if (wbytes1 != 1 || wbytes2 != 1 || wbytes3 != 1 || wbytes4 != 1) { if (wbytes1 != 1 || wbytes2 != 1 || wbytes3 != 1 || wbytes4 != 1) {
fprintf(stderr, fprintf(stderr,
"* Writing header %s %s %s to %s failed.\n", "\nError : Writing header %s %s %s %s failed.\n",
header_buf1, header_buf1,
header_buf2, header_buf2,
header_buf3, header_buf3,
header_buf4); header_buf4);
perror("Logfile header write.\n"); perror("Logfile header write");
goto return_succp; goto return_succp;
} }
#endif #endif
@ -1757,11 +1757,11 @@ static bool file_write_footer(
if (wbytes1 != 1 || wbytes3 != 1 || wbytes4 != 1) if (wbytes1 != 1 || wbytes3 != 1 || wbytes4 != 1)
{ {
fprintf(stderr, fprintf(stderr,
"* Writing header %s %s to %s failed.\n", "\nError : Writing header %s %s to %s failed.\n",
header_buf1, header_buf1,
header_buf3, header_buf3,
header_buf4); header_buf4);
perror("Logfile header write.\n"); perror("Logfile header write");
goto return_succp; goto return_succp;
} }
#endif #endif
@ -1875,7 +1875,7 @@ skygw_file_t* skygw_file_init(
int eno = errno; int eno = errno;
errno = 0; errno = 0;
fprintf(stderr, fprintf(stderr,
"* Writing header of log file %s failed due %d, %s.\n", "\nError : Writing header of log file %s failed due %d, %s.\n",
file->sf_fname, file->sf_fname,
eno, eno,
strerror(eno)); strerror(eno));