Megatest

Check-in [e99d345eb0]
Login
Overview
Comment:Added some instrumentation
Downloads: Tarball | ZIP archive | SQL archive
Timelines: family | ancestors | descendants | both | v1.70-captain-ulex | v1.70-defunct-try
Files: files | file ages | folders
SHA1: e99d345eb00a59ecbd63dd1f33c79a832c8f063e
User & Date: matt on 2020-01-29 22:38:28
Other Links: branch diff | manifest | tags
Context
2020-02-01
04:39
Added ability to pass in existing udata to ulex setup Leaf check-in: 3d501185de user: matt tags: v1.70-captain-ulex, v1.70-defunct-try
2020-01-29
22:38
Added some instrumentation check-in: e99d345eb0 user: matt tags: v1.70-captain-ulex, v1.70-defunct-try
21:06
send-recieve fully using read/write (not a space-delimited string). check-in: 86f34c5c1b user: matt tags: v1.70-captain-ulex, v1.70-defunct-try
Changes

Modified ulex/ulex.scm from [725a72d111] to [8636c80a0f].

576
577
578
579
580
581
582

583
584
585
586

587
588
589
590
591
592

593


594
595
596
597
598
599
600
576
577
578
579
580
581
582
583
584
585
586

587
588
589
590
591
592
593
594

595
596
597
598
599
600
601
602
603







+



-
+






+
-
+
+







		   (conc qrykey " " host-port)))))
	  (else (conc qrykey " BADDATA"))))
       ;; for work items:
       ;;    handler is one of; immediate, read-only, read-write, high-priority
       ((immediate read-only normal low-priority) ;; do this work immediately
	;; host-port (caller), pid (caller), qrykey (cookie), params <= all from first line
	;; data => a single line encoded however you want, or should I build json into it?
	(print "handlerkey=" handlerkey)
	(let* ((pdat (get-peer-dat udata host-port)))
	  (match params ;; dbfile prockey procparam
	    ((dbfile prockey procparam)
	     (case (string->symbol handlerkey)
	     (case handlerkey
	       ((immediate read-only)
		(process-request udata pdat dbfile qrykey prockey procparam data))
	       ((normal low-priority) ;; split off later and add logic to support low priority
		(add-to-work-queue udata pdat dbfile qrykey prockey procparam data))
	       (else
		#f)))
	    (else
	    (else (print "ERROR: params=" params)))))
	     (print "INFO: params=" params " handlerkey=" handlerkey " controldat=" controldat)
	     #f))))
       (else
	;; (add-to-work-queue udata (get-peer-dat udata host-port) handlerkey qrykey data)
	#f)))
    (else
     (print "BAD DATA? controldat=" controldat " data=" data)
     #f)));; handles the incoming messages and dispatches to queues