#include <file.h>

Inheritance diagram for dart::bin::File:

Public Types
enum	FileOpenMode { kRead = 0 , kWrite = 1 , kTruncate = 1 << 2 , kWriteOnly = 1 << 3 , kWriteTruncate = kWrite \| kTruncate , kWriteOnlyTruncate = kWriteOnly \| kTruncate }

enum	DartFileOpenMode { kDartRead = 0 , kDartWrite = 1 , kDartAppend = 2 , kDartWriteOnly = 3 , kDartWriteOnlyAppend = 4 }

enum	Type { kIsFile = 0 , kIsDirectory = 1 , kIsLink = 2 , kIsSock = 3 , kIsPipe = 4 , kDoesNotExist = 5 }

enum	Identical { kIdentical = 0 , kDifferent = 1 , kError = 2 }

enum	StdioHandleType { kTerminal = 0 , kPipe = 1 , kFile = 2 , kSocket = 3 , kOther = 4 , kTypeError = 5 }

enum	FileStat { kType = 0 , kCreatedTime = 1 , kModifiedTime = 2 , kAccessedTime = 3 , kMode = 4 , kSize = 5 , kStatSize = 6 }

enum	LockType { kLockMin = 0 , kLockUnlock = 0 , kLockShared = 1 , kLockExclusive = 2 , kLockBlockingShared = 3 , kLockBlockingExclusive = 4 , kLockMax = 4 }

enum	MapType { kReadOnly = 0 , kReadExecute = 1 , kReadWrite = 2 }

Public Member Functions
intptr_t	GetFD ()

MappedMemory *	Map (MapType type, int64_t position, int64_t length, void *start=nullptr)

int64_t	Read (void *buffer, int64_t num_bytes)

int64_t	Write (const void *buffer, int64_t num_bytes)

bool	ReadFully (void *buffer, int64_t num_bytes)

bool	WriteFully (const void *buffer, int64_t num_bytes)

bool	WriteByte (uint8_t byte)

