nl::Weave::Profiles::Echo_Next::WeaveEchoClient

#include <src/lib/profiles/echo/Next/WeaveEchoClient.h>

Provides the ability to send Weave EchoRequest messages to a peer node and receive
the corresponding EchoResponse messages.

Ringkasan

Class WeaveEchoClient menerapkan sisi inisiator protokol Weave Echo. Serupa dengan protokol ping ICMP, protokol Weave Echo dapat digunakan untuk menguji keaktifan dan keterjangkauan node Weave.

Aplikasi dapat menggunakan class WeaveEchoClient untuk mengirim pesan EchoRequest satu kali atau berulang ke node pembanding yang diidentifikasi oleh objek Binding. Class yang sesuai ada untuk merespons permintaan echo (lihat WeaveEchoServer).

Binding Klien

WeaveEchoClient mengambil objek Binding Weave yang digunakan untuk mengidentifikasi dan menjalin komunikasi dengan penerima permintaan gema yang dituju. Binding dapat dikonfigurasi dan disiapkan oleh aplikasi sebelum inisialisasi objek WeaveEchoClient, atau dapat dibiarkan tidak disiapkan, dalam hal ini WeaveEchoClient akan meminta persiapan binding sesuai permintaan (lihat Binding::RequestPrepare() untuk detailnya).

Persiapan Binding sesuai permintaan juga akan diminta jika gagal setelah memasuki status Siap.

Mode Berulang

Metode SendRepeating() dapat digunakan untuk memasukkan WeaveEchoClient ke mode SendRepeating. Dalam mode ini, objek klien mengirimkan urutan berulang pesan EchoRequest ke peer pada interval yang dikonfigurasi. Mode SendRepeating dapat dibatalkan dengan memanggil metode Stop().

Multicast dan Siaran

Objek WeaveEchoClient dapat digunakan untuk mengirim EchoRequests ke beberapa penerima secara bersamaan dengan mengonfigurasi objek Binding dengan alamat multicast IPv6 yang sesuai atau alamat broadcast jaringan lokal IPv4 (255.255.255.255). Saat objek WeaveEchoClient mendeteksi alamat peer multicast atau siaran, objek tersebut akan otomatis memasuki mode MultiResponse setelah mengirim EchoRequest.

Dalam mode ini, objek terus memproses dan mengirimkan semua pesan EchoResponse yang masuk di pertukaran yang sama. Objek akan tetap berada dalam mode MultiResponse hingga: 1) aplikasi memanggil Stop() atau Send(), 2) dalam mode SendRepeating, tiba waktunya untuk mengirim permintaan lain, atau 3) tidak ada respons yang diterima dan waktu tunggu penerimaan berakhir.

Peristiwa API

Selama operasinya, objek WeaveEchoClient akan memanggil aplikasi untuk meminta tindakan tertentu atau mengirimkan notifikasi peristiwa penting. Panggilan peristiwa API ini dibuat untuk fungsi callback yang saat ini dikonfigurasi pada objek klien. Kecuali jika dinyatakan, aplikasi bebas mengubah status klien selama callback peristiwa. Satu pengecualian keseluruhan adalah metode Shutdown() objek, yang mungkin tidak pernah dipanggil selama callback.

Peristiwa API berikut ditentukan:

PreparePayload

WeaveEchoClient akan membuat pesan EchoRequest dan meminta aplikasi untuk menyediakan payload. Jika aplikasi menginginkannya, aplikasi dapat menampilkan PacketBuffer baru yang berisi data payload. Jika aplikasi tidak menangani peristiwa ini, EchoRequest dengan payload panjang nol akan dikirim secara otomatis. Aplikasi TIDAK BOLEH mengubah status WeaveEchoClient selama callback ini.

RequestSent

Pesan EchoRequest telah dikirim ke peer.

ResponseReceived

Pesan EchoResponse diterima dari rekannya. Argumen ke peristiwa berisi payload respons dan informasi meta tentang pesan respons.

CommunicationError

Terjadi error saat membuat atau mengirim EchoRequest, atau saat menunggu respons. Contoh error yang dapat terjadi saat menunggu respons adalah error utama atau penutupan koneksi yang tidak terduga. Argumen ke peristiwa berisi alasan error.

ResponseTimeout

