anchor.diff:  	       ((rpc-server-exiting server))	   
   	     (when conn
   	       ;; a connection has been accepted -- process it 
  -	       (info "Connected to ~A:~A" (usocket:get-peer-address conn) (usocket:get-peer-port conn))
  +	       (info "Accepted connection from ~A:~A" (usocket:get-peer-address conn) (usocket:get-peer-port conn))
   	       (handler-case 
   		   (loop 
   		      (let ((stream (usocket:socket-stream conn)))
  +			(info "reading request")
   			(flexi-streams:with-input-from-sequence (input (read-fragmented-message stream))
  -			  (info "read request")
  +			  (info "successfully read request")
   			  (let ((buff (flexi-streams:with-output-to-sequence (output)
   					(handle-request input
   							output
  
positive.code: ;; ------------------------- handle a request from the stream --------------
  
  (defun read-fragmented-message (stream)
    (flexi-streams:with-output-to-sequence (output)
      (do ((done nil))
  	(done)
  
negative.code: 	(unless (zerop (logand length #x80000000))
  	  (setf done t
  		length (logand length (lognot #x80000000))))
  	(let ((buff (nibbles:make-octet-vector length)))
  	  (read-sequence buff stream)
  	  (write-sequence buff output))))))
  
  