1 Presence流程图
========Server===============================SDK===========================================Client============
SERVER
((1))
Platform::start OCInit2
((2)) "/oic/ad" +------------------+
OCCreateResource --------> | OCResource |
----> |------------------|
+-----------------+ / | uri,type,if,uuid | (no active)
|PresenceResource | / | attrs,propers |----> OC_OBSERVABLE
|-----------------| handle / | actionsetHead | ^
| handle | ----------/ | childresHead | |
| presenceTTL | /----- | observerHead | |
+-----------------+ / | entityHandler | |
/ |------------------| |
((3)) observerHead / | next | |
startPresence /------------------------------- +------------------+ |
/ ((4)) |
/ OCStartPresence |
v OC_ACTIVE |
+-------------------+ ChangeResouceProperty ---------------------+ (active)
| ResourceObserver | TTL=0
|-------------------| <------------ AddObserver
| observeId | OCPresenceTrigger
| resUri | SendPresenceNotification |
see ? <---+-TTL | | +--------+--------+
ocobserve.h | acceptFormat | | | | |
| query,token | | v v v
| devAddr | | CREATE CHANGE DELETE
| lowQosCount (NON)| | | | |
| forceHighQos (CON)| | OCCreateResource | OCDeleteResource
|-------------------| | +-----------------------------------+
| next | | | OCBindResource (collection) |
+-------------------+ Trigger: CREATE | | OCBindResourceTypeToResource |
+------------------------------------------------------+ | OCBindResourceInterfaceToResource |
| +------------+ +-----------------------------------+
| | OCPresence |
| |------------| CLIENT
| | TTL |
| | timeout[l] | g_cbList [[1]]
| | level | | thread2 Platform::start
| +------------+ v OCInit2 listeningFunc
| ^ +-------------------+ |
| | | ClientCB | "/oic/ad" | [[2]]
| | |-------------------|\ /-----------------------+----- subscribePresence
| | | requestUri | \ [[3]] / SubscribeCallback |
| | | sequenceNumber | \ OCDoResource | |
| +---| presence, TTL | \ / +-----------+--------\ thread2
| | payload, method | \ / | ---> presenceHandler
| | callback (cb-1) | AddClientCB | cb-1
| +-------------------+ ( Don't Call OCSendRequest ) | |
| | loop: |
| ((5)) | thread2 |
| createResource | --> OCProcess |
| ((6)) | | |
| OCCreateResource | |
| | | |
| +----------------------------+ | |
| v | |
+--------> SendPresenceNotification | |
| SendAllObserverNotification | |
| | | | |
| v | "/oic/ad" ((7)) "/oic/ad" | |
| AddServerRequest +-----------------> OCSendResponse -------------------------------> | |
| \ | |
| \ | |
| \ [[4]] ((8)) | |
| g_svrRequestTree \ OCHandleResponse <------------------------------ | |
| | +-------------------+ | | |
| +----> | OCServerRequest | | HandlePresenceResponse | |
| |-------------------| | | |
| | resourceUrl,reqID | | client = GetClientCBUsingUri("/oic/ad") | |
| | reqToken, query | | | |
| | payload, method | | ResetPresenceTTL | |
| | ehResponseHandler | | | |
| +-------------------+ | client->callback | |
| | -------------------------------------------|-------> | [[5]]
| | |
| thread2 | |
| processFunc [[6]] | |
| | OCProcessPresence |
| | loop: | |
| | | check ttl |
| | --> OCProcess ( only unicast make sense ) | |
| | | | |
| | | "/oic/ad" [[7.1]] check timeout[l] | |
| | | <---------------- OCSendRequest <---------------------------- | (Unicast) |
| | | timeout "/oic/ad" | |
| | | ((9)) [[8]] | check level |
| | | ----------------> OCHandleRequests | -----------> |
| | / | no ticks | [[7.2]]
| "/oic/ad" / | STACK_PRESENCE_TIMEOUT
| HandleVirtualResource |
| Trigger: CHANGE | DeleteClientCB <--------------------- |
+-----------------------------------+
STACK_DELETE_TRANSACTION / KEEP2 Observe流程图
|OC_REST_OBSERVE| <--------- observeResource <--- OC::OCRecource::observe
| <------------ |
Observers.insert | | onObserve
| | cb
| | |
| | | |
loop +----- | | | |
| | | | |
| | OCDoResponse | | |
notifyListOfObservers | ------------------|-------------> | wrapper switch |
| | | | ------------------------------> |
| |
| |
+----> |
|