Return to rtlm.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / example

start client development

    1: /*
    2:  * Test sequence for RTLM SQL modules
    3:  */
    4: #include <stdio.h>
    5: #include <stdlib.h>
    6: #include <string.h>
    7: #include <sys/types.h>
    8: #include <aitmqtt.h>
    9: 
   10: #if 0
   11: 	int ret = 0;
   12: 	mqtt_subscr_t *s, *p;
   13: 
   14: 	if (LoadConfig("/etc/mqtt.conf", &cfg)) {
   15: 		printf("Error:: Load config #%d - %s\n", cfg_GetErrno(), cfg_GetError());
   16: 		return 1;
   17: 	}
   18: 	if (!mqttLoadRTLM(&cfg, 0)) {
   19: 		printf("Error:: Can't load RTL ACC module\n");
   20: 		UnloadConfig(&cfg);
   21: 		return 2;
   22: 	}
   23: 	if (!mqttLoadRTLM(&cfg, 1)) {
   24: 		printf("Error:: Can't load RTL PUB module\n");
   25: 		mqttUnloadRTLM(0);
   26: 		UnloadConfig(&cfg);
   27: 		return 2;
   28: 	}
   29: 	if (!mqttLoadRTLM(&cfg, 2)) {
   30: 		printf("Error:: Can't load RTL LOG module\n");
   31: 		mqttUnloadRTLM(1);
   32: 		mqttUnloadRTLM(0);
   33: 		UnloadConfig(&cfg);
   34: 		return 2;
   35: 	}
   36: 
   37: 	acc = call.OpenACC(&cfg);
   38: 	if (!acc)
   39: 		goto end;
   40: 	pub = call.OpenPUB(&cfg);
   41: 	if (!pub)
   42: 		goto end;
   43: 	logg = call.OpenLOG(&cfg);
   44: 	if (!logg)
   45: 		goto end;
   46: 
   47: 	if (mqttMkDir(&cfg)) {
   48: 		printf("Error:: in statedir #%d - %s\n", errno, strerror(errno));
   49: 		goto end;
   50: 	}
   51: 
   52: 	call.LOG(logg, "success!\n");
   53: 	if ((ret = call.LoginACC(&cfg, acc, "misho", "test123")) == -1) {
   54: 		printf("Error:: Authentication problem\n");
   55: 		goto end;
   56: 	} else
   57: 		call.LOG(logg, "Login: %s\n", ret ? "ALLOW" : "DENIED");
   58: 
   59: 	if ((ret = call.InitSessPUB(&cfg, pub, "misho", "doophenschmerz", "127.0.0.1", 12345, 1, 
   60: 					"Topic43", "mmm", 2, 0)) == -1) {
   61: 		printf("Error:: Session init problem\n");
   62: 		goto end;
   63: 	} else
   64: 		call.LOG(logg, "InitSess: %d\n", ret);
   65: 
   66: 	if ((ret = call.ChkSessPUB(&cfg, pub, "misho", "doophenschmerz", "127.0._.%")) == -1) {
   67: 		printf("Error:: Session check problem\n");
   68: 		goto end;
   69: 	} else
   70: 		call.LOG(logg, "ChkSess: %d\n", ret);
   71: 
   72: 	if ((ret = call.DeletePUB(&cfg, pub, 10, "%", "%", "%", -1)) == -1) {
   73: 		printf("Error:: Clear problem\n");
   74: 		goto end;
   75: 	} else
   76: 		call.LOG(logg, "Clear: %d\n", ret);
   77: 
   78: 	if ((ret = call.WritePUB(&cfg, pub, 10, "oho/boho", "MRYN    \n tryn brymbryn", "misho", "1.1.1.1", 1)) == -1) {
   79: 		printf("Error:: Publish problem\n");
   80: 		goto end;
   81: 	} else
   82: 		call.LOG(logg, "Publish: %d\n", ret);
   83: 	if ((ret = call.WritePUB(&cfg, pub, 11, "boh", "testing", "misho", "1.1.1.2", 0)) == -1) {
   84: 		printf("Error:: Publish problem\n");
   85: 		goto end;
   86: 	} else
   87: 		call.LOG(logg, "Publish: %d\n", ret);
   88: 	if (!(s = call.ReadPUB(&cfg, pub, 10, "%", -1))) {
   89: 		printf("Error:: Subscribe problem\n");
   90: 		goto end;
   91: 	} else {
   92: 		call.LOG(logg, "Subscribe: %p\n", s);
   93: 		for (p = s; p->sub_topic._base; p++) {
   94: 			printf("Retain=%d Topic(%d)=%s Value(%d)=%s\n", p->sub_ret, 
   95: 					p->sub_topic._size, p->sub_topic._base, 
   96: 					p->sub_value._size, p->sub_value._base);
   97: 		}
   98: 		mqtt_subFree(&s);
   99: 	}
  100: 	if ((ret = call.DeletePUB(&cfg, pub, 11, "boh", "misho", "1.1.1._", 0)) == -1) {
  101: 		printf("Error:: Delete problem\n");
  102: 		goto end;
  103: 	} else
  104: 		call.LOG(logg, "Delete: %d\n", ret);
  105: 
  106: 	if ((ret = call.FiniSessPUB(&cfg, pub, "misho", "doophenschmerz", "127.0._.1%")) == -1) {
  107: 		printf("Error:: Session fini problem\n");
  108: 		goto end;
  109: 	} else
  110: 		call.LOG(logg, "FiniSess: %d\n", ret);
  111: 
  112: end:
  113: 	call.CloseLOG(logg);
  114: 	call.ClosePUB(pub);
  115: 	call.CloseACC(acc);
  116: 	mqttUnloadRTLM(2);
  117: 	mqttUnloadRTLM(1);
  118: 	mqttUnloadRTLM(0);
  119: 	UnloadConfig(&cfg);
  120: #endif