Lines Matching defs:result
120 CURLcode result = CURLE_OK;
123 result = Curl_nwrite(data, FIRSTSOCKET, buf, len, &n);
124 if(result)
125 return result;
139 return result;
251 CURLcode result = CURLE_OK;
299 result = Curl_rand_alnum(data, (unsigned char *)&client_id[clen],
305 result = CURLE_WEIRD_SERVER_REPLY;
322 result = CURLE_WEIRD_SERVER_REPLY;
332 result = CURLE_WEIRD_SERVER_REPLY;
337 if(!result)
338 result = mqtt_send(data, packet, packetlen);
345 return result;
350 CURLcode result = CURLE_OK;
352 result = mqtt_send(data, (char *)"\xe0\x00", 2);
355 return result;
362 CURLcode result;
369 result = Curl_read(data, data->conn->sock[FIRSTSOCKET],
371 if(result)
372 return result;
394 CURLcode result;
397 result = mqtt_recv_atleast(data, MQTT_CONNACK_LEN);
398 if(result)
410 result = CURLE_WEIRD_SERVER_REPLY;
415 return result;
422 CURLcode result = CURLE_URL_MALFORMAT;
424 result = Curl_urldecode(path + 1, 0, topic, topiclen, REJECT_NADA);
425 if(!result && (*topiclen > 0xffff)) {
427 result = CURLE_URL_MALFORMAT;
433 return result;
438 CURLcode result = CURLE_OK;
447 result = mqtt_get_topic(data, &topic, &topiclen);
448 if(result)
460 result = CURLE_OUT_OF_MEMORY;
473 result = mqtt_send(data, (char *)packet, packetlen);
478 return result;
489 CURLcode result;
492 result = mqtt_recv_atleast(data, MQTT_SUBACK_LEN);
493 if(result)
505 result = CURLE_WEIRD_SERVER_REPLY;
510 return result;
515 CURLcode result;
536 result = mqtt_get_topic(data, &topic, &topiclen);
537 if(result)
546 result = CURLE_OUT_OF_MEMORY;
560 result = mqtt_send(data, (char *)pkt, i);
565 return result;
623 CURLcode result = CURLE_OK;
635 result = mqtt_verify_suback(data);
636 if(result)
658 result = CURLE_WEIRD_SERVER_REPLY;
668 result = CURLE_FILESIZE_EXCEEDED;
682 result = Curl_read(data, sockfd, buffer, rest, &nread);
683 if(result) {
684 if(CURLE_AGAIN == result) {
691 result = CURLE_PARTIAL_FILE;
696 result = Curl_client_write(data, CLIENTWRITE_BODY, buffer, nread);
697 if(result)
708 result = CURLE_WEIRD_SERVER_REPLY;
712 return result;
717 CURLcode result = CURLE_OK;
720 result = mqtt_connect(data);
721 if(result) {
722 failf(data, "Error %d sending MQTT CONNECT request", result);
723 return result;
742 CURLcode result = CURLE_OK;
755 result = mqtt_send(data, mq->sendleftovers, mq->nsend);
757 if(result)
758 return result;
765 result = Curl_read(data, sockfd, (char *)&mq->firstbyte, 1, &nread);
766 if(result)
771 result = CURLE_RECV_ERROR;
781 result = Curl_read(data, sockfd, (char *)&byte, 1, &nread);
790 result = CURLE_WEIRD_SERVER_REPLY;
791 if(result)
807 result = mqtt_verify_connack(data);
808 if(result)
812 result = mqtt_publish(data);
813 if(!result) {
814 result = mqtt_disconnect(data);
820 result = mqtt_subscribe(data);
821 if(!result) {
830 result = mqtt_read_publish(data, done);
839 if(result == CURLE_AGAIN)
840 result = CURLE_OK;
841 return result;