From: Sweidan Omar Date: Mon, 6 Dec 2021 10:19:50 +0000 (+0000) Subject: git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube... X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=9efd00b67fb0ca470505858541d4d933c9d3adb9;p=mediacube.git git-tfs-id: [tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32416 --- diff --git a/server/user.jobengine.osgi.db/src/user/jobengine/db/ItemManager.java b/server/user.jobengine.osgi.db/src/user/jobengine/db/ItemManager.java index f543667d..96249b39 100644 --- a/server/user.jobengine.osgi.db/src/user/jobengine/db/ItemManager.java +++ b/server/user.jobengine.osgi.db/src/user/jobengine/db/ItemManager.java @@ -148,17 +148,18 @@ public class ItemManager extends MemoryCache implements IItemManager { traceIn(); contextPool = new ContextPool(); - // try { - // getItemTypes(); - // } catch (Exception e) { - // logger.error("Can't load item types. System message is: {}", e.getMessage()); - // } + // try { + // getItemTypes(); + // } catch (Exception e) { + // logger.error("Can't load item types. System message is: {}", e.getMessage()); + // } traceOut(); } @Override - public FileType createFileType(String name, String description, String videoCodec, String audioCodec, int videoTracks, int audioTracks, float frameRate) { + public FileType createFileType(String name, String description, String videoCodec, String audioCodec, + int videoTracks, int audioTracks, float frameRate) { traceIn(); FileType entity = new FileType(); entity.setPersister(this); @@ -269,8 +270,8 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public Metadata createMetadata(MetadataElement mde, ListType listType, GuiType guiType, String sqlField, StaticTables staticTable, String pojoField, - MdType... flags) { + public Metadata createMetadata(MetadataElement mde, ListType listType, GuiType guiType, String sqlField, + StaticTables staticTable, String pojoField, MdType... flags) { traceIn(); Metadata entity = new Metadata(); int values = MdType.getValues(flags); @@ -325,7 +326,8 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public MetadataType createMetadataType(String name, BaseType baseType, String javaType, String dataType, int length) { + public MetadataType createMetadataType(String name, BaseType baseType, String javaType, String dataType, + int length) { traceIn(); MetadataType entity = new MetadataType(); entity.setPersister(this); @@ -391,8 +393,8 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public StoreUri createStoreUri(RemoteStoreProtocol protocol, String uri, int portNumber, boolean isStream, boolean isSource, boolean isTarget, - String userName, String password, String rootPath) { + public StoreUri createStoreUri(RemoteStoreProtocol protocol, String uri, int portNumber, boolean isStream, + boolean isSource, boolean isTarget, String userName, String password, String rootPath) { traceIn(); StoreUri entity = new StoreUri(); entity.setPersister(this); @@ -409,7 +411,8 @@ public class ItemManager extends MemoryCache implements IItemManager { @Override public StoreUri createStoreUri(URI uri) { - StoreUri result = createStoreUri(RemoteStoreProtocol.fromString(uri.toString()), uri.getHost(), uri.getPort(), false, false, false, null, null, null); + StoreUri result = createStoreUri(RemoteStoreProtocol.fromString(uri.toString()), uri.getHost(), uri.getPort(), + false, false, false, null, null, null); result.setCurrentPath(uri.getPath()); return result; } @@ -430,8 +433,9 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public WorkflowAction createWorkflowAction(Timestamp touched, Timestamp started, Timestamp finished, boolean successful, String houseId, String description, - String source, String destination, String tag, long size) { + public WorkflowAction createWorkflowAction(Timestamp touched, Timestamp started, Timestamp finished, + boolean successful, String houseId, String description, String source, String destination, String tag, + long size) { traceIn(); WorkflowAction entity = new WorkflowAction(); @@ -471,7 +475,8 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public StoreUri ensureUri(String storeName, String uri, boolean isSystem, boolean isLowres, RemoteStoreProtocol protocol) { + public StoreUri ensureUri(String storeName, String uri, boolean isSystem, boolean isLowres, + RemoteStoreProtocol protocol) { Store store = getStore(storeName); StoreUri result = null; if (store == null) { @@ -492,14 +497,16 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public void executeQuery(Connection connection, String query, IResultSetConsumer consumer, IStatementDecorator decorator) { + public void executeQuery(Connection connection, String query, IResultSetConsumer consumer, + IStatementDecorator decorator) { ResultSet rs = null; PreparedStatement st = null; try { - //st = connection.prepareStatement(query, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); - // rs.last(); - // int size = rs.getRow(); - // rs.beforeFirst(); + // st = connection.prepareStatement(query, ResultSet.TYPE_SCROLL_INSENSITIVE, + // ResultSet.CONCUR_READ_ONLY); + // rs.last(); + // int size = rs.getRow(); + // rs.beforeFirst(); st = connection.prepareStatement(query); if (decorator != null) @@ -553,7 +560,8 @@ public class ItemManager extends MemoryCache implements IItemManager { } @Override - public int executeUpdate(Connection connection, String query, IStatementDecorator decorator, IResultSetConsumer keysConsumer) { + public int executeUpdate(Connection connection, String query, IStatementDecorator decorator, + IResultSetConsumer keysConsumer) { int result = -1; PreparedStatement st = null; ResultSet rs = null; @@ -636,7 +644,7 @@ public class ItemManager extends MemoryCache implements IItemManager { return result; } - //a map miatt az ID-k elerhetoek + // a map miatt az ID-k elerhetoek @Override public TreeMap getAllTags() { TreeMap result = new TreeMap<>(); @@ -671,11 +679,11 @@ public class ItemManager extends MemoryCache implements IItemManager { Store sysLowres = getSystemStore(true); StoreUri lowresUri = selectLowresUri(sysLowres); if (lowresUri == null) { - //az elsodlegesen tul keves a hely + // az elsodlegesen tul keves a hely StoreDAO dao = (StoreDAO) getBaseDAO(Store.class); List stores = ListUtils.cast(dao.getAll()); for (Store store : stores) { - //kompatibilitas miatt ez maradt + // kompatibilitas miatt ez maradt if (store.isLowres() || store.isSystem()) continue; lowresUri = selectLowresUri(store); @@ -687,7 +695,7 @@ public class ItemManager extends MemoryCache implements IItemManager { } else result = sysLowres; - //nincs mas + // nincs mas if (result == null) result = sysLowres; return result; @@ -793,8 +801,8 @@ public class ItemManager extends MemoryCache implements IItemManager { try { String date = df.format(scheduleDate.getTime()); String query = String.format( - "SELECT COUNT(*) as count, SUM(size) as duration FROM VW_RD_INGEST WHERE houseid='%s' AND finished LIKE '%s%%' GROUP BY houseid", houseId, - date); + "SELECT COUNT(*) as count, SUM(size) as duration FROM VW_RD_INGEST WHERE houseid='%s' AND finished LIKE '%s%%' GROUP BY houseid", + houseId, date); st = connection.prepareStatement(query); rs = st.executeQuery(); if (rs.next()) { @@ -1128,7 +1136,8 @@ public class ItemManager extends MemoryCache implements IItemManager { Calendar end = CalendarUtils.createZeroCalendar(date); end.add(Calendar.DAY_OF_YEAR, 1); WorkflowActionDAO dao = (WorkflowActionDAO) getBaseDAO(WorkflowAction.class); - return (List) (List) dao.getWorkflowActions(new Timestamp(begin.getTimeInMillis()), new Timestamp(end.getTimeInMillis())); + return (List) (List) dao.getWorkflowActions(new Timestamp(begin.getTimeInMillis()), + new Timestamp(end.getTimeInMillis())); } void initialize() { @@ -1334,17 +1343,18 @@ public class ItemManager extends MemoryCache implements IItemManager { return result; } - //min 5 GB szabad hely eseten ad vissza LOCAL uri-t + // min. 5 GB szabad hely eseten ad vissza LOCAL uri-t public StoreUri selectLowresUri(Store store) throws Exception { StoreUri result = null; List uris = store.getStoreUris(); if (uris != null && uris.size() > 1) { - uris = uris.stream().filter(u -> u.getProtocol() == RemoteStoreProtocol.LOCAL && u.isTarget()).sorted((u1, u2) -> { - return Integer.compare(u1.getPriority(), u2.getPriority()); - }).collect(Collectors.toList()); + uris = uris.stream().filter(u -> u.getProtocol() == RemoteStoreProtocol.LOCAL && u.isTarget()) + .sorted((u1, u2) -> { + return Integer.compare(u1.getPriority(), u2.getPriority()); + }).collect(Collectors.toList()); for (StoreUri uri : uris) { - //min 5GB + // min 5GB if (FileSystemUtils.freeSpaceKb(uri.toString(true)) > 5000000) { result = uri; break; @@ -1376,8 +1386,8 @@ public class ItemManager extends MemoryCache implements IItemManager { message = e.getClass().getName(); StackTraceElement element = Thread.currentThread().getStackTrace()[2]; message += String.format(", source: %1$s.%2$s", element.getClassName(), element.getMethodName()); - // if (logger != null) - // logger.error(message, e); + // if (logger != null) + // logger.error(message, e); throw new ItemManagerException(message); } }