dart::bin::Socket Class Reference

#include <socket.h>

Inheritance diagram for dart::bin::Socket:

Public Types
enum	SocketRequest { kLookupRequest = 0 , kListInterfacesRequest = 1 , kReverseLookupRequest = 2 }
enum	SocketFinalizer { kFinalizerNormal , kFinalizerListening , kFinalizerStdio , kFinalizerSignal }
enum	SocketType { kTcpSocket = 18 , kUdpSocket = 19 , kInternalSocket = 20 , kInternalSignalSocket = 21 }

Public Member Functions
	Socket (intptr_t fd)
intptr_t	fd () const
void	CloseFd ()
void	SetClosedFd ()
Dart_Port	isolate_port () const
Dart_Port	port () const
void	set_port (Dart_Port port)
uint8_t *	udp_receive_buffer () const
void	set_udp_receive_buffer (uint8_t *buffer)
Public Member Functions inherited from dart::bin::ReferenceCounted< Socket >
	ReferenceCounted ()
virtual	~ReferenceCounted ()
void	Retain ()
void	Release ()

Static Public Member Functions
static bool	Initialize ()
static intptr_t	CreateConnect (const RawAddr &addr)
static intptr_t	CreateUnixDomainConnect (const RawAddr &addr)
static intptr_t	CreateBindConnect (const RawAddr &addr, const RawAddr &source_addr)
static intptr_t	CreateUnixDomainBindConnect (const RawAddr &addr, const RawAddr &source_addr)
static intptr_t	CreateBindDatagram (const RawAddr &addr, bool reuseAddress, bool reusePort, int ttl=1)
static CObject *	LookupRequest (const CObjectArray &request)
static CObject *	ListInterfacesRequest (const CObjectArray &request)
static CObject *	ReverseLookupRequest (const CObjectArray &request)
static Dart_Port	GetServicePort ()
static void	SetSocketIdNativeField (Dart_Handle handle, intptr_t id, SocketFinalizer finalizer)
static void	ReuseSocketIdNativeField (Dart_Handle handle, Socket *socket, SocketFinalizer finalizer)
static Socket *	GetSocketIdNativeField (Dart_Handle socket)
static bool	short_socket_read ()
static void	set_short_socket_read (bool short_socket_read)
static bool	short_socket_write ()
static void	set_short_socket_write (bool short_socket_write)
static bool	IsSignalSocketFlag (intptr_t flag)

Friends
class	ReferenceCounted< Socket >

Detailed Description

Definition at line 27 of file socket.h.

Member Enumeration Documentation

SocketFinalizer

enum dart::bin::Socket::SocketFinalizer

Enumerator
kFinalizerNormal
kFinalizerListening
kFinalizerStdio
kFinalizerSignal

Definition at line 35 of file socket.h.

                       {
    kFinalizerNormal,
    kFinalizerListening,
    kFinalizerStdio,
    kFinalizerSignal,
  };

SocketRequest

enum dart::bin::Socket::SocketRequest

Enumerator
kLookupRequest
kListInterfacesRequest
kReverseLookupRequest

Definition at line 29 of file socket.h.

                     {
    kLookupRequest = 0,
    kListInterfacesRequest = 1,
    kReverseLookupRequest = 2,
  };

SocketType

enum dart::bin::Socket::SocketType

Enumerator
kTcpSocket
kUdpSocket
kInternalSocket
kInternalSignalSocket

Definition at line 43 of file socket.h.

                  {
    kTcpSocket = 18,
    kUdpSocket = 19,
    kInternalSocket = 20,
    kInternalSignalSocket = 21,
  };

Constructor & Destructor Documentation

Socket()

dart::bin::Socket::Socket ( intptr_t  fd )

explicit

Member Function Documentation

CloseFd()

void dart::bin::Socket::CloseFd

(

)

CreateBindConnect()

static intptr_t dart::bin::Socket::CreateBindConnect ( const RawAddr &  addr, const RawAddr &  source_addr  )

static

CreateBindDatagram()

static intptr_t dart::bin::Socket::CreateBindDatagram ( const RawAddr &  addr, bool  reuseAddress, bool  reusePort, int  ttl = 1  )

static

CreateConnect()

static intptr_t dart::bin::Socket::CreateConnect ( const RawAddr &  addr )

static

CreateUnixDomainBindConnect()

static intptr_t dart::bin::Socket::CreateUnixDomainBindConnect ( const RawAddr &  addr, const RawAddr &  source_addr  )

static

CreateUnixDomainConnect()

static intptr_t dart::bin::Socket::CreateUnixDomainConnect ( const RawAddr &  addr )

static

fd()

intptr_t dart::bin::Socket::fd ( ) const

inline

Definition at line 52 of file socket.h.

{ return fd_; }

GetServicePort()

static Dart_Port dart::bin::Socket::GetServicePort ( )

static

GetSocketIdNativeField()

