//
// Written by Curtis Olson, started November 1999.
//
-// Copyright (C) 1999 Curtis L. Olson - curt@flightgear.org
+// Copyright (C) 1999 Curtis L. Olson - http://www.flightgear.org/~curt
//
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License as
#include STL_STRING
-#ifdef _MSC_VER
+#if defined(_MSC_VER) || defined(__MINGW32__)
# include <io.h>
#endif
#include "sg_file.hxx"
-FG_USING_STD(string);
+SG_USING_STD(string);
-SGFile::SGFile() {
+SGFile::SGFile( const string &file) {
set_type( sgFileType );
+ file_name = file;
+ eof_flag = true;
}
// open the file based on specified direction
-bool SGFile::open( SGProtocolDir dir ) {
- if ( dir == SG_IO_OUT ) {
-#ifdef _MSC_VER
- fp = _open( file_name.c_str(), O_WRONLY | O_CREAT | O_TRUNC,
- 00666 );
-#else
- fp = std::open( file_name.c_str(), O_WRONLY | O_CREAT | O_TRUNC,
- S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP |
- S_IROTH | S_IWOTH );
-#endif
- } else if ( dir == SG_IO_IN ) {
-#ifdef _MSC_VER
- fp = _open( file_name.c_str(), O_RDONLY );
+bool SGFile::open( const SGProtocolDir d ) {
+ set_dir( d );
+
+ if ( get_dir() == SG_IO_OUT ) {
+#if defined(_MSC_VER) || defined(__MINGW32__)
+ int mode = 00666;
#else
- fp = std::open( file_name.c_str(), O_RDONLY );
+ mode_t mode = S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH;
#endif
+ fp = ::open( file_name.c_str(), O_WRONLY | O_CREAT | O_TRUNC, mode );
+ } else if ( get_dir() == SG_IO_IN ) {
+ fp = ::open( file_name.c_str(), O_RDONLY );
} else {
- FG_LOG( FG_IO, FG_ALERT,
+ SG_LOG( SG_IO, SG_ALERT,
"Error: bidirection mode not available for files." );
return false;
}
if ( fp == -1 ) {
- FG_LOG( FG_IO, FG_ALERT, "Error opening file: " << file_name );
+ SG_LOG( SG_IO, SG_ALERT, "Error opening file: " << file_name );
return false;
}
+ eof_flag = false;
return true;
}
// read a block of data of specified size
int SGFile::read( char *buf, int length ) {
// read a chunk
-#ifdef _MSC_VER
- int result = _read( fp, buf, length );
-#else
- int result = std::read( fp, buf, length );
-#endif
-
+ ssize_t result = ::read( fp, buf, length );
+ if ( length > 0 && result == 0 ) {
+ eof_flag = true;
+ }
return result;
}
int pos = lseek( fp, 0, SEEK_CUR );
// read a chunk
-#ifdef _MSC_VER
- int result = _read( fp, buf, length );
-#else
- int result = std::read( fp, buf, length );
-#endif
+ ssize_t result = ::read( fp, buf, length );
+ if ( length > 0 && result == 0 ) {
+ eof_flag = true;
+ }
// find the end of line and reset position
int i;
// write data to a file
-int SGFile::write( char *buf, int length ) {
-#ifdef _MSC_VER
- int result = _write( fp, buf, length );
-#else
- int result = std::write( fp, buf, length );
-#endif
+int SGFile::write( const char *buf, const int length ) {
+ int result = ::write( fp, buf, length );
if ( result != length ) {
- FG_LOG( FG_IO, FG_ALERT, "Error writing data: " << file_name );
+ SG_LOG( SG_IO, SG_ALERT, "Error writing data: " << file_name );
}
return result;
// write null terminated string to a file
-int SGFile::writestring( char *str ) {
+int SGFile::writestring( const char *str ) {
int length = strlen( str );
return write( str, length );
}
// close the port
bool SGFile::close() {
-#ifdef _MSC_VER
- if ( _close( fp ) == -1 ) {
-#else
- if ( std::close( fp ) == -1 ) {
-#endif
+ if ( ::close( fp ) == -1 ) {
return false;
}
+ eof_flag = true;
return true;
}