bool	Print (const char *format,...) PRINTF_ATTRIBUTE(2

bool	va_start (args, format)

	va_end (args)

bool	VPrint (const char *format, va_list args)

int64_t	Length ()

int64_t	Position ()

bool	SetPosition (int64_t position)

bool	Truncate (int64_t length)

bool	Flush ()

bool	Lock (LockType lock, int64_t start, int64_t end)

bool	IsClosed ()

void	Close ()

Dart_FinalizableHandle	FinalizableHandle () const

void	SetFinalizableHandle (Dart_FinalizableHandle handle)

void	DeleteFinalizableHandle (Dart_Isolate isolate, Dart_Handle strong_ref)

Public Member Functions inherited from dart::bin::ReferenceCounted< File >
	ReferenceCounted ()

virtual	~ReferenceCounted ()

void	Retain ()

void	Release ()

Static Public Member Functions
static File *	Open (Namespace namespc, const char path, FileOpenMode mode)

static File *	OpenUri (Namespace namespc, const char uri, FileOpenMode mode)

static CStringUniquePtr	UriToPath (const char *uri)

static File *	OpenStdio (int fd)

static File *	OpenFD (int fd)

static bool	Exists (Namespace namespc, const char path)

static bool	ExistsUri (Namespace namespc, const char uri)

static bool	Create (Namespace namespc, const char path, bool exclusive)

static bool	CreateLink (Namespace namespc, const char path, const char *target)

static bool	CreatePipe (Namespace namespc, File readPipe, File *writePipe)

static bool	Delete (Namespace namespc, const char path)

static bool	DeleteLink (Namespace namespc, const char path)

static bool	Rename (Namespace namespc, const char old_path, const char *new_path)

static bool	RenameLink (Namespace namespc, const char old_path, const char *new_path)

static bool	Copy (Namespace namespc, const char old_path, const char *new_path)

static int64_t	LengthFromPath (Namespace namespc, const char path)

static void	Stat (Namespace namespc, const char path, int64_t *data)

static time_t	LastModified (Namespace namespc, const char path)

static bool	SetLastModified (Namespace namespc, const char path, int64_t millis)

static time_t	LastAccessed (Namespace namespc, const char path)

static bool	SetLastAccessed (Namespace namespc, const char path, int64_t millis)

static bool	IsAbsolutePath (const char *path)

static const char *	PathSeparator ()

static const char *	StringEscapedPathSeparator ()

static Type	GetType (Namespace namespc, const char path, bool follow_links)

static Identical	AreIdentical (Namespace namespc_1, const char file_1, Namespace namespc_2, const char file_2)

static StdioHandleType	GetStdioHandleType (int fd)

static const char *	LinkTarget (Namespace namespc, const char pathname, char *dest=nullptr, int dest_size=0)

static const char *	GetCanonicalPath (Namespace namespc, const char path, char *dest=nullptr, int dest_size=0)

static const char *	ReadLink (const char *pathname)

static intptr_t	ReadLinkInto (const char pathname, char result, size_t result_size)

static intptr_t	CleanUnixPath (const char in, char out, intptr_t outlen)

static FileOpenMode	DartModeToFileMode (DartFileOpenMode mode)

static CObject *	ExistsRequest (const CObjectArray &request)

static CObject *	CreateRequest (const CObjectArray &request)

static CObject *	CreatePipeRequest (const CObjectArray &request)

static CObject *	DeleteRequest (const CObjectArray &request)

static CObject *	RenameRequest (const CObjectArray &request)

static CObject *	CopyRequest (const CObjectArray &request)

static CObject *	OpenRequest (const CObjectArray &request)

static CObject *	ResolveSymbolicLinksRequest (const CObjectArray &request)

static CObject *	CloseRequest (const CObjectArray &request)

static CObject *	PositionRequest (const CObjectArray &request)

static CObject *	SetPositionRequest (const CObjectArray &request)

static CObject *	TruncateRequest (const CObjectArray &request)

static CObject *	LengthRequest (const CObjectArray &request)

static CObject *	LengthFromPathRequest (const CObjectArray &request)

static CObject *	LastModifiedRequest (const CObjectArray &request)

static CObject *	SetLastModifiedRequest (const CObjectArray &request)

static CObject *	LastAccessedRequest (const CObjectArray &request)

static CObject *	SetLastAccessedRequest (const CObjectArray &request)

static CObject *	FlushRequest (const CObjectArray &request)

static CObject *	ReadByteRequest (const CObjectArray &request)

static CObject *	WriteByteRequest (const CObjectArray &request)

static CObject *	ReadRequest (const CObjectArray &request)

static CObject *	ReadIntoRequest (const CObjectArray &request)

static CObject *	WriteFromRequest (const CObjectArray &request)

static CObject *	CreateLinkRequest (const CObjectArray &request)

static CObject *	DeleteLinkRequest (const CObjectArray &request)

static CObject *	RenameLinkRequest (const CObjectArray &request)

static CObject *	LinkTargetRequest (const CObjectArray &request)

static CObject *	TypeRequest (const CObjectArray &request)

static CObject *	IdenticalRequest (const CObjectArray &request)

static CObject *	StatRequest (const CObjectArray &request)

static CObject *	LockRequest (const CObjectArray &request)

Public Attributes
bool	result = VPrint(format, args)

return	result

Friends
class	ReferenceCounted< File >

Detailed Description

Definition at line 53 of file file.h.

Member Enumeration Documentation

◆ DartFileOpenMode

enum dart::bin::File::DartFileOpenMode

Enumerator
kDartRead
kDartWrite
kDartAppend
kDartWriteOnly
kDartWriteOnlyAppend

Definition at line 67 of file file.h.

                        {
    kDartRead = 0,
    kDartWrite = 1,
    kDartAppend = 2,
    kDartWriteOnly = 3,
    kDartWriteOnlyAppend = 4
  };

◆ FileOpenMode

enum dart::bin::File::FileOpenMode

Enumerator
kRead
kWrite
kTruncate
kWriteOnly
kWriteTruncate
kWriteOnlyTruncate

Definition at line 55 of file file.h.

                    {
    kRead = 0,
    kWrite = 1,
    kTruncate = 1 << 2,
    kWriteOnly = 1 << 3,
    kWriteTruncate = kWrite | kTruncate,
    kWriteOnlyTruncate = kWriteOnly | kTruncate
  };

◆ FileStat

enum dart::bin::File::FileStat

Enumerator
kType
kCreatedTime
kModifiedTime
kAccessedTime
kMode
kSize
kStatSize

Definition at line 96 of file file.h.

                {
    // These match the constants in FileStat in file_system_entity.dart.
    kType = 0,
    kCreatedTime = 1,
    kModifiedTime = 2,
    kAccessedTime = 3,
    kMode = 4,
    kSize = 5,
    kStatSize = 6
  };

◆ Identical

enum dart::bin::File::Identical

Enumerator
kIdentical
kDifferent
kError

Definition at line 84 of file file.h.

84{ kIdentical = 0, kDifferent = 1, kError = 2 };

dart::bin::File::kError

@ kError

Definition: file.h:84

dart::bin::File::kDifferent

@ kDifferent

Definition: file.h:84

dart::bin::File::kIdentical

@ kIdentical

Definition: file.h:84

◆ LockType

enum dart::bin::File::LockType

Enumerator
kLockMin
kLockUnlock
kLockShared
kLockExclusive
kLockBlockingShared
kLockBlockingExclusive
kLockMax

Definition at line 107 of file file.h.

                {
    // These match the constants in FileStat in file_impl.dart.
    kLockMin = 0,
    kLockUnlock = 0,
    kLockShared = 1,
    kLockExclusive = 2,
    kLockBlockingShared = 3,
    kLockBlockingExclusive = 4,
    kLockMax = 4
  };

◆ MapType

enum dart::bin::File::MapType

Enumerator
kReadOnly
kReadExecute
kReadWrite

Definition at line 120 of file file.h.

               {
    kReadOnly = 0,
    kReadExecute = 1,
    kReadWrite = 2,
  };

◆ StdioHandleType

enum dart::bin::File::StdioHandleType

Enumerator
kTerminal
kPipe
kFile
kSocket
kOther
kTypeError

Definition at line 86 of file file.h.

                       {
    // These match the constants in stdio.dart.
    kTerminal = 0,
    kPipe = 1,
    kFile = 2,
    kSocket = 3,
    kOther = 4,
    kTypeError = 5
  };

◆ Type

enum dart::bin::File::Type

Enumerator
kIsFile
kIsDirectory
kIsLink
kIsSock
kIsPipe
kDoesNotExist

Definition at line 75 of file file.h.

            {
    kIsFile = 0,
    kIsDirectory = 1,
    kIsLink = 2,
    kIsSock = 3,  // Unix Domain Socket.
    kIsPipe = 4,  // FIFO/Pipe.
    kDoesNotExist = 5
  };

Member Function Documentation

◆ AreIdentical()

static Identical dart::bin::File::AreIdentical	(	Namespace *	namespc_1,
		const char *	file_1,
		Namespace *	namespc_2,
		const char *	file_2
	)

static

◆ CleanUnixPath()

intptr_t dart::bin::File::CleanUnixPath	(	const char *	in,
		char *	out,
		intptr_t	outlen
	)

static

Definition at line 655 of file file.cc.

                                                                       {
  if (in[0] == 0) {
    snprintf(out, outlen, ".");
    return 1;
  }
 
  const bool rooted = (in[0] == '/');
  intptr_t in_index = 0;   // Index of the next byte to read.
  intptr_t out_index = 0;  // Index of the next byte to write.
 
  if (rooted) {
    out[out_index++] = '/';
    in_index++;
  }
  // The output index at which '..' cannot be cleaned further.
  intptr_t dotdot = out_index;
 
  while (in[in_index] != 0) {
    if (in[in_index] == '/') {
      // 1. Reduce multiple slashes to a single slash.
      CHECK_CAN_INCREMENT(in_index);
      in_index++;
    } else if ((in[in_index] == '.') && IS_SEPARATOR(in[in_index + 1])) {
      // 2. Eliminate . path name elements (the current directory).
      CHECK_CAN_INCREMENT(in_index);
      in_index++;
    } else if ((in[in_index] == '.') && (in[in_index + 1] == '.') &&
               IS_SEPARATOR(in[in_index + 2])) {
      CHECK_CAN_INCREMENT(in_index + 1);
      in_index += 2;
      if (out_index > dotdot) {
        // 3. Eliminate .. path elements (the parent directory) and the element
        // that precedes them.
        out_index--;
        while ((out_index > dotdot) && (out[out_index] != '/')) {
          out_index--;
        }
      } else if (rooted) {
        // 4. Eliminate .. elements that begin a rooted path, that is, replace
        // /.. by / at the beginning of a path.
        continue;
      } else if (!rooted) {
        if (out_index > 0) {
          out[out_index++] = '/';
        }
        // 5. Leave intact .. elements that begin a non-rooted path.
        out[out_index++] = '.';
        out[out_index++] = '.';
        dotdot = out_index;
      }
    } else {
      if ((rooted && out_index != 1) || (!rooted && out_index != 0)) {
        // Add '/' before normal path component, for non-root components.
        out[out_index++] = '/';
      }
 
      while (!IS_SEPARATOR(in[in_index])) {
        CHECK_CAN_INCREMENT(in_index);
        out[out_index++] = in[in_index++];
      }
    }
  }
 
  if (out_index == 0) {
    snprintf(out, outlen, ".");
    return 1;
  }
 
  // Append null character.
  out[out_index] = 0;
  return out_index;
}

◆ Close()

void dart::bin::File::Close ( )

◆ CloseRequest()

CObject * dart::bin::File::CloseRequest ( const CObjectArray & request )

static

Definition at line 901 of file file.cc.

                                                       {
  if ((request.Length() != 1) || !request[0]->IsIntptr()) {
    return new CObjectIntptr(CObject::NewIntptr(-1));
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  // We have retained a reference to the file here. Therefore the file's
  // destructor can't be running. Since no further requests are dispatched by
  // the Dart code after an async close call, this Close() can't be racing
  // with any other call on the file. We don't do an extra Release(), and we
  // don't delete the weak persistent handle. The file is closed here, but the
  // memory will be cleaned up when the finalizer runs.
  ASSERT(!file->IsClosed());
  file->Close();
  return new CObjectIntptr(CObject::NewIntptr(0));
}

◆ Copy()

static bool dart::bin::File::Copy	(	Namespace *	namespc,
		const char *	old_path,
		const char *	new_path
	)

static

◆ CopyRequest()

CObject * dart::bin::File::CopyRequest ( const CObjectArray & request )

static

Definition at line 865 of file file.cc.

                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array old_path(request[1]);
  CObjectString new_path(request[2]);
  return File::Copy(namespc, reinterpret_cast<const char*>(old_path.Buffer()),
                    new_path.CString())
             ? CObject::True()
             : CObject::NewOSError();
}

◆ Create()

static bool dart::bin::File::Create	(	Namespace *	namespc,
		const char *	path,
		bool	exclusive
	)

static

◆ CreateLink()

static bool dart::bin::File::CreateLink	(	Namespace *	namespc,
		const char *	path,
		const char *	target
	)

static

◆ CreateLinkRequest()

CObject * dart::bin::File::CreateLinkRequest ( const CObjectArray & request )

static

Definition at line 1270 of file file.cc.

                                                            {
  if ((request.Length() != 3) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsUint8Array() || !request[2]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array link_name(request[1]);
  CObjectString target_name(request[2]);
  return File::CreateLink(namespc,
                          reinterpret_cast<const char*>(link_name.Buffer()),
                          target_name.CString())
             ? CObject::True()
             : CObject::NewOSError();
}

◆ CreatePipe()

static bool dart::bin::File::CreatePipe	(	Namespace *	namespc,
		File **	readPipe,
		File **	writePipe
	)

static

◆ CreatePipeRequest()

CObject * dart::bin::File::CreatePipeRequest ( const CObjectArray & request )

static

Definition at line 783 of file file.cc.

                                                            {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
 
  File* readPipe;
  File* writePipe;
  if (!CreatePipe(namespc, &readPipe, &writePipe)) {
    return CObject::NewOSError();
  }
 
  CObjectArray* pipes = new CObjectArray(CObject::NewArray(2));
  CObjectNativePointer* readHandle = new CObjectNativePointer(
      CObject::NewNativePointer(reinterpret_cast<intptr_t>(readPipe),
                                sizeof(*readPipe), ReleaseFile));
  CObjectNativePointer* writeHandle = new CObjectNativePointer(
      CObject::NewNativePointer(reinterpret_cast<intptr_t>(writePipe),
                                sizeof(*writePipe), ReleaseFile));
  pipes->SetAt(0, readHandle);
  pipes->SetAt(1, writeHandle);
  return pipes;
}

◆ CreateRequest()

CObject * dart::bin::File::CreateRequest ( const CObjectArray & request )

static

Definition at line 765 of file file.cc.

                                                        {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsBool()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filename(request[1]);
  CObjectBool exclusive(request[2]);
  return File::Create(namespc, reinterpret_cast<const char*>(filename.Buffer()),
                      exclusive.Value())
             ? CObject::True()
             : CObject::NewOSError();
}

◆ DartModeToFileMode()

File::FileOpenMode dart::bin::File::DartModeToFileMode ( DartFileOpenMode mode )

static

Definition at line 89 of file file_support.cc.

                                                               {
  ASSERT((mode == File::kDartRead) || (mode == File::kDartWrite) ||
         (mode == File::kDartAppend) || (mode == File::kDartWriteOnly) ||
         (mode == File::kDartWriteOnlyAppend));
  if (mode == File::kDartWrite) {
    return File::kWriteTruncate;
  }
  if (mode == File::kDartAppend) {
    return File::kWrite;
  }
  if (mode == File::kDartWriteOnly) {
    return File::kWriteOnlyTruncate;
  }
  if (mode == File::kDartWriteOnlyAppend) {
    return File::kWriteOnly;
  }
  return File::kRead;
}

◆ Delete()

static bool dart::bin::File::Delete	(	Namespace *	namespc,
		const char *	path
	)

static

◆ DeleteFinalizableHandle()

void dart::bin::File::DeleteFinalizableHandle	(	Dart_Isolate	isolate,
		Dart_Handle	strong_ref
	)

inline

Definition at line 216 of file file.h.

                                                                             {
    Dart_DeleteFinalizableHandle(finalizable_handle_, strong_ref);
    finalizable_handle_ = nullptr;
  }

◆ DeleteLink()

static bool dart::bin::File::DeleteLink	(	Namespace *	namespc,
		const char *	path
	)

static

◆ DeleteLinkRequest()

CObject * dart::bin::File::DeleteLinkRequest ( const CObjectArray & request )

static

Definition at line 1288 of file file.cc.

                                                            {
  if ((request.Length() != 2) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array link_path(request[1]);
  return File::DeleteLink(namespc,
                          reinterpret_cast<const char*>(link_path.Buffer()))
             ? CObject::True()
             : CObject::NewOSError();
}

◆ DeleteRequest()

CObject * dart::bin::File::DeleteRequest ( const CObjectArray & request )

static

Definition at line 832 of file file.cc.

                                                        {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::False();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::False();
  }
  CObjectUint8Array filename(request[1]);
  return File::Delete(namespc, reinterpret_cast<const char*>(filename.Buffer()))
             ? CObject::True()
             : CObject::NewOSError();
}

◆ Exists()

static bool dart::bin::File::Exists	(	Namespace *	namespc,
		const char *	path
	)

static

◆ ExistsRequest()

CObject * dart::bin::File::ExistsRequest ( const CObjectArray & request )

static

Definition at line 751 of file file.cc.

                                                        {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filename(request[1]);
  return CObject::Bool(
      File::Exists(namespc, reinterpret_cast<const char*>(filename.Buffer())));
}

◆ ExistsUri()

static bool dart::bin::File::ExistsUri	(	Namespace *	namespc,
		const char *	uri
	)

static

◆ FinalizableHandle()

Dart_FinalizableHandle dart::bin::File::FinalizableHandle ( ) const

inline

Definition at line 203 of file file.h.

                                                   {
    return finalizable_handle_;
  }

◆ Flush()

bool dart::bin::File::Flush ( )

◆ FlushRequest()

CObject * dart::bin::File::FlushRequest ( const CObjectArray & request )

static

Definition at line 1077 of file file.cc.

                                                       {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  return file->Flush() ? CObject::True() : CObject::NewOSError();
}

◆ GetCanonicalPath()

static const char * dart::bin::File::GetCanonicalPath	(	Namespace *	namespc,
		const char *	path,
		char *	dest = `nullptr`,
		int	dest_size = `0`
	)

static

◆ GetFD()

intptr_t dart::bin::File::GetFD ( )

◆ GetStdioHandleType()

static StdioHandleType dart::bin::File::GetStdioHandleType ( int fd )

static

◆ GetType()

static Type dart::bin::File::GetType	(	Namespace *	namespc,
		const char *	path,
		bool	follow_links
	)

static

◆ IdenticalRequest()

CObject * dart::bin::File::IdenticalRequest ( const CObjectArray & request )

static

Definition at line 1357 of file file.cc.

                                                           {
  if ((request.Length() != 3) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsString() || !request[2]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  CObjectString path1(request[1]);
  CObjectString path2(request[2]);
  File::Identical result =
      File::AreIdentical(namespc, path1.CString(), namespc, path2.CString());
  if (result == File::kError) {
    return CObject::NewOSError();
  }
  return (result == File::kIdentical) ? CObject::True() : CObject::False();
}

◆ IsAbsolutePath()

static bool dart::bin::File::IsAbsolutePath ( const char * path )

static

◆ IsClosed()

bool dart::bin::File::IsClosed ( )

◆ LastAccessed()

static time_t dart::bin::File::LastAccessed	(	Namespace *	namespc,
		const char *	path
	)

static

◆ LastAccessedRequest()

CObject * dart::bin::File::LastAccessedRequest ( const CObjectArray & request )

static

Definition at line 1003 of file file.cc.

                                                              {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filepath(request[1]);
  const int64_t return_value = File::LastAccessed(
      namespc, reinterpret_cast<const char*>(filepath.Buffer()));
  if (return_value < 0) {
    return CObject::NewOSError();
  }
  return new CObjectIntptr(
      CObject::NewInt64(return_value * kMillisecondsPerSecond));
}

◆ LastModified()

static time_t dart::bin::File::LastModified	(	Namespace *	namespc,
		const char *	path
	)

static

◆ LastModifiedRequest()

CObject * dart::bin::File::LastModifiedRequest ( const CObjectArray & request )

static

Definition at line 1040 of file file.cc.

                                                              {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filepath(request[1]);
  const int64_t return_value = File::LastModified(
      namespc, reinterpret_cast<const char*>(filepath.Buffer()));
  if (return_value < 0) {
    return CObject::NewOSError();
  }
  return new CObjectIntptr(
      CObject::NewInt64(return_value * kMillisecondsPerSecond));
}

◆ Length()

int64_t dart::bin::File::Length ( )

◆ LengthFromPath()

static int64_t dart::bin::File::LengthFromPath	(	Namespace *	namespc,
		const char *	path
	)

static

◆ LengthFromPathRequest()

CObject * dart::bin::File::LengthFromPathRequest ( const CObjectArray & request )

static

Definition at line 985 of file file.cc.

                                                                {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filepath(request[1]);
  const int64_t return_value = File::LengthFromPath(
      namespc, reinterpret_cast<const char*>(filepath.Buffer()));
  if (return_value < 0) {
    return CObject::NewOSError();
  }
  return new CObjectInt64(CObject::NewInt64(return_value));
}

◆ LengthRequest()

CObject * dart::bin::File::LengthRequest ( const CObjectArray & request )

static

Definition at line 969 of file file.cc.

                                                        {
  if ((request.Length() != 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t return_value = file->Length();
  if (return_value < 0) {
    return CObject::NewOSError();
  }
  return new CObjectInt64(CObject::NewInt64(return_value));
}

◆ LinkTarget()

static const char * dart::bin::File::LinkTarget	(	Namespace *	namespc,
		const char *	pathname,
		char *	dest = `nullptr`,
		int	dest_size = `0`
	)

static

◆ LinkTargetRequest()

CObject * dart::bin::File::LinkTargetRequest ( const CObjectArray & request )

static

Definition at line 1322 of file file.cc.

                                                            {
  if ((request.Length() != 2) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array link_path(request[1]);
  const char* target = File::LinkTarget(
      namespc, reinterpret_cast<const char*>(link_path.Buffer()));
  if (target == nullptr) {
    return CObject::NewOSError();
  }
  return new CObjectString(CObject::NewString(target));
}

◆ Lock()

bool dart::bin::File::Lock	(	LockType	lock,
		int64_t	start,
		int64_t	end
	)

◆ LockRequest()

CObject * dart::bin::File::LockRequest ( const CObjectArray & request )

static

Definition at line 1401 of file file.cc.

                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 4) || !request[1]->IsInt32OrInt64() ||
      !request[2]->IsInt32OrInt64() || !request[3]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t lock = CObjectInt32OrInt64ToInt64(request[1]);
  const int64_t start = CObjectInt32OrInt64ToInt64(request[2]);
  const int64_t end = CObjectInt32OrInt64ToInt64(request[3]);
  return file->Lock(static_cast<File::LockType>(lock), start, end)
             ? CObject::True()
             : CObject::NewOSError();
}

◆ Map()

MappedMemory * dart::bin::File::Map	(	MapType	type,
		int64_t	position,
		int64_t	length,
		void *	start = `nullptr`
	)

Maps or copies the file into memory.

'position' and 'length' should be page-aligned.

If 'start' is zero, allocates virtual memory for the mapping. When the returned 'MappedMemory' is destroyed, the mapping is removed.

If 'start' is non-zero, it must point within a suitably sized existing mapping. The returned 'MappedMemory' will not remove the mapping when it is destroyed; rather, the mapping will be removed when the enclosing mapping is removed. This mode is not supported on Fuchsia.

If 'type' is 'kReadWrite', writes to the mapping are not copied back to the file.

'position' + 'length' may be larger than the file size. In this case, the extra memory is zero-filled.

◆ Open()

static File * dart::bin::File::Open	(	Namespace *	namespc,
		const char *	path,
		FileOpenMode	mode
	)

static

◆ OpenFD()

static File * dart::bin::File::OpenFD ( int fd )

static

◆ OpenRequest()

CObject * dart::bin::File::OpenRequest ( const CObjectArray & request )

static

Definition at line 808 of file file.cc.

                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsInt32()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filename(request[1]);
  CObjectInt32 mode(request[2]);
  File::DartFileOpenMode dart_file_mode =
      static_cast<File::DartFileOpenMode>(mode.Value());
  File::FileOpenMode file_mode = File::DartModeToFileMode(dart_file_mode);
  File* file = File::Open(
      namespc, reinterpret_cast<const char*>(filename.Buffer()), file_mode);
  if (file == nullptr) {
    return CObject::NewOSError();
  }
  return new CObjectNativePointer(CObject::NewNativePointer(
      reinterpret_cast<intptr_t>(file), sizeof(*file), ReleaseFile));
}

◆ OpenStdio()

static File * dart::bin::File::OpenStdio ( int fd )

static

◆ OpenUri()

static File * dart::bin::File::OpenUri	(	Namespace *	namespc,
		const char *	uri,
		FileOpenMode	mode
	)

static

◆ PathSeparator()

static const char * dart::bin::File::PathSeparator ( )

static

◆ Position()

int64_t dart::bin::File::Position ( )

◆ PositionRequest()

CObject * dart::bin::File::PositionRequest ( const CObjectArray & request )

static

Definition at line 918 of file file.cc.

                                                          {
  if ((request.Length() != 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const intptr_t return_value = file->Position();
  if (return_value < 0) {
    return CObject::NewOSError();
  }
  return new CObjectIntptr(CObject::NewIntptr(return_value));
}

◆ Print()

bool dart::bin::File::Print	(	const char *	format,
			...
	)

◆ Read()

int64_t dart::bin::File::Read	(	void *	buffer,
		int64_t	num_bytes
	)

◆ ReadByteRequest()

CObject * dart::bin::File::ReadByteRequest ( const CObjectArray & request )

static

Definition at line 1089 of file file.cc.

                                                          {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  uint8_t buffer;
  const int64_t bytes_read = file->Read(reinterpret_cast<void*>(&buffer), 1);
  if (bytes_read < 0) {
    return CObject::NewOSError();
  }
  if (bytes_read == 0) {
    return new CObjectIntptr(CObject::NewIntptr(-1));
  }
  return new CObjectIntptr(CObject::NewIntptr(buffer));
}

◆ ReadFully()

bool dart::bin::File::ReadFully	(	void *	buffer,
		int64_t	num_bytes
	)

Definition at line 41 of file file_support.cc.

                                                    {
  int64_t remaining = num_bytes;
  char* current_buffer = reinterpret_cast<char*>(buffer);
  while (remaining > 0) {
    int64_t bytes_read = Read(current_buffer, remaining);
    if (bytes_read <= 0) {
      return false;
    }
    remaining -= bytes_read;       // Reduce the number of remaining bytes.
    current_buffer += bytes_read;  // Move the buffer forward.
  }
  return true;
}

◆ ReadIntoRequest()

CObject * dart::bin::File::ReadIntoRequest ( const CObjectArray & request )

static

Definition at line 1163 of file file.cc.

                                                          {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 2) || !request[1]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t length = CObjectInt32OrInt64ToInt64(request[1]);
  Dart_CObject* io_buffer = CObject::NewIOBuffer(length);
  if (io_buffer == nullptr) {
    return CObject::NewOSError();
  }
  uint8_t* data = io_buffer->value.as_external_typed_data.data;
  const int64_t bytes_read = file->Read(data, length);
  if (bytes_read < 0) {
    CObject::FreeIOBufferData(io_buffer);
    return CObject::NewOSError();
  }
 
  // Possibly shrink the used malloc() storage if the actual number of bytes is
  // significantly lower.
  CObject::ShrinkIOBuffer(io_buffer, bytes_read);
 
  auto external_array = new CObjectExternalUint8Array(io_buffer);
  CObjectArray* result = new CObjectArray(CObject::NewArray(3));
  result->SetAt(0, new CObjectIntptr(CObject::NewInt32(0)));
  result->SetAt(1, new CObjectInt64(CObject::NewInt64(bytes_read)));
  result->SetAt(2, external_array);
  return result;
}

◆ ReadLink()

static const char * dart::bin::File::ReadLink ( const char * pathname )

static

◆ ReadLinkInto()

static intptr_t dart::bin::File::ReadLinkInto	(	const char *	pathname,
		char *	result,
		size_t	result_size
	)

static

◆ ReadRequest()

CObject * dart::bin::File::ReadRequest ( const CObjectArray & request )

static

Definition at line 1128 of file file.cc.

                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 2) || !request[1]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t length = CObjectInt32OrInt64ToInt64(request[1]);
  Dart_CObject* io_buffer = CObject::NewIOBuffer(length);
  if (io_buffer == nullptr) {
    return CObject::NewOSError();
  }
  uint8_t* data = io_buffer->value.as_external_typed_data.data;
  const int64_t bytes_read = file->Read(data, length);
  if (bytes_read < 0) {
    CObject::FreeIOBufferData(io_buffer);
    return CObject::NewOSError();
  }
 
  // Possibly shrink the used malloc() storage if the actual number of bytes is
  // significantly lower.
  CObject::ShrinkIOBuffer(io_buffer, bytes_read);
 
  auto external_array = new CObjectExternalUint8Array(io_buffer);
  CObjectArray* result = new CObjectArray(CObject::NewArray(2));
  result->SetAt(0, new CObjectIntptr(CObject::NewInt32(0)));
  result->SetAt(1, external_array);
  return result;
}

◆ Rename()

static bool dart::bin::File::Rename	(	Namespace *	namespc,
		const char *	old_path,
		const char *	new_path
	)

static

◆ RenameLink()

static bool dart::bin::File::RenameLink	(	Namespace *	namespc,
		const char *	old_path,
		const char *	new_path
	)

static

◆ RenameLinkRequest()

CObject * dart::bin::File::RenameLinkRequest ( const CObjectArray & request )

static

Definition at line 1304 of file file.cc.

                                                            {
  if ((request.Length() != 3) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsUint8Array() || !request[2]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array old_path(request[1]);
  CObjectString new_path(request[2]);
  return File::RenameLink(namespc,
                          reinterpret_cast<const char*>(old_path.Buffer()),
                          new_path.CString())
             ? CObject::True()
             : CObject::NewOSError();
}

◆ RenameRequest()

CObject * dart::bin::File::RenameRequest ( const CObjectArray & request )

static

Definition at line 847 of file file.cc.

                                                        {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array old_path(request[1]);
  CObjectString new_path(request[2]);
  return File::Rename(namespc, reinterpret_cast<const char*>(old_path.Buffer()),
                      new_path.CString())
             ? CObject::True()
             : CObject::NewOSError();
}

◆ ResolveSymbolicLinksRequest()

CObject * dart::bin::File::ResolveSymbolicLinksRequest ( const CObjectArray & request )

static

Definition at line 883 of file file.cc.

                                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsUint8Array()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filename(request[1]);
  const char* result = File::GetCanonicalPath(
      namespc, reinterpret_cast<const char*>(filename.Buffer()));
  if (result == nullptr) {
    return CObject::NewOSError();
  }
  return new CObjectString(CObject::NewString(result));
}

◆ SetFinalizableHandle()

void dart::bin::File::SetFinalizableHandle ( Dart_FinalizableHandle handle )

inline

Definition at line 208 of file file.h.

                                                           {
    ASSERT(finalizable_handle_ == nullptr);
    finalizable_handle_ = handle;
  }

◆ SetLastAccessed()

static bool dart::bin::File::SetLastAccessed	(	Namespace *	namespc,
		const char *	path,
		int64_t	millis
	)

static

◆ SetLastAccessedRequest()

CObject * dart::bin::File::SetLastAccessedRequest ( const CObjectArray & request )

static

Definition at line 1022 of file file.cc.

                                                                 {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filepath(request[1]);
  const int64_t millis = CObjectInt32OrInt64ToInt64(request[2]);
  return File::SetLastAccessed(
             namespc, reinterpret_cast<const char*>(filepath.Buffer()), millis)
             ? CObject::Null()
             : CObject::NewOSError();
}

◆ SetLastModified()

static bool dart::bin::File::SetLastModified	(	Namespace *	namespc,
		const char *	path,
		int64_t	millis
	)

static

◆ SetLastModifiedRequest()

CObject * dart::bin::File::SetLastModifiedRequest ( const CObjectArray & request )

static

Definition at line 1059 of file file.cc.

                                                                 {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 3) || !request[1]->IsUint8Array() ||
      !request[2]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array filepath(request[1]);
  const int64_t millis = CObjectInt32OrInt64ToInt64(request[2]);
  return File::SetLastModified(
             namespc, reinterpret_cast<const char*>(filepath.Buffer()), millis)
             ? CObject::Null()
             : CObject::NewOSError();
}

◆ SetPosition()

bool dart::bin::File::SetPosition ( int64_t position )

◆ SetPositionRequest()

CObject * dart::bin::File::SetPositionRequest ( const CObjectArray & request )

static

Definition at line 934 of file file.cc.

                                                             {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 2) || !request[1]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t position = CObjectInt32OrInt64ToInt64(request[1]);
  return file->SetPosition(position) ? CObject::True() : CObject::NewOSError();
}

