fsync initial

Author: dwgebler

ext/standard/basic_functions_arginfo.h

@@ -2560,6 +2560,7 @@ ZEND_FUNCTION(fstat);
 ZEND_FUNCTION(fseek);
 ZEND_FUNCTION(ftell);
 ZEND_FUNCTION(fflush);
+ZEND_FUNCTION(fsync);
 ZEND_FUNCTION(fwrite);
 ZEND_FUNCTION(mkdir);
 ZEND_FUNCTION(rename);
@@ -3197,6 +3198,7 @@ static const zend_function_entry ext_functions[] = {
 	ZEND_FE(fseek, arginfo_fseek)
 	ZEND_FE(ftell, arginfo_ftell)
 	ZEND_FE(fflush, arginfo_fflush)
+	ZEND_FE(fsync, arginfo_fflush)
 	ZEND_FE(fwrite, arginfo_fwrite)
 	ZEND_FALIAS(fputs, fwrite, arginfo_fputs)
 	ZEND_FE(mkdir, arginfo_mkdir)

ext/standard/file.c

@@ -1170,6 +1170,26 @@ PHPAPI PHP_FUNCTION(fwrite)
 }
 /* }}} */
 
+PHPAPI PHP_FUNCTION(fsync)
+{
+	zval *res;
+	int ret;
+	php_stream *stream;
+
+	ZEND_PARSE_PARAMETERS_START(1, 1)
+		Z_PARAM_RESOURCE(res)
+	ZEND_PARSE_PARAMETERS_END();
+
+	PHP_STREAM_TO_ZVAL(stream, res);
+
+	ret = php_stream_sync(stream);
+	if (ret) {
+		RETURN_FALSE;
+	}
+	RETURN_TRUE;
+
+}
+
 /* {{{ Flushes output */
 PHPAPI PHP_FUNCTION(fflush)
 {

ext/standard/file.h

@@ -29,6 +29,7 @@ PHPAPI PHP_FUNCTION(fgetc);
 PHPAPI PHP_FUNCTION(fgets);
 PHPAPI PHP_FUNCTION(fwrite);
 PHPAPI PHP_FUNCTION(fflush);
+PHPAPI PHP_FUNCTION(fsync);
 PHPAPI PHP_FUNCTION(rewind);
 PHPAPI PHP_FUNCTION(ftell);
 PHPAPI PHP_FUNCTION(fseek);

main/php_streams.h

@@ -117,6 +117,7 @@ typedef struct _php_stream_ops  {
 	ssize_t (*read)(php_stream *stream, char *buf, size_t count);
 	int    (*close)(php_stream *stream, int close_handle);
 	int    (*flush)(php_stream *stream);
+	int    (*sync)(php_stream *stream);
 
 	const char *label; /* label for this ops structure */
 
@@ -336,6 +337,9 @@ PHPAPI int _php_stream_putc(php_stream *stream, int c);
 PHPAPI int _php_stream_flush(php_stream *stream, int closing);
 #define php_stream_flush(stream)	_php_stream_flush((stream), 0)
 
+PHPAPI int _php_stream_sync(php_stream *stream);
+#define php_stream_sync(stream)	        _php_stream_sync((stream))
+
 PHPAPI char *_php_stream_get_line(php_stream *stream, char *buf, size_t maxlen, size_t *returned_len);
 #define php_stream_gets(stream, buf, maxlen)	_php_stream_get_line((stream), (buf), (maxlen), NULL)
 

main/streams/plain_wrapper.c

@@ -520,6 +520,21 @@ static int php_stdiop_close(php_stream *stream, int close_handle)
 	return ret;
 }
 
+//dwg
+static int php_stdiop_sync(php_stream *stream)
+{
+	php_stdio_stream_data *data = (php_stdio_stream_data*)stream->abstract;
+
+	assert(data != NULL);
+
+	if (data->file) {
+		fflush(data->file);
+		return fsync(fileno(data->file));
+	}
+	return 0;
+	
+}
+
 static int php_stdiop_flush(php_stream *stream)
 {
 	php_stdio_stream_data *data = (php_stdio_stream_data*)stream->abstract;
@@ -958,6 +973,7 @@ static int php_stdiop_set_option(php_stream *stream, int option, int value, void
 PHPAPI php_stream_ops	php_stream_stdio_ops = {
 	php_stdiop_write, php_stdiop_read,
 	php_stdiop_close, php_stdiop_flush,
+	php_stdiop_sync,
 	"STDIO",
 	php_stdiop_seek,
 	php_stdiop_cast,

main/streams/streams.c

@@ -1224,6 +1224,15 @@ static ssize_t _php_stream_write_filtered(php_stream *stream, const char *buf, s
 	return consumed;
 }
 
+PHPAPI int _php_stream_sync(php_stream *stream)
+{
+	int ret = 0;
+	if (stream->ops->sync) {
+		ret = stream->ops->sync(stream);
+	}
+	return ret;
+}
+
 PHPAPI int _php_stream_flush(php_stream *stream, int closing)
 {
 	int ret = 0;