@@ -43,20 +43,16 @@ namespace gr {
43
43
namespace blocks {
44
44
45
45
file_sink_base::file_sink_base (const char * filename, bool is_binary, bool append)
46
- : d_fp(0 ),
47
- d_new_fp (0 ),
48
- d_updated(false ),
49
- d_is_binary(is_binary),
50
- d_append(append),
51
- d_base_logger(" file_sink_base" )
46
+ : d_fp(0 ), d_new_fp(0 ), d_updated(false ), d_is_binary(is_binary), d_append(append)
52
47
{
48
+ gr::configure_default_loggers (d_base_logger, d_base_debug_logger, " file_sink_base" );
53
49
if (!open (filename))
54
50
throw std::runtime_error (" can't open file" );
55
51
}
56
52
57
53
file_sink_base::~file_sink_base ()
58
54
{
59
- d_base_logger. info (" [destructor] Closing file" );
55
+ d_base_debug_logger-> debug (" [destructor] Closing file" );
60
56
close ();
61
57
if (d_fp) {
62
58
fclose (d_fp);
@@ -67,7 +63,7 @@ file_sink_base::~file_sink_base()
67
63
bool file_sink_base::open (const char * filename)
68
64
{
69
65
gr::thread::scoped_lock guard (d_mutex); // hold mutex for duration of this function
70
- d_base_logger. info (" opening file {:s}" , filename);
66
+ d_base_debug_logger-> debug (" opening file {:s}" , filename);
71
67
72
68
// we use the open system call to get access to the O_LARGEFILE flag.
73
69
int fd;
@@ -79,7 +75,7 @@ bool file_sink_base::open(const char* filename)
79
75
flags = O_WRONLY | O_CREAT | O_TRUNC | OUR_O_LARGEFILE | OUR_O_BINARY;
80
76
}
81
77
if ((fd = ::open (filename, flags, 0664 )) < 0 ) {
82
- d_base_logger. error (" [::open] {:s}: {:s}" , filename, strerror (errno));
78
+ d_base_logger-> error (" [::open] {:s}: {:s}" , filename, strerror (errno));
83
79
return false ;
84
80
}
85
81
if (d_new_fp) { // if we've already got a new one open, close it
@@ -88,7 +84,7 @@ bool file_sink_base::open(const char* filename)
88
84
}
89
85
90
86
if ((d_new_fp = fdopen (fd, d_is_binary ? " wb" : " w" )) == NULL ) {
91
- d_base_logger. error (" [fdopen] {:s}: {:s}" , filename, strerror (errno));
87
+ d_base_logger-> error (" [fdopen] {:s}: {:s}" , filename, strerror (errno));
92
88
::close (fd); // don't leak file descriptor if fdopen fails.
93
89
}
94
90
@@ -100,7 +96,7 @@ void file_sink_base::close()
100
96
{
101
97
gr::thread::scoped_lock guard (d_mutex); // hold mutex for duration of this function
102
98
103
- d_base_logger. info (" Closing file" );
99
+ d_base_debug_logger-> debug (" Closing file" );
104
100
if (d_new_fp) {
105
101
fclose (d_new_fp);
106
102
d_new_fp = 0 ;
@@ -112,7 +108,7 @@ void file_sink_base::do_update()
112
108
{
113
109
if (d_updated) {
114
110
gr::thread::scoped_lock guard (d_mutex); // hold mutex for duration of this block
115
- d_base_logger. info (" updating" );
111
+ d_base_debug_logger-> debug (" updating" );
116
112
if (d_fp)
117
113
fclose (d_fp);
118
114
d_fp = d_new_fp; // install new file pointer
@@ -123,7 +119,7 @@ void file_sink_base::do_update()
123
119
124
120
void file_sink_base::set_unbuffered (bool unbuffered)
125
121
{
126
- d_base_logger. info (" Setting to {:s}buffered state" , unbuffered ? " un" : " " );
122
+ d_base_debug_logger-> debug (" Setting to {:s}buffered state" , unbuffered ? " un" : " " );
127
123
d_unbuffered = unbuffered;
128
124
}
129
125
0 commit comments