Source code
Revision control
Copy as Markdown
Other Tools
/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
#include "primpl.h"
#include <string.h>
#include <fcntl.h>
#ifdef XP_UNIX
# if defined(AIX) || defined(QNX)
/* To pick up sysconf */
# include <unistd.h>
# else
/* To pick up getrlimit, setrlimit */
# include <sys/time.h>
# include <sys/resource.h>
# endif
#endif /* XP_UNIX */
extern PRLock* _pr_flock_lock;
extern PRCondVar* _pr_flock_cv;
static PRInt32 PR_CALLBACK FileRead(PRFileDesc* fd, void* buf, PRInt32 amount) {
PRInt32 rv = 0;
PRThread* me = _PR_MD_CURRENT_THREAD();
if (_PR_PENDING_INTERRUPT(me)) {
me->flags &= ~_PR_INTERRUPT;
PR_SetError(PR_PENDING_INTERRUPT_ERROR, 0);
rv = -1;
}
if (_PR_IO_PENDING(me)) {
PR_SetError(PR_IO_PENDING_ERROR, 0);
rv = -1;
}
if (rv == -1) {
return rv;
}
rv = _PR_MD_READ(fd, buf, amount);
if (rv < 0) {
PR_ASSERT(rv == -1);
}
PR_LOG(_pr_io_lm, PR_LOG_MAX, ("read -> %d", rv));
return rv;
}
static PRInt32 PR_CALLBACK FileWrite(PRFileDesc* fd, const void* buf,
PRInt32 amount) {
PRInt32 rv = 0;
PRInt32 temp, count;
PRThread* me = _PR_MD_CURRENT_THREAD();
if (_PR_PENDING_INTERRUPT(me)) {
me->flags &= ~_PR_INTERRUPT;
PR_SetError(PR_PENDING_INTERRUPT_ERROR, 0);
rv = -1;
}
if (_PR_IO_PENDING(me)) {
PR_SetError(PR_IO_PENDING_ERROR, 0);
rv = -1;
}
if (rv != 0) {
return rv;
}
count = 0;
#if !defined(_PR_HAVE_O_APPEND) /* Bugzilla: 4090, 276330 */
if (fd->secret->appendMode) {
if (PR_Seek64(fd, 0, PR_SEEK_END) == -1) {
return -1;
}
} /* if (fd->secret->appendMode...) */
#endif /* _PR_HAVE_O_APPEND */
while (amount > 0) {
temp = _PR_MD_WRITE(fd, buf, amount);
if (temp < 0) {
count = -1;
break;
}
count += temp;
if (fd->secret->nonblocking) {
break;
}
buf = (const void*)((const char*)buf + temp);
amount -= temp;
}
PR_LOG(_pr_io_lm, PR_LOG_MAX, ("write -> %d", count));
return count;
}
static PROffset32 PR_CALLBACK FileSeek(PRFileDesc* fd, PROffset32 offset,
PRSeekWhence whence) {
PROffset32 result;
result = _PR_MD_LSEEK(fd, offset, whence);
return result;
}
static PROffset64 PR_CALLBACK FileSeek64(PRFileDesc* fd, PROffset64 offset,
PRSeekWhence whence) {
PROffset64 result;
result = _PR_MD_LSEEK64(fd, offset, whence);
return result;
}
static PRInt32 PR_CALLBACK FileAvailable(PRFileDesc* fd) {
PRInt32 result, cur, end;
cur = _PR_MD_LSEEK(fd, 0, PR_SEEK_CUR);
if (cur >= 0) {
end = _PR_MD_LSEEK(fd, 0, PR_SEEK_END);
}
if ((cur < 0) || (end < 0)) {
return -1;
}
result = end - cur;
_PR_MD_LSEEK(fd, cur, PR_SEEK_SET);
return result;
}
static PRInt64 PR_CALLBACK FileAvailable64(PRFileDesc* fd) {
PRInt64 result, cur, end;
PRInt64 minus_one;
LL_I2L(minus_one, -1);
cur = _PR_MD_LSEEK64(fd, LL_ZERO, PR_SEEK_CUR);
if (LL_GE_ZERO(cur)) {
end = _PR_MD_LSEEK64(fd, LL_ZERO, PR_SEEK_END);
}
if (!LL_GE_ZERO(cur) || !LL_GE_ZERO(end)) {
return minus_one;
}
LL_SUB(result, end, cur);
(void)_PR_MD_LSEEK64(fd, cur, PR_SEEK_SET);
return result;
}
static PRInt32 PR_CALLBACK PipeAvailable(PRFileDesc* fd) {
PRInt32 rv;
rv = _PR_MD_PIPEAVAILABLE(fd);
return rv;
}
static PRInt64 PR_CALLBACK PipeAvailable64(PRFileDesc* fd) {
PRInt64 rv;
LL_I2L(rv, _PR_MD_PIPEAVAILABLE(fd));
return rv;
}
static PRStatus PR_CALLBACK PipeSync(PRFileDesc* fd) { return PR_SUCCESS; }
static PRStatus PR_CALLBACK FileGetInfo(PRFileDesc* fd, PRFileInfo* info) {
PRInt32 rv;
rv = _PR_MD_GETOPENFILEINFO(fd, info);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
static PRStatus PR_CALLBACK FileGetInfo64(PRFileDesc* fd, PRFileInfo64* info) {
/* $$$$ NOT YET IMPLEMENTED */
PRInt32 rv;
rv = _PR_MD_GETOPENFILEINFO64(fd, info);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
static PRStatus PR_CALLBACK FileSync(PRFileDesc* fd) {
PRInt32 result;
result = _PR_MD_FSYNC(fd);
if (result < 0) {
return PR_FAILURE;
}
return PR_SUCCESS;
}
static PRStatus PR_CALLBACK FileClose(PRFileDesc* fd) {
if (!fd || !fd->secret ||
(fd->secret->state != _PR_FILEDESC_OPEN &&
fd->secret->state != _PR_FILEDESC_CLOSED)) {
PR_SetError(PR_BAD_DESCRIPTOR_ERROR, 0);
return PR_FAILURE;
}
if (fd->secret->state == _PR_FILEDESC_OPEN) {
if (_PR_MD_CLOSE_FILE(fd->secret->md.osfd) < 0) {
return PR_FAILURE;
}
fd->secret->state = _PR_FILEDESC_CLOSED;
}
PR_FreeFileDesc(fd);
return PR_SUCCESS;
}
static PRInt16 PR_CALLBACK FilePoll(PRFileDesc* fd, PRInt16 in_flags,
PRInt16* out_flags) {
*out_flags = 0;
return in_flags;
} /* FilePoll */
static PRIOMethods _pr_fileMethods = {PR_DESC_FILE,
FileClose,
FileRead,
FileWrite,
FileAvailable,
FileAvailable64,
FileSync,
FileSeek,
FileSeek64,
FileGetInfo,
FileGetInfo64,
(PRWritevFN)_PR_InvalidInt,
(PRConnectFN)_PR_InvalidStatus,
(PRAcceptFN)_PR_InvalidDesc,
(PRBindFN)_PR_InvalidStatus,
(PRListenFN)_PR_InvalidStatus,
(PRShutdownFN)_PR_InvalidStatus,
(PRRecvFN)_PR_InvalidInt,
(PRSendFN)_PR_InvalidInt,
(PRRecvfromFN)_PR_InvalidInt,
(PRSendtoFN)_PR_InvalidInt,
FilePoll,
(PRAcceptreadFN)_PR_InvalidInt,
(PRTransmitfileFN)_PR_InvalidInt,
(PRGetsocknameFN)_PR_InvalidStatus,
(PRGetpeernameFN)_PR_InvalidStatus,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRGetsocketoptionFN)_PR_InvalidStatus,
(PRSetsocketoptionFN)_PR_InvalidStatus,
(PRSendfileFN)_PR_InvalidInt,
(PRConnectcontinueFN)_PR_InvalidStatus,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt};
PR_IMPLEMENT(const PRIOMethods*) PR_GetFileMethods(void) {
return &_pr_fileMethods;
}
static PRIOMethods _pr_pipeMethods = {PR_DESC_PIPE,
FileClose,
FileRead,
FileWrite,
PipeAvailable,
PipeAvailable64,
PipeSync,
(PRSeekFN)_PR_InvalidInt,
(PRSeek64FN)_PR_InvalidInt64,
(PRFileInfoFN)_PR_InvalidStatus,
(PRFileInfo64FN)_PR_InvalidStatus,
(PRWritevFN)_PR_InvalidInt,
(PRConnectFN)_PR_InvalidStatus,
(PRAcceptFN)_PR_InvalidDesc,
(PRBindFN)_PR_InvalidStatus,
(PRListenFN)_PR_InvalidStatus,
(PRShutdownFN)_PR_InvalidStatus,
(PRRecvFN)_PR_InvalidInt,
(PRSendFN)_PR_InvalidInt,
(PRRecvfromFN)_PR_InvalidInt,
(PRSendtoFN)_PR_InvalidInt,
FilePoll,
(PRAcceptreadFN)_PR_InvalidInt,
(PRTransmitfileFN)_PR_InvalidInt,
(PRGetsocknameFN)_PR_InvalidStatus,
(PRGetpeernameFN)_PR_InvalidStatus,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRGetsocketoptionFN)_PR_InvalidStatus,
(PRSetsocketoptionFN)_PR_InvalidStatus,
(PRSendfileFN)_PR_InvalidInt,
(PRConnectcontinueFN)_PR_InvalidStatus,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt,
(PRReservedFN)_PR_InvalidInt};
PR_IMPLEMENT(const PRIOMethods*) PR_GetPipeMethods(void) {
return &_pr_pipeMethods;
}
PR_IMPLEMENT(PRFileDesc*) PR_Open(const char* name, PRIntn flags, PRIntn mode) {
PROsfd osfd;
PRFileDesc* fd = 0;
#if !defined(_PR_HAVE_O_APPEND)
PRBool appendMode = (PR_APPEND & flags) ? PR_TRUE : PR_FALSE;
#endif
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
/* Map pr open flags and mode to os specific flags */
osfd = _PR_MD_OPEN(name, flags, mode);
if (osfd != -1) {
fd = PR_AllocFileDesc(osfd, &_pr_fileMethods);
if (!fd) {
(void)_PR_MD_CLOSE_FILE(osfd);
} else {
#if !defined(_PR_HAVE_O_APPEND)
fd->secret->appendMode = appendMode;
#endif
_PR_MD_INIT_FD_INHERITABLE(fd, PR_FALSE);
}
}
return fd;
}
PR_IMPLEMENT(PRFileDesc*)
PR_OpenFile(const char* name, PRIntn flags, PRIntn mode) {
PROsfd osfd;
PRFileDesc* fd = 0;
#if !defined(_PR_HAVE_O_APPEND)
PRBool appendMode = (PR_APPEND & flags) ? PR_TRUE : PR_FALSE;
#endif
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
/* Map pr open flags and mode to os specific flags */
osfd = _PR_MD_OPEN_FILE(name, flags, mode);
if (osfd != -1) {
fd = PR_AllocFileDesc(osfd, &_pr_fileMethods);
if (!fd) {
(void)_PR_MD_CLOSE_FILE(osfd);
} else {
#if !defined(_PR_HAVE_O_APPEND)
fd->secret->appendMode = appendMode;
#endif
_PR_MD_INIT_FD_INHERITABLE(fd, PR_FALSE);
}
}
return fd;
}
PR_IMPLEMENT(PRInt32) PR_GetSysfdTableMax(void) {
#if defined(XP_UNIX) && !defined(AIX) && !defined(QNX)
struct rlimit rlim;
if (getrlimit(RLIMIT_NOFILE, &rlim) < 0) {
/* XXX need to call PR_SetError() */
return -1;
}
return rlim.rlim_max;
#elif defined(AIX) || defined(QNX)
return sysconf(_SC_OPEN_MAX);
#elif defined(WIN32)
/*
* There is a systemwide limit of 65536 user handles.
*/
return 16384;
#else
write me;
#endif
}
PR_IMPLEMENT(PRInt32) PR_SetSysfdTableSize(int table_size) {
#if defined(XP_UNIX) && !defined(AIX) && !defined(QNX)
struct rlimit rlim;
PRInt32 tableMax = PR_GetSysfdTableMax();
if (tableMax < 0) {
return -1;
}
if (tableMax > FD_SETSIZE) {
tableMax = FD_SETSIZE;
}
rlim.rlim_max = tableMax;
/* Grow as much as we can; even if too big */
if (rlim.rlim_max < table_size) {
rlim.rlim_cur = rlim.rlim_max;
} else {
rlim.rlim_cur = table_size;
}
if (setrlimit(RLIMIT_NOFILE, &rlim) < 0) {
/* XXX need to call PR_SetError() */
return -1;
}
return rlim.rlim_cur;
#elif defined(AIX) || defined(QNX) || defined(WIN32)
PR_SetError(PR_NOT_IMPLEMENTED_ERROR, 0);
return -1;
#else
write me;
#endif
}
PR_IMPLEMENT(PRStatus) PR_Delete(const char* name) {
PRInt32 rv;
rv = _PR_MD_DELETE(name);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
PR_IMPLEMENT(PRStatus) PR_GetFileInfo(const char* fn, PRFileInfo* info) {
PRInt32 rv;
rv = _PR_MD_GETFILEINFO(fn, info);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
PR_IMPLEMENT(PRStatus) PR_GetFileInfo64(const char* fn, PRFileInfo64* info) {
PRInt32 rv;
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
rv = _PR_MD_GETFILEINFO64(fn, info);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
PR_IMPLEMENT(PRStatus) PR_Rename(const char* from, const char* to) {
PRInt32 rv;
rv = _PR_MD_RENAME(from, to);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
PR_IMPLEMENT(PRStatus) PR_Access(const char* name, PRAccessHow how) {
PRInt32 rv;
rv = _PR_MD_ACCESS(name, how);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
/*
** Import an existing OS file to NSPR
*/
PR_IMPLEMENT(PRFileDesc*) PR_ImportFile(PROsfd osfd) {
PRFileDesc* fd = NULL;
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
fd = PR_AllocFileDesc(osfd, &_pr_fileMethods);
if (!fd) {
(void)_PR_MD_CLOSE_FILE(osfd);
} else {
_PR_MD_INIT_FD_INHERITABLE(fd, PR_TRUE);
}
return fd;
}
/*
** Import an existing OS pipe to NSPR
*/
PR_IMPLEMENT(PRFileDesc*) PR_ImportPipe(PROsfd osfd) {
PRFileDesc* fd = NULL;
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
fd = PR_AllocFileDesc(osfd, &_pr_pipeMethods);
if (!fd) {
(void)_PR_MD_CLOSE_FILE(osfd);
} else {
_PR_MD_INIT_FD_INHERITABLE(fd, PR_TRUE);
#ifdef WINNT
fd->secret->md.sync_file_io = PR_TRUE;
#endif
}
return fd;
}
#ifndef NO_NSPR_10_SUPPORT
/*
* This function is supposed to be for backward compatibility with
* nspr 1.0. Therefore, it still uses the nspr 1.0 error-reporting
* mechanism -- returns a PRInt32, which is the error code when the call
* fails.
*
* If we need this function in nspr 2.0, it should be changed to
* return PRStatus, as follows:
*
* PR_IMPLEMENT(PRStatus) PR_Stat(const char *name, struct stat *buf)
* {
* PRInt32 rv;
*
* rv = _PR_MD_STAT(name, buf);
* if (rv < 0)
* return PR_FAILURE;
* else
* return PR_SUCCESS;
* }
*
* -- wtc, 2/14/97.
*/
PR_IMPLEMENT(PRInt32) PR_Stat(const char* name, struct stat* buf) {
PRInt32 rv;
rv = _PR_MD_STAT(name, buf);
return rv;
}
#endif /* ! NO_NSPR_10_SUPPORT */
PR_IMPLEMENT(PRStatus) PR_LockFile(PRFileDesc* fd) {
PRStatus status = PR_SUCCESS;
#ifdef WINNT
if (!fd->secret->md.io_model_committed) {
PRInt32 rv;
rv = _md_Associate((HANDLE)fd->secret->md.osfd);
PR_ASSERT(0 != rv);
fd->secret->md.io_model_committed = PR_TRUE;
}
#endif
PR_Lock(_pr_flock_lock);
while (fd->secret->lockCount == -1) {
PR_WaitCondVar(_pr_flock_cv, PR_INTERVAL_NO_TIMEOUT);
}
if (fd->secret->lockCount == 0) {
fd->secret->lockCount = -1;
PR_Unlock(_pr_flock_lock);
status = _PR_MD_LOCKFILE(fd->secret->md.osfd);
PR_Lock(_pr_flock_lock);
fd->secret->lockCount = (status == PR_SUCCESS) ? 1 : 0;
PR_NotifyAllCondVar(_pr_flock_cv);
} else {
fd->secret->lockCount++;
}
PR_Unlock(_pr_flock_lock);
return status;
}
PR_IMPLEMENT(PRStatus) PR_TLockFile(PRFileDesc* fd) {
PRStatus status = PR_SUCCESS;
#ifdef WINNT
if (!fd->secret->md.io_model_committed) {
PRInt32 rv;
rv = _md_Associate((HANDLE)fd->secret->md.osfd);
PR_ASSERT(0 != rv);
fd->secret->md.io_model_committed = PR_TRUE;
}
#endif
PR_Lock(_pr_flock_lock);
if (fd->secret->lockCount == 0) {
status = _PR_MD_TLOCKFILE(fd->secret->md.osfd);
PR_ASSERT(status == PR_SUCCESS || fd->secret->lockCount == 0);
if (status == PR_SUCCESS) {
fd->secret->lockCount = 1;
}
} else {
fd->secret->lockCount++;
}
PR_Unlock(_pr_flock_lock);
return status;
}
PR_IMPLEMENT(PRStatus) PR_UnlockFile(PRFileDesc* fd) {
PRStatus rv = PR_SUCCESS;
PR_Lock(_pr_flock_lock);
if (fd->secret->lockCount == 1) {
rv = _PR_MD_UNLOCKFILE(fd->secret->md.osfd);
if (rv == PR_SUCCESS) {
fd->secret->lockCount = 0;
}
} else {
fd->secret->lockCount--;
}
PR_Unlock(_pr_flock_lock);
return rv;
}
PR_IMPLEMENT(PRStatus)
PR_CreatePipe(PRFileDesc** readPipe, PRFileDesc** writePipe) {
#if defined(WIN32) && !defined(WINCE)
HANDLE readEnd, writeEnd;
SECURITY_ATTRIBUTES pipeAttributes;
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
ZeroMemory(&pipeAttributes, sizeof(pipeAttributes));
pipeAttributes.nLength = sizeof(pipeAttributes);
pipeAttributes.bInheritHandle = TRUE;
if (CreatePipe(&readEnd, &writeEnd, &pipeAttributes, 0) == 0) {
PR_SetError(PR_UNKNOWN_ERROR, GetLastError());
return PR_FAILURE;
}
*readPipe = PR_AllocFileDesc((PROsfd)readEnd, &_pr_pipeMethods);
if (NULL == *readPipe) {
CloseHandle(readEnd);
CloseHandle(writeEnd);
return PR_FAILURE;
}
*writePipe = PR_AllocFileDesc((PROsfd)writeEnd, &_pr_pipeMethods);
if (NULL == *writePipe) {
PR_Close(*readPipe);
CloseHandle(writeEnd);
return PR_FAILURE;
}
# ifdef WINNT
(*readPipe)->secret->md.sync_file_io = PR_TRUE;
(*writePipe)->secret->md.sync_file_io = PR_TRUE;
# endif
(*readPipe)->secret->inheritable = _PR_TRI_TRUE;
(*writePipe)->secret->inheritable = _PR_TRI_TRUE;
return PR_SUCCESS;
#elif defined(XP_UNIX)
int pipefd[2];
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
if (pipe(pipefd) == -1) {
/* XXX map pipe error */
PR_SetError(PR_UNKNOWN_ERROR, errno);
return PR_FAILURE;
}
*readPipe = PR_AllocFileDesc(pipefd[0], &_pr_pipeMethods);
if (NULL == *readPipe) {
close(pipefd[0]);
close(pipefd[1]);
return PR_FAILURE;
}
*writePipe = PR_AllocFileDesc(pipefd[1], &_pr_pipeMethods);
if (NULL == *writePipe) {
PR_Close(*readPipe);
close(pipefd[1]);
return PR_FAILURE;
}
_PR_MD_MAKE_NONBLOCK(*readPipe);
_PR_MD_INIT_FD_INHERITABLE(*readPipe, PR_FALSE);
_PR_MD_MAKE_NONBLOCK(*writePipe);
_PR_MD_INIT_FD_INHERITABLE(*writePipe, PR_FALSE);
return PR_SUCCESS;
#else
PR_SetError(PR_NOT_IMPLEMENTED_ERROR, 0);
return PR_FAILURE;
#endif
}
#ifdef MOZ_UNICODE
/* ================ UTF16 Interfaces ================================ */
PR_IMPLEMENT(PRFileDesc*)
PR_OpenFileUTF16(const PRUnichar* name, PRIntn flags, PRIntn mode) {
PROsfd osfd;
PRFileDesc* fd = 0;
# if !defined(_PR_HAVE_O_APPEND)
PRBool appendMode = (PR_APPEND & flags) ? PR_TRUE : PR_FALSE;
# endif
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
/* Map pr open flags and mode to os specific flags */
osfd = _PR_MD_OPEN_FILE_UTF16(name, flags, mode);
if (osfd != -1) {
fd = PR_AllocFileDesc(osfd, &_pr_fileMethods);
if (!fd) {
(void)_PR_MD_CLOSE_FILE(osfd);
} else {
# if !defined(_PR_HAVE_O_APPEND)
fd->secret->appendMode = appendMode;
# endif
_PR_MD_INIT_FD_INHERITABLE(fd, PR_FALSE);
}
}
return fd;
}
PR_IMPLEMENT(PRStatus)
PR_GetFileInfo64UTF16(const PRUnichar* fn, PRFileInfo64* info) {
PRInt32 rv;
if (!_pr_initialized) {
_PR_ImplicitInitialization();
}
rv = _PR_MD_GETFILEINFO64_UTF16(fn, info);
if (rv < 0) {
return PR_FAILURE;
} else {
return PR_SUCCESS;
}
}
/* ================ UTF16 Interfaces ================================ */
#endif /* MOZ_UNICODE */