nl::Weave::Profiles::DataManagement_Current::SubscriptionClient

요약

공개 유형
@130 enum
EventCallback)(void *const aAppState, EventID aEvent, const InEventParam &aInParam, OutEventParam &aOutParam) typedef
void(*
구독 이벤트를 애플리케이션에 전달하는 콜백입니다.
EventID{
  kEvent_OnSubscriptionTerminated = 1,
  kEvent_OnExchangeStart = 2,
  kEvent_OnSubscribeRequestPrepareNeeded = 3,
  kEvent_OnSubscriptionEstablished = 4,
  kEvent_OnNotificationRequest = 5,
  kEvent_OnNotificationProcessed = 6,
  kEvent_OnEventStreamReceived = 7,
  kEvent_OnSubscriptionActivity = 8,
  kEvent_OnUpdateComplete = 9,
  kEvent_OnNoMorePendingUpdates = 10
} 		enum
ResubscribePolicyCallback)(void *const aAppState, ResubscribeParam &aInParam, uint32_t &aOutIntervalMsec) typedef
void(*
다음 정기 결제 재신청 전에 대기할 시간 간격을 가져오는 콜백입니다.

공개 정적 함수
DefaultEventHandler(EventID aEvent, const InEventParam & aInParam, OutEventParam & aOutParam)
void
DefaultResubscribePolicyCallback(void *const aAppState, ResubscribeParam & aInParam, uint32_t & aOutIntervalMsec)
void
기본 정책 구현은 피보나치 수열을 따라 최대 WDM_RESUBSCRIPTION_MAX_FIBONACCI_STEP_INDEX까지 계속 증가하는 기간 동안 밀리초 해상도의 임의 시간대를 선택합니다.

공개 함수
AbortSubscription(void)
void
구독을 취소합니다.
ClearUpdated(TraitUpdatableDataSink *aDataSink, PropertyPathHandle aPropertyHandle)
DisableResubscribe(void)
void
정기 결제 재신청 메커니즘을 사용 중지합니다.
DiscardUpdates()
void
업데이트 대기 중인 TraitPath 집합을 비우고 진행 중인 업데이트 요청(있는 경우)을 취소하도록 SubscriptionClient에 지시합니다.
EnableResubscribe(ResubscribePolicyCallback aCallback)
void
자동 정기 결제 재신청을 사용 설정합니다.
EndSubscription(void)
구독을 종료합니다.
FlushUpdate()
애플리케이션이 모든 TraitUpdatableDataSinks 변형을 완료했음을 나타냅니다.
FlushUpdate(bool aForce)
Free(void)
void
이 SubscriptionClient 객체를 해제합니다.
GetBinding(void) const
GetLivenessTimeoutMsec(void) const
uint32_t
GetPeerNodeId(void) const
uint64_t
GetSubscriptionId(uint64_t *const apSubscriptionId)
IndicateActivity(void)
void
InitiateCounterSubscription(const uint32_t aLivenessTimeoutSec)
void
InitiateSubscription(void)
void
SubscriptionClient를 카운터 구독자가 아닌 시작자로 구성하고 그렇지 않은 경우 구독을 불러옵니다.
IsCanceling() const
bool
IsEstablished()
bool
IsEstablishedIdle()
bool
IsFree()
bool
IsInProgressOrEstablished()
bool
IsInResubscribeHoldoff()
bool
IsRetryEnabled()
bool
IsTerminated()
bool
IsUpdatePendingOrInProgress()
bool
LockUpdateMutex(void)
void
OnCatalogChanged()
void
이 메서드는 TraitDataSink 카탈로그가 수정되었을 때 호출해야 합니다.
ResetResubscribe(void)
void
정기 결제 재신청 메커니즘을 시작합니다.
SetLivenessTimeoutMsec(uint32_t val)
void
SetUpdated(TraitUpdatableDataSink *aDataSink, PropertyPathHandle aPropertyHandle, bool aIsConditional)
SuspendUpdateRetries()
void
업데이트 요청 재시도를 중지하도록 SubscriptionClient에 지시합니다.
UnlockUpdateMutex(void)
void

구조체
nl::Weave::Profiles::DataManagement_Current::SubscriptionClient::LastObservedEvent
nl::Weave::Profiles::DataManagement_Current::SubscriptionClient::ResubscribeParam

Union
nl::Weave::Profiles::DataManagement_Current::SubscriptionClient::InEventParam
nl::Weave::Profiles::DataManagement_Current::SubscriptionClient::OutEventParam

공개 유형

@130

 @130

EventCallback

void(* EventCallback)(void *const aAppState, EventID aEvent, const InEventParam &aInParam, OutEventParam &aOutParam)

구독 이벤트를 애플리케이션에 전달하는 콜백입니다.

세부정보
매개변수
[in] aAppState
SubscriptionClient 초기화 중에 설정된 앱 상태 포인터입니다.
[in] aEvent
진행 중인 이벤트를 나타냅니다.
[in] aInParam
이벤트에 관한 추가 세부정보가 포함된 구조
[out] aOutParam
애플리케이션에서 전달한 정보

EventID

 EventID
속성
kEvent_OnEventStreamReceived

SubscriptionEngine이 NotificationRequest 메시지 내에 이벤트 스트림을 포함할 때 생성됩니다.

이 시점에서 애플리케이션은 EndSubscription(), AbortSubscription() 또는 Free()를 호출할 수 있습니다.

kEvent_OnExchangeStart

바인딩이 준비되고 ExchangeContext가 설정된 후 메시지가 전송되기 전에 생성됩니다.

애플리케이션이 ExchangeContext 설정을 조정할 수 있는 마지막 기회입니다. mEC은 유효하므로 제한 시간 설정에 맞게 조정할 수 있습니다. 애플리케이션은 클라이언트의 다른 필드를 터치해서는 안 되며 ExchangeContext를 닫으면 안 됩니다.

kEvent_OnNoMorePendingUpdates

업데이트 세트의 모든 경로가 피어에 의해 처리되었으며 더 이상 경로를 업데이트할 필요가 없음을 나타내는 이벤트입니다.

kEvent_OnNotificationProcessed

SubscriptionEngine이 NotificationRequest 메시지 처리를 완료하면 생성됩니다.

이 시점에서 애플리케이션은 EndSubscription(), AbortSubscription() 또는 Free()를 호출할 수 있습니다.

kEvent_OnNotificationRequest

NotificationRequest 수신 시 생성됩니다.

이 시점에서 애플리케이션은 EndSubscription(), AbortSubscription() 또는 Free()를 호출할 수 있습니다.

kEvent_OnSubscribeRequestPrepareNeeded

엔진이 SubscriptionsRequest를 전송할 준비가 되면 전송됩니다.

애플리케이션은 구독하려는 경로를 채워야 합니다.

kEvent_OnSubscriptionActivity

구독 활동을 나타내는 이벤트입니다.

클라이언트가 구독 활동에 대한 표시를 수신할 때마다 생성됩니다. 여기에는 성공적인 구독 설정, NotificationRequest 수신 또는 SubscriptionsConfirm 메시지에 대한 응답의 상태 보고서 수신이 포함됩니다.

kEvent_OnSubscriptionEstablished

구독이 성공적으로 설정되면 생성됩니다.

이 시점에서 애플리케이션은 EndSubscription(), AbortSubscription() 또는 Free()를 호출할 수 있습니다.

kEvent_OnSubscriptionTerminated

이 구독의 종료를 표시합니다.

nl::Weave::Profiles::DataManagement_Current::SubscriptionClient::EventCallback에 전송된 매개변수는 자동으로 정기 결제 재신청을 시도할지 여부를 나타냅니다.

이벤트 핸들러 호출 중에 클라이언트의 상태는 Terminated입니다. 재시도를 시도하지 않으면 이벤트 핸들러가 반환될 때 클라이언트의 상태가 Initialized로 전환됩니다. 그러지 않으면 상태가 ResubscribeHoldoff로 전환되고 보류 시간 후에 정기 결제를 다시 설정하려고 시도합니다.

애플리케이션은 이 상태에서 AbortSubscription() 또는 Free()를 호출할 수 있습니다.

전송된 매개변수에는 구독 종료 이유를 나타내는 오류 코드도 포함됩니다.

구독이 여러 가지 이유 (WRM ACK 누락, ExchangeContext 할당 실패, 응답 시간 초과 등)로 인해 해지되었을 수 있습니다. 클라이언트에서 생성될 수 있는 일부 오류 코드는 다음과 같습니다.

오류 코드 의미
WEAVE_ERROR_INVALID_MESSAGE_TYPE 인식할 수 없는 메시지가 수신되었습니다.
WEAVE_ERROR_TIMEOUT 확인이 수신되지 않거나 활성 검사가 실패합니다.
WEAVE_ERROR_INCORRECT_STATE 예상치 못한 상태로 메시지가 수신되었습니다.
WEAVE_ERROR_STATUS_REPORT_RECEIVED 상태 보고서가 수신되었습니다.
WEAVE_ERROR_INVALID_ARGUMENT 구독 요청 입력란이 잘못되었습니다.

kEvent_OnUpdateComplete

업데이트 완료를 나타내는 이벤트입니다.

이벤트 매개변수는 특정 특성 경로의 업데이트가 성공했는지 실패했는지 나타냅니다.

ResubscribePolicyCallback

void(* ResubscribePolicyCallback)(void *const aAppState, ResubscribeParam &aInParam, uint32_t &aOutIntervalMsec)

다음 정기 결제 재신청 전에 대기할 시간 간격을 가져오는 콜백입니다.

재구독을 포기하기로 결정한 애플리케이션은 이 함수에서 중단/해제할 수 있습니다.

세부정보
매개변수
[in] aAppState
SubscriptionClient 초기화 중에 설정된 앱 상태 포인터입니다.
[in] aInParam
재시도에 관한 추가 세부정보가 포함된 구조체입니다.
[out] aOutIntervalMsec
다음 재시도 전 대기 시간(밀리초)

공개 정적 함수

DefaultEventHandler

void DefaultEventHandler(
  EventID aEvent,
  const InEventParam & aInParam,
  OutEventParam & aOutParam
)

DefaultResubscribePolicyCallback

void DefaultResubscribePolicyCallback(
  void *const aAppState,
  ResubscribeParam & aInParam,
  uint32_t & aOutIntervalMsec
)

기본 정책 구현은 피보나치 수열을 따라 최대 WDM_RESUBSCRIPTION_MAX_FIBONACCI_STEP_INDEX까지 계속 증가하는 기간 동안 밀리초 해상도의 임의 시간대를 선택합니다.

WDM_RESUBSCRIPTION_MAX_FIBONACCI_STEP_INDEX 이후의 무작위 대기 시간의 평균은 약 1시간입니다. 재시도 횟수가 0으로 재설정되면 시퀀스가 처음부터 다시 시작됩니다.

공개 함수

AbortSubscription

void AbortSubscription(
  void
)

구독을 취소합니다.

클라이언트 구독을 취소합니다.

구독과 관련된 모든 트래픽 수락을 즉시 중지하고 모든 기본 커뮤니케이션 리소스를 해제합니다. SubscriptionClient 객체 자체는 유효하며 다시 사용할 수 있습니다.

구독 게시자에게 알리지 않고, 애플리케이션의 이벤트 핸들러에 OnSubscriptionTerminated 이벤트를 전송하지 않고 클라이언트 구독 종료를 종료합니다. 상호 구독이 있는 경우 카운터 구독도 종료됩니다.

AbortSubscription()을 호출하면 SubscriptionClient 객체가 Terminated 상태로 전환됩니다. 종료 프로세스가 완료되면 객체가 Initialized 상태로 전환됩니다. 두 전환은 AbortSubscription() 호출 내에서 동기식으로 발생합니다.

AbortSubscription()이 반환되면 SubscriptionClient 객체를 사용하여 다른 구독을 시작하거나 Free() 메서드를 호출하여 해제할 수 있습니다.

ClearUpdated

WEAVE_ERROR ClearUpdated(
  TraitUpdatableDataSink *aDataSink,
  PropertyPathHandle aPropertyHandle
)

DisableResubscribe

void DisableResubscribe(
  void
)

정기 결제 재신청 메커니즘을 사용 중지합니다.

정기 결제 재신청이 대기 중이었다면 취소됩니다.

DiscardUpdates

void DiscardUpdates()

업데이트 대기 중인 TraitPath 집합을 비우고 진행 중인 업데이트 요청(있는 경우)을 취소하도록 SubscriptionClient에 지시합니다.

이 메서드는 모든 콜백에서 호출할 수 있습니다.

EnableResubscribe

void EnableResubscribe(
  ResubscribePolicyCallback aCallback
)

자동 정기 결제 재신청을 사용 설정합니다.

콜백을 연결하여 실패 시 다음 재시도 시간을 지정합니다.

세부정보
매개변수
[in] aCallback
실패 후 다시 시도하기 전에 대기할 시간을 가져오는 콜백입니다(선택사항). NULL이면 기본 정책을 사용합니다.

EndSubscription

WEAVE_ERROR EndSubscription(
  void
)

구독을 종료합니다.

클라이언트 구독을 단계적으로 종료합니다.

WDM_ENABLE_SUBSCRIPTION_CANCEL 컴파일 시간 옵션이 사용 설정되면 피어에 CancelRequest를 전송하여 구독을 정상적으로 종료합니다. 구독과 연결된 리소스는 피어의 응답 또는 제한 시간 시 해제됩니다. 옵션이 사용 중지되면 호출은 AbortSubscription()과 동일합니다.

구독의 클라이언트 측을 단계적으로 종료합니다. 구독 취소 지원이 사용 설정된 경우 구독 취소 요청 메시지가 구독 게시자에게 전송되고 시스템은 구독을 종료하기 전에 응답을 기다립니다. 그렇지 않으면 AbortSubscription()과 유사한 방식으로 구독이 즉시 종료됩니다. 상호 구독이 있는 경우 카운터 구독도 종료됩니다.

SubscriptionsCancelRequest의 응답을 기다리는 동안 SubscriptionClient가 Canceling 상태로 전환됩니다.

종료 프로세스가 시작되면 SubscriptionClient 객체가 Terminated 상태로 전환되고 OnSubscriptionTerminated 이벤트가 애플리케이션의 이벤트 핸들러에 전달됩니다. 취소 지원이 사용 설정되지 않은 경우 이벤트 핸들러는 EndSubscription() 호출 내에서 동기식으로 호출될 수 있습니다.

애플리케이션의 이벤트 핸들러가 반환되면 SubscriptionClient 객체가 Initialized 상태로 전환됩니다. 이 시점에서 SubscriptionClient 객체를 사용하여 다른 정기 결제를 시작하거나 Free() 메서드를 호출하여 해제할 수 있습니다.

FlushUpdate

WEAVE_ERROR FlushUpdate()

애플리케이션이 모든 TraitUpdatableDataSinks 변형을 완료했음을 나타냅니다.

이전 업데이트 교환이 진행되지 않는 한 클라이언트는 업데이트 요청 1회로 업데이트됨으로 표시된 모든 데이터를 가져와 응답자에게 전송합니다. 이 메서드는 어느 스레드에서든 호출할 수 있습니다.

세부정보
매개변수
[in] aForce
true인 경우 향후 재시도가 예약된 경우에도 업데이트가 즉시 전송됩니다. 이 매개변수는 기본적으로 false로 간주됩니다.
반환
성공한 경우 WEAVE_NO_ERROR, 다른 WEAVE_ERROR 코드를 반환합니다.

FlushUpdate

WEAVE_ERROR FlushUpdate(
  bool aForce
)

무료

void Free(
  void
)

이 SubscriptionClient 객체를 해제합니다.

SubscriptionClient 객체를 해제합니다.

필요한 경우 AbortSubscription()을 호출하고 이 SubscriptionClient 객체에서 refcount를 해제합니다. 올바르게 사용하면 객체가 객체 풀로 반환될 수 있습니다.

SubscriptionClient 객체를 해제합니다. 정기 결제가 활성 상태이거나 진행 중인 경우 AbortSubscription()을 호출하는 것과 유사한 방식으로 정기 결제가 즉시 종료됩니다. 진행 중인 업데이트 요청이 있으면 이와 비슷하게 취소됩니다.

애플리케이션은 SubscriptionClient 객체의 전체 기간 동안 정확히 한 번 Free()를 호출해야 합니다. Free()가 호출된 후에는 해당 객체를 더 이상 참조하면 안 됩니다.

GetBinding

Binding * GetBinding(
  void
) const

GetLivenessTimeoutMsec

uint32_t GetLivenessTimeoutMsec(
  void
) const

GetPeerNodeId

uint64_t GetPeerNodeId(
  void
) const

GetSubscriptionId

WEAVE_ERROR GetSubscriptionId(
  uint64_t *const apSubscriptionId
)

IndicateActivity

void IndicateActivity(
  void
)

InitiateCounterSubscription

void InitiateCounterSubscription(
  const uint32_t aLivenessTimeoutSec
)

InitiateSubscription

void InitiateSubscription(
  void
)

SubscriptionClient를 카운터 구독자가 아닌 시작자로 구성하고 그렇지 않은 경우 구독을 불러옵니다.

IsCanceling

bool IsCanceling() const

IsEstablished

bool IsEstablished()

IsEstablishedIdle

bool IsEstablishedIdle()

IsFree

bool IsFree()

IsInProgressOrEstablished

bool IsInProgressOrEstablished()

IsInResubscribeHoldoff

bool IsInResubscribeHoldoff()

IsRetryEnabled

bool IsRetryEnabled()

IsTerminated

bool IsTerminated()

IsUpdatePendingOrInProgress

bool IsUpdatePendingOrInProgress()

LockUpdateMutex

void LockUpdateMutex(
  void
)

OnCatalogChanged

void OnCatalogChanged()

이 메서드는 TraitDataSink 카탈로그가 수정되었을 때 호출해야 합니다.

ResetResubscribe

void ResetResubscribe(
  void
)

정기 결제 재신청 메커니즘을 시작합니다.

즉시 재시도가 시작됩니다.

SetLivenessTimeoutMsec

void SetLivenessTimeoutMsec(
  uint32_t val
)

SetUpdated

WEAVE_ERROR SetUpdated(
  TraitUpdatableDataSink *aDataSink,
  PropertyPathHandle aPropertyHandle,
  bool aIsConditional
)

SuspendUpdateRetries

void SuspendUpdateRetries()

업데이트 요청 재시도를 중지하도록 SubscriptionClient에 지시합니다.

애플리케이션이 모든 메타데이터를 삭제하지 않고 일정 기간 동안 업데이트를 일시 중지할 수 있도록 합니다. FlushUpdate가 호출되면 업데이트와 재시도가 재개됩니다. 업데이트가 진행 중일 때 업데이트를 정지하기 위해 호출하면 업데이트가 취소되지 않지만, 실패하는 경우 FlushUpdate가 다시 호출될 때까지 재시도되지 않습니다.

UnlockUpdateMutex

void UnlockUpdateMutex(
  void
)