Map<String, InvocationInfo> procInfoMap = m_connectionStates.get(connectionId);
if (procInfoMap == null) {
procInfoMap = new NonBlockingHashMap<String, InvocationInfo>();
needToInsert = true;
}
InvocationInfo info = procInfoMap.get(procedureName);
if(info == null){
info = new InvocationInfo(connectionHostname);
procInfoMap.put(procedureName, info);
}
info.processInvocation((int)TimeUnit.NANOSECONDS.toMillis(deltaNanos), status);
m_latencyInfo.recordValue(Math.max(1, Math.min(TimeUnit.NANOSECONDS.toMicros(deltaNanos), m_latencyInfo.getHighestTrackableValue())));
if (needToInsert) {
m_connectionStates.put(connectionId, procInfoMap);
}
}