1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
/* +------------------------------------+
* | Inspire Internet Relay Chat Daemon |
* +------------------------------------+
*
* InspIRCd: (C) 2002-2007 InspIRCd Development Team
* See: http://www.inspircd.org/wiki/index.php/Credits
*
* This program is free but copyrighted software; see
* the file COPYING for details.
*
* ---------------------------------------------------
*/
#include <time.h>
#include <string>
#include <sstream>
#include <fstream>
#include "socketengine.h"
#include "inspircd_se_config.h"
#include "filelogger.h"
FileLogger::FileLogger(InspIRCd* Instance, FILE* logfile)
: ServerInstance(Instance), log(logfile), writeops(0)
{
if (log)
{
irc::sockets::NonBlocking(fileno(log));
SetFd(fileno(log));
buffer.clear();
}
}
bool FileLogger::Readable()
{
return false;
}
void FileLogger::HandleEvent(EventType et, int errornum)
{
WriteLogLine("");
if (log)
ServerInstance->SE->DelFd(this);
}
void FileLogger::WriteLogLine(const std::string &line)
{
if (line.length())
buffer.append(line);
if (log)
{
int written = fprintf(log,"%s",buffer.c_str());
#ifdef WINDOWS
buffer.clear();
#else
if ((written >= 0) && (written < (int)buffer.length()))
{
buffer.erase(0, buffer.length());
ServerInstance->SE->AddFd(this);
}
else if (written == -1)
{
if (errno == EAGAIN)
ServerInstance->SE->AddFd(this);
}
else
{
/* Wrote the whole buffer, and no need for write callback */
buffer.clear();
}
#endif
if (writeops++ % 20)
{
fflush(log);
}
}
}
void FileLogger::Close()
{
if (log)
{
/* Burlex: Windows assumes nonblocking on FILE* pointers anyway, and also "file" fd's aren't the same
* as socket fd's.
*/
#ifndef WIN32
int flags = fcntl(fileno(log), F_GETFL, 0);
fcntl(fileno(log), F_SETFL, flags ^ O_NONBLOCK);
#endif
if (buffer.size())
fprintf(log,"%s",buffer.c_str());
#ifndef WINDOWS
ServerInstance->SE->DelFd(this);
#endif
fflush(log);
fclose(log);
}
buffer.clear();
}
FileLogger::~FileLogger()
{
this->Close();
}
|