◆ Stat()

static void dart::bin::File::Stat	(	Namespace *	namespc,
		const char *	path,
		int64_t *	data
	)

static

◆ StatRequest()

CObject * dart::bin::File::StatRequest ( const CObjectArray & request )

static

Definition at line 1376 of file file.cc.

                                                      {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if ((request.Length() != 2) || !request[1]->IsString()) {
    return CObject::IllegalArgumentError();
  }
  int64_t data[File::kStatSize];
  CObjectString path(request[1]);
  File::Stat(namespc, path.CString(), data);
  if (data[File::kType] == File::kDoesNotExist) {
    return CObject::NewOSError();
  }
  CObjectArray* result = new CObjectArray(CObject::NewArray(File::kStatSize));
  for (int i = 0; i < File::kStatSize; ++i) {
    result->SetAt(i, new CObjectInt64(CObject::NewInt64(data[i])));
  }
  CObjectArray* wrapper = new CObjectArray(CObject::NewArray(2));
  wrapper->SetAt(0, new CObjectInt32(CObject::NewInt32(CObject::kSuccess)));
  wrapper->SetAt(1, result);
  return wrapper;
}

◆ StringEscapedPathSeparator()

static const char * dart::bin::File::StringEscapedPathSeparator ( )

static

◆ Truncate()

