| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/ |
| D | MQTTClient.c | 69 unsigned char* sendbuf, size_t sendbuf_size, unsigned char* readbuf, size_t readbuf_size) in MQTTClientInit() argument
83 c->readbuf = readbuf; in MQTTClientInit()
134 int rc = c->ipstack->mqttread(c->ipstack, c->readbuf, 1, TimerLeftMS(timer)); in readPacket()
144 …len += MQTTPacket_encode(c->readbuf + 1, rem_len); /* put the original remaining length back into … in readPacket()
154 …if (rem_len > 0 && (rc = c->ipstack->mqttread(c->ipstack, c->readbuf + len, rem_len, TimerLeftMS(t… in readPacket()
160 header.byte = c->readbuf[0]; in readPacket()
315 …0x%{public}x, packet_type=0x%{public}x,errno = [%{public}d]", c->readbuf[0], c->readbuf[1], rc, pa… in cycle()
337 … (unsigned char**)&msg.payload, (int*)&msg.payloadlen, c->readbuf, c->readbuf_size) != 1) in cycle()
362 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in cycle()
500 … if (MQTTDeserialize_connack(&data->sessionPresent, &data->rc, c->readbuf, c->readbuf_size) == 1) in MQTTConnectWithResults()
[all …]
|
| D | MQTTClient.h | 108 *readbuf; member
141 unsigned char* sendbuf, size_t sendbuf_size, unsigned char* readbuf, size_t readbuf_size);
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/freertos/ |
| D | MQTTEcho.c | 30 unsigned char sendbuf[80], readbuf[80]; in prvMQTTEchoTask() local
37 MQTTClientInit(&client, &network, 30000, sendbuf, sizeof(sendbuf), readbuf, sizeof(readbuf)); in prvMQTTEchoTask()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 256 unsigned char readbuf[MAX_MQTT_PACKET_SIZE]; variable
456 rc = ipstack.read(readbuf, 1, timer.left_ms()); in readPacket()
463 …len += MQTTPacket_encode(readbuf + 1, rem_len); /* put the original remaining length into the buff… in readPacket()
472 if (rem_len > 0 && (ipstack.read(readbuf + len, rem_len, timer.left_ms()) != rem_len)) in readPacket()
475 header.byte = readbuf[0]; in readPacket()
486 MQTTFormat_toClientString(printbuf, sizeof(printbuf), readbuf, len)); in readPacket()
607 … (unsigned char**)&msg.payload, (int*)&msg.payloadlen, readbuf, MAX_MQTT_PACKET_SIZE) != 1) in cycle()
645 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) in cycle()
756 (unsigned char*)&data.rc, readbuf, MAX_MQTT_PACKET_SIZE) == 1) in connect()
875 …if (MQTTDeserialize_suback(&mypacketid, 1, &count, &data.grantedQoS, readbuf, MAX_MQTT_PACKET_SIZE… in subscribe()
[all …]
|
| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTClient-C/src/ |
| D | MQTTClient.h | 96 *readbuf; member
128 unsigned char* sendbuf, size_t sendbuf_size, unsigned char* readbuf, size_t readbuf_size);
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/linux/ |
| D | stdoutsub.c | 199 unsigned char readbuf[100]; in main() local
221 MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/test/ |
| D | test1.c | 358 unsigned char readbuf[100]; in test1() local
368 MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); in test1()
436 unsigned char readbuf[100]; in test2() local
447 MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); in test2()
593 unsigned char readbuf[100]; in test3() local
603 MQTTClientInit(&c, &n, 1000, buf, 100, readbuf, 100); in test3()
|
| /device/soc/bestechnic/bes2600/liteos_m/components/drivers/touch/ |
| D | touch_fts.c | 48 …i2c_read(struct i2c_client *client, uint8_t *writebuf, int writelen, uint8_t *readbuf, int readlen) in fts_i2c_read() argument
71 .buf = readbuf, in fts_i2c_read()
87 .buf = readbuf, in fts_i2c_read()
|
| /device/board/isoftstone/yangfan/kernel/src/driv/net/rockchip_wlan/rkwifi/bcmdhd/ |
| D | dhd_msgbuf.c | 9166 char *readbuf; local
9183 readbuf = (char *)dhd->prot->hmaptest.mem.va + dhd->prot->hmaptest.offset;
9187 DHD_ERROR(("hmaptest cmplt: FW has written at 0x%p\n", readbuf));
9191 DHD_ERROR(("0x%08x\n", *(int *)(readbuf + i)));
|