Socket * dart::bin::Socket::GetSocketIdNativeField ( Dart_Handle  socket )

static

Definition at line 1496 of file socket.cc.

                                                             {
  intptr_t id;
  Dart_Handle err =
      Dart_GetNativeInstanceField(socket_obj, kSocketIdNativeField, &id);
  if (Dart_IsError(err)) {
    Dart_PropagateError(err);
  }
  Socket* socket = reinterpret_cast<Socket*>(id);
  if (socket == nullptr) {
    Dart_PropagateError(Dart_NewUnhandledExceptionError(
        DartUtils::NewInternalError("No native peer")));
  }
  return socket;
}

Initialize()

static bool dart::bin::Socket::Initialize ( )

static

isolate_port()

Dart_Port dart::bin::Socket::isolate_port ( ) const

inline

Definition at line 61 of file socket.h.

{ return isolate_port_; }

IsSignalSocketFlag()

static bool dart::bin::Socket::IsSignalSocketFlag ( intptr_t  flag )

inlinestatic

Definition at line 111 of file socket.h.

                                                {
    return ((flag & (0x1 << kInternalSignalSocket)) != 0);
  }

ListInterfacesRequest()

CObject * dart::bin::Socket::ListInterfacesRequest ( const CObjectArray &  request )

static

Definition at line 1134 of file socket.cc.

                                                                  {
  if ((request.Length() == 1) && request[0]->IsInt32()) {
    CObjectInt32 type(request[0]);
    CObject* result = nullptr;
    OSError* os_error = nullptr;
    AddressList<InterfaceSocketAddress>* addresses =
        SocketBase::ListInterfaces(type.Value(), &os_error);
    if (addresses != nullptr) {
      CObjectArray* array =
          new CObjectArray(CObject::NewArray(addresses->count() + 1));
      array->SetAt(0, new CObjectInt32(CObject::NewInt32(0)));
      for (intptr_t i = 0; i < addresses->count(); i++) {
        InterfaceSocketAddress* interface = addresses->GetAt(i);
        SocketAddress* addr = interface->socket_address();
        CObjectArray* entry = new CObjectArray(CObject::NewArray(5));
 
        CObjectInt32* type =
            new CObjectInt32(CObject::NewInt32(addr->GetType()));
        entry->SetAt(0, type);
 
        CObjectString* as_string =
            new CObjectString(CObject::NewString(addr->as_string()));
        entry->SetAt(1, as_string);
 
        RawAddr raw = addr->addr();
        CObjectUint8Array* data = SocketAddress::ToCObject(raw);
        entry->SetAt(2, data);
 
        CObjectString* interface_name =
            new CObjectString(CObject::NewString(interface->interface_name()));
        entry->SetAt(3, interface_name);
 
        CObjectInt64* interface_index =
            new CObjectInt64(CObject::NewInt64(interface->interface_index()));
        entry->SetAt(4, interface_index);
 
        array->SetAt(i + 1, entry);
      }
      result = array;
      delete addresses;
    } else {
      result = CObject::NewOSError(os_error);
      delete os_error;
    }
    return result;
  }
  return CObject::IllegalArgumentError();
}

LookupRequest()

CObject * dart::bin::Socket::LookupRequest ( const CObjectArray &  request )

static

Definition at line 1057 of file socket.cc.

                                                          {
  if ((request.Length() == 2) && request[0]->IsString() &&
      request[1]->IsInt32()) {
    CObjectString host(request[0]);
    CObjectInt32 type(request[1]);
    CObject* result = nullptr;
    OSError* os_error = nullptr;
    AddressList<SocketAddress>* addresses =
        SocketBase::LookupAddress(host.CString(), type.Value(), &os_error);
    if (addresses != nullptr) {
      CObjectArray* array =
          new CObjectArray(CObject::NewArray(addresses->count() + 1));
      array->SetAt(0, new CObjectInt32(CObject::NewInt32(0)));
      for (intptr_t i = 0; i < addresses->count(); i++) {
        SocketAddress* addr = addresses->GetAt(i);
        CObjectArray* entry = new CObjectArray(CObject::NewArray(4));
 
        CObjectInt32* type =
            new CObjectInt32(CObject::NewInt32(addr->GetType()));
        entry->SetAt(0, type);
 
        CObjectString* as_string =
            new CObjectString(CObject::NewString(addr->as_string()));
        entry->SetAt(1, as_string);
 
        RawAddr raw = addr->addr();
        CObjectUint8Array* data = SocketAddress::ToCObject(raw);
        entry->SetAt(2, data);
 
        CObjectInt64* scope_id = new CObjectInt64(
            CObject::NewInt64(SocketAddress::GetAddrScope(raw)));
        entry->SetAt(3, scope_id);
 
        array->SetAt(i + 1, entry);
      }
      result = array;
      delete addresses;
    } else {
      result = CObject::NewOSError(os_error);
      delete os_error;
    }
    return result;
  }
  return CObject::IllegalArgumentError();
}

