/src/logging-log4cxx/src/main/cpp/fileoutputstream.cpp

Source
/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <log4cxx/logstring.h>
#include <log4cxx/helpers/fileoutputstream.h>
#include <log4cxx/helpers/pool.h>
#include <log4cxx/helpers/exception.h>
#include <log4cxx/helpers/bytebuffer.h>
#include <apr_file_io.h>

using namespace LOG4CXX_NS;
using namespace LOG4CXX_NS::helpers;

struct FileOutputStream::FileOutputStreamPrivate
{
  FileOutputStreamPrivate() : fileptr(nullptr) {}

  Pool pool;
  apr_file_t* fileptr;
};

IMPLEMENT_LOG4CXX_OBJECT(FileOutputStream)

FileOutputStream::FileOutputStream(const LogString& filename,
  bool append) : m_priv(std::make_unique<FileOutputStreamPrivate>())
{
  m_priv->fileptr = open(filename, append, m_priv->pool);
}

FileOutputStream::FileOutputStream(const logchar* filename,
  bool append) : m_priv(std::make_unique<FileOutputStreamPrivate>())
{
  m_priv->fileptr = open(filename, append, m_priv->pool);
}

apr_file_t* FileOutputStream::open(const LogString& filename,
  bool append, Pool& pool)
{
  apr_fileperms_t perm = APR_OS_DEFAULT;
  apr_int32_t flags = APR_WRITE | APR_CREATE;

  if (append)
  {
    flags |= APR_APPEND;
  }
  else
  {
    flags |= APR_TRUNCATE;
  }

  File fn;
  fn.setPath(filename);
  apr_file_t* fileptr = 0;
  apr_status_t stat = fn.open(&fileptr, flags, perm, pool);

  if (stat != APR_SUCCESS)
  {
    throw IOException(filename, stat);
  }

  return fileptr;
}

FileOutputStream::~FileOutputStream()
{
  if (m_priv->fileptr)
  {
    apr_file_close(m_priv->fileptr);
  }
}

void FileOutputStream::close(Pool& /* p */)
{
  if (m_priv->fileptr)
  {
    apr_status_t stat = apr_file_close(m_priv->fileptr);

    if (stat != APR_SUCCESS)
    {
      throw IOException(stat);
    }

    m_priv->fileptr = NULL;
  }
}

void FileOutputStream::flush(Pool& /* p */)
{
}

void FileOutputStream::write(ByteBuffer& buf, Pool& /* p */ )
{
  if (m_priv->fileptr == NULL)
  {
    throw NullPointerException(LOG4CXX_STR("FileOutputStream"));
  }

  size_t nbytes = buf.remaining();
  while (nbytes > 0)
  {
    apr_status_t stat = apr_file_write(
        m_priv->fileptr, buf.current(), &nbytes);

    if (stat != APR_SUCCESS)
    {
      throw IOException(stat);
    }

    nbytes = buf.increment_position(nbytes);
  }
}

apr_file_t* FileOutputStream::getFilePtr() const{
  return m_priv->fileptr;
}


Line	Count	Source
1		/*
2		* Licensed to the Apache Software Foundation (ASF) under one or more
3		* contributor license agreements. See the NOTICE file distributed with
4		* this work for additional information regarding copyright ownership.
5		* The ASF licenses this file to You under the Apache License, Version 2.0
6		* (the "License"); you may not use this file except in compliance with
7		* the License. You may obtain a copy of the License at
8		*
9		* http://www.apache.org/licenses/LICENSE-2.0
10		*
11		* Unless required by applicable law or agreed to in writing, software
12		* distributed under the License is distributed on an "AS IS" BASIS,
13		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14		* See the License for the specific language governing permissions and
15		* limitations under the License.
16		*/
17
18		#include <log4cxx/logstring.h>
19		#include <log4cxx/helpers/fileoutputstream.h>
20		#include <log4cxx/helpers/pool.h>
21		#include <log4cxx/helpers/exception.h>
22		#include <log4cxx/helpers/bytebuffer.h>
23		#include <apr_file_io.h>
24
25		using namespace LOG4CXX_NS;
26		using namespace LOG4CXX_NS::helpers;
27
28		struct FileOutputStream::FileOutputStreamPrivate
29		{
30	858	FileOutputStreamPrivate() : fileptr(nullptr) {}
31
32		Pool pool;
33		apr_file_t* fileptr;
34		};
35
36		IMPLEMENT_LOG4CXX_OBJECT(FileOutputStream)
37
38		FileOutputStream::FileOutputStream(const LogString& filename,
39	858	bool append) : m_priv(std::make_unique<FileOutputStreamPrivate>())
40	858	{
41	858	m_priv->fileptr = open(filename, append, m_priv->pool);
42	858	}
43
44		FileOutputStream::FileOutputStream(const logchar* filename,
45	0	bool append) : m_priv(std::make_unique<FileOutputStreamPrivate>())
46	0	{
47	0	m_priv->fileptr = open(filename, append, m_priv->pool);
48	0	}
49
50		apr_file_t* FileOutputStream::open(const LogString& filename,
51		bool append, Pool& pool)
52	858	{
53	858	apr_fileperms_t perm = APR_OS_DEFAULT;
54	858	apr_int32_t flags = APR_WRITE \| APR_CREATE;
55
56	858	if (append)
57	418	{
58	418	flags \|= APR_APPEND;
59	418	}
60	440	else
61	440	{
62	440	flags \|= APR_TRUNCATE;
63	440	}
64
65	858	File fn;
66	858	fn.setPath(filename);
67	858	apr_file_t* fileptr = 0;
68	858	apr_status_t stat = fn.open(&fileptr, flags, perm, pool);
69
70	858	if (stat != APR_SUCCESS)
71	0	{
72	0	throw IOException(filename, stat);
73	0	}
74
75	858	return fileptr;
76	858	}
77
78		FileOutputStream::~FileOutputStream()
79	858	{
80	858	if (m_priv->fileptr)
81	0	{
82	0	apr_file_close(m_priv->fileptr);
83	0	}
84	858	}
85
86		void FileOutputStream::close(Pool& /* p */)
87	858	{
88	858	if (m_priv->fileptr)
89	858	{
90	858	apr_status_t stat = apr_file_close(m_priv->fileptr);
91
92	858	if (stat != APR_SUCCESS)
93	0	{
94	0	throw IOException(stat);
95	0	}
96
97	858	m_priv->fileptr = NULL;
98	858	}
99	858	}
100
101		void FileOutputStream::flush(Pool& /* p */)
102	4.28k	{
103	4.28k	}
104
105		void FileOutputStream::write(ByteBuffer& buf, Pool& /* p */ )
106	4.28k	{
107	4.28k	if (m_priv->fileptr == NULL)
108	0	{
109	0	throw NullPointerException(LOG4CXX_STR("FileOutputStream"));
110	0	}
111
112	4.28k	size_t nbytes = buf.remaining();
113	8.56k	while (nbytes > 0)
114	4.28k	{
115	4.28k	apr_status_t stat = apr_file_write(
116	4.28k	m_priv->fileptr, buf.current(), &nbytes);
117
118	4.28k	if (stat != APR_SUCCESS)
119	0	{
120	0	throw IOException(stat);
121	0	}
122
123	4.28k	nbytes = buf.increment_position(nbytes);
124	4.28k	}
125	4.28k	}
126
127	0	apr_file_t* FileOutputStream::getFilePtr() const{
128	0	return m_priv->fileptr;
129	0	}
130

Coverage Report

Created: 2026-04-12 06:23