Lines Matching refs:obj
77 MtpObject obj = mObject.getChild(path); in onEvent() local
83 if (obj == null) { in onEvent()
89 handleRemovedObject(obj); in onEvent()
420 for (MtpObject obj : mObjects.values()) { in close()
421 if (obj.getObserver() != null) { in close()
422 obj.getObserver().stopWatching(); in close()
423 obj.setObserver(null); in close()
426 for (MtpObject obj : mRoots.values()) { in close()
427 if (obj.getObserver() != null) { in close()
428 obj.getObserver().stopWatching(); in close()
429 obj.setObserver(null); in close()
483 private synchronized boolean isSpecialSubDir(MtpObject obj) { in isSpecialSubDir() argument
484 return obj.getParent().isRoot() && mSubdirectories != null in isSpecialSubDir()
485 && !mSubdirectories.contains(obj.getName()); in isSpecialSubDir()
494 MtpObject obj = null; in getByPath() local
497 obj = root; in getByPath()
502 if (obj == null || !obj.isDir()) in getByPath()
506 if (!obj.isVisited()) in getByPath()
507 getChildren(obj); in getByPath()
508 obj = obj.getChild(name); in getByPath()
510 return obj; in getByPath()
577 MtpObject obj = parent == 0 ? getStorageRoot(storageId) : getObject(parent); in getObjects() local
578 if (obj == null) in getObjects()
580 ret = getObjects(objs, obj, format, recursive); in getObjects()
664 MtpObject obj = new MtpObject(newName, getNextObjectId(), parent.mStorage, parent, isDir); in addObjectToCache() local
665 mObjects.put(obj.getId(), obj); in addObjectToCache() local
666 parent.addChild(obj); in addObjectToCache()
667 return obj; in addObjectToCache()
706 MtpObject obj = parent.getChild(path); in handleAddedObject() local
707 if (obj != null) { in handleAddedObject()
708 MtpObjectState state = obj.getState(); in handleAddedObject()
709 op = obj.getOperation(); in handleAddedObject()
710 if (obj.isDir() != isDir && state != MtpObjectState.FROZEN_REMOVED) in handleAddedObject()
711 Log.d(TAG, "Inconsistent directory info! " + obj.getPath()); in handleAddedObject()
712 obj.setDir(isDir); in handleAddedObject()
716 obj.setState(MtpObjectState.FROZEN_ADDED); in handleAddedObject()
719 obj.setState(MtpObjectState.NORMAL); in handleAddedObject()
729 Log.i(TAG, state + " transitioned to " + obj.getState() + " in op " + op); in handleAddedObject()
731 obj = MtpStorageManager.this.addObjectToCache(parent, path, isDir); in handleAddedObject()
732 if (obj != null) { in handleAddedObject()
733 MtpStorageManager.this.mMtpNotifier.sendObjectAdded(obj.getId()); in handleAddedObject()
746 if (op == MtpOperation.COPY && !obj.isVisited()) in handleAddedObject()
749 if (obj.getObserver() != null) { in handleAddedObject()
753 obj.setObserver(new MtpObjectObserver(obj)); in handleAddedObject()
754 obj.getObserver().startWatching(); in handleAddedObject()
755 obj.setVisited(true); in handleAddedObject()
759 try (DirectoryStream<Path> stream = Files.newDirectoryStream(obj.getPath())) { in handleAddedObject()
763 handleAddedObject(obj, file.getFileName().toString(), in handleAddedObject()
768 obj.getObserver().stopWatching(); in handleAddedObject()
769 obj.setObserver(null); in handleAddedObject()
774 private synchronized void handleRemovedObject(MtpObject obj) { in handleRemovedObject() argument
775 MtpObjectState state = obj.getState(); in handleRemovedObject()
776 MtpOperation op = obj.getOperation(); in handleRemovedObject()
779 obj.setState(MtpObjectState.FROZEN_REMOVED); in handleRemovedObject()
782 removeObjectFromCache(obj, op != MtpOperation.RENAME, false); in handleRemovedObject()
785 obj.setState(MtpObjectState.FROZEN_REMOVED); in handleRemovedObject()
788 if (MtpStorageManager.this.removeObjectFromCache(obj, true, true)) in handleRemovedObject()
789 MtpStorageManager.this.mMtpNotifier.sendObjectRemoved(obj.getId()); in handleRemovedObject()
793 Log.e(TAG, "Got unexpected object remove for " + obj.getName()); in handleRemovedObject()
796 Log.i(TAG, state + " transitioned to " + obj.getState() + " in op " + op); in handleRemovedObject()
801 MtpObject obj = parent.getChild(path); in handleChangedObject() local
802 if (obj != null) { in handleChangedObject()
804 if ((!obj.isDir()) && (obj.getSize() > 0)) in handleChangedObject()
806 MtpObjectState state = obj.getState(); in handleChangedObject()
807 op = obj.getOperation(); in handleChangedObject()
808 MtpStorageManager.this.mMtpNotifier.sendObjectInfoChanged(obj.getId()); in handleChangedObject()
810 … Log.d(TAG, "sendObjectInfoChanged: id=" + obj.getId() + ",size=" + obj.getSize()); in handleChangedObject()
836 MtpObject obj = mObjects.get(key); in dump() local
837 Log.i(TAG, key + " | " + (obj.getParent() == null ? obj.getParent().getId() : "null") in dump()
838 + " | " + obj.getName() + " | " + (obj.isDir() ? "dir" : "obj") in dump()
839 + " | " + (obj.isVisited() ? "v" : "nv") + " | " + obj.getState()); in dump()
853 for (MtpObject obj : objs) { in checkConsistency()
854 if (!obj.exists()) { in checkConsistency()
855 Log.w(TAG, "Object doesn't exist " + obj.getPath() + " " + obj.getId()); in checkConsistency()
858 if (obj.getState() != MtpObjectState.NORMAL) { in checkConsistency()
859 Log.w(TAG, "Object " + obj.getPath() + " in state " + obj.getState()); in checkConsistency()
862 if (obj.getOperation() != MtpOperation.NONE) { in checkConsistency()
863 Log.w(TAG, "Object " + obj.getPath() + " in operation " + obj.getOperation()); in checkConsistency()
866 if (!obj.isRoot() && mObjects.get(obj.getId()) != obj) { in checkConsistency()
867 Log.w(TAG, "Object " + obj.getPath() + " is not in map correctly"); in checkConsistency()
870 if (obj.getParent() != null) { in checkConsistency()
871 if (obj.getParent().isRoot() && obj.getParent() in checkConsistency()
872 != mRoots.get(obj.getParent().getId())) { in checkConsistency()
873 Log.w(TAG, "Root parent is not in root mapping " + obj.getPath()); in checkConsistency()
876 if (!obj.getParent().isRoot() && obj.getParent() in checkConsistency()
877 != mObjects.get(obj.getParent().getId())) { in checkConsistency()
878 Log.w(TAG, "Parent is not in object mapping " + obj.getPath()); in checkConsistency()
881 if (obj.getParent().getChild(obj.getName()) != obj) { in checkConsistency()
882 Log.w(TAG, "Child does not exist in parent " + obj.getPath()); in checkConsistency()
886 if (obj.isDir()) { in checkConsistency()
887 if (obj.isVisited() == (obj.getObserver() == null)) { in checkConsistency()
888 Log.w(TAG, obj.getPath() + " is " + (obj.isVisited() ? "" : "not ") in checkConsistency()
889 + " visited but observer is " + obj.getObserver()); in checkConsistency()
892 if (!obj.isVisited() && obj.getChildren().size() > 0) { in checkConsistency()
893 Log.w(TAG, obj.getPath() + " is not visited but has children"); in checkConsistency()
896 try (DirectoryStream<Path> stream = Files.newDirectoryStream(obj.getPath())) { in checkConsistency()
899 if (obj.isVisited() && in checkConsistency()
900 obj.getChild(file.getFileName().toString()) == null && in checkConsistency()
901 (mSubdirectories == null || !obj.isRoot() || in checkConsistency()
908 for (MtpObject child : obj.getChildren()) { in checkConsistency()
941 MtpObject obj = addObjectToCache(parent, name, format == MtpConstants.FORMAT_ASSOCIATION); in beginSendObject() local
942 if (obj == null) in beginSendObject()
944 obj.setState(MtpObjectState.FROZEN); in beginSendObject()
945 obj.setOperation(MtpOperation.ADD); in beginSendObject()
946 return obj.getId(); in beginSendObject()
955 public synchronized boolean endSendObject(MtpObject obj, boolean succeeded) { in endSendObject() argument
958 return generalEndAddObject(obj, succeeded, true); in endSendObject()
968 public synchronized boolean beginRenameObject(MtpObject obj, String newName) { in beginRenameObject() argument
970 Log.v(TAG, "beginRenameObject " + obj.getName() + " " + newName); in beginRenameObject()
971 if (obj.isRoot()) in beginRenameObject()
973 if (isSpecialSubDir(obj)) in beginRenameObject()
975 if (obj.getParent().getChild(newName) != null) in beginRenameObject()
979 MtpObject oldObj = obj.copy(false); in beginRenameObject()
980 obj.setName(newName); in beginRenameObject()
981 obj.getParent().addChild(obj); in beginRenameObject()
983 return generalBeginRenameObject(oldObj, obj); in beginRenameObject()
993 public synchronized boolean endRenameObject(MtpObject obj, String oldName, boolean success) { in endRenameObject() argument
996 MtpObject parent = obj.getParent(); in endRenameObject()
1003 temp.setName(obj.getName()); in endRenameObject()
1004 temp.setState(obj.getState()); in endRenameObject()
1005 oldObj = obj; in endRenameObject()
1008 obj = temp; in endRenameObject()
1009 parent.addChild(obj); in endRenameObject()
1012 return generalEndRenameObject(oldObj, obj, success); in endRenameObject()
1021 public synchronized boolean beginRemoveObject(MtpObject obj) { in beginRemoveObject() argument
1023 Log.v(TAG, "beginRemoveObject " + obj.getName()); in beginRemoveObject()
1024 return !obj.isRoot() && !isSpecialSubDir(obj) in beginRemoveObject()
1025 && generalBeginRemoveObject(obj, MtpOperation.DELETE); in beginRemoveObject()
1034 public synchronized boolean endRemoveObject(MtpObject obj, boolean success) { in endRemoveObject() argument
1038 if (obj.isDir()) { in endRemoveObject()
1039 for (MtpObject child : new ArrayList<>(obj.getChildren())) in endRemoveObject()
1043 return generalEndRemoveObject(obj, success, true) && ret; in endRemoveObject()
1052 public synchronized boolean beginMoveObject(MtpObject obj, MtpObject newParent) { in beginMoveObject() argument
1055 if (obj.isRoot()) in beginMoveObject()
1057 if (isSpecialSubDir(obj)) in beginMoveObject()
1060 if (newParent.getChild(obj.getName()) != null) in beginMoveObject()
1063 if (obj.getStorageId() != newParent.getStorageId()) { in beginMoveObject()
1069 MtpObject newObj = obj.copy(true); in beginMoveObject()
1072 return generalBeginRemoveObject(obj, MtpOperation.RENAME) in beginMoveObject()
1076 MtpObject oldObj = obj.copy(false); in beginMoveObject()
1077 obj.setParent(newParent); in beginMoveObject()
1079 obj.getParent().addChild(obj); in beginMoveObject()
1080 return generalBeginRenameObject(oldObj, obj); in beginMoveObject()
1157 private synchronized boolean generalEndAddObject(MtpObject obj, boolean succeeded, in generalEndAddObject() argument
1159 switch (obj.getState()) { in generalEndAddObject()
1164 obj.setState(MtpObjectState.FROZEN_ONESHOT_ADD); in generalEndAddObject()
1167 if (!removeObjectFromCache(obj, removeGlobal, false)) { in generalEndAddObject()
1173 obj.setState(MtpObjectState.NORMAL); in generalEndAddObject()
1175 MtpObject parent = obj.getParent(); in generalEndAddObject()
1177 if (!removeObjectFromCache(obj, removeGlobal, false)) in generalEndAddObject()
1179 handleAddedObject(parent, obj.getName(), obj.isDir()); in generalEndAddObject()
1184 if (!removeObjectFromCache(obj, removeGlobal, false)) in generalEndAddObject()
1188 mMtpNotifier.sendObjectRemoved(obj.getId()); in generalEndAddObject()
1198 private synchronized boolean generalEndRemoveObject(MtpObject obj, boolean success, in generalEndRemoveObject() argument
1200 switch (obj.getState()) { in generalEndRemoveObject()
1204 obj.setState(MtpObjectState.FROZEN_ONESHOT_DEL); in generalEndRemoveObject()
1207 obj.setState(MtpObjectState.NORMAL); in generalEndRemoveObject()
1212 obj.setState(MtpObjectState.NORMAL); in generalEndRemoveObject()
1215 MtpObject parent = obj.getParent(); in generalEndRemoveObject()
1216 if (!removeObjectFromCache(obj, removeGlobal, false)) in generalEndRemoveObject()
1218 handleAddedObject(parent, obj.getName(), obj.isDir()); in generalEndRemoveObject()
1223 if (!removeObjectFromCache(obj, removeGlobal, false)) in generalEndRemoveObject()
1227 mMtpNotifier.sendObjectRemoved(obj.getId()); in generalEndRemoveObject()
1251 private synchronized boolean generalBeginRemoveObject(MtpObject obj, MtpOperation op) { in generalBeginRemoveObject() argument
1252 obj.setState(MtpObjectState.FROZEN); in generalBeginRemoveObject()
1253 obj.setOperation(op); in generalBeginRemoveObject()
1254 if (obj.isDir()) { in generalBeginRemoveObject()
1255 for (MtpObject child : obj.getChildren()) in generalBeginRemoveObject()
1261 private synchronized boolean generalBeginCopyObject(MtpObject obj, boolean newId) { in generalBeginCopyObject() argument
1262 obj.setState(MtpObjectState.FROZEN); in generalBeginCopyObject()
1263 obj.setOperation(MtpOperation.COPY); in generalBeginCopyObject()
1265 obj.setId(getNextObjectId()); in generalBeginCopyObject()
1266 mObjects.put(obj.getId(), obj); in generalBeginCopyObject() local
1268 if (obj.isDir()) in generalBeginCopyObject()
1269 for (MtpObject child : obj.getChildren()) in generalBeginCopyObject()
1275 …private synchronized boolean generalEndCopyObject(MtpObject obj, boolean success, boolean addGloba… in generalEndCopyObject() argument
1277 mObjects.put(obj.getId(), obj); in generalEndCopyObject() local
1279 if (obj.isDir()) { in generalEndCopyObject()
1280 for (MtpObject child : new ArrayList<>(obj.getChildren())) { in generalEndCopyObject()
1285 ret = generalEndAddObject(obj, success, success || !addGlobal) && ret; in generalEndCopyObject()