dart::PendingCall Class Reference

Public Member Functions
	PendingCall (void **buffer, size_t *length)
	~PendingCall ()
Dart_Port	port () const
void	PostAndWait (Dart_Port port, Dart_CObject *object)

Static Public Member Functions
static void	HandleResponse (Dart_Port p, Dart_CObject *message)

Detailed Description

Definition at line 629 of file ffi_test_functions_vmspecific.cc.

Constructor & Destructor Documentation

PendingCall()

dart::PendingCall::PendingCall ( void **  buffer, size_t *  length  )

inline

Definition at line 631 of file ffi_test_functions_vmspecific.cc.

      : response_buffer_(buffer), response_length_(length) {
    receive_port_ =
        Dart_NewNativePort_DL("cpp-response", &PendingCall::HandleResponse,
                              /*handle_concurrently=*/false);
  }

~PendingCall()

dart::PendingCall::~PendingCall ( )

inline

Definition at line 637 of file ffi_test_functions_vmspecific.cc.

{ Dart_CloseNativePort_DL(receive_port_); }

Member Function Documentation

HandleResponse()

static void dart::PendingCall::HandleResponse ( Dart_Port  p, Dart_CObject *  message  )

inlinestatic

Definition at line 652 of file ffi_test_functions_vmspecific.cc.

                                                                 {
    if (message->type != Dart_CObject_kArray) {
      FATAL("C   :   Wrong Data: message->type != Dart_CObject_kArray.\n");
    }
    Dart_CObject** c_response_args = message->value.as_array.values;
    Dart_CObject* c_pending_call = c_response_args[0];
    Dart_CObject* c_message = c_response_args[1];
    printf("C   :   HandleResponse (call: %" Px ", message: %" Px ").\n",
           reinterpret_cast<intptr_t>(c_pending_call),
           reinterpret_cast<intptr_t>(c_message));
 
    auto pending_call = reinterpret_cast<PendingCall*>(
        c_pending_call->type == Dart_CObject_kInt64
            ? c_pending_call->value.as_int64
            : c_pending_call->value.as_int32);
 
    pending_call->ResolveCall(c_message);
  }

port()

Dart_Port dart::PendingCall::port ( ) const

inline

Definition at line 639 of file ffi_test_functions_vmspecific.cc.

{ return receive_port_; }

PostAndWait()

void dart::PendingCall::PostAndWait ( Dart_Port  port, Dart_CObject *  object  )

inline

Definition at line 641 of file ffi_test_functions_vmspecific.cc.

                                                         {
    std::unique_lock<std::mutex> lock(mutex);
    const bool success = Dart_PostCObject_DL(port, object);
    if (!success) FATAL("Failed to send message, invalid port or isolate died");
 
    printf("C   :  Waiting for result.\n");
    while (!notified) {
      cv.wait(lock);
    }
  }

---

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

• third_party/dart-lang/sdk/runtime/bin/ffi_test/ffi_test_functions_vmspecific.cc