configd.tproj/session.c

   1 /*
   2  * Copyright (c) 2000-2003 Apple Computer, Inc. All rights reserved.
   3  *
   4  * @APPLE_LICENSE_HEADER_START@
   5  *
   6  * This file contains Original Code and/or Modifications of Original Code
   7  * as defined in and that are subject to the Apple Public Source License
   8  * Version 2.0 (the 'License'). You may not use this file except in
   9  * compliance with the License. Please obtain a copy of the License at
  10  * http://www.opensource.apple.com/apsl/ and read it before using this
  11  * file.
  12  *
  13  * The Original Code and all software distributed under the License are
  14  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  15  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  16  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  17  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
  18  * Please see the License for the specific language governing rights and
  19  * limitations under the License.
  20  *
  21  * @APPLE_LICENSE_HEADER_END@
  22  */
  23
  24 /*
  25  * Modification History
  26  *
  27  * June 1, 2001                 Allan Nathanson <ajn@apple.com>
  28  * - public API conversion
  29  *
  30  * March 24, 2000               Allan Nathanson <ajn@apple.com>
  31  * - initial revision
  32  */
  33
  34 #include "configd.h"
  35 #include "configd_server.h"
  36 #include "session.h"
  37
  38 /* information maintained for each active session */
  39 static serverSessionRef *sessions = NULL;
  40 static int              nSessions = 0;
  41
  42
  43 __private_extern__
  44 serverSessionRef
  45 getSession(mach_port_t server)
  46 {
  47         int     i;
  48
  49         if (server == MACH_PORT_NULL) {
  50                 SCLog(TRUE, LOG_NOTICE, CFSTR("Excuse me, why is getSession() being called with an invalid port?"));
  51                 return NULL;
  52         }
  53
  54         for (i = 0; i < nSessions; i++) {
  55                 serverSessionRef        thisSession = sessions[i];
  56
  57                 if (thisSession == NULL) {
  58                         /* found an empty slot, skip it */
  59                         continue;
  60                 } else if (thisSession->key == server) {
  61                         return thisSession;     /* we've seen this server before */
  62                 } else if (thisSession->store &&
  63                                       (((SCDynamicStorePrivateRef)thisSession->store)->notifySignalTask == server)) {
  64                         return thisSession;
  65                 }
  66         }
  67
  68         /* no sessions available */
  69         return NULL;
  70 }
  71
  72
  73 __private_extern__
  74 serverSessionRef
  75 addSession(CFMachPortRef server)
  76 {
  77         int     i;
  78         int     n = -1;
  79
  80         if (nSessions <= 0) {
  81                 /* new session (actually, the first) found */
  82                 sessions = malloc(sizeof(serverSessionRef));
  83                 n = 0;
  84                 nSessions = 1;
  85         } else {
  86                 for (i = 0; i < nSessions; i++) {
  87                         if (sessions[i] == NULL) {
  88                                 /* found an empty slot, use it */
  89                                 n = i;
  90                         }
  91                 }
  92                 /* new session identified */
  93                 if (n < 0) {
  94                         /* no empty slots, add one to the list */
  95                         n = nSessions++;
  96                         sessions = reallocf(sessions, ((nSessions) * sizeof(serverSessionRef)));
  97                 }
  98         }
  99
 100         // allocate a new session for this server
 101         sessions[n] = malloc(sizeof(serverSession));
 102         sessions[n]->key                 = CFMachPortGetPort(server);
 103         sessions[n]->serverPort          = server;
 104         sessions[n]->serverRunLoopSource = NULL;
 105         sessions[n]->store               = NULL;
 106         sessions[n]->callerEUID          = 1;           /* not "root" */
 107         sessions[n]->callerEGID          = 1;           /* not "wheel" */
 108
 109         return sessions[n];
 110 }
 111
 112
 113 __private_extern__
 114 void
 115 removeSession(mach_port_t server)
 116 {
 117         int                     i;
 118         serverSessionRef        thisSession;
 119         CFStringRef             sessionKey;
 120
 121         for (i = 0; i < nSessions; i++) {
 122                 thisSession = sessions[i];
 123
 124                 if (thisSession == NULL) {
 125                         /* found an empty slot, skip it */
 126                         continue;
 127                 } else if (thisSession->key == server) {
 128                         /*
 129                          * We don't need any remaining information in the
 130                          * sessionData dictionary, remove it.
 131                          */
 132                         sessionKey = CFStringCreateWithFormat(NULL, NULL, CFSTR("%d"), server);
 133                         CFDictionaryRemoveValue(sessionData, sessionKey);
 134                         CFRelease(sessionKey);
 135
 136                         /*
 137                          * Lastly, get rid of the per-session structure.
 138                          */
 139                         free(thisSession);
 140                         sessions[i] = NULL;
 141
 142                         return;
 143                 }
 144         }
 145
 146         return;
 147 }
 148
 149
 150 __private_extern__
 151 void
 152 cleanupSession(mach_port_t server)
 153 {
 154         int             i;
 155
 156         for (i = 0; i < nSessions; i++) {
 157                 serverSessionRef        thisSession = sessions[i];
 158
 159                 if ((thisSession != NULL) && (thisSession->key == server)) {
 160                         /*
 161                          * session entry still exists.
 162                          */
 163
 164                         if (_configd_trace) {
 165                                 SCTrace(TRUE, _configd_trace, CFSTR("cleanup : %5d\n"), server);
 166                         }
 167
 168                         /*
 169                          * Ensure that any changes made while we held the "lock"
 170                          * are discarded.
 171                          */
 172                         if ((storeLocked > 0) &&
 173                             ((SCDynamicStorePrivateRef)thisSession->store)->locked) {
 174                                 /*
 175                                  * swap store and associated data which, after
 176                                  * being closed, will result in the restoration
 177                                  * of the original pre-"locked" data.
 178                                  */
 179                                 _swapLockedStoreData();
 180                         }
 181
 182                         /*
 183                          * Close any open connections including cancelling any outstanding
 184                          * notification requests and releasing any locks.
 185                          */
 186                         (void) __SCDynamicStoreClose(&thisSession->store, TRUE);
 187
 188                         /*
 189                          * Lastly, remove the session entry.
 190                          */
 191                         removeSession(server);
 192
 193                         return;
 194                 }
 195         }
 196         return;
 197 }
 198
 199
 200 __private_extern__
 201 void
 202 listSessions()
 203 {
 204         int     i;
 205
 206         fprintf(stderr, "Current sessions:");
 207         for (i = 0; i < nSessions; i++) {
 208                 serverSessionRef        thisSession = sessions[i];
 209
 210                 if (thisSession == NULL) {
 211                         continue;
 212                 }
 213
 214                 fprintf(stderr, " %d", thisSession->key);
 215
 216                 if (thisSession->store) {
 217                         task_t  task = ((SCDynamicStorePrivateRef)thisSession->store)->notifySignalTask;
 218
 219                         if (task != TASK_NULL) {
 220                                fprintf(stderr, "/%d", task);
 221                         }
 222                 }
 223         }
 224         fprintf(stderr, "\n");
 225 }
 226