Update path to xapp descriptor. Add schema parser library

[ric-app/mc.git] / schemaparser / sample2.cc

diff --git a/schemaparser/sample2.cc b/schemaparser/sample2.cc
new file mode 100644 (file)
index 0000000..5fef558
--- /dev/null
+++ b/schemaparser/sample2.cc
@@ -0,0 +1,119 @@
+#include<stdio.h>
+#include<stdlib.h>
+#include<string.h>
+
+#include<string>
+#include<iostream>
+#include<fstream>
+
+#include"schemaparser.h"
+
+struct vstring32 {
+    unsigned int length;
+    unsigned int offset;
+    unsigned int reserved;
+};
+
+
+struct thpt{
+       unsigned long long int TS;
+       unsigned long long int e_RAB_ID;
+       unsigned long long int UE_ID;
+       vstring32 GNB_ID;
+       double measurement_interval;
+       unsigned long long int active_throughput;
+       unsigned long long int average_throughput;
+       unsigned long long int min_throughput;
+       unsigned long long int max_throughput;
+};
+       
+
+using namespace std;
+using namespace mc_schema;
+
+int main(int argc, char **argv){
+//             Get the nib.json file
+       string directory = ".";
+       if(argc>1){
+               directory = argv[1];
+       }
+       string inflnm = directory + "/" + string("nib.json");
+
+       ifstream infl(inflnm);
+       if(!infl){
+               cerr << "Error, can't open " << inflnm << endl;
+               exit(1);
+       }
+       string line;
+       string nib_str;
+       while(getline(infl, line)){
+               nib_str += line;
+       }
+       infl.close();
+
+//             Load the schemas
+       mc_schemas *mcs = new_mc_schemas(nib_str);
+       if(mcs->has_errors()){
+               fprintf(stderr, "Errors loading the schemas:\n%s\n",mcs->get_errors().c_str());
+       }else{
+               vector<string> streams = mcs->get_streams();
+               printf("Loaded %ld streams:\n", streams.size());
+               for(int i=0;i<streams.size(); ++i){
+                       string str_rep = mcs->get_query_rep(streams[i])->to_string();
+                       printf("\t%s\n",str_rep.c_str());
+               }
+       }
+
+//             Load a sample record
+       char buf[150];
+       thpt *t = (thpt *)buf;
+       t->TS = 10001;
+       t->e_RAB_ID = 2;
+       t->UE_ID = 3;
+
+       t->GNB_ID.length = 6;
+       t->GNB_ID.offset = sizeof(thpt);
+       string foobar("foobar");
+       strncpy(buf+sizeof(thpt), foobar.c_str(), 6);
+
+       t->measurement_interval = 10.1;
+       t->active_throughput = 4;
+       t->average_throughput = 5;
+       t->min_throughput = 6;
+       t->max_throughput = 7;
+
+       int t_len = sizeof(thpt)+6;
+       
+//             Get the throughput_ue schema
+       query_rep *qr = mcs->get_query_rep("throughput_ue");
+
+//             Extract stuff by various methods
+       int ts_idx = qr->get_index_of_field("TS");
+       int ts_type = qr->get_type(ts_idx);
+       int ts_offset = qr->get_offset(ts_idx);
+       field_handle ts_handle = qr->get_handle(ts_idx);
+
+       string ts_s = get_field_string(ts_handle, buf, t_len);
+       unsigned long long int ts_lu = get_field_ullong(ts_handle, buf, t_len);
+       unsigned int ts_u = get_field_uint(ts_handle, buf, t_len);
+       printf("ts string=%s, ullong=%lld, uint = %d\n",ts_s.c_str(), ts_lu, ts_u);
+
+       field_handle erab_handle = qr->get_handle(1);
+       access_result erab_ar = get_field_by_handle(erab_handle, buf, t_len);
+       printf("erab = %lld\n", erab_ar.r.l);
+
+       access_result ue_ar = get_field_by_index(qr, 2, buf, t_len);
+       printf("ue = %lld\n", ue_ar.r.l);
+
+       int gnb_idx = qr->get_index_of_field("GNB_ID");
+       field_handle gnb_handle = qr->get_handle(gnb_idx);
+       string gnb = get_field_string(gnb_handle, buf, t_len);
+       printf("gnb=%s\n",gnb.c_str());
+
+       access_result mt_ar = get_field_by_index(qr, 8, buf, t_len);
+       printf("mt = %lld, type=%d\n", mt_ar.r.l, mt_ar.field_data_type);
+
+       access_result none_ar = get_field_by_index(qr, 9, buf, t_len);
+       printf("none = %lld, type=%d\n", none_ar.r.l, none_ar.field_data_type);
+
+}