bool dart::bin::File::Truncate ( int64_t length )

◆ TruncateRequest()

CObject * dart::bin::File::TruncateRequest ( const CObjectArray & request )

static

Definition at line 950 of file file.cc.

                                                          {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 2) || !request[1]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t length = CObjectInt32OrInt64ToInt64(request[1]);
  if (file->Truncate(length)) {
    return CObject::True();
  }
  return CObject::NewOSError();
}

◆ TypeRequest()

CObject * dart::bin::File::TypeRequest ( const CObjectArray & request )

static

Definition at line 1340 of file file.cc.

                                                      {
  if ((request.Length() != 3) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  Namespace* namespc = CObjectToNamespacePointer(request[0]);
  RefCntReleaseScope<Namespace> rs(namespc);
  if (!request[1]->IsUint8Array() || !request[2]->IsBool()) {
    return CObject::IllegalArgumentError();
  }
  CObjectUint8Array path(request[1]);
  CObjectBool follow_links(request[2]);
  File::Type type =
      File::GetType(namespc, reinterpret_cast<const char*>(path.Buffer()),
                    follow_links.Value());
  return new CObjectInt32(CObject::NewInt32(type));
}

◆ UriToPath()

static CStringUniquePtr dart::bin::File::UriToPath ( const char * uri )

static

◆ va_end()

dart::bin::File::va_end ( args )

◆ va_start()

bool dart::bin::File::va_start	(	args	,
		format
	)

◆ VPrint()

bool dart::bin::File::VPrint	(	const char *	format,
		va_list	args
	)

◆ Write()

int64_t dart::bin::File::Write	(	const void *	buffer,
		int64_t	num_bytes
	)

◆ WriteByte()

bool dart::bin::File::WriteByte ( uint8_t byte )

inline

Definition at line 165 of file file.h.

165{ return WriteFully(&byte, 1); }

dart::bin::File::WriteFully

bool WriteFully(const void *buffer, int64_t num_bytes)

Definition: file_support.cc:55

◆ WriteByteRequest()

CObject * dart::bin::File::WriteByteRequest ( const CObjectArray & request )

static

Definition at line 1109 of file file.cc.

                                                           {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 2) || !request[1]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  const int64_t byte = CObjectInt32OrInt64ToInt64(request[1]);
  uint8_t buffer = static_cast<uint8_t>(byte & 0xff);
  return file->WriteFully(reinterpret_cast<void*>(&buffer), 1)
             ? new CObjectInt64(CObject::NewInt64(1))
             : CObject::NewOSError();
}

