Author: cwiklik
Date: Fri Mar 28 16:30:43 2014
New Revision: 1582809
URL: http://svn.apache.org/r1582809
Log:
UIMA-3708 reduced logging in the PM
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-pm/src/main/java/org/apache/uima/ducc/pm/ProcessManagerComponent.java
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-pm/src/main/java/org/apache/uima/ducc/pm/ProcessManagerComponent.java
URL:
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-pm/src/main/java/org/apache/uima/ducc/pm/ProcessManagerComponent.java?rev=1582809&r1=1582808&r2=1582809&view=diff
==============================================================================
---
uima/sandbox/uima-ducc/trunk/uima-ducc-pm/src/main/java/org/apache/uima/ducc/pm/ProcessManagerComponent.java
(original)
+++
uima/sandbox/uima-ducc/trunk/uima-ducc-pm/src/main/java/org/apache/uima/ducc/pm/ProcessManagerComponent.java
Fri Mar 28 16:30:43 2014
@@ -156,17 +156,11 @@ implements ProcessManager {
addArgument(((DuccUimaDeploymentDescriptor)dcj.getUimaDeployableConfiguration()).getDeploymentDescriptorPath());
}
-
- // Calculate Process memory allocation including a fudge
factor (if one is defined). The
- // returned value is in terms of Megs.
-// long processAdjustedMemorySize =
-//
calculateProcessMemoryAssignment(dcj.getSchedulingInfo().getShareMemorySize(),
-// dcj.getSchedulingInfo().getShareMemoryUnits());
// add fudge factor (5% default) to adjust memory computed
above
processAdjustedMemorySize += (processAdjustedMemorySize *
((double)fudgeFactor/100));
pma.setMaxMemoryWithFudge(processAdjustedMemorySize);
- logger.info(methodName,dcj.getDuccId(),"--------------- User
Requested Memory For
Process:"+dcj.getSchedulingInfo().getShareMemorySize()+dcj.getSchedulingInfo().getShareMemoryUnits()+"
PM Calculated Memory Assignment of:"+processAdjustedMemorySize);
+ logger.debug(methodName,dcj.getDuccId(),"--------------- User
Requested Memory For
Process:"+dcj.getSchedulingInfo().getShareMemorySize()+dcj.getSchedulingInfo().getShareMemoryUnits()+"
PM Calculated Memory Assignment of:"+processAdjustedMemorySize);
ICommandLine driverCmdLine = null;
IDuccProcess driverProcess = null;
@@ -198,14 +192,14 @@ implements ProcessManager {
IDuccReservationMap reservationMap =
((DuccWorkReservation)
entry.getValue()).getReservationMap();
reservationList.add(new DuccUserReservation(userId,
((DuccWorkReservation) entry.getValue()).getDuccId(), reservationMap));
- logger.info(methodName,null,"--------------- Added
reservation for user:"+userId);
+ logger.debug(methodName,null,"--------------- Added
reservation for user:"+userId);
}
}
}
logger.info(methodName, null , "---- PM Dispatching DuccJobsStateEvent
request to Agent(s) - State Map Size:"+jobDeploymentList.size()+" Reservation
List:"+reservationList.size());
// Dispatch state update to agents
eventDispatcher.dispatch(new
DuccJobsStateEvent(DuccEvent.EventType.PM_STATE, jobDeploymentList,
reservationList));
- logger.info(methodName, null , "+++++ PM Dispatched State To Agent(s)");
+ logger.debug(methodName, null , "+++++ PM Dispatched State To Agent(s)");
} catch( Throwable t ) {
logger.error(methodName,null,t);
}