registration.h

Go to the documentation of this file.

/*
 *******************************************************************
 *
 * Copyright 2016 Intel Corporation All rights reserved.
 *
 *-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 *-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
 */

#ifndef _DPS_REGISTRATION_H
#define _DPS_REGISTRATION_H

#include <dps/dps.h>

#ifdef __cplusplus
extern "C" {
#endif

#define DPS_REGISTRATION_PUT_TIMEOUT 2000 
#define DPS_REGISTRATION_GET_TIMEOUT 5000 
extern const char* DPS_RegistryTopicString;

/*
 * Registration entry flags
 */
#define DPS_CANDIDATE_TRYING   0x01  
#define DPS_CANDIDATE_FAILED   0x02  
#define DPS_CANDIDATE_LINKED   0x04  
#define DPS_CANDIDATE_UNLINKED 0x08  
#define DPS_CANDIDATE_INVALID  0x10  
typedef struct _DPS_Registration {
    uint8_t flags; 
    char* addrText; 
} DPS_Registration;

typedef struct _DPS_RegistrationList {
    uint8_t size;     
    uint8_t count;    
    DPS_Registration list[1]; 
} DPS_RegistrationList;

DPS_RegistrationList* DPS_CreateRegistrationList(uint8_t size);

void DPS_DestroyRegistrationList(DPS_RegistrationList* regs);

typedef void (*DPS_OnRegPutComplete)(DPS_Status status, void* data);

DPS_Status DPS_Registration_Put(DPS_Node* node, const char* addrText, const char* tenantString,
                                uint16_t timeout, DPS_OnRegPutComplete cb, void* data);

DPS_Status DPS_Registration_PutSyn(DPS_Node* node, const char* addrText, const char* tenantString,
                                   uint16_t timeout);

typedef void (*DPS_OnRegGetComplete)(DPS_RegistrationList* regs, DPS_Status status, void* data);

DPS_Status DPS_Registration_Get(DPS_Node* node, const char* addrText, const char* tenantString,
                                DPS_RegistrationList* regs, uint16_t timeout, DPS_OnRegGetComplete cb,
                                void* data);

DPS_Status DPS_Registration_GetSyn(DPS_Node* node, const char* addrText, const char* tenantString,
                                   DPS_RegistrationList* regs, uint16_t timeout);

typedef void (*DPS_OnRegLinkToComplete)(DPS_Node* node, DPS_RegistrationList* regs, const DPS_NodeAddress* addr, DPS_Status status, void* data);

DPS_Status DPS_Registration_LinkTo(DPS_Node* node, DPS_RegistrationList* regs, DPS_OnRegLinkToComplete cb, void* data);

DPS_Status DPS_Registration_LinkToSyn(DPS_Node* node, DPS_RegistrationList* regs, DPS_NodeAddress* addr);
 // end of registration group
 // end of services group

#ifdef __cplusplus
}
#endif

#endif