1 | #include <stdio.h>
|
---|
2 | #include <ctype.h>
|
---|
3 | #include <time.h>
|
---|
4 | #include <dim.h>
|
---|
5 | #include <dic.h>
|
---|
6 | #include <dis.h>
|
---|
7 |
|
---|
8 | extern int WebDID_Debug;
|
---|
9 |
|
---|
10 | typedef struct item{
|
---|
11 | struct item *next;
|
---|
12 | DNS_SERVER_INFO server;
|
---|
13 | DNS_SERVICE_INFO *service_ptr;
|
---|
14 | char name[MAX_NAME];
|
---|
15 | int match;
|
---|
16 | int busy;
|
---|
17 | int isSMI;
|
---|
18 | }SERVER;
|
---|
19 |
|
---|
20 | typedef struct nitem{
|
---|
21 | struct nitem *next;
|
---|
22 | SERVER *server_head;
|
---|
23 | char name[MAX_NAME];
|
---|
24 | int match;
|
---|
25 | int busy;
|
---|
26 | int hasSMI;
|
---|
27 | }NODE;
|
---|
28 | NODE *Node_head = (NODE *)0;
|
---|
29 |
|
---|
30 | typedef struct sitem{
|
---|
31 | struct sitem *next;
|
---|
32 | char name[MAX_NAME];
|
---|
33 | int sid;
|
---|
34 | void *buffer;
|
---|
35 | int buffer_size;
|
---|
36 | int size;
|
---|
37 | time_t timestamp;
|
---|
38 | void *buffer_str;
|
---|
39 | int buffer_str_size;
|
---|
40 | int str_size;
|
---|
41 | int conn_id;
|
---|
42 | time_t last_subscribed;
|
---|
43 | time_t last_updated;
|
---|
44 | int n_browsers;
|
---|
45 | }CURR_SERVICE;
|
---|
46 | CURR_SERVICE *Curr_service_head = (CURR_SERVICE *)0;
|
---|
47 |
|
---|
48 | typedef struct bitem{
|
---|
49 | struct bitem *next;
|
---|
50 | int id;
|
---|
51 | int subscribe;
|
---|
52 | time_t last_subscribed;
|
---|
53 | time_t last_updated;
|
---|
54 | time_t last_polled;
|
---|
55 | int conn_id;
|
---|
56 | int n_services;
|
---|
57 | int n_servers;
|
---|
58 | int n_nodes;
|
---|
59 | CURR_SERVICE *servicep;
|
---|
60 | char *JSONBuffer;
|
---|
61 | int JSONBufferSize;
|
---|
62 | char pattern[256];
|
---|
63 | char curr_command[MAX_NAME];
|
---|
64 | char *service_format_ptr;
|
---|
65 | }BROWSER;
|
---|
66 | BROWSER *Browser_head = (BROWSER *)0;
|
---|
67 |
|
---|
68 | char *JSONBuffer = 0;
|
---|
69 | int JSONBufferSize = 0;
|
---|
70 | char JSONHeader[256] = {'\0'};
|
---|
71 |
|
---|
72 | int First_time = 1;
|
---|
73 | int Curr_view_opt = -1;
|
---|
74 | char Curr_view_opt_par[80];
|
---|
75 | char Curr_service_name[132];
|
---|
76 | char Curr_service_format[256];
|
---|
77 | int Curr_service_print_type = 0;
|
---|
78 | int N_nodes = 0;
|
---|
79 | int N_servers = 0;
|
---|
80 | int N_services = 0;
|
---|
81 | static char no_link = -1;
|
---|
82 | int no_link_int = -1;
|
---|
83 | FILE *fptr;
|
---|
84 |
|
---|
85 | char *Service_content_str;
|
---|
86 | char *Curr_service_list = 0;
|
---|
87 | char *Curr_client_list = 0;
|
---|
88 | int Curr_service_id = 0;
|
---|
89 | SERVER *Got_Service_List = 0;
|
---|
90 | SERVER *Got_Client_List = 0;
|
---|
91 |
|
---|
92 | int Timer_q;
|
---|
93 | char Title[128];
|
---|
94 |
|
---|
95 | int did_init(char *local_node, int dns_port)
|
---|
96 | {
|
---|
97 | void update_servers();
|
---|
98 | char icon_title[128];
|
---|
99 | char dns_node[128];
|
---|
100 | int ret;
|
---|
101 |
|
---|
102 | dim_init();
|
---|
103 | dic_disable_padding();
|
---|
104 | dis_disable_padding();
|
---|
105 |
|
---|
106 | ret = dim_get_dns_node(dns_node);
|
---|
107 | if(!ret)
|
---|
108 | {
|
---|
109 | strcpy(dns_node, local_node);
|
---|
110 | dim_set_dns_node(dns_node);
|
---|
111 | }
|
---|
112 | dns_port = dic_get_dns_port();
|
---|
113 | if(dns_port != DNS_PORT)
|
---|
114 | {
|
---|
115 | sprintf(Title,"DIM DNS: %s:%d",dns_node,dns_port);
|
---|
116 | }
|
---|
117 | else
|
---|
118 | {
|
---|
119 | sprintf(Title,"DIM DNS: %s",dns_node);
|
---|
120 | }
|
---|
121 | sprintf(icon_title,"DID %s",dns_node);
|
---|
122 | dim_print_date_time();
|
---|
123 | printf("webDid Starting up on %s\n\t serving %s\n", local_node, Title);
|
---|
124 | Timer_q = dtq_create();
|
---|
125 | dic_info_service("DIS_DNS/SERVER_INFO",MONITORED,0,0,0,update_servers,0,
|
---|
126 | &no_link,1);
|
---|
127 | return 1;
|
---|
128 | }
|
---|
129 |
|
---|
130 | SERVER *find_server(NODE *nodep, int pid)
|
---|
131 | {
|
---|
132 | SERVER *servp;
|
---|
133 | DNS_SERVER_INFO *ptr;
|
---|
134 |
|
---|
135 | servp = nodep->server_head;
|
---|
136 | while( (servp = (SERVER *)sll_get_next((SLL *)servp)) )
|
---|
137 | {
|
---|
138 | ptr = &servp->server;
|
---|
139 | if(ptr->pid == pid)
|
---|
140 | {
|
---|
141 | return(servp);
|
---|
142 | }
|
---|
143 | }
|
---|
144 | return ((SERVER *)0);
|
---|
145 | }
|
---|
146 |
|
---|
147 | NODE *find_node(char *node)
|
---|
148 | {
|
---|
149 | NODE *nodep;
|
---|
150 |
|
---|
151 | nodep = Node_head;
|
---|
152 | while( (nodep = (NODE *)sll_get_next((SLL *)nodep)) )
|
---|
153 | {
|
---|
154 | if(!strcmp(nodep->name,node))
|
---|
155 | {
|
---|
156 | return(nodep);
|
---|
157 | }
|
---|
158 | }
|
---|
159 | return ((NODE *)0);
|
---|
160 | }
|
---|
161 |
|
---|
162 | int find_server_service_pattern(SERVER *servp, char *pattern)
|
---|
163 | {
|
---|
164 | DNS_SERVICE_INFO *servicep;
|
---|
165 | int n_services, i;
|
---|
166 | int n_found = 0;
|
---|
167 |
|
---|
168 | servicep = servp->service_ptr;
|
---|
169 | n_services = servp->server.n_services;
|
---|
170 | for(i = 0; i < n_services; i++)
|
---|
171 | {
|
---|
172 | if(strstr(servicep->name, pattern))
|
---|
173 | {
|
---|
174 | n_found++;
|
---|
175 | }
|
---|
176 | servicep++;
|
---|
177 | }
|
---|
178 | return(n_found);
|
---|
179 | }
|
---|
180 |
|
---|
181 | int find_service_pattern(NODE *nodep, SERVER *servpp, char *pattern, int *n_servers)
|
---|
182 | {
|
---|
183 | SERVER *servp;
|
---|
184 | int ret, n_found = 0;
|
---|
185 | int n_servers_found = 0;
|
---|
186 |
|
---|
187 | if(!servpp)
|
---|
188 | {
|
---|
189 | servp = nodep->server_head;
|
---|
190 | while( (servp = (SERVER *)sll_get_next((SLL *)servp)) )
|
---|
191 | {
|
---|
192 | if((ret = find_server_service_pattern(servp, pattern)))
|
---|
193 | {
|
---|
194 | n_found += ret;
|
---|
195 | n_servers_found++;
|
---|
196 | }
|
---|
197 | }
|
---|
198 | }
|
---|
199 | else
|
---|
200 | {
|
---|
201 | if((ret = find_server_service_pattern(servpp, pattern)))
|
---|
202 | {
|
---|
203 | n_found += ret;
|
---|
204 | }
|
---|
205 | }
|
---|
206 | if(n_servers != 0)
|
---|
207 | *n_servers = n_servers_found;
|
---|
208 | return(n_found);
|
---|
209 | }
|
---|
210 |
|
---|
211 | CURR_SERVICE *find_curr_service(char *service)
|
---|
212 | {
|
---|
213 | CURR_SERVICE *servicep;
|
---|
214 |
|
---|
215 | servicep = Curr_service_head ;
|
---|
216 | while( (servicep = (CURR_SERVICE *)sll_get_next((SLL *)servicep)) )
|
---|
217 | {
|
---|
218 | if(!strcmp(servicep->name,service))
|
---|
219 | {
|
---|
220 | return(servicep);
|
---|
221 | }
|
---|
222 | }
|
---|
223 | return ((CURR_SERVICE *)0);
|
---|
224 | }
|
---|
225 |
|
---|
226 | BROWSER *find_browser(int id)
|
---|
227 | {
|
---|
228 | BROWSER *browserp;
|
---|
229 |
|
---|
230 | browserp = Browser_head;
|
---|
231 | while( (browserp = (BROWSER *)sll_get_next((SLL *)browserp)) )
|
---|
232 | {
|
---|
233 | if(browserp->id == id)
|
---|
234 | {
|
---|
235 | return(browserp);
|
---|
236 | }
|
---|
237 | }
|
---|
238 | return ((BROWSER *)0);
|
---|
239 | }
|
---|
240 | /*
|
---|
241 | void set_browser_changes(int n_services, int n_servers, int n_nodes)
|
---|
242 | {
|
---|
243 | BROWSER *browserp;
|
---|
244 |
|
---|
245 | browserp = Browser_head;
|
---|
246 | while( (browserp = (BROWSER *)sll_get_next((SLL *)browserp)) )
|
---|
247 | {
|
---|
248 | if(browserp->n_services != n_services)
|
---|
249 | browserp->n_services_changed = 1;
|
---|
250 | if(browserp->n_servers != n_servers)
|
---|
251 | browserp->n_servers_changed = 1;
|
---|
252 | if(browserp->n_nodes != n_nodes)
|
---|
253 | browserp->n_nodes_changed = 1;
|
---|
254 | }
|
---|
255 | }
|
---|
256 | */
|
---|
257 | void prepare_browser_tree()
|
---|
258 | {
|
---|
259 | BROWSER *browserp;
|
---|
260 | int prepareJSONTree();
|
---|
261 |
|
---|
262 | browserp = Browser_head;
|
---|
263 | while( (browserp = (BROWSER *)sll_get_next((SLL *)browserp)) )
|
---|
264 | {
|
---|
265 | if(browserp->pattern[0] != '\0')
|
---|
266 | prepareJSONTree(browserp);
|
---|
267 | }
|
---|
268 | }
|
---|
269 | /*
|
---|
270 | void clear_browser_changes(BROWSER *browserp)
|
---|
271 | {
|
---|
272 | browserp->n_services_changed = 0;
|
---|
273 | browserp->n_servers_changed = 0;
|
---|
274 | browserp->n_nodes_changed = 0;
|
---|
275 | }
|
---|
276 | */
|
---|
277 | void update_servers(int *tag, DNS_DID *buffer, int *size)
|
---|
278 | {
|
---|
279 | int n_services, service_size;
|
---|
280 | SERVER *servp;
|
---|
281 | NODE *nodep;
|
---|
282 | int j;
|
---|
283 | char str[MAX_NAME], sname[MAX_NAME], *ptr;
|
---|
284 | int prepareJSONTree();
|
---|
285 | int prepareJSONHeader();
|
---|
286 |
|
---|
287 | if(tag){}
|
---|
288 | if(!Node_head)
|
---|
289 | {
|
---|
290 | Node_head = (NODE *)malloc(sizeof(NODE));
|
---|
291 | sll_init((SLL *)Node_head);
|
---|
292 | }
|
---|
293 | if(First_time)
|
---|
294 | {
|
---|
295 | First_time = 0;
|
---|
296 | }
|
---|
297 |
|
---|
298 | if(!*size)
|
---|
299 | return;
|
---|
300 | if(*(char *)buffer == -1)
|
---|
301 | {
|
---|
302 | N_servers = 0;
|
---|
303 | N_services = 0;
|
---|
304 | return;
|
---|
305 | }
|
---|
306 | buffer->server.n_services = vtohl(buffer->server.n_services);
|
---|
307 | buffer->server.pid = vtohl(buffer->server.pid);
|
---|
308 | n_services = buffer->server.n_services;
|
---|
309 |
|
---|
310 | if(n_services == 1)
|
---|
311 | return;
|
---|
312 | strcpy(sname, buffer->server.task);
|
---|
313 | if(n_services > 1)
|
---|
314 | {
|
---|
315 | for(j = 0; j < n_services; j++)
|
---|
316 | {
|
---|
317 | buffer->services[j].type = vtohl(
|
---|
318 | buffer->services[j].type);
|
---|
319 | buffer->services[j].status = vtohl(
|
---|
320 | buffer->services[j].status);
|
---|
321 | buffer->services[j].n_clients = vtohl(
|
---|
322 | buffer->services[j].n_clients);
|
---|
323 | if((int)strlen(sname) == MAX_TASK_NAME-4-1)
|
---|
324 | {
|
---|
325 | strcpy(str,buffer->services[j].name);
|
---|
326 | if( (ptr = strstr(str,"/CLIENT_LIST")) )
|
---|
327 | {
|
---|
328 | *ptr = '\0';
|
---|
329 | strcpy(sname,str);
|
---|
330 | }
|
---|
331 | }
|
---|
332 | }
|
---|
333 | }
|
---|
334 | if (!(nodep = find_node(buffer->server.node)))
|
---|
335 | {
|
---|
336 | if(n_services)
|
---|
337 | {
|
---|
338 | N_nodes++;
|
---|
339 | nodep = (NODE *)malloc(sizeof(NODE));
|
---|
340 | strcpy(nodep->name,buffer->server.node);
|
---|
341 | nodep->hasSMI = 0;
|
---|
342 | nodep->server_head = (SERVER *)malloc(sizeof(SERVER));
|
---|
343 | sll_init((SLL *)nodep->server_head);
|
---|
344 | sll_insert_queue((SLL *)Node_head,(SLL *)nodep);
|
---|
345 | }
|
---|
346 | }
|
---|
347 | if (!(servp = find_server(nodep,buffer->server.pid)))
|
---|
348 | {
|
---|
349 | if(n_services)
|
---|
350 | {
|
---|
351 | servp = (SERVER *)malloc(sizeof(SERVER));
|
---|
352 | strcpy(servp->name,sname);
|
---|
353 | servp->next = 0;
|
---|
354 | servp->busy = 0;
|
---|
355 | servp->server.n_services = 0;
|
---|
356 | servp->service_ptr = 0;
|
---|
357 | servp->isSMI = 0;
|
---|
358 | if(strstr(sname,"_SMI"))
|
---|
359 | {
|
---|
360 | servp->isSMI = 1;
|
---|
361 | nodep->hasSMI = 1;
|
---|
362 | }
|
---|
363 | sll_insert_queue((SLL *)nodep->server_head,(SLL *)servp);
|
---|
364 | }
|
---|
365 | }
|
---|
366 | if(n_services != 0)
|
---|
367 | {
|
---|
368 | if(n_services == servp->server.n_services)
|
---|
369 | {
|
---|
370 | return;
|
---|
371 | }
|
---|
372 | if(servp->server.n_services == 0)
|
---|
373 | N_servers++;
|
---|
374 | if(servp->server.n_services != -1)
|
---|
375 | N_services -= servp->server.n_services;
|
---|
376 | memcpy(&servp->server,&buffer->server,sizeof(DNS_SERVER_INFO));
|
---|
377 | if(servp->service_ptr)
|
---|
378 | {
|
---|
379 | free(servp->service_ptr);
|
---|
380 | servp->service_ptr = 0;
|
---|
381 | }
|
---|
382 | if(n_services != -1)
|
---|
383 | {
|
---|
384 | service_size = n_services*(int)sizeof(DNS_SERVICE_INFO);
|
---|
385 | servp->service_ptr = (DNS_SERVICE_INFO *)malloc((size_t)service_size);
|
---|
386 | memcpy(servp->service_ptr, buffer->services, (size_t)service_size);
|
---|
387 | N_services += n_services;
|
---|
388 | }
|
---|
389 | servp->busy = 1;
|
---|
390 | }
|
---|
391 | else
|
---|
392 | {
|
---|
393 | if(servp)
|
---|
394 | {
|
---|
395 | N_servers--;
|
---|
396 | if(servp->server.n_services != -1)
|
---|
397 | {
|
---|
398 | N_services -= servp->server.n_services;
|
---|
399 | }
|
---|
400 | servp->server.n_services = 0;
|
---|
401 | servp->busy = -1;
|
---|
402 | servp->isSMI = 0;
|
---|
403 | }
|
---|
404 | }
|
---|
405 | if(JSONHeader[0])
|
---|
406 | prepareJSONHeader();
|
---|
407 | }
|
---|
408 |
|
---|
409 | void got_update_services(BROWSER **tag, char *buffer, int *size)
|
---|
410 | {
|
---|
411 | BROWSER *browserp;
|
---|
412 |
|
---|
413 | if(size){}
|
---|
414 | browserp = (BROWSER *)*tag;
|
---|
415 | if(browserp->service_format_ptr)
|
---|
416 | free(browserp->service_format_ptr);
|
---|
417 | browserp->service_format_ptr = (char *)malloc(strlen(buffer)+1);
|
---|
418 | strcpy(browserp->service_format_ptr, buffer);
|
---|
419 | }
|
---|
420 |
|
---|
421 | char *update_services(char *node, char *server, int pid, int browser)
|
---|
422 | {
|
---|
423 | char str[MAX_NAME];
|
---|
424 | NODE *nodep;
|
---|
425 | SERVER *servp;
|
---|
426 | char *ptr;
|
---|
427 | BROWSER *browserp;
|
---|
428 | char *prepareJSONServiceList();
|
---|
429 | BROWSER *create_browser();
|
---|
430 |
|
---|
431 | if(!(browserp = find_browser(browser)))
|
---|
432 | browserp = create_browser(browser);
|
---|
433 |
|
---|
434 | if(server){}
|
---|
435 | sprintf(str,"%s/SERVICE_LIST",server);
|
---|
436 | dic_info_service(str,ONCE_ONLY,20,0,0,
|
---|
437 | got_update_services,(dim_long)browserp,"None",5);
|
---|
438 | if((nodep = find_node(node)))
|
---|
439 | {
|
---|
440 | if((servp = find_server(nodep, pid)))
|
---|
441 | {
|
---|
442 | ptr = prepareJSONServiceList(servp, node, pid, browserp);
|
---|
443 | }
|
---|
444 | }
|
---|
445 | return ptr;
|
---|
446 | }
|
---|
447 |
|
---|
448 | void get_curr_service_format()
|
---|
449 | {
|
---|
450 | char *format;
|
---|
451 | char *dic_get_format();
|
---|
452 | /*
|
---|
453 | char str[256], *ptr, *ptr1;
|
---|
454 | int rpc_flag;
|
---|
455 |
|
---|
456 | strcpy(str,Curr_service_name);
|
---|
457 | rpc_flag = 0;
|
---|
458 | if( (ptr = strstr(str,"/RpcIn")) )
|
---|
459 | {
|
---|
460 | *ptr = '\0';
|
---|
461 | rpc_flag = 1;
|
---|
462 | }
|
---|
463 | if( (ptr = strstr(str,"/RpcOut")) )
|
---|
464 | {
|
---|
465 | *ptr = '\0';
|
---|
466 | rpc_flag = 2;
|
---|
467 | }
|
---|
468 | strcat(str,"|");
|
---|
469 | */
|
---|
470 | format = dic_get_format(0);
|
---|
471 | /*
|
---|
472 | if( (ptr = strstr(Curr_service_list,str)) )
|
---|
473 | {
|
---|
474 | if(!rpc_flag)
|
---|
475 | {
|
---|
476 | ptr += (int)strlen(str);
|
---|
477 | ptr1 = strchr(ptr,'|');
|
---|
478 | }
|
---|
479 | else if(rpc_flag == 1)
|
---|
480 | {
|
---|
481 | ptr += (int)strlen(str);
|
---|
482 | ptr1 = strchr(ptr,',');
|
---|
483 | }
|
---|
484 | else
|
---|
485 | {
|
---|
486 | ptr += (int)strlen(str);
|
---|
487 | ptr = strchr(ptr,',');
|
---|
488 | ptr++;
|
---|
489 | ptr1 = strchr(ptr,'|');
|
---|
490 | }
|
---|
491 | strncpy(Curr_service_format,ptr,(int)(ptr1 - ptr));
|
---|
492 | Curr_service_format[(int)(ptr1-ptr)] = '\0';
|
---|
493 | }
|
---|
494 | */
|
---|
495 | if(format)
|
---|
496 | strcpy(Curr_service_format,format);
|
---|
497 | else
|
---|
498 | Curr_service_format[0] = '\0';
|
---|
499 | }
|
---|
500 |
|
---|
501 | void get_service_format(char *buffer, char *service, char *format)
|
---|
502 | {
|
---|
503 | char str[256], *ptr, *ptr1;
|
---|
504 | int rpc_flag;
|
---|
505 |
|
---|
506 | strcpy(str, service);
|
---|
507 | rpc_flag = 0;
|
---|
508 | *format = '\0';
|
---|
509 | if( (ptr = strstr(str,"/RpcIn")) )
|
---|
510 | {
|
---|
511 | *ptr = '\0';
|
---|
512 | rpc_flag = 1;
|
---|
513 | }
|
---|
514 | if( (ptr = strstr(str,"/RpcOut")) )
|
---|
515 | {
|
---|
516 | *ptr = '\0';
|
---|
517 | rpc_flag = 2;
|
---|
518 | }
|
---|
519 | strcat(str,"|");
|
---|
520 | if( (ptr = strstr(buffer, str)) )
|
---|
521 | {
|
---|
522 | if(!rpc_flag)
|
---|
523 | {
|
---|
524 | ptr += (int)strlen(str);
|
---|
525 | ptr1 = strchr(ptr,'|');
|
---|
526 | }
|
---|
527 | else if(rpc_flag == 1)
|
---|
528 | {
|
---|
529 | ptr += (int)strlen(str);
|
---|
530 | ptr1 = strchr(ptr,',');
|
---|
531 | }
|
---|
532 | else
|
---|
533 | {
|
---|
534 | ptr += (int)strlen(str);
|
---|
535 | ptr = strchr(ptr,',');
|
---|
536 | ptr++;
|
---|
537 | ptr1 = strchr(ptr,'|');
|
---|
538 | }
|
---|
539 | strncpy(format,ptr,(size_t)(ptr1 - ptr));
|
---|
540 | format[(int)(ptr1-ptr)] = '\0';
|
---|
541 | }
|
---|
542 | }
|
---|
543 |
|
---|
544 | int delete_curr_service(CURR_SERVICE *servicep)
|
---|
545 | {
|
---|
546 |
|
---|
547 | if(WebDID_Debug)
|
---|
548 | printf("\nUnsubscribing %s\n\n",servicep->name);
|
---|
549 | dic_release_service(servicep->sid);
|
---|
550 | if(servicep->buffer_size)
|
---|
551 | free(servicep->buffer);
|
---|
552 | if(servicep->buffer_str_size)
|
---|
553 | free(servicep->buffer_str);
|
---|
554 | sll_remove((SLL *)Curr_service_head, (SLL *)servicep);
|
---|
555 | free(servicep);
|
---|
556 | return(1);
|
---|
557 | }
|
---|
558 |
|
---|
559 | int delete_browser(BROWSER *browserp)
|
---|
560 | {
|
---|
561 | CURR_SERVICE *servicep;
|
---|
562 |
|
---|
563 | if((servicep = browserp->servicep))
|
---|
564 | {
|
---|
565 | servicep->n_browsers--;
|
---|
566 | if(!servicep->n_browsers)
|
---|
567 | delete_curr_service(servicep);
|
---|
568 | }
|
---|
569 | if(browserp->service_format_ptr)
|
---|
570 | free(browserp->service_format_ptr);
|
---|
571 | sll_remove((SLL *)Browser_head, (SLL *)browserp);
|
---|
572 | free(browserp);
|
---|
573 | return(1);
|
---|
574 | }
|
---|
575 |
|
---|
576 | void check_browser( BROWSER *tag)
|
---|
577 | {
|
---|
578 | BROWSER *browserp;
|
---|
579 | time_t tsecs;
|
---|
580 |
|
---|
581 | browserp = (BROWSER *)tag;
|
---|
582 | if(WebDID_Debug)
|
---|
583 | printf("\nCheck_browser %d\n",browserp->id);
|
---|
584 | tsecs = time((time_t *)0);
|
---|
585 | if((tsecs - browserp->last_polled) > 20)
|
---|
586 | {
|
---|
587 | if(WebDID_Debug)
|
---|
588 | printf("\nDeleting browser %d\n\n",browserp->id);
|
---|
589 | delete_browser(browserp);
|
---|
590 | }
|
---|
591 | else
|
---|
592 | dtq_start_timer(10, check_browser, browserp);
|
---|
593 | }
|
---|
594 |
|
---|
595 | BROWSER *create_browser(int id)
|
---|
596 | {
|
---|
597 | BROWSER *browserp;
|
---|
598 |
|
---|
599 | if(!Browser_head)
|
---|
600 | {
|
---|
601 | Browser_head = (BROWSER *)malloc(sizeof(BROWSER));
|
---|
602 | sll_init((SLL *)Browser_head);
|
---|
603 | }
|
---|
604 | browserp = (BROWSER *)malloc(sizeof(BROWSER));
|
---|
605 | browserp->id = id;
|
---|
606 | browserp->last_subscribed = 0;
|
---|
607 | browserp->last_updated = 0;
|
---|
608 | browserp->last_polled = 0;
|
---|
609 | browserp->n_nodes = 0;
|
---|
610 | browserp->n_servers = 0;
|
---|
611 | browserp->n_services = 0;
|
---|
612 | browserp->servicep = 0;
|
---|
613 | browserp->JSONBuffer = 0;
|
---|
614 | browserp->JSONBufferSize = 0;
|
---|
615 | browserp->pattern[0] = '\0';
|
---|
616 | browserp->service_format_ptr = 0;
|
---|
617 | browserp->curr_command[0] = '\0';
|
---|
618 | sll_insert_queue((SLL *)Browser_head,(SLL *)browserp);
|
---|
619 | dtq_start_timer(10, check_browser, browserp);
|
---|
620 | return browserp;
|
---|
621 | }
|
---|
622 |
|
---|
623 | int update_command_data(char *service, int conn_id, BROWSER *browserp)
|
---|
624 | {
|
---|
625 | char format[MAX_NAME];
|
---|
626 | char answer[MAX_NAME*3];
|
---|
627 | extern void sendData();
|
---|
628 |
|
---|
629 | if(browserp->service_format_ptr)
|
---|
630 | {
|
---|
631 | get_service_format(browserp->service_format_ptr, service, format);
|
---|
632 | if(WebDID_Debug)
|
---|
633 | printf("CMD data %s %s\n",service,format);
|
---|
634 | }
|
---|
635 | else
|
---|
636 | {
|
---|
637 | strcpy(format,"?");
|
---|
638 | }
|
---|
639 | strcpy(browserp->curr_command, service);
|
---|
640 | sprintf(answer,"To %s (%s)",service, format);
|
---|
641 | sendData(conn_id, answer, 4);
|
---|
642 | return 1;
|
---|
643 | }
|
---|
644 |
|
---|
645 | int update_service_data(char *service, int conn_id, int subscribe, int req, int browser, int force)
|
---|
646 | {
|
---|
647 | CURR_SERVICE *servicep;
|
---|
648 | time_t tsecs;
|
---|
649 | void recv_service_info();
|
---|
650 | extern void sendData();
|
---|
651 | BROWSER *browserp;
|
---|
652 |
|
---|
653 | if(req){}
|
---|
654 | if(!Curr_service_head)
|
---|
655 | {
|
---|
656 | Curr_service_head = (CURR_SERVICE *)malloc(sizeof(CURR_SERVICE));
|
---|
657 | sll_init((SLL *)Curr_service_head);
|
---|
658 | }
|
---|
659 | if(!(browserp = find_browser(browser)))
|
---|
660 | browserp = create_browser(browser);
|
---|
661 | if(force == -1)
|
---|
662 | {
|
---|
663 | update_command_data(service, conn_id, browserp);
|
---|
664 | return 1;
|
---|
665 | }
|
---|
666 | if((servicep = browserp->servicep))
|
---|
667 | {
|
---|
668 | servicep->n_browsers--;
|
---|
669 | if(!servicep->n_browsers)
|
---|
670 | delete_curr_service(servicep);
|
---|
671 | }
|
---|
672 | if(!(servicep = find_curr_service(service)))
|
---|
673 | {
|
---|
674 | servicep = (CURR_SERVICE *)malloc(sizeof(CURR_SERVICE));
|
---|
675 | strcpy(servicep->name,service);
|
---|
676 | servicep->conn_id = conn_id;
|
---|
677 | servicep->buffer = 0;
|
---|
678 | servicep->buffer_size = 0;
|
---|
679 | servicep->size = 0;
|
---|
680 | servicep->buffer_str = 0;
|
---|
681 | servicep->buffer_str_size = 0;
|
---|
682 | servicep->str_size = 0;
|
---|
683 | servicep->last_updated = 0;
|
---|
684 | tsecs = time((time_t *)0);
|
---|
685 | browserp->last_subscribed = tsecs;
|
---|
686 | browserp->last_updated = tsecs;
|
---|
687 | servicep->last_subscribed = tsecs;
|
---|
688 | servicep->n_browsers = 0;
|
---|
689 | sll_insert_queue((SLL *)Curr_service_head,(SLL *)servicep);
|
---|
690 | servicep->sid = (int)dic_info_service_stamped( service, MONITORED, subscribe, 0, 0,
|
---|
691 | recv_service_info, servicep, &no_link_int, 4);
|
---|
692 | }
|
---|
693 | else
|
---|
694 | {
|
---|
695 | if(servicep->size)
|
---|
696 | {
|
---|
697 | if((servicep->timestamp > browserp->last_updated) || (force))
|
---|
698 | {
|
---|
699 | sendData(conn_id, servicep->buffer_str, 4);
|
---|
700 | }
|
---|
701 | else
|
---|
702 | {
|
---|
703 | sendData(conn_id, "", 4);
|
---|
704 | }
|
---|
705 | browserp->last_updated = servicep->timestamp;
|
---|
706 | }
|
---|
707 | }
|
---|
708 | if(force)
|
---|
709 | {
|
---|
710 | browserp->servicep = servicep;
|
---|
711 | servicep->n_browsers++;
|
---|
712 | }
|
---|
713 | return 1;
|
---|
714 | }
|
---|
715 |
|
---|
716 | int check_browser_changes(char *service, int conn_id, int subscribe, int req, int browser, int force)
|
---|
717 | {
|
---|
718 | CURR_SERVICE *servicep;
|
---|
719 | time_t tsecs;
|
---|
720 | void recv_service_info();
|
---|
721 | extern void sendData();
|
---|
722 | BROWSER *browserp;
|
---|
723 | char answer[256];
|
---|
724 | int service_changed = 0;
|
---|
725 |
|
---|
726 | if(req){}
|
---|
727 | if(subscribe){}
|
---|
728 | if(!(browserp = find_browser(browser)))
|
---|
729 | browserp = create_browser(browser);
|
---|
730 | if(!Curr_service_head)
|
---|
731 | {
|
---|
732 | Curr_service_head = (CURR_SERVICE *)malloc(sizeof(CURR_SERVICE));
|
---|
733 | sll_init((SLL *)Curr_service_head);
|
---|
734 | }
|
---|
735 | if(service[0] != '\0')
|
---|
736 | {
|
---|
737 | if((servicep = find_curr_service(service)))
|
---|
738 | {
|
---|
739 | if(servicep->size)
|
---|
740 | {
|
---|
741 | if((servicep->timestamp > browserp->last_updated) || (force))
|
---|
742 | {
|
---|
743 | service_changed = 1;
|
---|
744 | }
|
---|
745 | }
|
---|
746 | }
|
---|
747 | }
|
---|
748 | /*
|
---|
749 | sprintf(answer,"%d %d %d %d\n",
|
---|
750 | browserp->n_services_changed, browserp->n_servers_changed,
|
---|
751 | browserp->n_nodes_changed, service_changed);
|
---|
752 | */
|
---|
753 | sprintf(answer,"%d %d %d %d %d %d %d\n",
|
---|
754 | N_services, N_servers, N_nodes, service_changed,
|
---|
755 | browserp->n_services, browserp->n_servers, browserp->n_nodes);
|
---|
756 | sendData(conn_id, answer, 4);
|
---|
757 | tsecs = time((time_t *)0);
|
---|
758 | browserp->last_polled = tsecs;
|
---|
759 | return 1;
|
---|
760 | }
|
---|
761 |
|
---|
762 | int find_services(char *pattern, int conn_id, int browser, int force)
|
---|
763 | {
|
---|
764 | void recv_service_info();
|
---|
765 | extern void sendData();
|
---|
766 | BROWSER *browserp;
|
---|
767 | char format[MAX_NAME];
|
---|
768 | int prepareJSONTree();
|
---|
769 | void did_prepare_command();
|
---|
770 |
|
---|
771 | if(conn_id){}
|
---|
772 | if(!(browserp = find_browser(browser)))
|
---|
773 | browserp = create_browser(browser);
|
---|
774 | if(force == -1)
|
---|
775 | {
|
---|
776 | if(browserp->service_format_ptr)
|
---|
777 | {
|
---|
778 | get_service_format(browserp->service_format_ptr, browserp->curr_command, format);
|
---|
779 | did_prepare_command(pattern, browserp->curr_command, format);
|
---|
780 | }
|
---|
781 | return 1;
|
---|
782 | }
|
---|
783 | if(conn_id){}
|
---|
784 | if(!(browserp = find_browser(browser)))
|
---|
785 | browserp = create_browser(browser);
|
---|
786 | strcpy(browserp->pattern, pattern);
|
---|
787 | return 1;
|
---|
788 | }
|
---|
789 |
|
---|
790 | void recv_service_info(void **tag, int *buffer, int *size)
|
---|
791 | {
|
---|
792 | int conn_id;
|
---|
793 | void print_service_formatted();
|
---|
794 | extern void sendData();
|
---|
795 | CURR_SERVICE *servicep;
|
---|
796 | time_t tsecs;
|
---|
797 |
|
---|
798 | servicep = *tag;
|
---|
799 | conn_id = servicep->conn_id;
|
---|
800 | if (servicep->buffer_size < *size)
|
---|
801 | {
|
---|
802 | if(servicep->buffer_size)
|
---|
803 | free(servicep->buffer);
|
---|
804 | servicep->buffer = malloc((size_t)*size);
|
---|
805 | servicep->buffer_size = *size;
|
---|
806 | }
|
---|
807 | memcpy(servicep->buffer, (char *)buffer, (size_t)*size);
|
---|
808 | servicep->size = *size;
|
---|
809 | if (servicep->buffer_str_size < (1024 + (*size)*16))
|
---|
810 | {
|
---|
811 | if(servicep->buffer_str_size)
|
---|
812 | free(servicep->buffer_str);
|
---|
813 | servicep->buffer_str = malloc((size_t)(1024 + (*size)*16));
|
---|
814 | servicep->buffer_str_size = 1024 + (*size)*16;
|
---|
815 | }
|
---|
816 | Service_content_str = servicep->buffer_str;
|
---|
817 | strcpy(Curr_service_name, servicep->name);
|
---|
818 | get_curr_service_format();
|
---|
819 | if((*size == 4 ) && (*buffer == -1))
|
---|
820 | {
|
---|
821 | sprintf(Service_content_str,
|
---|
822 | "Service %s Not Available", Curr_service_name);
|
---|
823 | }
|
---|
824 | else
|
---|
825 | {
|
---|
826 | print_service_formatted(servicep, buffer, *size);
|
---|
827 | }
|
---|
828 | if(servicep->last_updated == 0)
|
---|
829 | {
|
---|
830 | sendData(conn_id, Service_content_str, 4);
|
---|
831 | tsecs = time((time_t *)0);
|
---|
832 | servicep->last_updated = tsecs;
|
---|
833 | }
|
---|
834 | }
|
---|
835 |
|
---|
836 | void print_service_formatted(CURR_SERVICE *servicep, void *buff, int size)
|
---|
837 | {
|
---|
838 | char type;
|
---|
839 | int num, ret;
|
---|
840 | char str[256];
|
---|
841 | char *ptr;
|
---|
842 | void *buffer_ptr;
|
---|
843 | char timestr[256], aux[64], sizestr[64];
|
---|
844 | int quality = 0, secs = 0, mili = 0;
|
---|
845 | int did_write_string(char, int, void **, int);
|
---|
846 | time_t tsecs;
|
---|
847 |
|
---|
848 | if(size < 1024)
|
---|
849 | sprintf(sizestr,"%d bytes",size);
|
---|
850 | else if (size < 1024*1024)
|
---|
851 | sprintf(sizestr,"%2.2f Kb",(float)size/1024);
|
---|
852 | else
|
---|
853 | sprintf(sizestr,"%2.2f Mb",(float)size/(1024*1024));
|
---|
854 |
|
---|
855 | sprintf(Service_content_str,
|
---|
856 | "<FONT FACE=\"consolas\">Service %s (%s) Contents :<br /> <br />", Curr_service_name,
|
---|
857 | Curr_service_format);
|
---|
858 | dic_get_timestamp(0, &secs, &mili);
|
---|
859 | quality = dic_get_quality(0);
|
---|
860 | tsecs = secs;
|
---|
861 | servicep->timestamp = tsecs;
|
---|
862 | my_ctime(&tsecs, timestr, 128);
|
---|
863 | ptr = strrchr(timestr,' ');
|
---|
864 | strcpy(aux, ptr);
|
---|
865 | sprintf(ptr,".%03d",mili);
|
---|
866 | strcat(timestr, aux);
|
---|
867 | timestr[(int)strlen(timestr)-1] = '\0';
|
---|
868 |
|
---|
869 | sprintf(str," Timestamp: %s         Quality: %d    Size: %s<br /><br />",
|
---|
870 | timestr, quality, sizestr);
|
---|
871 |
|
---|
872 | strcat(Service_content_str,str);
|
---|
873 | ptr = Curr_service_format;
|
---|
874 | buffer_ptr = buff;
|
---|
875 | while(*ptr)
|
---|
876 | {
|
---|
877 | type = *ptr++;
|
---|
878 | if(*ptr == ':')
|
---|
879 | {
|
---|
880 | ptr++;
|
---|
881 | sscanf(ptr, "%d", &num);
|
---|
882 | ret = did_write_string(type, num, &buffer_ptr, size);
|
---|
883 | size -= ret;
|
---|
884 | if( (ptr = strchr(ptr,';')) )
|
---|
885 | ptr++;
|
---|
886 | else
|
---|
887 | break;
|
---|
888 | }
|
---|
889 | else
|
---|
890 | {
|
---|
891 | ret = did_write_string(type, 0, &buffer_ptr, size);
|
---|
892 | size -= ret;
|
---|
893 | break;
|
---|
894 | }
|
---|
895 | }
|
---|
896 | strcat(Service_content_str,"</FONT>");
|
---|
897 | }
|
---|
898 |
|
---|
899 |
|
---|
900 | int did_write_string(char type, int num, void **buffer_ptr, int ssize)
|
---|
901 | {
|
---|
902 | void *ptr;
|
---|
903 | int size, psize;
|
---|
904 |
|
---|
905 | void print_service_standard();
|
---|
906 | void print_service_char();
|
---|
907 | void print_service_short();
|
---|
908 | void print_service_float();
|
---|
909 | void print_service_double();
|
---|
910 |
|
---|
911 | ptr = *buffer_ptr;
|
---|
912 | switch(type)
|
---|
913 | {
|
---|
914 | case 'L':
|
---|
915 | case 'l':
|
---|
916 | strcat(Service_content_str," L");
|
---|
917 | if(!num)
|
---|
918 | size = ssize/(int)sizeof(int);
|
---|
919 | else
|
---|
920 | size = num;
|
---|
921 | psize = size * (int)sizeof(int);
|
---|
922 | print_service_standard(ptr, size);
|
---|
923 | break;
|
---|
924 | case 'I':
|
---|
925 | case 'i':
|
---|
926 | strcat(Service_content_str," I");
|
---|
927 | if(!num)
|
---|
928 | size = ssize/(int)sizeof(int);
|
---|
929 | else
|
---|
930 | size = num;
|
---|
931 | psize = size * (int)sizeof(int);
|
---|
932 | print_service_standard(ptr, size);
|
---|
933 | break;
|
---|
934 | case 'S':
|
---|
935 | case 's':
|
---|
936 | strcat(Service_content_str," S");
|
---|
937 | if(!num)
|
---|
938 | size = ssize/(int)sizeof(short);
|
---|
939 | else
|
---|
940 | size = num;
|
---|
941 | psize = size * (int)sizeof(short);
|
---|
942 | print_service_short(ptr, size);
|
---|
943 | break;
|
---|
944 | case 'F':
|
---|
945 | case 'f':
|
---|
946 | strcat(Service_content_str," F");
|
---|
947 | if(!num)
|
---|
948 | size = ssize/(int)sizeof(float);
|
---|
949 | else
|
---|
950 | size = num;
|
---|
951 | psize = size * (int)sizeof(float);
|
---|
952 | print_service_float(ptr, size);
|
---|
953 | break;
|
---|
954 | case 'D':
|
---|
955 | case 'd':
|
---|
956 | strcat(Service_content_str," D");
|
---|
957 | if(!num)
|
---|
958 | size = ssize/(int)sizeof(double);
|
---|
959 | else
|
---|
960 | size = num;
|
---|
961 | psize = size * (int)sizeof(double);
|
---|
962 | print_service_double(ptr, size);
|
---|
963 | break;
|
---|
964 | case 'X':
|
---|
965 | case 'x':
|
---|
966 | strcat(Service_content_str," X");
|
---|
967 | if(!num)
|
---|
968 | size = ssize/(int)sizeof(longlong);
|
---|
969 | else
|
---|
970 | size = num;
|
---|
971 | psize = size * (int)sizeof(longlong);
|
---|
972 | print_service_standard(ptr, size*2);
|
---|
973 | break;
|
---|
974 | case 'C':
|
---|
975 | case 'c':
|
---|
976 | default:
|
---|
977 | strcat(Service_content_str," C");
|
---|
978 | if(!num)
|
---|
979 | size = ssize;
|
---|
980 | else
|
---|
981 | size = num;
|
---|
982 | psize = size;
|
---|
983 | print_service_char(ptr, size);
|
---|
984 | }
|
---|
985 | ptr = (char *)ptr + psize;
|
---|
986 | *buffer_ptr = ptr;
|
---|
987 | return psize;
|
---|
988 | }
|
---|
989 |
|
---|
990 | void sprintf_html(char *str, int n, int value)
|
---|
991 | {
|
---|
992 | char tmp[80];
|
---|
993 | int min, i;
|
---|
994 |
|
---|
995 | str[0] = '\0';
|
---|
996 | min = sprintf(tmp,"%d",value);
|
---|
997 | for(i = 0; i < (n-min); i++)
|
---|
998 | {
|
---|
999 | strcat(str," ");
|
---|
1000 | }
|
---|
1001 | strcat(str, tmp);
|
---|
1002 | }
|
---|
1003 |
|
---|
1004 | void print_service_standard(int *buff, int size)
|
---|
1005 | {
|
---|
1006 | int i,j;
|
---|
1007 | char *ptr, str[80], tmp[256];
|
---|
1008 | int last[4];
|
---|
1009 |
|
---|
1010 | ptr = Service_content_str;
|
---|
1011 | ptr += (int)strlen(Service_content_str);
|
---|
1012 | for( i = 0; i < size; i++)
|
---|
1013 | {
|
---|
1014 | strcpy(tmp,"");
|
---|
1015 | if(i%4 == 0)
|
---|
1016 | {
|
---|
1017 | if(i != 0)
|
---|
1018 | {
|
---|
1019 | strcat(tmp," ");
|
---|
1020 | }
|
---|
1021 | sprintf_html(str, 7, i);
|
---|
1022 | strcat(tmp,str);
|
---|
1023 | }
|
---|
1024 | if(!(i%4))
|
---|
1025 | strcat(tmp,"H: ");
|
---|
1026 | sprintf(str,"    %08X",buff[i]);
|
---|
1027 | strcat(tmp,str);
|
---|
1028 | last[i%4] = buff[i];
|
---|
1029 | if((i%4 == 3) || (i == (size-1)))
|
---|
1030 | {
|
---|
1031 | strcat(tmp,"<br />");
|
---|
1032 | for(j = 0; j <= (i%4); j++)
|
---|
1033 | {
|
---|
1034 | if(j == 0)
|
---|
1035 | strcat(tmp,"        D: ");
|
---|
1036 | sprintf_html(str, 12, last[j]);
|
---|
1037 | strcat(tmp,str);
|
---|
1038 | }
|
---|
1039 | strcat(tmp,"<br />");
|
---|
1040 | }
|
---|
1041 | strcpy(ptr, tmp);
|
---|
1042 | ptr += (int)strlen(tmp);
|
---|
1043 | }
|
---|
1044 | strcpy(tmp,"<br />");
|
---|
1045 | strcpy(ptr, tmp);
|
---|
1046 | }
|
---|
1047 |
|
---|
1048 | void print_service_longlong(longlong *buff, int size)
|
---|
1049 | {
|
---|
1050 | int i,j;
|
---|
1051 | char *ptr, str[80], tmp[256];
|
---|
1052 | longlong last[4];
|
---|
1053 |
|
---|
1054 | ptr = Service_content_str;
|
---|
1055 | ptr += (int)strlen(Service_content_str);
|
---|
1056 | for( i = 0; i < size; i++)
|
---|
1057 | {
|
---|
1058 | strcpy(tmp,"");
|
---|
1059 | if(i%4 == 0)
|
---|
1060 | {
|
---|
1061 | if(i != 0)
|
---|
1062 | {
|
---|
1063 | strcat(tmp," ");
|
---|
1064 | }
|
---|
1065 | sprintf_html(str, 7, i);
|
---|
1066 | strcat(tmp,str);
|
---|
1067 | }
|
---|
1068 | if(!(i%4))
|
---|
1069 | strcat(tmp,"H: ");
|
---|
1070 | sprintf(str,"    %08X",(unsigned)buff[i]);
|
---|
1071 | strcat(tmp,str);
|
---|
1072 | last[i%4] = buff[i];
|
---|
1073 | if((i%4 == 3) || (i == (size-1)))
|
---|
1074 | {
|
---|
1075 | strcat(tmp,"<br />");
|
---|
1076 | for(j = 0; j <= (i%4); j++)
|
---|
1077 | {
|
---|
1078 | if(j == 0)
|
---|
1079 | strcat(tmp,"        D: ");
|
---|
1080 | sprintf_html(str, 12, (int)last[j]);
|
---|
1081 | strcat(tmp,str);
|
---|
1082 | }
|
---|
1083 | strcat(tmp,"<br />");
|
---|
1084 | }
|
---|
1085 | strcpy(ptr, tmp);
|
---|
1086 | ptr += (int)strlen(tmp);
|
---|
1087 | }
|
---|
1088 | strcpy(tmp,"<br />");
|
---|
1089 | strcpy(ptr, tmp);
|
---|
1090 | }
|
---|
1091 |
|
---|
1092 | void print_service_short(short *buff, int size)
|
---|
1093 | {
|
---|
1094 | int i,j;
|
---|
1095 | char *ptr, str[80], tmp[256];
|
---|
1096 | short last[8];
|
---|
1097 |
|
---|
1098 | ptr = Service_content_str;
|
---|
1099 | ptr += (int)strlen(Service_content_str);
|
---|
1100 | for( i = 0; i < size; i++)
|
---|
1101 | {
|
---|
1102 | strcpy(tmp,"");
|
---|
1103 | if(i%8 == 0)
|
---|
1104 | {
|
---|
1105 | if(i != 0)
|
---|
1106 | {
|
---|
1107 | strcat(tmp," ");
|
---|
1108 | }
|
---|
1109 | sprintf_html(str, 7, i);
|
---|
1110 | strcat(tmp,str);
|
---|
1111 | }
|
---|
1112 | if(!(i%8))
|
---|
1113 | strcat(tmp,"H: ");
|
---|
1114 | sprintf(str,"  %04X",buff[i]);
|
---|
1115 | strcat(tmp,str);
|
---|
1116 | last[i%8] = buff[i];
|
---|
1117 | if((i%8 == 7) || (i == (size-1)))
|
---|
1118 | {
|
---|
1119 | strcat(tmp,"<br />");
|
---|
1120 | for(j = 0; j <= (i%8); j++)
|
---|
1121 | {
|
---|
1122 | if(j == 0)
|
---|
1123 | strcat(tmp,"        D: ");
|
---|
1124 | sprintf_html(str, 6, last[j]);
|
---|
1125 | strcat(tmp,str);
|
---|
1126 | }
|
---|
1127 | strcat(tmp,"<br />");
|
---|
1128 | }
|
---|
1129 | strcpy(ptr, tmp);
|
---|
1130 | ptr += (int)strlen(tmp);
|
---|
1131 | }
|
---|
1132 | strcpy(tmp,"<br />");
|
---|
1133 | strcpy(ptr, tmp);
|
---|
1134 | }
|
---|
1135 |
|
---|
1136 | void print_service_char(char *buff, int size)
|
---|
1137 | {
|
---|
1138 | int i,j;
|
---|
1139 | char *asc, *ptr, str[80], tmp[256];
|
---|
1140 |
|
---|
1141 | asc = (char *)buff;
|
---|
1142 | ptr = Service_content_str;
|
---|
1143 | ptr += (int)strlen(Service_content_str);
|
---|
1144 | for( i = 0; i < size; i++)
|
---|
1145 | {
|
---|
1146 | strcpy(tmp,"");
|
---|
1147 | if(i%16 == 0)
|
---|
1148 | {
|
---|
1149 | if(i != 0)
|
---|
1150 | {
|
---|
1151 | strcat(tmp," ");
|
---|
1152 | }
|
---|
1153 | sprintf_html(str, 7, i);
|
---|
1154 | strcat(tmp,str);
|
---|
1155 | }
|
---|
1156 | if(!(i%16))
|
---|
1157 | strcat(tmp,"H: ");
|
---|
1158 | sprintf(str,"%02X",buff[i]);
|
---|
1159 | /* strcat(tmp,str);
|
---|
1160 | */
|
---|
1161 | strcat(tmp," ");
|
---|
1162 | strcat(tmp,&str[(int)strlen(str)-2]);
|
---|
1163 | /*
|
---|
1164 | if(i%4 == 3)
|
---|
1165 | strcat(tmp," ");
|
---|
1166 | */
|
---|
1167 | if((i%16 == 15) || (i == (size-1)))
|
---|
1168 | {
|
---|
1169 | if(i%16 != 15)
|
---|
1170 | {
|
---|
1171 | for(j = 1; j < 16 - (i%16); j++)
|
---|
1172 | strcat(tmp,"   ");
|
---|
1173 | }
|
---|
1174 | strcat(tmp,"    '");
|
---|
1175 | for(j = 0; j <= (i%16) ; j++)
|
---|
1176 | {
|
---|
1177 | if(isprint(asc[j]))
|
---|
1178 | {
|
---|
1179 | sprintf(str,"%c",asc[j]);
|
---|
1180 | strcat(tmp,str);
|
---|
1181 | }
|
---|
1182 | else
|
---|
1183 | {
|
---|
1184 | sprintf(str,".");
|
---|
1185 | strcat(tmp,str);
|
---|
1186 | }
|
---|
1187 | }
|
---|
1188 | strcat(tmp,"'<br />");
|
---|
1189 | asc = (char *)&buff[i+1];
|
---|
1190 | }
|
---|
1191 | strcpy(ptr, tmp);
|
---|
1192 | ptr += (int)strlen(tmp);
|
---|
1193 | }
|
---|
1194 | strcpy(tmp,"<br />");
|
---|
1195 | strcpy(ptr, tmp);
|
---|
1196 | }
|
---|
1197 |
|
---|
1198 | void print_service_float(float *buff, int size)
|
---|
1199 | {
|
---|
1200 | int i;
|
---|
1201 | char *ptr, str[80], tmp[256];
|
---|
1202 |
|
---|
1203 | ptr = Service_content_str;
|
---|
1204 | ptr += (int)strlen(Service_content_str);
|
---|
1205 | for( i = 0; i < size; i++)
|
---|
1206 | {
|
---|
1207 | strcpy(tmp,"");
|
---|
1208 | if(i%4 == 0)
|
---|
1209 | {
|
---|
1210 | if(i != 0)
|
---|
1211 | {
|
---|
1212 | strcat(tmp," ");
|
---|
1213 | }
|
---|
1214 | sprintf_html(str, 7, i);
|
---|
1215 | strcat(tmp,str);
|
---|
1216 | }
|
---|
1217 | sprintf(str,"%12.3G",*(buff++));
|
---|
1218 | strcat(tmp,str);
|
---|
1219 | if((i%4 == 3) || (i == size-1))
|
---|
1220 | {
|
---|
1221 | strcat(tmp,"<br />");
|
---|
1222 | }
|
---|
1223 | strcpy(ptr, tmp);
|
---|
1224 | ptr += (int)strlen(tmp);
|
---|
1225 | }
|
---|
1226 | strcpy(tmp,"<br />");
|
---|
1227 | strcpy(ptr, tmp);
|
---|
1228 | ptr += (int)strlen(tmp);
|
---|
1229 | }
|
---|
1230 |
|
---|
1231 | void print_service_double(double *buff, int size)
|
---|
1232 | {
|
---|
1233 | int i;
|
---|
1234 | char *ptr, str[80], tmp[256];
|
---|
1235 |
|
---|
1236 | ptr = Service_content_str;
|
---|
1237 | ptr += (int)strlen(Service_content_str);
|
---|
1238 | for( i = 0; i < size; i++)
|
---|
1239 | {
|
---|
1240 | strcpy(tmp,"");
|
---|
1241 | if(i%4 == 0)
|
---|
1242 | {
|
---|
1243 | if(i != 0)
|
---|
1244 | {
|
---|
1245 | strcat(tmp," ");
|
---|
1246 | }
|
---|
1247 | sprintf_html(str, 7, i);
|
---|
1248 | strcat(tmp,str);
|
---|
1249 | }
|
---|
1250 | sprintf(str,"%12.3G",*(buff++));
|
---|
1251 | strcat(tmp,str);
|
---|
1252 | if((i%4 == 3) || (i == size-1))
|
---|
1253 | {
|
---|
1254 | strcat(tmp,"<br />");
|
---|
1255 | }
|
---|
1256 | strcpy(ptr, tmp);
|
---|
1257 | ptr += (int)strlen(tmp);
|
---|
1258 | }
|
---|
1259 | strcpy(tmp,"<br />");
|
---|
1260 | strcpy(ptr, tmp);
|
---|
1261 | ptr += (int)strlen(tmp);
|
---|
1262 | }
|
---|
1263 |
|
---|
1264 | char *addJSONStart(char *ptr)
|
---|
1265 | {
|
---|
1266 | char *ptro;
|
---|
1267 |
|
---|
1268 | strcat(ptr,"{\n");
|
---|
1269 | ptro = ptr + (int)strlen(ptr);
|
---|
1270 | return ptro;
|
---|
1271 | }
|
---|
1272 |
|
---|
1273 | char *addJSONEnd(char *ptr)
|
---|
1274 | {
|
---|
1275 | char *ptro;
|
---|
1276 |
|
---|
1277 | strcat(ptr,"}\n");
|
---|
1278 | ptro = ptr + (int)strlen(ptr);
|
---|
1279 | return ptro;
|
---|
1280 | }
|
---|
1281 |
|
---|
1282 | char *addJSONNodeStart(char *ptr, char *node)
|
---|
1283 | {
|
---|
1284 | char *ptro;
|
---|
1285 |
|
---|
1286 | sprintf(ptr,"%s: [\n", node);
|
---|
1287 | ptro = ptr + (int)strlen(ptr);
|
---|
1288 | return ptro;
|
---|
1289 | }
|
---|
1290 |
|
---|
1291 | char *addJSONNodeEnd(char *ptr)
|
---|
1292 | {
|
---|
1293 | char *ptro;
|
---|
1294 |
|
---|
1295 | strcat(ptr,"]\n");
|
---|
1296 | ptro = ptr + (int)strlen(ptr);
|
---|
1297 | return ptro;
|
---|
1298 | }
|
---|
1299 |
|
---|
1300 | char *addJSONChildStart(char *ptr, char *child, int sep)
|
---|
1301 | {
|
---|
1302 | char *ptro;
|
---|
1303 |
|
---|
1304 | if(sep)
|
---|
1305 | sprintf(ptr,"{ %s, ", child);
|
---|
1306 | else
|
---|
1307 | sprintf(ptr,"{ %s", child);
|
---|
1308 | ptro = ptr + (int)strlen(ptr);
|
---|
1309 | return ptro;
|
---|
1310 | }
|
---|
1311 |
|
---|
1312 | char *addJSONChildEnd(char *ptr, int sep)
|
---|
1313 | {
|
---|
1314 | char *ptro;
|
---|
1315 |
|
---|
1316 | if(sep)
|
---|
1317 | strcat(ptr," },\n");
|
---|
1318 | else
|
---|
1319 | strcat(ptr," }\n");
|
---|
1320 | ptro = ptr + (int)strlen(ptr);
|
---|
1321 | return ptro;
|
---|
1322 | }
|
---|
1323 |
|
---|
1324 | char *getJSONBuffer(char *node, int browser)
|
---|
1325 | {
|
---|
1326 | BROWSER *browserp;
|
---|
1327 | int prepareJSONTree();
|
---|
1328 |
|
---|
1329 | if(browser)
|
---|
1330 | {
|
---|
1331 | if((browserp = find_browser(browser)))
|
---|
1332 | {
|
---|
1333 | if(browserp->pattern[0] != '\0')
|
---|
1334 | {
|
---|
1335 | prepareJSONTree(node, browserp);
|
---|
1336 | return(browserp->JSONBuffer);
|
---|
1337 | }
|
---|
1338 | browserp->n_services = 0;
|
---|
1339 | browserp->n_servers = 0;
|
---|
1340 | browserp->n_nodes = 0;
|
---|
1341 | }
|
---|
1342 | }
|
---|
1343 | prepareJSONTree(node, 0);
|
---|
1344 | return(JSONBuffer);
|
---|
1345 | }
|
---|
1346 |
|
---|
1347 | char *getJSONHeader()
|
---|
1348 | {
|
---|
1349 | int prepareJSONHeader();
|
---|
1350 |
|
---|
1351 | if(JSONHeader[0] == '\0')
|
---|
1352 | prepareJSONHeader();
|
---|
1353 | return(JSONHeader);
|
---|
1354 | }
|
---|
1355 |
|
---|
1356 | int getNodeLabel(char *name, char *label)
|
---|
1357 | {
|
---|
1358 | int i;
|
---|
1359 | extern int web_get_node_name();
|
---|
1360 |
|
---|
1361 | web_get_node_name(name, label);
|
---|
1362 | for(i = 0; i < ((int)strlen(label) + 1); i++)
|
---|
1363 | {
|
---|
1364 | label[i] = (char)tolower((int)label[i]);
|
---|
1365 | if(label[i] == '.')
|
---|
1366 | {
|
---|
1367 | label[i] = '\0';
|
---|
1368 | break;
|
---|
1369 | }
|
---|
1370 | }
|
---|
1371 | return 1;
|
---|
1372 | }
|
---|
1373 |
|
---|
1374 | int prepareJSONTree(char *node, BROWSER *browserp)
|
---|
1375 | {
|
---|
1376 | char *ptr;
|
---|
1377 | NODE *nodep;
|
---|
1378 | SERVER *servp;
|
---|
1379 | char str[256], aux[128];
|
---|
1380 | int selective = 0;
|
---|
1381 | int n_nodes, tot_n_nodes;
|
---|
1382 | int n_servers, tot_n_servers;
|
---|
1383 | int ret, n_found = 0;
|
---|
1384 |
|
---|
1385 | if(browserp)
|
---|
1386 | {
|
---|
1387 | if(browserp->pattern[0] != '\0')
|
---|
1388 | selective = 1;
|
---|
1389 | else
|
---|
1390 | return(0);
|
---|
1391 | }
|
---|
1392 | if(!selective)
|
---|
1393 | {
|
---|
1394 | if(JSONBufferSize == 0)
|
---|
1395 | {
|
---|
1396 | JSONBuffer = malloc((size_t)(N_nodes*128+N_servers*128));
|
---|
1397 | }
|
---|
1398 | else if (JSONBufferSize < N_nodes*128+N_servers*128)
|
---|
1399 | {
|
---|
1400 | free(JSONBuffer);
|
---|
1401 | JSONBuffer = malloc((size_t)(N_nodes*128+N_servers*128));
|
---|
1402 | }
|
---|
1403 | ptr = JSONBuffer;
|
---|
1404 | }
|
---|
1405 | else
|
---|
1406 | {
|
---|
1407 | if(browserp->JSONBufferSize == 0)
|
---|
1408 | {
|
---|
1409 | browserp->JSONBuffer = malloc((size_t)(N_nodes*128+N_servers*128));
|
---|
1410 | }
|
---|
1411 | else if (browserp->JSONBufferSize < N_nodes*128+N_servers*128)
|
---|
1412 | {
|
---|
1413 | free(browserp->JSONBuffer);
|
---|
1414 | browserp->JSONBuffer = malloc((size_t)(N_nodes*128+N_servers*128));
|
---|
1415 | }
|
---|
1416 | ptr = browserp->JSONBuffer;
|
---|
1417 | }
|
---|
1418 | *ptr = '\0';
|
---|
1419 | if(!strcmp(node, "src"))
|
---|
1420 | {
|
---|
1421 | ptr = addJSONStart(ptr);
|
---|
1422 | ptr = addJSONNodeStart(ptr,"children");
|
---|
1423 | sprintf(str,"text: \"%s\", id: \"Nodes\", expanded: false", Title);
|
---|
1424 | ptr = addJSONChildStart(ptr,str,1);
|
---|
1425 | ptr = addJSONNodeStart(ptr,"children");
|
---|
1426 | nodep = Node_head;
|
---|
1427 | tot_n_nodes = 0;
|
---|
1428 | while( (nodep = (NODE *)sll_get_next((SLL *)nodep)) )
|
---|
1429 | {
|
---|
1430 | nodep->match = 1;
|
---|
1431 | if(selective)
|
---|
1432 | {
|
---|
1433 | if(!(ret = find_service_pattern(nodep, 0, browserp->pattern, &tot_n_servers)))
|
---|
1434 | {
|
---|
1435 | nodep->match = 0;
|
---|
1436 | continue;
|
---|
1437 | }
|
---|
1438 | else
|
---|
1439 | {
|
---|
1440 | n_found += ret;
|
---|
1441 | }
|
---|
1442 | }
|
---|
1443 | tot_n_nodes++;
|
---|
1444 | }
|
---|
1445 | n_nodes = 0;
|
---|
1446 | nodep = Node_head;
|
---|
1447 | while( (nodep = (NODE *)sll_get_next((SLL *)nodep)) )
|
---|
1448 | {
|
---|
1449 | if(!nodep->match)
|
---|
1450 | continue;
|
---|
1451 | getNodeLabel(nodep->name, aux);
|
---|
1452 | sprintf(str,"text: \"%s\", id: \"%s\", qtip: \"%s\"",
|
---|
1453 | aux, nodep->name, nodep->name);
|
---|
1454 | ptr = addJSONChildStart(ptr,str,0);
|
---|
1455 | n_nodes++;
|
---|
1456 | if(WebDID_Debug)
|
---|
1457 | printf("adding %s %d %d\n",nodep->name, n_nodes, tot_n_nodes);
|
---|
1458 | if(n_nodes < tot_n_nodes)
|
---|
1459 | ptr = addJSONChildEnd(ptr,1);
|
---|
1460 | else
|
---|
1461 | ptr = addJSONChildEnd(ptr,0);
|
---|
1462 | }
|
---|
1463 | ptr = addJSONNodeEnd(ptr);
|
---|
1464 | ptr = addJSONChildEnd(ptr,0);
|
---|
1465 | ptr = addJSONNodeEnd(ptr);
|
---|
1466 | ptr = addJSONEnd(ptr);
|
---|
1467 | if(selective)
|
---|
1468 | {
|
---|
1469 | browserp->n_services = n_found;
|
---|
1470 | browserp->n_servers = tot_n_servers;
|
---|
1471 | browserp->n_nodes = tot_n_nodes;
|
---|
1472 | }
|
---|
1473 | }
|
---|
1474 | else
|
---|
1475 | {
|
---|
1476 | if((nodep = find_node(node)))
|
---|
1477 | {
|
---|
1478 | ptr = addJSONStart(ptr);
|
---|
1479 | ptr = addJSONNodeStart(ptr,"children");
|
---|
1480 | servp = nodep->server_head;
|
---|
1481 | tot_n_servers = 0;
|
---|
1482 | while( (servp = (SERVER *)sll_get_next((SLL *)servp)) )
|
---|
1483 | {
|
---|
1484 | servp->match = 1;
|
---|
1485 | if(servp->busy != 1)
|
---|
1486 | {
|
---|
1487 | servp->match = 0;
|
---|
1488 | continue;
|
---|
1489 | }
|
---|
1490 | if(selective)
|
---|
1491 | {
|
---|
1492 | if(!(ret = find_service_pattern(nodep, servp, browserp->pattern, 0)))
|
---|
1493 | {
|
---|
1494 | servp->match = 0;
|
---|
1495 | continue;
|
---|
1496 | }
|
---|
1497 | else
|
---|
1498 | {
|
---|
1499 | n_found += ret;
|
---|
1500 | }
|
---|
1501 | }
|
---|
1502 | tot_n_servers++;
|
---|
1503 | }
|
---|
1504 | n_servers = 0;
|
---|
1505 | servp = nodep->server_head;
|
---|
1506 | while( (servp = (SERVER *)sll_get_next((SLL *)servp)) )
|
---|
1507 | {
|
---|
1508 | if(!servp->match)
|
---|
1509 | continue;
|
---|
1510 | sprintf(str,"text: \"%s\", id: \"%d\", leaf: true, icon: \"server.png\"",servp->name, servp->server.pid);
|
---|
1511 | ptr = addJSONChildStart(ptr,str,0);
|
---|
1512 | n_servers++;
|
---|
1513 | if(n_servers < tot_n_servers)
|
---|
1514 | ptr = addJSONChildEnd(ptr,1);
|
---|
1515 | else
|
---|
1516 | ptr = addJSONChildEnd(ptr,0);
|
---|
1517 | }
|
---|
1518 | ptr = addJSONNodeEnd(ptr);
|
---|
1519 | ptr = addJSONEnd(ptr);
|
---|
1520 | }
|
---|
1521 | }
|
---|
1522 | /*
|
---|
1523 | if(!selective)
|
---|
1524 | printf(" Nodes&Servers %s\n",JSONBuffer);
|
---|
1525 | else
|
---|
1526 | printf(" Nodes&Servers %s\n",browserp->JSONBuffer);
|
---|
1527 | */
|
---|
1528 | return(1);
|
---|
1529 | }
|
---|
1530 |
|
---|
1531 | int prepareJSONHeader()
|
---|
1532 | {
|
---|
1533 | char *ptr;
|
---|
1534 | char str[128];
|
---|
1535 |
|
---|
1536 | ptr = JSONHeader;
|
---|
1537 | *ptr = '\0';
|
---|
1538 | ptr = addJSONStart(ptr);
|
---|
1539 | ptr = addJSONNodeStart(ptr,"items");
|
---|
1540 | sprintf(str,"text: \"%s\"",Title);
|
---|
1541 | ptr = addJSONChildStart(ptr,str,0);
|
---|
1542 | ptr = addJSONChildEnd(ptr,1);
|
---|
1543 | sprintf(str,"text: \"%d Servers Known - %d Services Available\"",N_servers, N_services);
|
---|
1544 | ptr = addJSONChildStart(ptr,str,0);
|
---|
1545 | ptr = addJSONChildEnd(ptr,0);
|
---|
1546 | ptr = addJSONNodeEnd(ptr);
|
---|
1547 | ptr = addJSONEnd(ptr);
|
---|
1548 | if(WebDID_Debug)
|
---|
1549 | printf(" Header %s\n",JSONHeader);
|
---|
1550 | return(1);
|
---|
1551 | }
|
---|
1552 |
|
---|
1553 | char *JSONServices = 0;
|
---|
1554 | int JSONServicesSize = 0;
|
---|
1555 | char *prepareJSONServiceList(SERVER *servp, char *node, int pid, BROWSER *browserp)
|
---|
1556 | {
|
---|
1557 | DNS_SERVICE_INFO *servicep;
|
---|
1558 | char *ptr;
|
---|
1559 | int n_services, i;
|
---|
1560 | char str[256], type_str[256];
|
---|
1561 | int selective = 0;
|
---|
1562 | int n_found = 0, n;
|
---|
1563 |
|
---|
1564 | servicep = servp->service_ptr;
|
---|
1565 | n_services = servp->server.n_services;
|
---|
1566 | if(JSONServicesSize == 0)
|
---|
1567 | {
|
---|
1568 | JSONServices = malloc((size_t)(n_services*256));
|
---|
1569 | }
|
---|
1570 | else if (JSONServicesSize < n_services*256)
|
---|
1571 | {
|
---|
1572 | free(JSONServices);
|
---|
1573 | JSONServices = malloc((size_t)(n_services*256));
|
---|
1574 | }
|
---|
1575 | if(browserp)
|
---|
1576 | {
|
---|
1577 | if(browserp->pattern[0] != '\0')
|
---|
1578 | selective = 1;
|
---|
1579 | }
|
---|
1580 | n_found = n_services;
|
---|
1581 | if(selective)
|
---|
1582 | {
|
---|
1583 | n_found = find_server_service_pattern(servp, browserp->pattern);
|
---|
1584 | }
|
---|
1585 | ptr = JSONServices;
|
---|
1586 | *ptr = '\0';
|
---|
1587 | ptr = addJSONStart(ptr);
|
---|
1588 | ptr = addJSONNodeStart(ptr,"children");
|
---|
1589 | if(selective)
|
---|
1590 | sprintf(str,"text: \"%s (%d/%d services, pid %d)\"",servp->name, n_found, n_services, servp->server.pid);
|
---|
1591 | else
|
---|
1592 | sprintf(str,"text: \"%s (%d services, pid %d)\"",servp->name, n_services, servp->server.pid);
|
---|
1593 | ptr = addJSONChildStart(ptr,str,1);
|
---|
1594 | ptr = addJSONNodeStart(ptr,"children");
|
---|
1595 | servicep = servp->service_ptr;
|
---|
1596 | n = 0;
|
---|
1597 | for(i = 0; i < n_services; i++)
|
---|
1598 | {
|
---|
1599 | /*
|
---|
1600 | printf("Service type = %d\n",servicep->type);
|
---|
1601 | */
|
---|
1602 | if((!selective) || (strstr(servicep->name, browserp->pattern)))
|
---|
1603 | {
|
---|
1604 | if(servicep->type == 1)
|
---|
1605 | {
|
---|
1606 | sprintf(type_str,"%d@%s|%s|CMD", pid, node, servicep->name);
|
---|
1607 | sprintf(str,"text: \"%s\", id: \"%s\", leaf: true, icon: \"leaf_cmd.gif\"",servicep->name, type_str);
|
---|
1608 | }
|
---|
1609 | else
|
---|
1610 | {
|
---|
1611 | sprintf(type_str,"%d@%s|%s", pid, node, servicep->name);
|
---|
1612 | sprintf(str,"text: \"%s\", id: \"%s\", leaf: true",servicep->name, type_str);
|
---|
1613 | }
|
---|
1614 | ptr = addJSONChildStart(ptr,str,0);
|
---|
1615 | n++;
|
---|
1616 | if(n < n_found)
|
---|
1617 | ptr = addJSONChildEnd(ptr,1);
|
---|
1618 | else
|
---|
1619 | ptr = addJSONChildEnd(ptr,0);
|
---|
1620 | }
|
---|
1621 | servicep++;
|
---|
1622 | }
|
---|
1623 | ptr = addJSONNodeEnd(ptr);
|
---|
1624 | ptr = addJSONChildEnd(ptr,0);
|
---|
1625 | ptr = addJSONNodeEnd(ptr);
|
---|
1626 | ptr = addJSONEnd(ptr);
|
---|
1627 | return JSONServices;
|
---|
1628 | }
|
---|
1629 |
|
---|
1630 | int matchString( char *wzString, char *wzPattern )
|
---|
1631 | {
|
---|
1632 | switch (*wzPattern){
|
---|
1633 | case '\0':
|
---|
1634 | return !*wzString;
|
---|
1635 | case '*':
|
---|
1636 | return matchString(wzString, wzPattern+1) ||
|
---|
1637 | ( *wzString && matchString(wzString+1, wzPattern) );
|
---|
1638 | case '?':
|
---|
1639 | return *wzString &&
|
---|
1640 | matchString(wzString+1, wzPattern+1);
|
---|
1641 | default:
|
---|
1642 | return (*wzPattern == *wzString) &&
|
---|
1643 | matchString(wzString+1, wzPattern+1);
|
---|
1644 | }
|
---|
1645 | }
|
---|
1646 |
|
---|
1647 | int get_type_size(char type)
|
---|
1648 | {
|
---|
1649 | int size;
|
---|
1650 |
|
---|
1651 | switch(type)
|
---|
1652 | {
|
---|
1653 | case 'L':
|
---|
1654 | case 'l':
|
---|
1655 | size = sizeof(long);
|
---|
1656 | break;
|
---|
1657 | case 'I':
|
---|
1658 | case 'i':
|
---|
1659 | size = sizeof(int);
|
---|
1660 | break;
|
---|
1661 | case 'S':
|
---|
1662 | case 's':
|
---|
1663 | size = sizeof(short);
|
---|
1664 | break;
|
---|
1665 | case 'F':
|
---|
1666 | case 'f':
|
---|
1667 | size = sizeof(float);
|
---|
1668 | break;
|
---|
1669 | case 'D':
|
---|
1670 | case 'd':
|
---|
1671 | size = sizeof(double);
|
---|
1672 | break;
|
---|
1673 | case 'C':
|
---|
1674 | case 'c':
|
---|
1675 | default:
|
---|
1676 | size = 1;
|
---|
1677 | }
|
---|
1678 | return(size);
|
---|
1679 | }
|
---|
1680 |
|
---|
1681 | void did_prepare_command(char *str, char *service, char *format)
|
---|
1682 | {
|
---|
1683 | char type;
|
---|
1684 | int num;
|
---|
1685 | int size, full_size = 0;
|
---|
1686 | char *ptr;
|
---|
1687 | static int last_size = 0;
|
---|
1688 | static void *last_buffer = 0;
|
---|
1689 | void *buffer_ptr;
|
---|
1690 | char *str_ptr;
|
---|
1691 | void did_read_string(char, int, void **, char **);
|
---|
1692 |
|
---|
1693 | str_ptr = str;
|
---|
1694 | ptr = format;
|
---|
1695 | while(*ptr)
|
---|
1696 | {
|
---|
1697 | type = *ptr++;
|
---|
1698 | if(*ptr == ':')
|
---|
1699 | {
|
---|
1700 | ptr++;
|
---|
1701 | size = get_type_size(type);
|
---|
1702 | sscanf(ptr, "%d", &num);
|
---|
1703 | full_size += size * num;
|
---|
1704 | if( (ptr = strchr(ptr,';')) )
|
---|
1705 | ptr++;
|
---|
1706 | else
|
---|
1707 | break;
|
---|
1708 | }
|
---|
1709 | }
|
---|
1710 |
|
---|
1711 | full_size += 256;
|
---|
1712 | if(full_size > last_size)
|
---|
1713 | {
|
---|
1714 | if(last_size)
|
---|
1715 | free(last_buffer);
|
---|
1716 | last_buffer = malloc((size_t)full_size);
|
---|
1717 | last_size = full_size;
|
---|
1718 | }
|
---|
1719 | memset(last_buffer, 0, (size_t)last_size);
|
---|
1720 | buffer_ptr = last_buffer;
|
---|
1721 | ptr = format;
|
---|
1722 | while(*ptr)
|
---|
1723 | {
|
---|
1724 | type = *ptr++;
|
---|
1725 | if(*ptr == ':')
|
---|
1726 | {
|
---|
1727 | ptr++;
|
---|
1728 | sscanf(ptr, "%d", &num);
|
---|
1729 | did_read_string(type, num, &buffer_ptr, &str_ptr);
|
---|
1730 | if(!str_ptr)
|
---|
1731 | break;
|
---|
1732 | if( (ptr = strchr(ptr,';')) )
|
---|
1733 | ptr++;
|
---|
1734 | else
|
---|
1735 | break;
|
---|
1736 | }
|
---|
1737 | else
|
---|
1738 | {
|
---|
1739 | did_read_string(type, 0, &buffer_ptr, &str_ptr);
|
---|
1740 | break;
|
---|
1741 | }
|
---|
1742 | }
|
---|
1743 | full_size = (int) ((char *)buffer_ptr - (char *)last_buffer);
|
---|
1744 | dic_cmnd_service(service,last_buffer,full_size);
|
---|
1745 | }
|
---|
1746 |
|
---|
1747 | int read_str_int(char *str)
|
---|
1748 | {
|
---|
1749 | int i;
|
---|
1750 | if((str[0] == '0') && (str[1] == 'x'))
|
---|
1751 | sscanf(str+2,"%x",&i);
|
---|
1752 | else
|
---|
1753 | sscanf(str,"%d",&i);
|
---|
1754 | return(i);
|
---|
1755 | }
|
---|
1756 |
|
---|
1757 | int read_str_char(char *str, char *cc)
|
---|
1758 | {
|
---|
1759 | int num;
|
---|
1760 |
|
---|
1761 | if(str[0] == '\'')
|
---|
1762 | *cc = str[1];
|
---|
1763 | else if(str[0] == '\"')
|
---|
1764 | return(0);
|
---|
1765 | else if((str[0] == '0') && (str[1] == 'x'))
|
---|
1766 | {
|
---|
1767 | sscanf(str+2,"%x",&num);
|
---|
1768 | if(num <= 0xff)
|
---|
1769 | *cc = (char)num;
|
---|
1770 | else
|
---|
1771 | return(-1);
|
---|
1772 | }
|
---|
1773 | else if(isalpha(str[0]))
|
---|
1774 | return(-1);
|
---|
1775 | else
|
---|
1776 | {
|
---|
1777 | sscanf(str,"%d",&num);
|
---|
1778 | if(num <= 0xff)
|
---|
1779 | *cc = (char)num;
|
---|
1780 | else
|
---|
1781 | return(-1);
|
---|
1782 | }
|
---|
1783 | return(1);
|
---|
1784 | }
|
---|
1785 |
|
---|
1786 | void did_read_string(char type, int num, void **buffer_ptr, char **str_ptr)
|
---|
1787 | {
|
---|
1788 | int i, ret = 0;
|
---|
1789 | float ff;
|
---|
1790 | double dd;
|
---|
1791 | void *ptr;
|
---|
1792 | char *strp, *ptr1;
|
---|
1793 | char cc;
|
---|
1794 | short s;
|
---|
1795 |
|
---|
1796 | strp = *str_ptr;
|
---|
1797 | ptr = *buffer_ptr;
|
---|
1798 | if(!num)
|
---|
1799 | num = 1000000;
|
---|
1800 | switch(type)
|
---|
1801 | {
|
---|
1802 | case 'L':
|
---|
1803 | case 'l':
|
---|
1804 | case 'I':
|
---|
1805 | case 'i':
|
---|
1806 | for(i = 0; i<num; i++)
|
---|
1807 | {
|
---|
1808 | *(int *)ptr = read_str_int(strp);
|
---|
1809 | ptr = (int *)ptr +1;
|
---|
1810 | if( (strp = strchr(strp,' ')) )
|
---|
1811 | strp++;
|
---|
1812 | else
|
---|
1813 | break;
|
---|
1814 | }
|
---|
1815 | break;
|
---|
1816 | case 'S':
|
---|
1817 | case 's':
|
---|
1818 | for(i = 0; i<num; i++)
|
---|
1819 | {
|
---|
1820 | s = (short)read_str_int(strp);
|
---|
1821 | *((short *)ptr) = s;
|
---|
1822 | ptr = (short *)ptr +1;
|
---|
1823 | if( (strp = strchr(strp,' ')) )
|
---|
1824 | strp++;
|
---|
1825 | else
|
---|
1826 | break;
|
---|
1827 | }
|
---|
1828 | break;
|
---|
1829 | case 'F':
|
---|
1830 | case 'f':
|
---|
1831 | for(i = 0; i<num; i++)
|
---|
1832 | {
|
---|
1833 | sscanf(strp,"%f",&ff);
|
---|
1834 | *(float *)ptr = ff;
|
---|
1835 | ptr = (float *)ptr +1;
|
---|
1836 | if( (strp = strchr(strp,' ')) )
|
---|
1837 | strp++;
|
---|
1838 | else
|
---|
1839 | break;
|
---|
1840 | }
|
---|
1841 | break;
|
---|
1842 | case 'D':
|
---|
1843 | case 'd':
|
---|
1844 | for(i = 0; i<num; i++)
|
---|
1845 | {
|
---|
1846 | sscanf(strp,"%f",&ff);
|
---|
1847 | dd = (double)ff;
|
---|
1848 | *(double *)ptr = dd;
|
---|
1849 | ptr = (double *)ptr +1;
|
---|
1850 | if( (strp = strchr(strp,' ')) )
|
---|
1851 | strp++;
|
---|
1852 | else
|
---|
1853 | break;
|
---|
1854 | }
|
---|
1855 | break;
|
---|
1856 | case 'C':
|
---|
1857 | case 'c':
|
---|
1858 | default:
|
---|
1859 | for(i = 0; i<num; i++)
|
---|
1860 | {
|
---|
1861 | if((ret = read_str_char(strp, &cc)) <= 0)
|
---|
1862 | break;
|
---|
1863 | *(char *)ptr = cc;
|
---|
1864 | ptr = (char *)ptr +1;
|
---|
1865 | if( (strp = strchr(strp,' ')) )
|
---|
1866 | strp++;
|
---|
1867 | else
|
---|
1868 | break;
|
---|
1869 | }
|
---|
1870 | if(ret <= 0)
|
---|
1871 | {
|
---|
1872 | if(!ret)
|
---|
1873 | {
|
---|
1874 | strp++;
|
---|
1875 | }
|
---|
1876 | num = (int)strlen(strp)+1;
|
---|
1877 | strncpy((char *)ptr,strp,(size_t)num);
|
---|
1878 | if( (ptr1 = (char *)strchr((char *)ptr,'\"')) )
|
---|
1879 | {
|
---|
1880 | num--;
|
---|
1881 | *ptr1 = '\0';
|
---|
1882 | }
|
---|
1883 | ptr = (char *)ptr + num;
|
---|
1884 | if( (strp = strchr(strp,' ')) )
|
---|
1885 | strp++;
|
---|
1886 | else
|
---|
1887 | break;
|
---|
1888 | }
|
---|
1889 | }
|
---|
1890 | *buffer_ptr = ptr;
|
---|
1891 | *str_ptr = strp;
|
---|
1892 | }
|
---|