Lines Matching defs:Client

110 typedef struct Client {  struct
111 void *lock_generic; /* generic lock */
112 uint32_t packet_id; /* packet id */
113 uint32_t request_timeout_ms; /* request timeout in millisecond */
114 uint32_t cycle_timeout_ms;
115 uint32_t buf_size_send; /* send buffer size in byte */
118 uint32_t buf_size_send_max; /* send buffer size max limit in byte */
119 uint32_t buf_size_read_max; /* recv buffer size max limit in byte */
122 uint32_t buf_size_read; /* read buffer size in byte */
123 uint8_t keepalive_probes; /* keepalive probes */
125 char *buf_send; /* pointer of send buffer */
126 char *buf_read; /* pointer of read buffer */
128 char buf_send[IOTX_MC_TX_MAX_LEN];
129 char buf_read[IOTX_MC_RX_MAX_LEN];
132 struct list_head list_sub_handle; /* list of subscribe handle */
134 iotx_mc_topic_handle_t list_sub_handle[IOTX_MC_SUBHANDLE_LIST_MAX_LEN];
136 utils_network_t ipstack; /* network parameter */
137 iotx_time_t next_ping_time; /* next ping time */
138 iotx_mc_state_t client_state; /* state of MQTT client */
139 iotx_mc_reconnect_param_t reconnect_param; /* reconnect parameter */
140 MQTTPacket_connectData connect_data; /* connection parameter */
143 struct list_head list_pub_wait_ack; /* list of wait publish ack */
145 iotx_mc_pub_info_t list_pub_wait_ack[IOTX_MC_REPUB_NUM_MAX];
149 struct list_head list_sub_sync_ack;
151 mqtt_sub_sync_node_t list_sub_sync_ack[IOTX_MC_SUBSYNC_LIST_MAX_LEN];
153 void *lock_list_pub; /* lock for list of QoS1 pub */
154 void *lock_write_buf; /* lock of write */
155 void *lock_read_buf; /* lock of write */
156 void *lock_yield;
157 iotx_mqtt_event_handle_t handle_event; /* event handle */
159 int used;