◆ WriteFromRequest()

CObject * dart::bin::File::WriteFromRequest ( const CObjectArray & request )

static

Definition at line 1227 of file file.cc.

                                                           {
  if ((request.Length() < 1) || !request[0]->IsIntptr()) {
    return CObject::IllegalArgumentError();
  }
  File* file = CObjectToFilePointer(request[0]);
  RefCntReleaseScope<File> rs(file);
  if ((request.Length() != 4) ||
      (!request[1]->IsTypedData() && !request[1]->IsArray()) ||
      !request[2]->IsInt32OrInt64() || !request[3]->IsInt32OrInt64()) {
    return CObject::IllegalArgumentError();
  }
  if (file->IsClosed()) {
    return CObject::FileClosedError();
  }
  int64_t start = CObjectInt32OrInt64ToInt64(request[2]);
  int64_t end = CObjectInt32OrInt64ToInt64(request[3]);
  int64_t length = end - start;
  const uint8_t* buffer_start;
  if (request[1]->IsTypedData()) {
    CObjectTypedData typed_data(request[1]);
    start = start * SizeInBytes(typed_data.Type());
    length = length * SizeInBytes(typed_data.Type());
    buffer_start = typed_data.Buffer() + start;
  } else {
    CObjectArray array(request[1]);
    uint8_t* allocated_buffer = Dart_ScopeAllocate(length);
    buffer_start = allocated_buffer;
    for (int i = 0; i < length; i++) {
      if (array[i + start]->IsInt32OrInt64()) {
        int64_t value = CObjectInt32OrInt64ToInt64(array[i + start]);
        allocated_buffer[i] = static_cast<uint8_t>(value & 0xFF);
      } else {
        // Unsupported type.
        return CObject::IllegalArgumentError();
      }
    }
    start = 0;
  }
  return file->WriteFully(reinterpret_cast<const void*>(buffer_start), length)
             ? new CObjectInt64(CObject::NewInt64(length))
             : CObject::NewOSError();
}

