DirectVolume.cpp revision 3374b41f1fea95dab455f565e6fc6db456bddc8b
1/* 2 * Copyright (C) 2008 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17#include <stdio.h> 18#include <stdlib.h> 19#include <string.h> 20#include <errno.h> 21 22#include <linux/kdev_t.h> 23 24#define LOG_TAG "DirectVolume" 25 26#include <cutils/log.h> 27#include <sysutils/NetlinkEvent.h> 28 29#include "DirectVolume.h" 30#include "VolumeManager.h" 31#include "ResponseCode.h" 32 33// #define PARTITION_DEBUG 34 35DirectVolume::DirectVolume(VolumeManager *vm, const char *label, 36 const char *mount_point, int partIdx) : 37 Volume(vm, label, mount_point) { 38 mPartIdx = partIdx; 39 40 mPaths = new PathCollection(); 41 for (int i = 0; i < MAX_PARTITIONS; i++) 42 mPartMinors[i] = -1; 43 mPendingPartMap = 0; 44 mDiskMajor = -1; 45 mDiskMinor = -1; 46 mDiskNumParts = 0; 47 48 setState(Volume::State_NoMedia); 49} 50 51DirectVolume::~DirectVolume() { 52 PathCollection::iterator it; 53 54 for (it = mPaths->begin(); it != mPaths->end(); ++it) 55 free(*it); 56 delete mPaths; 57} 58 59int DirectVolume::addPath(const char *path) { 60 mPaths->push_back(strdup(path)); 61 return 0; 62} 63 64dev_t DirectVolume::getDiskDevice() { 65 return MKDEV(mDiskMajor, mDiskMinor); 66} 67 68dev_t DirectVolume::getShareDevice() { 69 if (mPartIdx != -1) { 70 return MKDEV(mDiskMajor, mPartIdx); 71 } else { 72 return MKDEV(mDiskMajor, mDiskMinor); 73 } 74} 75 76void DirectVolume::handleVolumeShared() { 77 setState(Volume::State_Shared); 78} 79 80void DirectVolume::handleVolumeUnshared() { 81 setState(Volume::State_Idle); 82} 83 84int DirectVolume::handleBlockEvent(NetlinkEvent *evt) { 85 const char *dp = evt->findParam("DEVPATH"); 86 87 PathCollection::iterator it; 88 for (it = mPaths->begin(); it != mPaths->end(); ++it) { 89 if (!strncmp(dp, *it, strlen(*it))) { 90 /* We can handle this disk */ 91 int action = evt->getAction(); 92 const char *devtype = evt->findParam("DEVTYPE"); 93 94 if (action == NetlinkEvent::NlActionAdd) { 95 int major = atoi(evt->findParam("MAJOR")); 96 int minor = atoi(evt->findParam("MINOR")); 97 char nodepath[255]; 98 99 snprintf(nodepath, 100 sizeof(nodepath), "/dev/block/vold/%d:%d", 101 major, minor); 102 if (createDeviceNode(nodepath, major, minor)) { 103 SLOGE("Error making device node '%s' (%s)", nodepath, 104 strerror(errno)); 105 } 106 if (!strcmp(devtype, "disk")) { 107 handleDiskAdded(dp, evt); 108 } else { 109 handlePartitionAdded(dp, evt); 110 } 111 } else if (action == NetlinkEvent::NlActionRemove) { 112 if (!strcmp(devtype, "disk")) { 113 handleDiskRemoved(dp, evt); 114 } else { 115 handlePartitionRemoved(dp, evt); 116 } 117 } else if (action == NetlinkEvent::NlActionChange) { 118 if (!strcmp(devtype, "disk")) { 119 handleDiskChanged(dp, evt); 120 } else { 121 handlePartitionChanged(dp, evt); 122 } 123 } else { 124 SLOGW("Ignoring non add/remove/change event"); 125 } 126 127 return 0; 128 } 129 } 130 errno = ENODEV; 131 return -1; 132} 133 134void DirectVolume::handleDiskAdded(const char *devpath, NetlinkEvent *evt) { 135 mDiskMajor = atoi(evt->findParam("MAJOR")); 136 mDiskMinor = atoi(evt->findParam("MINOR")); 137 138 const char *tmp = evt->findParam("NPARTS"); 139 if (tmp) { 140 mDiskNumParts = atoi(tmp); 141 } else { 142 SLOGW("Kernel block uevent missing 'NPARTS'"); 143 mDiskNumParts = 1; 144 } 145 146 char msg[255]; 147 148 int partmask = 0; 149 int i; 150 for (i = 1; i <= mDiskNumParts; i++) { 151 partmask |= (1 << i); 152 } 153 mPendingPartMap = partmask; 154 155 if (mDiskNumParts == 0) { 156#ifdef PARTITION_DEBUG 157 SLOGD("Dv::diskIns - No partitions - good to go son!"); 158#endif 159 setState(Volume::State_Idle); 160 } else { 161#ifdef PARTITION_DEBUG 162 SLOGD("Dv::diskIns - waiting for %d partitions (mask 0x%x)", 163 mDiskNumParts, mPendingPartMap); 164#endif 165 setState(Volume::State_Pending); 166 } 167 168 snprintf(msg, sizeof(msg), "Volume %s %s disk inserted (%d:%d)", 169 getLabel(), getMountpoint(), mDiskMajor, mDiskMinor); 170 mVm->getBroadcaster()->sendBroadcast(ResponseCode::VolumeDiskInserted, 171 msg, false); 172} 173 174void DirectVolume::handlePartitionAdded(const char *devpath, NetlinkEvent *evt) { 175 int major = atoi(evt->findParam("MAJOR")); 176 int minor = atoi(evt->findParam("MINOR")); 177 178 int part_num; 179 180 const char *tmp = evt->findParam("PARTN"); 181 182 if (tmp) { 183 part_num = atoi(tmp); 184 } else { 185 SLOGW("Kernel block uevent missing 'PARTN'"); 186 part_num = 1; 187 } 188 189 if (part_num > mDiskNumParts) { 190 mDiskNumParts = part_num; 191 } 192 193 if (major != mDiskMajor) { 194 SLOGE("Partition '%s' has a different major than its disk!", devpath); 195 return; 196 } 197#ifdef PARTITION_DEBUG 198 SLOGD("Dv:partAdd: part_num = %d, minor = %d\n", part_num, minor); 199#endif 200 if (part_num >= MAX_PARTITIONS) { 201 SLOGE("Dv:partAdd: ignoring part_num = %d (max: %d)\n", part_num, MAX_PARTITIONS-1); 202 } else { 203 mPartMinors[part_num -1] = minor; 204 } 205 mPendingPartMap &= ~(1 << part_num); 206 207 if (!mPendingPartMap) { 208#ifdef PARTITION_DEBUG 209 SLOGD("Dv:partAdd: Got all partitions - ready to rock!"); 210#endif 211 if (getState() != Volume::State_Formatting) { 212 setState(Volume::State_Idle); 213 } 214 } else { 215#ifdef PARTITION_DEBUG 216 SLOGD("Dv:partAdd: pending mask now = 0x%x", mPendingPartMap); 217#endif 218 } 219} 220 221void DirectVolume::handleDiskChanged(const char *devpath, NetlinkEvent *evt) { 222 int major = atoi(evt->findParam("MAJOR")); 223 int minor = atoi(evt->findParam("MINOR")); 224 225 if ((major != mDiskMajor) || (minor != mDiskMinor)) { 226 return; 227 } 228 229 SLOGI("Volume %s disk has changed", getLabel()); 230 const char *tmp = evt->findParam("NPARTS"); 231 if (tmp) { 232 mDiskNumParts = atoi(tmp); 233 } else { 234 SLOGW("Kernel block uevent missing 'NPARTS'"); 235 mDiskNumParts = 1; 236 } 237 238 int partmask = 0; 239 int i; 240 for (i = 1; i <= mDiskNumParts; i++) { 241 partmask |= (1 << i); 242 } 243 mPendingPartMap = partmask; 244 245 if (getState() != Volume::State_Formatting) { 246 if (mDiskNumParts == 0) { 247 setState(Volume::State_Idle); 248 } else { 249 setState(Volume::State_Pending); 250 } 251 } 252} 253 254void DirectVolume::handlePartitionChanged(const char *devpath, NetlinkEvent *evt) { 255 int major = atoi(evt->findParam("MAJOR")); 256 int minor = atoi(evt->findParam("MINOR")); 257 SLOGD("Volume %s %s partition %d:%d changed\n", getLabel(), getMountpoint(), major, minor); 258} 259 260void DirectVolume::handleDiskRemoved(const char *devpath, NetlinkEvent *evt) { 261 int major = atoi(evt->findParam("MAJOR")); 262 int minor = atoi(evt->findParam("MINOR")); 263 char msg[255]; 264 265 SLOGD("Volume %s %s disk %d:%d removed\n", getLabel(), getMountpoint(), major, minor); 266 snprintf(msg, sizeof(msg), "Volume %s %s disk removed (%d:%d)", 267 getLabel(), getMountpoint(), major, minor); 268 mVm->getBroadcaster()->sendBroadcast(ResponseCode::VolumeDiskRemoved, 269 msg, false); 270 setState(Volume::State_NoMedia); 271} 272 273void DirectVolume::handlePartitionRemoved(const char *devpath, NetlinkEvent *evt) { 274 int major = atoi(evt->findParam("MAJOR")); 275 int minor = atoi(evt->findParam("MINOR")); 276 char msg[255]; 277 int state; 278 279 SLOGD("Volume %s %s partition %d:%d removed\n", getLabel(), getMountpoint(), major, minor); 280 281 /* 282 * The framework doesn't need to get notified of 283 * partition removal unless it's mounted. Otherwise 284 * the removal notification will be sent on the Disk 285 * itself 286 */ 287 state = getState(); 288 if (state != Volume::State_Mounted && state != Volume::State_Shared) { 289 return; 290 } 291 292 if ((dev_t) MKDEV(major, minor) == mCurrentlyMountedKdev) { 293 /* 294 * Yikes, our mounted partition is going away! 295 */ 296 297 snprintf(msg, sizeof(msg), "Volume %s %s bad removal (%d:%d)", 298 getLabel(), getMountpoint(), major, minor); 299 mVm->getBroadcaster()->sendBroadcast(ResponseCode::VolumeBadRemoval, 300 msg, false); 301 302 if (mVm->cleanupAsec(this, true)) { 303 SLOGE("Failed to cleanup ASEC - unmount will probably fail!"); 304 } 305 306 if (Volume::unmountVol(true)) { 307 SLOGE("Failed to unmount volume on bad removal (%s)", 308 strerror(errno)); 309 // XXX: At this point we're screwed for now 310 } else { 311 SLOGD("Crisis averted"); 312 } 313 } else if (state == Volume::State_Shared) { 314 /* removed during mass storage */ 315 snprintf(msg, sizeof(msg), "Volume %s bad removal (%d:%d)", 316 getLabel(), major, minor); 317 mVm->getBroadcaster()->sendBroadcast(ResponseCode::VolumeBadRemoval, 318 msg, false); 319 320 if (mVm->unshareVolume(getLabel(), "ums")) { 321 SLOGE("Failed to unshare volume on bad removal (%s)", 322 strerror(errno)); 323 } else { 324 SLOGD("Crisis averted"); 325 } 326 } 327} 328 329/* 330 * Called from base to get a list of devicenodes for mounting 331 */ 332int DirectVolume::getDeviceNodes(dev_t *devs, int max) { 333 334 if (mPartIdx == -1) { 335 // If the disk has no partitions, try the disk itself 336 if (!mDiskNumParts) { 337 devs[0] = MKDEV(mDiskMajor, mDiskMinor); 338 return 1; 339 } 340 341 int i; 342 for (i = 0; i < mDiskNumParts; i++) { 343 if (i == max) 344 break; 345 devs[i] = MKDEV(mDiskMajor, mPartMinors[i]); 346 } 347 return mDiskNumParts; 348 } 349 devs[0] = MKDEV(mDiskMajor, mPartMinors[mPartIdx -1]); 350 return 1; 351} 352