base.lisp

   1 ;;;; -*- Mode: Lisp; Syntax: ANSI-Common-Lisp; Base: 10; Package: modlisp -*-
   2 ;;;; *************************************************************************
   3 ;;;; FILE IDENTIFICATION
   4 ;;;;
   5 ;;;; Name:          base.lisp
   6 ;;;; Purpose:       Utility functions for modlisp package
   7 ;;;; Programmer:    Kevin M. Rosenberg
   8 ;;;; Date Started:  Dec 2002
   9 ;;;;
  10 ;;;; $Id: base.lisp,v 1.11 2003/07/11 02:38:00 kevin Exp $
  11 ;;;; *************************************************************************
  12
  13 (in-package #:modlisp)
  14
  15 (defun modlisp-start (&key (port +default-modlisp-port+)
  16                       (processor 'demo-modlisp-command-processor)
  17                       (processor-args nil)
  18                       (catch-errors t)
  19                       timeout
  20                       number-fixed-workers)
  21   (let ((listener (make-instance 'listener :port port
  22                                  :base-name "modlisp"
  23                                  :function 'modlisp-command-issuer
  24                                  :function-args (cons processor processor-args)
  25                                  :format :text
  26                                  :wait nil
  27                                  :catch-errors catch-errors
  28                                  :timeout timeout
  29                                  :number-fixed-workers number-fixed-workers)))
  30     (init/listener listener :start)))
  31
  32
  33 (defun modlisp-stop (listener)
  34   (init/listener listener :stop))
  35
  36 (defun modlisp-stop-all ()
  37   (stop-all/listener))
  38
  39 ;; Internal functions
  40
  41 (defun modlisp-command-issuer (*modlisp-socket* processor &rest args)
  42   "generates commands from modlisp, issues commands to processor-fun"
  43   (unwind-protect
  44        (progn
  45          (let ((*number-worker-requests* 0)
  46                (*close-modlisp-socket* t))
  47            (do ((command (read-modlisp-command) (read-modlisp-command)))
  48                ((null command))
  49              (apply processor command args)
  50              (finish-output *modlisp-socket*)
  51              (incf *number-worker-requests*)
  52              (incf *number-server-requests*)
  53              (when *close-modlisp-socket*
  54                (return)))))
  55     (close-active-socket *modlisp-socket*)))
  56
  57 (defun header-value (header key)
  58   "Returns the value of a modlisp header"
  59   (cdr (assoc key header :test #'string=)))
  60
  61 (defun read-modlisp-command ()
  62   (ignore-errors
  63     (let* ((header (read-modlisp-header))
  64            (content-length (header-value header "content-length"))
  65            (content (when content-length
  66                       (make-string
  67                        (parse-integer content-length :junk-allowed t)))))
  68      (when content
  69        (read-sequence content *modlisp-socket*)
  70        (push (cons "posted-content" content) header))
  71      header)))
  72
  73 (defun read-modlisp-line ()
  74   (kmrcl:string-right-trim-one-char
  75    #\return
  76    (read-line *modlisp-socket* nil nil)))
  77
  78 (defun read-modlisp-header ()
  79   (loop for key = (read-modlisp-line)
  80       while (and key
  81                  (string-not-equal key "end")
  82                  (> (length key) 1))
  83       for value = (read-modlisp-line)
  84       collect (cons key value)))
  85
  86 (defun write-header-line (key value)
  87   (write-string key *modlisp-socket*)
  88   (write-char #\NewLine *modlisp-socket*)
  89   (write-string value *modlisp-socket*)
  90   (write-char #\NewLine *modlisp-socket*))
  91
  92