◆ WriteFully()

bool dart::bin::File::WriteFully	(	const void *	buffer,
		int64_t	num_bytes
	)

Definition at line 55 of file file_support.cc.

                                                           {
  int64_t remaining = num_bytes;
  const char* current_buffer = reinterpret_cast<const char*>(buffer);
  while (remaining > 0) {
    // On Windows, narrowing conversion from int64_t to DWORD will cause
    // unexpected error.
    // On MacOS, a single write() with more than kMaxInt32 will have
    // "invalid argument" error.
    // Therefore, limit the size for single write.
    int64_t byte_to_write = remaining > kMaxInt32 ? kMaxInt32 : remaining;
    int64_t bytes_written = Write(current_buffer, byte_to_write);
    if (bytes_written < 0) {
      return false;
    }
    remaining -= bytes_written;       // Reduce the number of remaining bytes.
    current_buffer += bytes_written;  // Move the buffer forward.
  }
  if (capture_stdout || capture_stderr) {
    intptr_t fd = GetFD();
    const char* result = nullptr;
    if ((fd == STDOUT_FILENO) && capture_stdout) {
      result = Dart_ServiceSendDataEvent(
          "Stdout", "WriteEvent", reinterpret_cast<const uint8_t*>(buffer),
          num_bytes);
    } else if ((fd == STDERR_FILENO) && capture_stderr) {
      result = Dart_ServiceSendDataEvent(
          "Stderr", "WriteEvent", reinterpret_cast<const uint8_t*>(buffer),
          num_bytes);
    }
    ASSERT(result == nullptr);
  }
  return true;
}

