/*

* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:

*

*/

// connectors for re-entrant networking system calls

#include <sys/errno.h>

#include "sysreent.h"

#include "aeselectreent.h"

#include <unistd.h>

#include <fcntl.h>		// for open()

#include <sys/ioctl.h>

#include <stdarg.h> 

#include <utf.h>

#include <unistd.h>

#include <sys/types.h>

#include <spawn.h>

#include <charconv.h>

#include "sys/stat.h"

#include <wchar.h>

#include "systemspecialfilercg.h"

#include "link.h"

#include "errno.h"

#include "sysif.h"

#include "lposix.h"

#define	MAXPATHLEN	256	/* E32STD.H: KMaxFullName */

TInt __EPOC32_WDIR::UpdateNarrow()

	{

	return -1;		//this is not supported.

	}

TInt __EPOC32_DIR::UpdateNarrow()

	{

	//update the narrow one

	TInt ret = CnvUtfConverter::ConvertFromUnicodeToUtf8(iCurrentNarrowName, iCurrentName);

	if (ret >= 0)

		{

		iCurrentNarrow.d_namlen=(short)iCurrentNarrowName.Length();

		memcpy(iCurrentNarrow.d_name,iCurrentNarrowName.PtrZ(),iCurrentNarrowName.Length() + 1);

		}

	return ret;

	}

__EPOC32_WDIR::~__EPOC32_WDIR()

	{

	delete iPath;

	delete iEntries;

	}

TInt __EPOC32_WDIR::Open(const wchar_t* _path,int* aErrno)

	{

	TParse name;

	TInt err = Backend()->ResolvePath(name,_path,NULL);

	if (!err)

		err = Open(name.DriveAndPath());

	if (err)

		MapError(err,*aErrno);

	return err;

	}

TInt __EPOC32_WDIR::Open(const TDesC& aPath)

	{

	delete iPath;

	iPath=aPath.Alloc();		//allocate space for a hbufc and initialise it to the TDesC contents

	return Open();

	}

TInt __EPOC32_WDIR::Open()

	{

	delete iEntries;

	iEntries=0;

	iIndex = 0;

	iCount = 0 ;

	if (iPath==0)

		{

		return ENOMEM;

		}

	RFs& session = Backend()->FileSession();

	TInt err=session.GetDir(*iPath,KEntryAttMaskSupported,ESortByName+EDescending,iEntries);

	if (!err) 

		{

		// iCount is actually a Last Index, not the number of entries!

		iCount = iEntries->Count()-1;

		iIndex = 0;

		}

	return err;

	}

