From: Florian L. <fle...@us...> - 2005-11-15 12:51:06
|
Update of /cvsroot/magicmap/magicmapserver/src/net/sf/magicmap/server/facade In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv29526/src/net/sf/magicmap/server/facade Modified Files: PositionFacade2.java Log Message: Implementation des Positioning-Caches Index: PositionFacade2.java =================================================================== RCS file: /cvsroot/magicmap/magicmapserver/src/net/sf/magicmap/server/facade/PositionFacade2.java,v retrieving revision 1.9 retrieving revision 1.10 diff -C2 -d -r1.9 -r1.10 *** PositionFacade2.java 14 Nov 2005 14:11:29 -0000 1.9 --- PositionFacade2.java 15 Nov 2005 12:50:56 -0000 1.10 *************** *** 46,50 **** --- 46,54 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); createOrUpdatePositionInternal(sessionId, mapName, positionX, positionY, character, positionName, fixed, pm); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ e.printStackTrace(); *************** *** 227,232 **** PersistenceManager pm = null; try{ ! pm = JDOUtil.pmfactory.getPersistenceManager(); createOrUpdateClientPositionInternal(sessionId, mapName, positionX, positionY, character, clientMac, fixed, pm); } catch (Exception e){ e.printStackTrace(); --- 231,240 ---- PersistenceManager pm = null; try{ ! pm = JDOUtil.pmfactory.getPersistenceManager(); ! pm.currentTransaction().begin(); createOrUpdateClientPositionInternal(sessionId, mapName, positionX, positionY, character, clientMac, fixed, pm); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ e.printStackTrace(); *************** *** 286,289 **** --- 294,298 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); checkSession(sessionId, pm); Map map = checkMap(mapName, positionX, positionY, pm); *************** *** 303,307 **** pos.setPosY(positionY); PositionCache.getPositionCache().createOrUpdatePosition(map,pos); ! } catch (Exception e){ e.printStackTrace(); --- 312,318 ---- pos.setPosY(positionY); PositionCache.getPositionCache().createOrUpdatePosition(map,pos); ! if (pm.currentTransaction().isActive()){ ! pm.currentTransaction().commit(); ! } } catch (Exception e){ e.printStackTrace(); *************** *** 328,334 **** --- 339,349 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); checkSession(sessionId, pm); Map map = checkMap(mapname, newPositionX, newPositionY, pm); PositionCache.getPositionCache().movePosition(map, positionId, newPositionX, newPositionY, fixed); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ *************** *** 355,361 **** --- 370,380 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); checkSession(sessionId, pm); Map map = checkMap(mapname, pm); PositionCache.getPositionCache().deletePosition(map,positionId); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ e.printStackTrace(); *************** *** 384,390 **** --- 403,413 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); checkSession(sessionId, pm); Map map = checkMap(mapName, pm); result = PositionCache.getPositionCache().getPositionsForMapSince(map,timeStamp); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ e.printStackTrace(); *************** *** 413,416 **** --- 436,440 ---- try{ pm = JDOUtil.pmfactory.getPersistenceManager(); + pm.currentTransaction().begin(); checkSession(sessionId, pm); Map map = checkMap(mapName, pm); *************** *** 418,421 **** --- 442,448 ---- PositionDTO pos = PositionCache.getPositionCache().getPositionForClientOnMap(map,clientMac); positionResult = String.valueOf(pos.getPosX())+ "#" + String.valueOf(pos.getPosY()) + "#" + String.valueOf(pos.isFixed()); + if (pm.currentTransaction().isActive()){ + pm.currentTransaction().commit(); + } } catch (Exception e){ e.printStackTrace(); |