EchoResponse tidak diterima pada waktu yang ditentukan. Waktu tunggu respons dikontrol oleh properti DefaultResponseTimeout pada objek Binding.

RequestAborted

Pertukaran Echo yang sedang berlangsung dibatalkan karena ada permintaan yang dibuat untuk mengirim EchoRequest lain sebelum respons diterima untuk pesan sebelumnya. Hal ini dapat terjadi dalam mode SendRepeating saat tiba waktunya untuk mengirim EchoRequest berikutnya. Hal ini juga dapat terjadi jika aplikasi memanggil Send() setelah EchoRequest dikirim, tetapi sebelum respons apa pun diterima.

Saat objek berada dalam mode MultiResponse, peristiwa akan disembunyikan jika setidaknya satu pesan EchoResponse telah diterima.

Konstruktor dan Destruktor

WeaveEchoClient(void)

Jenis publik

EventCallback)(void *appState, EventType eventType, const InEventParam &inParam, OutEventParam &outParam) typedef
void(*
EventType{
  kEvent_PreparePayload = 1,
  kEvent_RequestSent = 2,
  kEvent_ResponseReceived = 3,
  kEvent_CommunicationError = 4,
  kEvent_ResponseTimeout = 5,
  kEvent_RequestAborted = 6,
  kEvent_DefaultCheck = 100
}
enum
State{
  kState_NotInitialized = 0,
  kState_Idle = 1,
  kState_PreparingBinding = 2,
  kState_RequestInProgress = 3,
  kState_WaitingToSend = 4
}
enum

Atribut publik

AppState
void *
Pointer ke data khusus aplikasi.

Fungsi publik

GetBinding(void) const
Menampilkan pointer ke objek Binding yang terkait dengan WeaveEchoClient.
GetEventCallback(void) const
EventCallback
Menampilkan pointer ke fungsi callback peristiwa API yang saat ini dikonfigurasi pada objek WeaveEchoClient.
GetState(void) const
Ambil status objek WeaveEchoClient saat ini.
Init(Binding *binding, EventCallback eventCallback, void *appState)
Lakukan inisialisasi objek WeaveEchoClient.
IsSendRrepeating() const
bool
Menampilkan true jika objek WeaveEchoClient saat ini dalam mode pengiriman berulang.
RequestInProgress() const
bool
Menampilkan true (benar) jika EchoRequest telah dikirim dan objek WeaveEchoClient menunggu respons.
Send(void)
Kirim pesan EchoRequest ke peer.
Send(PacketBuffer *payloadBuf)
Kirim pesan EchoRequest ke peer dengan payload tertentu.
SendRepeating(uint32_t sendIntervalMS)
Mulai mengirim urutan pesan EchoRequest yang berulang ke peer.
SetEventCallback(EventCallback eventCallback)
void
Menetapkan fungsi callback peristiwa API pada objek WeaveEchoClient.
Shutdown(void)
void
Menonaktifkan objek WeaveEchoClient yang sebelumnya diinisialisasi.
Stop(void)
void
Menghentikan pertukaran Echo yang sedang berlangsung dan membatalkan mode pengulangan pengiriman.

Fungsi statis publik

DefaultEventHandler(void *appState, EventType eventType, const InEventParam & inParam, OutEventParam & outParam)
void
Pengendali default untuk peristiwa WeaveEchoClient API.

Struct

nl::Weave::Profiles::Echo_Next::WeaveEchoClient::InEventParam

Parameter input ke peristiwa API WeaveEchoClient.

nl::Weave::Profiles::Echo_Next::WeaveEchoClient::OutEventParam

Parameter output ke peristiwa API WeaveEchoClient.

Jenis publik

EventCallback

void(* EventCallback)(void *appState, EventType eventType, const InEventParam &inParam, OutEventParam &outParam)

EventType

 EventType
Properti
kEvent_CommunicationError

Terjadi error komunikasi saat mengirim EchoRequest atau menunggu respons.

kEvent_DefaultCheck

Digunakan untuk memverifikasi penanganan peristiwa default yang benar dalam aplikasi.

kEvent_PreparePayload

Aplikasi diminta untuk menyiapkan payload untuk Echo request.

kEvent_RequestAborted

Pertukaran Echo yang sedang berlangsung dibatalkan karena ada permintaan untuk memulai pertukaran lain.

kEvent_RequestSent

Pesan EchoRequest telah dikirim ke peer.

kEvent_ResponseReceived

Pesan EchoResponse diterima dari rekannya.

kEvent_ResponseTimeout

EchoResponse tidak diterima pada waktu yang ditentukan.

Negara Bagian

 State
Properti
kState_Idle

Objek klien tidak ada aktivitas.

kState_NotInitialized

Objek klien tidak diinisialisasi.

kState_PreparingBinding

Objek klien menunggu binding siap.

kState_RequestInProgress

Pesan EchoRequest telah dikirim dan objek klien sedang menunggu respons.

kState_WaitingToSend

SendRepeating() telah dipanggil dan objek klien menunggu waktu berikutnya untuk mengirim EchoRequest.

Atribut publik

AppState

void * AppState

Pointer ke data khusus aplikasi.

Fungsi publik

GetBinding

Binding * GetBinding(
  void
) const 

Menampilkan pointer ke objek Binding yang terkait dengan WeaveEchoClient.

GetEventCallback

EventCallback GetEventCallback(
  void
) const 

Menampilkan pointer ke fungsi callback peristiwa API yang saat ini dikonfigurasi pada objek WeaveEchoClient.

GetState

State GetState(
  void
) const 

Ambil status objek WeaveEchoClient saat ini.

Inisiasi

WEAVE_ERROR Init(
  Binding *binding,
  EventCallback eventCallback,
  void *appState
)

Lakukan inisialisasi objek WeaveEchoClient.

Lakukan inisialisasi objek WeaveEchoClient sebagai persiapan untuk mengirim pesan echo ke peer.

Detail
Parameter
[in] binding
Objek Binding yang akan digunakan untuk berkomunikasi dengan node peer.
[in] eventCallback
Pointer ke fungsi yang akan dipanggil oleh objek WeaveEchoClient untuk mengirimkan peristiwa API ke aplikasi.
[in] appState
Pointer ke objek yang didefinisikan aplikasi yang akan diteruskan kembali ke aplikasi setiap kali peristiwa API terjadi.

IsSendRrepeating

bool IsSendRrepeating() const 

Menampilkan true jika objek WeaveEchoClient saat ini dalam mode pengiriman berulang.

RequestInProgress

bool RequestInProgress() const 

Menampilkan true (benar) jika EchoRequest telah dikirim dan objek WeaveEchoClient menunggu respons.

Kirim

WEAVE_ERROR Send(
  void
)

Kirim pesan EchoRequest ke peer.

Metode ini memulai proses pengiriman pesan EchoRequest ke node peer. Jika dan saat pesan EchoResponse yang sesuai diterima, pesan akan dikirimkan ke aplikasi melalui peristiwa ResponseReceived API.

Saat membentuk pesan EchoRequest, WeaveEchoClient akan membuat permintaan ke aplikasi, melalui peristiwa PreparePayload API, untuk menyiapkan payload pesan.

Jika objek Binding tidak dalam status Siap saat metode ini dipanggil, permintaan akan dibuat ke metode Binding::RequestPrepare() untuk memulai persiapan on-demand. Operasi pengiriman kemudian akan dimasukkan dalam antrean sampai proses ini selesai. Kedalaman maksimum antrean ini adalah satu. Jadi, setiap panggilan ke Send() saat ada pengiriman sebelumnya dalam antrean akan menghasilkan hanya satu EchoRequest yang dikirim.

Memanggil Send() saat WeaveEchoClient berada dalam mode kirim berulang (yaitu karena panggilan sebelumnya ke SendRepeating()) memiliki efek mempercepat dan mereset siklus pengiriman, tetapi tidak mengeluarkan WeaveEchoClient dari mode pengiriman berulang.

Kirim

WEAVE_ERROR Send(
  PacketBuffer *payloadBuf
)

Kirim pesan EchoRequest ke peer dengan payload tertentu.

Metode ini memulai proses pengiriman pesan EchoRequest ke node peer. Konten buffering payload yang disediakan akan dikirim ke peer sebagai payload pesan EchoRequest. Jika dan saat pesan EchoResponse yang sesuai diterima, pesan akan dikirimkan ke aplikasi melalui peristiwa ResponseReceived API.

Setelah memanggil metode ini, kepemilikan buffer payload yang disediakan akan diteruskan ke objek WeaveEchoClient, yang bertanggung jawab untuk membebaskannya. Hal ini berlaku terlepas dari apakah metode berhasil diselesaikan atau error.

Jika objek Binding tidak dalam status Siap saat metode ini dipanggil, permintaan akan dibuat ke metode Binding::RequestPrepare() untuk memulai persiapan on-demand. Operasi pengiriman kemudian akan dimasukkan dalam antrean sampai proses ini selesai. Kedalaman maksimum antrean ini adalah satu. Jadi, setiap panggilan ke Send() saat ada pengiriman sebelumnya dalam antrean akan menghasilkan hanya satu EchoRequest yang dikirim.

Memanggil Send() saat WeaveEchoClient berada dalam mode kirim berulang (yaitu karena panggilan sebelumnya ke SendRepeating()) memiliki efek mempercepat dan mereset siklus pengiriman, tetapi tidak mengeluarkan WeaveEchoClient dari mode pengiriman berulang.

Detail
Parameter
[in] payloadBuf
Objek PacketBuffer yang berisi data payload yang akan dikirim ke peer. Kepemilikan buffer ini akan diteruskan ke objek WeaveEchoClient dalam semua kasus.

SendRepeating

WEAVE_ERROR SendRepeating(
  uint32_t sendIntervalMS
)

Mulai mengirim urutan pesan EchoRequest yang berulang ke peer.

Metode ini memulai proses berulang pengiriman pesan EchoRequest ke peer. Saat pesan EchoResponse diterima dari peer, pesan tersebut akan dikirim ke aplikasi melalui peristiwa ResponseReceived API.

Saat SendRepeating() dipanggil, WeaveEchoClient akan memasuki mode kirim berulang, yang akan tetap bertahan hingga Stop() dipanggil atau terjadi error Binding. Memanggil SendRepeating() beberapa kali memiliki efek untuk mereset siklus pengiriman dan memperbarui interval.

Pengiriman awal urutan terjadi pada saat SendRepeating() dipanggil, atau setiap kali Binding menjadi siap setelah SendRepeating() dipanggil (lihat di bawah). Pengiriman berikutnya terjadi setelahnya pada interval yang ditentukan.

Setiap kali pengiriman terjadi, WeaveEchoClient akan membuat permintaan ke aplikasi melalui peristiwa PreparePayload API, untuk menyiapkan payload pesan.

Jika objek Binding tidak dalam status Siap saat tiba waktunya untuk mengirim pesan, permintaan akan dibuat ke metode Binding::RequestPrepare() untuk memulai persiapan on demand. Pengiriman pesan berulang berikutnya akan dijeda hingga proses ini selesai. Kegagalan selama persiapan Binding on demand akan menyebabkan WeaveEchoClient keluar dari mode pengulangan pengiriman.

SetEventCallback

void SetEventCallback(
  EventCallback eventCallback
)

Menetapkan fungsi callback peristiwa API pada objek WeaveEchoClient.

Nonaktif

void Shutdown(
  void
)

Menonaktifkan objek WeaveEchoClient yang sebelumnya diinisialisasi.

Perhatikan bahwa metode ini hanya dapat dipanggil jika metode Init() telah dipanggil sebelumnya.

Hentikan

void Stop(
  void
)

Menghentikan pertukaran Echo yang sedang berlangsung dan membatalkan mode pengulangan pengiriman.

WeaveEchoClient

 WeaveEchoClient(
  void
)

Fungsi statis publik

DefaultEventHandler

void DefaultEventHandler(
  void *appState,
  EventType eventType,
  const InEventParam & inParam,
  OutEventParam & outParam
)

Pengendali default untuk peristiwa WeaveEchoClient API.

Aplikasi diharuskan memanggil metode ini untuk setiap peristiwa API yang tidak dikenali atau ditangani. Parameter yang diberikan harus sama dengan parameter yang diteruskan oleh objek klien ke fungsi pengendali peristiwa aplikasi.

Detail
Parameter
[in] appState
Pointer ke informasi status yang ditentukan aplikasi yang terkait dengan objek klien.
[in] eventType
ID peristiwa yang diteruskan oleh callback peristiwa
[in] inParam
Referensi parameter peristiwa input yang diteruskan oleh callback peristiwa
[in] outParam
Referensi parameter peristiwa output yang diteruskan oleh callback peristiwa