1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
#include <ngx_config.h>
#include <ngx_core.h>
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 (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;
}
}
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;
}
/* TODO: as read file */
ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
{
size_t n;
if (WriteFile(file->fd, buf, size, &n, NULL) == 0) {
ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "WriteFile() failed");
return NGX_ERROR;
}
file->offset += n;
return n;
}
/* TODO: log error */
int ngx_file_append_mode(ngx_fd_t fd)
{
if (SetFilePointer(fd, 0, NULL, FILE_END) == 0xFFFFFFFF) {
if (GetLastError() != NO_ERROR) {
return NGX_ERROR;
}
}
return NGX_OK;
}
|