extern "C" {

/* A reentrant version of open() */

EXPORT_C int _open_r (int *aErrno, const wchar_t *name, int mode, int perms)

	{	

	return Backend()->open(name, mode, perms, *aErrno);

	}

/*A reentrant version of wopen() */

EXPORT_C int _wopen_r (int *aErrno, const wchar_t *name, int mode, int perms)

	{

	return Backend()->open(name, mode, perms, *aErrno);

	}

/* A reentrant version of read()*/

EXPORT_C int _read_r (int *aErrno, int fd, char *buf, size_t nbyte)

	{

	return Backend()->read(fd, buf, nbyte, *aErrno);

	}

/* A reentrant version of write()*/

EXPORT_C int _write_r (int *aErrno, int fd, const char *buf, size_t nbyte)

	{

	return Backend()->write(fd, buf, nbyte, *aErrno);

	}

/* A reentrant version of close()*/

EXPORT_C int _close_r (int *aErrno, int fd)

	{

	return Backend()->close(fd, *aErrno);

	}

/* A reentrant version of fsync()*/

EXPORT_C int _fsync_r (int *aErrno, int fd)

	{

	return Backend()->fsync(fd, *aErrno);

	}

/*A reentrant version of fseek()*/

EXPORT_C off_t _lseek_r (int *aErrno, int fd, off_t pos, int whence)

	{

	return Backend()->lseek(fd, pos, whence, *aErrno);

	}

/* A reentrant version of fstat()*/

EXPORT_C int _fstat_r (int *aErrno, int fd, struct stat *st) 

	{

	return Backend()->fstat(fd, st, *aErrno);

	}

/* A reentrant version of stat().

*/

EXPORT_C int _stat_r (int *aErrno, const wchar_t *name, struct stat *st) 

	{

	return Backend()->stat(name, st, *aErrno);

	}

EXPORT_C int _utime_r (int *aErrno, const wchar_t *name,const  struct utimbuf *filetimes) 

	{

	return Backend()->utime(name, filetimes, *aErrno);

	}

/* A reentrant version of wstat().

*/

EXPORT_C int _wstat_r (int *aErrno, const wchar_t *name, struct stat *st) 

	{

	return Backend()->stat(name, st, *aErrno);

	}

/* A reentrant version of dup().

*/

EXPORT_C int _dup_r (int *aErrno, int aFid)

	{

	return Backend()->dup(aFid, *aErrno);

	}

/* A reentrant version of dup2().

*/

EXPORT_C int _dup2_r (int *aErrno, int aFid1, int aFid2)

	{

	return Backend()->dup2(aFid1, aFid2, *aErrno);

	}

/* A reentrant version of ioctl().

*/

EXPORT_C int _ioctl_r (int *aErrno, int aFid, int aCmd, void* aParam)

	{

	return Backend()->ioctl(aFid, aCmd, aParam, *aErrno);

	}

/* A wide-character version of reentrant of getcwd().

*/

EXPORT_C wchar_t * _wgetcwd_r (int *aErrno, wchar_t *_buf, size_t _size)

	{

	if (_buf==0)

		{

		_buf=(wchar_t *)User::Alloc(_size*sizeof(wchar_t));

		if (_buf==0)

			{

			*aErrno=ENOMEM;

			return _buf;

			}

		}

	return Backend()->getcwd(_buf, _size, *aErrno);

	}

/* A reentrant version of chdir().

*/

EXPORT_C int _chdir_r (int *aErrno, const wchar_t *_path)

	{

	return Backend()->chdir(_path, *aErrno);

	}

/* A reentrant version of wchdir().

*/

EXPORT_C int _wchdir_r (int *aErrno, const wchar_t *_path)

	{

	return Backend()->chdir(_path, *aErrno);

	}

/* A reentrant version of rmdir().

*/

EXPORT_C int _rmdir_r (int *aErrno, const wchar_t *_path)

	{

	 return Backend()->rmdir(_path, *aErrno);

	}

/* A reentrant version of wrmdir().

*/

EXPORT_C int _wrmdir_r (int *aErrno, const wchar_t *_path)

	{

	return Backend()->rmdir(_path, *aErrno);

	}

/* A reentrant version of mkdir().

*/

EXPORT_C int _mkdir_r (int *aErrno, const wchar_t *_path, mode_t _mode)

	{

	return Backend()->mkdir(_path, _mode, *aErrno);

	}

/* A reentrant version of wmkdir().

*/

EXPORT_C int _wmkdir_r (int *aErrno, const wchar_t *_path, mode_t _mode)

	{

	return Backend()->mkdir(_path, _mode, *aErrno);

	}

/* A reentrant version of chmod().

*/

EXPORT_C int _chmod_r (int *aErrno, const wchar_t *_path, mode_t _mode)

	{

	return Backend()->chmod(_path, _mode, *aErrno);

	}

/* A reentrant version of chmod().

*/

EXPORT_C int _fchmod_r (int *aErrno, int _fd , mode_t _mode)

	{

	return Backend()->fchmod(_fd, _mode, *aErrno);

	}

/* A reentrant version of wchmod().

*/

EXPORT_C int _wchmod_r (int *aErrno, const wchar_t *_path, mode_t _mode)

	{

	return Backend()->chmod(_path, _mode, *aErrno);

	}

/* A wide-character version of reentrant of unlink().

*/

EXPORT_C int _wunlink_r (int *aErrno, const wchar_t *_path)

	{

	return Backend()->unlink(_path, *aErrno);

	}

/* A reentrant version of rename().

*/

EXPORT_C int _rename_r (int *aErrno, const wchar_t *oldpath, const wchar_t *newpath)

	{

	return Backend()->rename(oldpath, newpath, *aErrno);

	}

/* A wide-character version of reentrant of rename().

*/

EXPORT_C int _wrename_r (int *aErrno, const wchar_t *oldpath, const wchar_t *newpath)

	{

	return Backend()->rename(oldpath, newpath, *aErrno);

	}

/* A wide-character version of reentrant of realpath().

*/

EXPORT_C wchar_t * _wrealpath_r (int *aErrno, const wchar_t *relpath, wchar_t *resolved)

	{

		if(relpath == NULL || resolved == NULL)   //invalid arguments

			{

				*aErrno = EFAULT;

				return (NULL);

			}

	TPtr16 name((TText16*)resolved,MAXPATHLEN);

	TParse path;

	TInt err = Backend()->ResolvePath(path, relpath, &name);

	if (!err)

		{

		err = path.SetNoWild(path.DriveAndPath(),NULL,&name);

		if (!err)

			{

			name = path.FullName();

			name.ZeroTerminate();

			return resolved;

			}

		}

	MapError(err, *aErrno);

	return 0;

	}

LOCAL_C TInt _parseCmd (const wchar_t* command, wchar_t* exepath, TDes& buf)

	{

	TLex lexer((TText*)command);

	buf = lexer.NextToken();

	WcsCpy(exepath,(wchar_t*)buf.PtrZ());

	lexer.SkipSpace();

	if (!lexer.Eos())

		{

		buf = lexer.Remainder();

		buf.TrimRight();

		}

	return KErrNone;

	}

EXPORT_C int _wpopen_r (int* aErrno, const wchar_t* command, const char* mode)

	{

	wchar_t exepath[KMaxPath+1];

	TFileName buf;

	if (_parseCmd(command, exepath, buf) == KErrNotFound)

		{

		// no such file

		*aErrno = ENOENT;

		return -1;

		}

	return Backend()->popen(exepath, (wchar_t*)buf.PtrZ(), mode, *aErrno);

	}

EXPORT_C int _pclose_r(int* aErrno, int aFid)

	{

	return Backend()->pclose(aFid, *aErrno);

	}

/* A wide-character version of reentrant of popen3().

*/

EXPORT_C int _wpopen3_r (int* aErrno, const wchar_t* file, const wchar_t* cmd, 

						 wchar_t** envp, int fids[3])

	{

	wchar_t* cmdargs = NULL;

	if (cmd)

		{

		TFileName buf = (TText*)cmd;

		buf.Trim();

		cmdargs = (wchar_t*)buf.PtrZ();

		}

	return Backend()->popen3(file, cmdargs, envp, fids, *aErrno);

	}

/* A reentrant version of waitpid().

*/

EXPORT_C int _waitpid_r (int *aErrno, int pid, int* status, int options)

	{

	return Backend()->waitpid(pid, status, options, *aErrno);

	}

/* A reentrant version of wait().

*/

EXPORT_C int _wait_r (int *aErrno, int* status)

	{

	return _waitpid_r(aErrno, -1, status, 0);

	}

/* A wide-character version of reentrant of system().

*/

EXPORT_C int _wsystem_r (int *aErrno, const wchar_t* command)

	{

	wchar_t exepath[KMaxPath+1];

	TFileName buf;		

	if (NULL == command)

		{

		return 1;	// special case, says that we do support wsystem().

		}		

	if (_parseCmd(command, (wchar_t*)exepath, buf) == KErrNotFound)

		{

		// no such file

		*aErrno = ENOENT;

		return -1;

		}

	return Backend()->system(exepath, (wchar_t*)buf.PtrZ(), *aErrno);

	}

/* A reentrant version of select().

*/

EXPORT_C int _select_r(int *aErrno, int maxfd, fd_set *readfds, fd_set *writefds,

					   fd_set *exceptfds, struct timeval *tvptr)

	{

	return Backend()->select(maxfd, readfds, writefds, exceptfds, tvptr, *aErrno);

	}	

EXPORT_C int _fchdir_r(int *aErrno, int filedesc)

	{

	struct stat st;

	if(_fstat_r(aErrno, filedesc, &st)!=0)

		{

		*aErrno  = EBADF ;//Not an open file descriptor

		return -1;

		}

	else 

		{

		if (!(S_ISDIR(st.st_mode)))

			{

			*aErrno = ENOTDIR ; //Not a directory

			return -1;

			}

		}

	const wchar_t* dirName(NULL) ;

	dirName = Backend()->GetDirName (filedesc);

	if( dirName )

		{

		return Backend()->chdir(dirName, *aErrno);

		}

	else

		{

		//fildesc does not refer to a valid fd.

		*aErrno = ENOTDIR;

		return -1;

		}

	}

/*

Gets the path name of the current working directory.

If a buffer is specified, the path name is placed in that buffer,

and the address of the buffer is returned. 

@return If successful returns buf, if a non-null pointer was specified, 

or the address of the allocated memory otherwise.

@param anErrno Ref to the error no. 

@param _buf Points to the buffer to copy the current working directory to, 

or NULL if getcwd() should allocate the buffer.

@param _size Is the size, in bytes, of the array of characters that buf points to.

*/

/* A reentrant version of getcwd()*/

EXPORT_C wchar_t * _getcwd_r (int *aErrno, wchar_t *_buf, size_t _size)

	{

	return Backend()->getcwd(_buf, _size, *aErrno);

	}

// -----------------------------------------------------------------------------

// Function name: link

// Description: Provides link functionality.

// Returns:  0    : On success

//          -1    : On error

// In case of error, errno value set

// Remark: This is a simulated functionality and not supported by the platform     

// -----------------------------------------------------------------------------

//

EXPORT_C int _link_r(int *aErrno, const wchar_t *_oldwidename, const wchar_t *_newwidename)

	{

   	return Backend()->link(_oldwidename, _newwidename, *aErrno);					            

	}

// -----------------------------------------------------------------------------

// Function name: unlink

// Description: Provides unlink functionality.

// Returns:  0    : On success

//          -1    : On error

// In case of error, errno value set

//      

// -----------------------------------------------------------------------------

//

EXPORT_C int _unlink_r(int *aErrno, const wchar_t *_pathwidename)

	{

	return Backend()->unlink(_pathwidename, *aErrno);				            

	}

EXPORT_C int _posix_spawn_r(pid_t* pid, const wchar_t* wpath, 

							const posix_spawn_file_actions_t* file_actions,

							const posix_spawnattr_t* attrp,