Added read and write filters, fixed bugs with pre-queue filters and que-wait callbacks, added ns_tls, ns_cls, and ns_quewait commands.
| 1 | /* |
| 2 | * The contents of this file are subject to the AOLserver Public License |
| 3 | * Version 1.1 (the "License"); you may not use this file except in |
| 4 | * compliance with the License. You may obtain a copy of the License at |
| 5 | * http://aolserver.com/. |
| 6 | * |
| 7 | * Software distributed under the License is distributed on an "AS IS" |
| 8 | * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See |
| 9 | * the License for the specific language governing rights and limitations |
| 10 | * under the License. |
| 11 | * |
| 12 | * The Original Code is AOLserver Code and related documentation |
| 13 | * distributed by AOL. |
| 14 | * |
| 15 | * The Initial Developer of the Original Code is America Online, |
| 16 | * Inc. Portions created by AOL are Copyright (C) 1999 America Online, |
| 17 | * Inc. All Rights Reserved. |
| 18 | * |
| 19 | * Alternatively, the contents of this file may be used under the terms |
| 20 | * of the GNU General Public License (the "GPL"), in which case the |
| 21 | * provisions of GPL are applicable instead of those above. If you wish |
| 22 | * to allow use of your version of this file only under the terms of the |
| 23 | * GPL and not to allow others to use your version of this file under the |
| 24 | * License, indicate your decision by deleting the provisions above and |
| 25 | * replace them with the notice and other provisions required by the GPL. |
| 26 | * If you do not delete the provisions above, a recipient may use your |
| 27 | * version of this file under either the License or the GPL. |
| 28 | */ |
| 29 | |
| 30 | /* |
| 31 | * tclstore.c -- |
| 32 | * |
| 33 | * Thread and connection local storage Tcl commands. |
| 34 | */ |
| 35 | |
| 36 | static const char *RCSID = "@(#) $Header: /cvsroot-fuse/aolserver/aolserver/nsd/tclstore.c,v 1.1 2009/12/08 04:12:20 jgdavidson Exp $, compiled: " __DATE__ " " __TIME__; |
| 37 | |
| 38 | #include "nsd.h" |
| 39 | |
| 40 | /* |
| 41 | * Static functions defined in this file. |
| 42 | */ |
| 43 | |
| 44 | static int <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_StoreObjCmd">StoreObjCmd</a>(ClientData data, Tcl_Interp *interp, int objc, Tcl_Obj **objv, int tls); |
| 45 | |
| 46 | |
| 47 | /* |
| 48 | *---------------------------------------------------------------------- |
| 49 | * |
| 50 | * <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_NsTclTlsObjCmd">NsTclTlsObjCmd</a>, <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_NsTclClsObjCmd">NsTclClsObjCmd</a> -- |
| 51 | * |
| 52 | * Implements ns_tls and ns_cls as obj commands. |
| 53 | * |
| 54 | * Results: |
| 55 | * Tcl result. |
| 56 | * |
| 57 | * Side effects: |
| 58 | * See docs. |
| 59 | * |
| 60 | *---------------------------------------------------------------------- |
| 61 | */ |
| 62 | |
| 63 | int |
| 64 | <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_NsTclTlsObjCmd">NsTclTlsObjCmd</a>(ClientData data, Tcl_Interp *interp, int objc, Tcl_Obj **objv, Ns_Conn *conn) |
| 65 | { |
| 66 | return <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_StoreObjCmd">StoreObjCmd</a>(data, interp, objc, objv, 1); |
| 67 | } |
| 68 | |
| 69 | int |
| 70 | <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_NsTclClsObjCmd">NsTclClsObjCmd</a>(ClientData data, Tcl_Interp *interp, int objc, Tcl_Obj **objv, Ns_Conn *conn) |
| 71 | { |
| 72 | return <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_StoreObjCmd">StoreObjCmd</a>(data, interp, objc, objv, 0); |
| 73 | } |
| 74 | |
| 75 | static int |
| 76 | <a href="/cvs/aolserver/aolserver/nsd/tclstore.c#A_StoreObjCmd">StoreObjCmd</a>(ClientData arg, Tcl_Interp *interp, int objc, Tcl_Obj **objv, int tls) |
| 77 | { |
| 78 | static CONST char *opts[] = { |
| 79 | "alloc", "get", "set", NULL |
| 80 | }; |
| 81 | enum { |
| 82 | AllocIdx, GetIdx, SetIdx |
| 83 | } _nsmayalias opt; |
| 84 | Ns_Conn *conn; |
| 85 | char *val; |
| 86 | int id; |
| 87 | |
| 88 | if (objc < 2) { |
| 89 | Tcl_WrongNumArgs(interp, 1, objv, "option ?arg ...?"); |
| 90 | return TCL_ERROR; |
| 91 | } |
| 92 | if (Tcl_GetIndexFromObj(interp, objv[1], opts, "option", 0, |
| 93 | (int *) &opt) != TCL_OK) { |
| 94 | return TCL_ERROR; |
| 95 | } |
| 96 | if (opt == AllocIdx) { |
| 97 | if (objc != 2) { |
| 98 | Tcl_WrongNumArgs(interp, 2, objv, NULL); |
| 99 | return TCL_ERROR; |
| 100 | } |
| 101 | if (tls) { |
| 102 | Ns_TlsAlloc((Ns_Tls *) &id, ns_free); |
| 103 | } else { |
| 104 | <a href="/cvs/aolserver/aolserver/nsd/cls.c#A_Ns_ClsAlloc">Ns_ClsAlloc</a>((Ns_Cls *) &id, ns_free); |
| 105 | } |
| 106 | Tcl_SetObjResult(interp, Tcl_NewIntObj(id)); |
| 107 | } else { |
| 108 | if (!tls && <a href="/cvs/aolserver/aolserver/nsd/tclresp.c#A_NsTclGetConn">NsTclGetConn</a>((NsInterp *) arg, &conn) != TCL_OK) { |
| 109 | return TCL_ERROR; |
| 110 | } |
| 111 | if (objc < 3) { |
| 112 | Tcl_WrongNumArgs(interp, 2, objv, "index"); |
| 113 | return TCL_ERROR; |
| 114 | } |
| 115 | if (Tcl_GetIntFromObj(interp, objv[2], &id) != TCL_OK) { |
| 116 | return TCL_ERROR; |
| 117 | } |
| 118 | if (id < 1 || id >= (tls ? NS_THREAD_MAXTLS : NS_CONN_MAXCLS)) { |
| 119 | Tcl_AppendResult(interp, "invalid id: ", Tcl_GetString(objv[2]), NULL); |
| 120 | return TCL_ERROR; |
| 121 | } |
| 122 | if (tls) { |
| 123 | val = Ns_TlsGet((Ns_Tls *) &id); |
| 124 | } else { |
| 125 | val = <a href="/cvs/aolserver/aolserver/nsd/cls.c#A_Ns_ClsGet">Ns_ClsGet</a>((Ns_Cls *) &id, conn); |
| 126 | } |
| 127 | if (opt == GetIdx) { |
| 128 | Tcl_SetResult(interp, val, TCL_VOLATILE); |
| 129 | } else { |
| 130 | if (objc != 4) { |
| 131 | Tcl_WrongNumArgs(interp, 2, objv, "index value"); |
| 132 | return TCL_ERROR; |
| 133 | } |
| 134 | if (val) { |
| 135 | ns_free(val); |
| 136 | } |
| 137 | val = ns_strdup(Tcl_GetString(objv[3])); |
| 138 | if (tls) { |
| 139 | Ns_TlsSet((Ns_Tls *) &id, (void **) val); |
| 140 | } else { |
| 141 | <a href="/cvs/aolserver/aolserver/nsd/cls.c#A_Ns_ClsSet">Ns_ClsSet</a>((Ns_Cls *) &id, conn, (void **) val); |
| 142 | } |
| 143 | } |
| 144 | } |
| 145 | return TCL_OK; |
| 146 | } |
Copyright © 2010 Geeknet, Inc. All rights reserved. Terms of Use