Lines Matching refs:client
300 void test1_sendAndReceive(MQTT::Client<IPStack, Countdown, 1000>& client, int qos, const char* test… in test1_sendAndReceive() argument
320 rc = client.publish(test_topic, pubmsg); in test1_sendAndReceive()
327 client.yield(100); in test1_sendAndReceive()
339 client.yield(1000); in test1_sendAndReceive()
356 MQTT::Client<IPStack, Countdown, 1000> client = MQTT::Client<IPStack, Countdown, 1000>(ipstack); in test1() local
379 rc = client.connect(data); in test1()
384 rc = client.subscribe(test_topic, subsqos, messageArrived); in test1()
387 test1_sendAndReceive(client, 0, test_topic); in test1()
388 test1_sendAndReceive(client, 1, test_topic); in test1()
389 test1_sendAndReceive(client, 2, test_topic); in test1()
393 rc = client.unsubscribe(test_topic); in test1()
395 rc = client.disconnect(); in test1()
402 rc = client.connect(data); in test1()
404 rc = client.disconnect(); in test1()
433 MQTT::Client<IPStack, Countdown, 1000> client = MQTT::Client<IPStack, Countdown, 1000>(ipstack); in test2() local
457 rc = client.connect(data, connack); in test2()
466 rc = client.disconnect(); in test2()
474 rc = client.connect(data, connack); in test2()
482 rc = client.subscribe(test_topic, subsqos, messageArrived, suback); in test2()
487 rc = client.disconnect(); in test2()
495 rc = client.connect(data, connack); in test2()
502 rc = client.disconnect(); in test2()
510 rc = client.connect(data, connack); in test2()
517 rc = client.disconnect(); in test2()
550 int check_subs_exist(MQTT::Client<IPStack, Countdown, 1000>& client, const char* test_topic, int wh… in check_subs_exist() argument
563 rc = client.publish(test_topic, pubmsg); in check_subs_exist()
570 client.yield(100); in check_subs_exist()
598 MQTT::Client<IPStack, Countdown, 1000> client = MQTT::Client<IPStack, Countdown, 1000>(ipstack); in test3() local
615 assert("Good rc in connack", client.isConnected() == false, in test3()
616 "isconnected was %d", client.isConnected()); in test3()
625 rc = client.connect(data, connack); in test3()
634 assert("Good rc in connack", client.isConnected() == true, in test3()
635 "isconnected was %d", client.isConnected()); in test3()
637 rc = client.disconnect(); in test3()
645 rc = client.connect(data, connack); in test3()
653 rc = client.subscribe(test_topic, subsqos, messageArrived, suback); in test3()
658 check_subs_exist(client, test_topic, 1); in test3()
660 rc = client.subscribe(test_topic, subsqos, messageArrived2, suback); in test3()
665 check_subs_exist(client, test_topic, 2); in test3()
667 rc = client.disconnect(); in test3()
675 rc = client.connect(data, connack); in test3()
682 check_subs_exist(client, test_topic, 2); in test3()
684 rc = client.subscribe(test_topic, subsqos, messageArrived, suback); in test3()
689 check_subs_exist(client, test_topic, 1); in test3()
698 rc = client.publish("MQTTSAS topic", pubmsg); in test3()
703 while (client.isConnected() && (wait_seconds-- > 0)) in test3()
705 client.yield(1000); in test3()
707 assert("Disconnected", !client.isConnected(), "isConnected was %d", in test3()
708 client.isConnected()); in test3()
715 rc = client.connect(data, connack); in test3()
722 check_subs_exist(client, test_topic, 1); in test3()
724 rc = client.subscribe(test_topic, subsqos, messageArrived2, suback); in test3()
729 check_subs_exist(client, test_topic, 2); in test3()
731 rc = client.disconnect(); in test3()
739 rc = client.connect(data, connack); in test3()
746 rc = client.subscribe(test_topic, subsqos, messageArrived2, suback); in test3()
751 check_subs_exist(client, test_topic, 2); in test3()
753 rc = client.disconnect(); in test3()