From owner-p4-projects@FreeBSD.ORG Fri Apr 9 22:19:13 2004 Return-Path: Delivered-To: p4-projects@freebsd.org Received: by hub.freebsd.org (Postfix, from userid 32767) id 3574D16A4D0; Fri, 9 Apr 2004 22:19:13 -0700 (PDT) Delivered-To: perforce@freebsd.org Received: from mx1.FreeBSD.org (mx1.freebsd.org [216.136.204.125]) by hub.freebsd.org (Postfix) with ESMTP id 09CF816A4CE for ; Fri, 9 Apr 2004 22:19:13 -0700 (PDT) Received: from repoman.freebsd.org (repoman.freebsd.org [216.136.204.115]) by mx1.FreeBSD.org (Postfix) with ESMTP id 018CC43D5F for ; Fri, 9 Apr 2004 22:19:13 -0700 (PDT) (envelope-from scottl@freebsd.org) Received: from repoman.freebsd.org (localhost [127.0.0.1]) by repoman.freebsd.org (8.12.10/8.12.10) with ESMTP id i3A5JCGe069962 for ; Fri, 9 Apr 2004 22:19:12 -0700 (PDT) (envelope-from scottl@freebsd.org) Received: (from perforce@localhost) by repoman.freebsd.org (8.12.10/8.12.10/Submit) id i3A5JCZ0069959 for perforce@freebsd.org; Fri, 9 Apr 2004 22:19:12 -0700 (PDT) (envelope-from scottl@freebsd.org) Date: Fri, 9 Apr 2004 22:19:12 -0700 (PDT) Message-Id: <200404100519.i3A5JCZ0069959@repoman.freebsd.org> X-Authentication-Warning: repoman.freebsd.org: perforce set sender to scottl@freebsd.org using -f From: Scott Long To: Perforce Change Reviews Subject: PERFORCE change 50769 for review X-BeenThere: p4-projects@freebsd.org X-Mailman-Version: 2.1.1 Precedence: list List-Id: p4 projects tree changes List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Sat, 10 Apr 2004 05:19:13 -0000 http://perforce.freebsd.org/chv.cgi?CH=50769 Change 50769 by scottl@scottl-junior-camlock on 2004/04/09 22:18:20 Create basic workitem infrastructure. The only defined workitem right now is to execute a provided CCB. Affected files ... .. //depot/projects/scottl-camlock/src/sys/cam/cam_probe.c#2 edit Differences ... ==== //depot/projects/scottl-camlock/src/sys/cam/cam_probe.c#2 (text+ko) ==== @@ -42,6 +42,7 @@ #include #include #include +#include #ifdef PC98 #include /* geometry translation */ @@ -103,9 +104,59 @@ u_int8_t digest[16]; } probe_softc; +typedef enum { + WORK_EXECUTE_CCB = 0x1, +} cam_workflags; + +struct cam_workitem { + TAILQ_ENTRY(cam_workitem) work_links; + cam_workflags command; + void *data; + void (*cbfcnp)(void *); +}; + +static struct proc *probe_proc; +static struct mtx probe_workmtx; +static int probe_workflags; +static TAILQ_HEAD(,cam_workitem) probe_worklist; + +#define PROBE_FLAG_EXIT 0x1 + static void +probe_work(void *dummy) +{ + struct cam_workitem *work; + + mtx_lock(&probe_workmtx); + while ((probe_workflags & PROBE_FLAG_EXIT) == 0) { + if ((work = TAILQ_FIRST(&probe_worklist)) == NULL) { + msleep(&probe_worklist, &probe_workmtx, PRIBIO, + "probew", 0); + continue; + } + TAILQ_REMOVE(&probe_worklist, work, work_links); + + switch (work->command) { + case WORK_EXECUTE_CCB: + xpt_action((union ccb *)work->data); + break; + default: + panic("Unknown CAM work item %d\n", work->command); + } + } + mtx_unlock(&probe_workmtx); + + kthread_exit(0); +} + +static void probe_periph_init() { + + mtx_init(&probe_workmtx, "Probe Mutex", NULL, MTX_DEF); + TAILQ_INIT(&probe_worklist); + if (kthread_create(probe_work, NULL, &probe_proc, 0, 0, "probe_work")) + printf("Warning: cannot create probe kthread\n"); } static cam_status