Mercurial > hg > nginx
diff src/os/win32/ngx_files.c @ 184:1bf718ce0dde
nginx-0.0.1-2003-11-14-10:20:34 import
author | Igor Sysoev <igor@sysoev.ru> |
---|---|
date | Fri, 14 Nov 2003 07:20:34 +0000 |
parents | 4c698194c56d |
children | d5f50cefc322 |
line wrap: on
line diff
--- a/src/os/win32/ngx_files.c +++ b/src/os/win32/ngx_files.c @@ -6,13 +6,73 @@ 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) { + + /* + * 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 { + ovlp.Internal = 0; + ovlp.InternalHigh = 0; + ovlp.Offset = (DWORD) offset; + ovlp.OffsetHigh = (DWORD) (offset >> 32); + ovlp.hEvent = NULL; + + povlp = &ovlp; + } + + if (ReadFile(file->fd, buf, size, &n, povlp) == 0) { + ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "ReadFile() failed"); + return NGX_ERROR; + } + + file->offset += n; + + return n; +} + + +ssize_t ngx_write_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 (ngx_win32_version < NGX_WIN_NT) { - long high_offset; - ngx_err_t err; /* * in Win9X the overlapped pointer must be NULL @@ -47,8 +107,6 @@ ssize_t ngx_read_file(ngx_file_t *file, povlp = NULL; } else { - -#endif ovlp.Internal = 0; ovlp.InternalHigh = 0; ovlp.Offset = (DWORD) offset; @@ -56,80 +114,7 @@ ssize_t ngx_read_file(ngx_file_t *file, 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"); - return NGX_ERROR; - } - - file->offset += n; - - return n; -} - - -ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset) -{ - 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 (WIN9X) - } -#endif if (WriteFile(file->fd, buf, size, &n, povlp) == 0) { ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "WriteFile() failed"); @@ -142,15 +127,103 @@ ssize_t ngx_write_file(ngx_file_t *file, } +ssize_t ngx_write_chain_to_file(ngx_file_t *file, ngx_chain_t *cl, + off_t offset, ngx_pool_t *pool) +{ + char *buf, *prev; + size_t size; + ssize_t total, n; + + total = 0; + + while (cl) { + buf = cl->hunk->pos; + prev = buf; + size = 0; + + /* coalesce the neighbouring hunks */ + + while (cl && prev == cl->hunk->pos) { + size += cl->hunk->last - cl->hunk->pos; + prev = cl->hunk->last; + cl = cl->next; + } + + n = ngx_write_file(file, buf, size, offset); + + if (n == NGX_ERROR) { + return NGX_ERROR; + } + + total += n; + offset += n; + } + + return total; +} + + +int ngx_rename_file(ngx_str_t *from, ngx_str_t *to, ngx_pool_t *pool) +{ + int rc, collision; + u_int num; + char *name; + ngx_err_t err; + + name = ngx_palloc(pool, to->len + 1 + 10 + 1 + sizeof("DELETE")); + ngx_memcpy(name, to->data, to->len); + + collision = 0; + + /* mutex_lock() (per cache or single ?) */ + + do { + num = ngx_next_temp_number(collision); + + ngx_snprintf(name + to->len, 1 + 10 + 1 + sizeof("DELETE"), + ".%010u.DELETE", num); + + if (MoveFile(to->data, name) == 0) { + err = ngx_errno; + if (err == NGX_ENOENT || err == NGX_ENOTDIR) { + return NGX_ERROR; + } + + collision = 1; + ngx_log_error(NGX_LOG_ERR, pool->log, ngx_errno, + "MoveFile() failed"); + } + + } while (collision); + + if (ngx_win32_version >= NGX_WIN_NT) { + if (DeleteFile(name) == 0) { + ngx_log_error(NGX_LOG_ERR, pool->log, ngx_errno, + "DeleteFile() failed"); + } + } + + if (MoveFile(from->data, to->data) == 0) { + rc = NGX_ERROR; + + } else { + rc = NGX_OK; + } + + if (rc == NGX_ERROR) { + ngx_log_error(NGX_LOG_ERR, pool->log, ngx_errno, "MoveFile() failed"); + } + + /* mutex_unlock() */ + + return rc; +} + + int ngx_file_append_mode(ngx_fd_t fd) { - 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"); + if (ngx_errno != NO_ERROR) { return NGX_ERROR; } }