Friends And Related Function Documentation

◆ ReferenceCounted< File >

friend class ReferenceCounted< File >

friend

Definition at line 356 of file file.h.

Member Data Documentation

◆ result [1/2]

bool dart::bin::File::result = VPrint(format, args)

Definition at line 170 of file file.h.

◆ result [2/2]

return dart::bin::File::result

Definition at line 172 of file file.h.

The documentation for this class was generated from the following files:

third_party/dart-lang/sdk/runtime/bin/file.h
third_party/dart-lang/sdk/runtime/bin/file.cc
third_party/dart-lang/sdk/runtime/bin/file_support.cc

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ DartFileOpenMode

◆ FileOpenMode

◆ FileStat

◆ Identical

◆ LockType

◆ MapType

◆ StdioHandleType

◆ Type

Member Function Documentation

◆ AreIdentical()

◆ CleanUnixPath()

◆ Close()

◆ CloseRequest()

◆ Copy()

◆ CopyRequest()

◆ Create()

◆ CreateLink()

◆ CreateLinkRequest()

◆ CreatePipe()

◆ CreatePipeRequest()

◆ CreateRequest()

◆ DartModeToFileMode()

◆ Delete()

◆ DeleteFinalizableHandle()

◆ DeleteLink()

◆ DeleteLinkRequest()

◆ DeleteRequest()

◆ Exists()

◆ ExistsRequest()

◆ ExistsUri()

◆ FinalizableHandle()

◆ Flush()

◆ FlushRequest()

◆ GetCanonicalPath()

◆ GetFD()

◆ GetStdioHandleType()

◆ GetType()

◆ IdenticalRequest()

◆ IsAbsolutePath()

◆ IsClosed()

◆ LastAccessed()

◆ LastAccessedRequest()

◆ LastModified()

◆ LastModifiedRequest()

◆ Length()

◆ LengthFromPath()

◆ LengthFromPathRequest()

◆ LengthRequest()

◆ LinkTarget()

◆ LinkTargetRequest()

◆ Lock()

◆ LockRequest()

◆ Map()

◆ Open()

◆ OpenFD()

◆ OpenRequest()

◆ OpenStdio()

◆ OpenUri()

◆ PathSeparator()

◆ Position()

◆ PositionRequest()

◆ Print()

◆ Read()

◆ ReadByteRequest()

◆ ReadFully()

◆ ReadIntoRequest()

◆ ReadLink()

◆ ReadLinkInto()

◆ ReadRequest()

◆ Rename()

◆ RenameLink()

◆ RenameLinkRequest()

◆ RenameRequest()