diff options
Diffstat (limited to 'src/os/win32')
| -rw-r--r-- | src/os/win32/ngx_files.c | 120 | ||||
| -rw-r--r-- | src/os/win32/ngx_files.h | 10 | ||||
| -rw-r--r-- | src/os/win32/ngx_os.h | 49 | ||||
| -rw-r--r-- | src/os/win32/ngx_win32_config.h | 3 |
4 files changed, 158 insertions, 24 deletions
diff --git a/src/os/win32/ngx_files.c b/src/os/win32/ngx_files.c index faeb93d5c..139d141cb 100644 --- a/src/os/win32/ngx_files.c +++ b/src/os/win32/ngx_files.c @@ -6,26 +6,49 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset) { size_t n; - long high_offset; - ngx_err_t err; OVERLAPPED ovlp, *povlp; +#if (WIN9X) + if (ngx_win32_version < NGX_WIN_NT) { - high_offset = (long) (offset >> 32); - if (SetFilePointer(file->fd, (long) offset, &high_offset, FILE_BEGIN) - == 0xFFFFFFFF) - { - err = ngx_errno; - if (err != NO_ERROR) { - ngx_log_error(NGX_LOG_ERR, file->log, err, - "SeekFilePointer() failed"); - return NGX_ERROR; + long high_offset; + ngx_err_t err; + + /* + * in Win9X the overlapped pointer must be NULL + * so we need to use SetFilePointer() to set the offset + */ + + if (file->offset != offset) { + + /* + * the maximum file size on FAT16 is 2G, but on FAT32 it's 4G so we + * need to use high_offset because a single offset is signed value + */ + + high_offset = (long) (offset >> 32); + if (SetFilePointer(file->fd, (long) offset, &high_offset, + FILE_BEGIN) == INVALID_SET_FILE_POINTER) + { + /* + * INVALID_SET_FILE_POINTER is 0xffffffff and it can be valid + * value for large file so we need also to check GetLastError() + */ + + err = ngx_errno; + if (err != NO_ERROR) { + ngx_log_error(NGX_LOG_ERR, file->log, err, + "SeekFilePointer() failed"); + return NGX_ERROR; + } } } povlp = NULL; } else { + +#endif ovlp.Internal = 0; ovlp.InternalHigh = 0; ovlp.Offset = (DWORD) offset; @@ -33,7 +56,10 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset) ovlp.hEvent = NULL; povlp = &ovlp; + +#if (WIN9X) } +#endif if (ReadFile(file->fd, buf, size, &n, povlp) == 0) { ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "ReadFile() failed"); @@ -46,13 +72,66 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset) } -/* TODO: as read file */ - ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset) { - size_t n; + size_t n; + OVERLAPPED ovlp, *povlp; + +#if (WIN9X) + + if (ngx_win32_version < NGX_WIN_NT) { + long high_offset; + ngx_err_t err; + + /* + * in Win9X the overlapped pointer must be NULL + * so we need to use SetFilePointer() to set the offset + */ + + if (file->offset != offset) { + + /* + * the maximum file size on FAT16 is 2G, but on FAT32 it's 4G so we + * need to use high_offset because a single offset is signed value + */ + + high_offset = (long) (offset >> 32); + if (SetFilePointer(file->fd, (long) offset, &high_offset, + FILE_BEGIN) == INVALID_SET_FILE_POINTER) + { + /* + * INVALID_SET_FILE_POINTER is 0xffffffff and it can be valid + * value for large file so we need also to check GetLastError() + */ + + err = ngx_errno; + if (err != NO_ERROR) { + ngx_log_error(NGX_LOG_ERR, file->log, err, + "SeekFilePointer() failed"); + return NGX_ERROR; + } + } + } + + povlp = NULL; + + } else { + +#endif + + ovlp.Internal = 0; + ovlp.InternalHigh = 0; + ovlp.Offset = (DWORD) offset; + ovlp.OffsetHigh = (DWORD) (offset >> 32); + ovlp.hEvent = NULL; + + povlp = &ovlp; - if (WriteFile(file->fd, buf, size, &n, NULL) == 0) { +#if (WIN9X) + } +#endif + + if (WriteFile(file->fd, buf, size, &n, povlp) == 0) { ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "WriteFile() failed"); return NGX_ERROR; } @@ -63,12 +142,15 @@ ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset) } -/* TODO: log error */ - int ngx_file_append_mode(ngx_fd_t fd) { - if (SetFilePointer(fd, 0, NULL, FILE_END) == 0xFFFFFFFF) { - if (GetLastError() != NO_ERROR) { + ngx_err_t err; + + if (SetFilePointer(fd, 0, NULL, FILE_END) == INVALID_SET_FILE_POINTER) { + err = ngx_errno; + if (err != NO_ERROR) { + ngx_log_error(NGX_LOG_ERR, file->log, err, + "SeekFilePointer() failed"); return NGX_ERROR; } } diff --git a/src/os/win32/ngx_files.h b/src/os/win32/ngx_files.h index 8e739e9fb..8e386e8ca 100644 --- a/src/os/win32/ngx_files.h +++ b/src/os/win32/ngx_files.h @@ -6,11 +6,17 @@ #include <ngx_core.h> -/* INVALID_FILE_ATTRIBUTES specified but not defined at least in MSVC6SP2 */ +/* INVALID_FILE_ATTRIBUTES is specified but not defined at least in MSVC6SP2 */ #ifndef INVALID_FILE_ATTRIBUTES -#define INVALID_FILE_ATTRIBUTES 0xFFFFFFFF +#define INVALID_FILE_ATTRIBUTES 0xffffffff #endif +/* INVALID_SET_FILE_POINTER is not defined at least in MSVC6SP2 */ +#ifndef INVALID_SET_FILE_POINTER +#define INVALID_SET_FILE_POINTER 0xffffffff +#endif + + #define NGX_INVALID_FILE INVALID_HANDLE_VALUE #define NGX_FILE_ERROR 0 diff --git a/src/os/win32/ngx_os.h b/src/os/win32/ngx_os.h new file mode 100644 index 000000000..96f1c2d1f --- /dev/null +++ b/src/os/win32/ngx_os.h @@ -0,0 +1,49 @@ +ifndef _NGX_OS_H_INCLUDED_ +#define _NGX_OS_H_INCLUDED_ + + +#include <ngx_config.h> +#include <ngx_core.h> + +#define NGX_IO_SENDFILE 1 +#define NGX_IO_ZEROCOPY 2 + +#if (HAVE_SENDFILE) +#define NGX_HAVE_SENDFILE NGX_IO_SENDFILE +#else +#define NGX_HAVE_SENDFILE 0 +#endif + +#if (HAVE_ZEROCOPY) +#define NGX_HAVE_ZEROCOPY NGX_IO_ZEROCOPY +#else +#define NGX_HAVE_ZEROCOPY 0 +#endif + + + +typedef struct { + ssize_t (*recv)(ngx_connection_t *c, char *buf, size_t size); + ssize_t (*recv_chain)(ngx_connection_t *c, ngx_chain_t *in); + ssize_t (*send)(ngx_connection_t *c, char *buf, size_t size); + ngx_chain_t *(*send_chain)(ngx_connection_t *c, ngx_chain_t *in); + int flags; +} ngx_os_io_t; + + +int ngx_os_init(ngx_log_t *log); + + +extern ngx_os_io_t ngx_os_io; +extern int ngx_max_sockets; +extern int ngx_inherited_nonblocking; +extern int ngx_win32_version; + + +extern int restart; +extern int rotate; + + + +#endif /* _NGX_OS_H_INCLUDED_ */ + diff --git a/src/os/win32/ngx_win32_config.h b/src/os/win32/ngx_win32_config.h index 9ec07cf88..23164328b 100644 --- a/src/os/win32/ngx_win32_config.h +++ b/src/os/win32/ngx_win32_config.h @@ -4,10 +4,7 @@ #define WIN32 1 -/* STUB */ #define NGX_WIN_NT 200000 -extern int ngx_win32_version; -/**/ |