port()

Dart_Port dart::bin::Socket::port ( ) const

inline

Definition at line 63 of file socket.h.

{ return port_; }

ReuseSocketIdNativeField()

void dart::bin::Socket::ReuseSocketIdNativeField ( Dart_Handle  handle, Socket *  socket, SocketFinalizer  finalizer  )

static

Definition at line 1456 of file socket.cc.

                                                                 {
  Dart_Handle err = Dart_SetNativeInstanceField(
      handle, kSocketIdNativeField, reinterpret_cast<intptr_t>(socket));
  if (Dart_IsError(err)) {
    Dart_PropagateError(err);
  }
  Dart_HandleFinalizer callback;
  switch (finalizer) {
    case kFinalizerNormal:
      callback = NormalSocketFinalizer;
      break;
    case kFinalizerListening:
      callback = ListeningSocketFinalizer;
      break;
    case kFinalizerStdio:
      callback = StdioSocketFinalizer;
      break;
    case kFinalizerSignal:
      callback = SignalSocketFinalizer;
      break;
    default:
      callback = nullptr;
      UNREACHABLE();
      break;
  }
  if (callback != nullptr) {
    Dart_NewFinalizableHandle(handle, reinterpret_cast<void*>(socket),
                              sizeof(Socket), callback);
  }
}

ReverseLookupRequest()

CObject * dart::bin::Socket::ReverseLookupRequest ( const CObjectArray &  request )

static

Definition at line 1103 of file socket.cc.

                                                                 {
  if ((request.Length() == 1) && request[0]->IsTypedData()) {
    CObjectUint8Array addr_object(request[0]);
    RawAddr addr;
    int len = addr_object.Length();
    memset(reinterpret_cast<void*>(&addr), 0, sizeof(RawAddr));
    if (len == sizeof(in_addr)) {
      addr.in.sin_family = AF_INET;
      memmove(reinterpret_cast<void*>(&addr.in.sin_addr), addr_object.Buffer(),
              len);
    } else {
      ASSERT(len == sizeof(in6_addr));
      addr.in6.sin6_family = AF_INET6;
      memmove(reinterpret_cast<void*>(&addr.in6.sin6_addr),
              addr_object.Buffer(), len);
    }
 
    OSError* os_error = nullptr;
    const intptr_t kMaxHostLength = 1025;
    char host[kMaxHostLength];
    if (SocketBase::ReverseLookup(addr, host, kMaxHostLength, &os_error)) {
      return new CObjectString(CObject::NewString(host));
    } else {
      CObject* result = CObject::NewOSError(os_error);
      delete os_error;
      return result;
    }
  }
  return CObject::IllegalArgumentError();
}

set_port()

void dart::bin::Socket::set_port ( Dart_Port  port )

inline

Definition at line 64 of file socket.h.

{ port_ = port; }

set_short_socket_read()

static void dart::bin::Socket::set_short_socket_read ( bool  short_socket_read )

inlinestatic

Definition at line 103 of file socket.h.

                                                            {
    short_socket_read_ = short_socket_read;
  }

set_short_socket_write()

static void dart::bin::Socket::set_short_socket_write ( bool  short_socket_write )

inlinestatic

Definition at line 107 of file socket.h.

                                                              {
    short_socket_write_ = short_socket_write;
  }

set_udp_receive_buffer()

void dart::bin::Socket::set_udp_receive_buffer ( uint8_t *  buffer )

inline

Definition at line 67 of file socket.h.

{ udp_receive_buffer_ = buffer; }

SetClosedFd()

void dart::bin::Socket::SetClosedFd

(

)

SetSocketIdNativeField()

void dart::bin::Socket::SetSocketIdNativeField ( Dart_Handle  handle, intptr_t  id, SocketFinalizer  finalizer  )

static

Definition at line 1489 of file socket.cc.

                                                               {
  Socket* socket = new Socket(id);
  ReuseSocketIdNativeField(handle, socket, finalizer);
}

short_socket_read()

static bool dart::bin::Socket::short_socket_read ( )

inlinestatic

Definition at line 102 of file socket.h.

{ return short_socket_read_; }

short_socket_write()

static bool dart::bin::Socket::short_socket_write ( )

inlinestatic

Definition at line 106 of file socket.h.

{ return short_socket_write_; }

udp_receive_buffer()

uint8_t * dart::bin::Socket::udp_receive_buffer ( ) const

inline

Definition at line 66 of file socket.h.

{ return udp_receive_buffer_; }

Friends And Related Symbol Documentation

ReferenceCounted< Socket >

friend class ReferenceCounted< Socket >

friend

Definition at line 130 of file socket.h.

---

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

• third_party/dart-lang/sdk/runtime/bin/socket.h
• third_party/dart-lang/sdk/runtime/bin/socket.cc