| /glassfish-3.1.2/ejb/ejb-container/src/main/java/com/sun/ejb/containers/ |
| H A D | TimerPrimaryKey.java | 47 public String timerId; field in class:TimerPrimaryKey
53 timerId = pk;
57 return timerId;
64 return (tpk.timerId.equals(timerId));
71 return timerId.hashCode();
76 return timerId;
|
| H A D | EJBTimerService.java | 547 TimerPrimaryKey timerId = getPrimaryKey(timer);
548 container.addSchedule(timerId, ts);
571 TimerPrimaryKey timerId = getPrimaryKey(timer);
572 if (getTimerState(timerId) != null) {
605 (timerId, initialExpiration,
612 timerCache_.addTimer(timerId, timerState);
701 timerIdsToRemove.add(timerId);
710 "Skipping timer " + timerId +
723 TimerPrimaryKey timerId = nextTimer.getTimerId();
725 scheduleTask(timerId, expiratio
868 rescheduleTask(TimerPrimaryKey timerId, Date expiration) argument
872 scheduleTask(TimerPrimaryKey timerId, Date expiration) argument
876 scheduleTask(TimerPrimaryKey timerId, Date expiration, boolean rescheduled) argument
932 cancelTask(TimerPrimaryKey timerId) argument
962 restoreTaskToDelivered(TimerPrimaryKey timerId) argument
980 expungeTimer(TimerPrimaryKey timerId) argument
1069 expungeTimer(TimerPrimaryKey timerId, boolean removeTimerBean) argument
1497 getTimerState(TimerPrimaryKey timerId) argument
1501 getNonPersistentTimerState(TimerPrimaryKey timerId) argument
1514 cancelTimer(TimerPrimaryKey timerId) argument
1552 getNextTimeout(TimerPrimaryKey timerId) argument
1589 getInfo(TimerPrimaryKey timerId) argument
1605 getScheduleExpression(TimerPrimaryKey timerId) argument
1611 isCalendarTimer(TimerPrimaryKey timerId) argument
1617 isPersistent(TimerPrimaryKey timerId) argument
1635 timerExists(TimerPrimaryKey timerId) argument
1660 getTimerSchedule(TimerPrimaryKey timerId) argument
1681 removeTimerBean(TimerPrimaryKey timerId) argument
1691 getPersistentTimer(TimerPrimaryKey timerId) argument
1702 getNonPersistentTimer(TimerPrimaryKey timerId) argument
1723 deliverTimeout(TimerPrimaryKey timerId) argument
1936 postEjbTimeout(TimerPrimaryKey timerId) argument
2029 checkForTimerValidity(TimerPrimaryKey timerId) argument
2041 getValidTimerFromDB(TimerPrimaryKey timerId) argument
2104 taskExpired(TimerPrimaryKey timerId) argument
2178 addTimerSynchronization(EJBContextImpl context_, String timerId, Date initialExpiration, long containerId, String ownerId) argument
2186 addTimerSynchronization(EJBContextImpl context_, String timerId, Date initialExpiration, long containerId, String ownerId, boolean persistent) argument
2218 cancelTimerSynchronization(EJBContextImpl context_, TimerPrimaryKey timerId, long containerId, String ownerId) argument
2225 cancelTimerSynchronization(EJBContextImpl context_, TimerPrimaryKey timerId, long containerId, String ownerId, boolean persistent) argument
2294 getContainerSynch(EJBContextImpl context_, String timerId, boolean persistent) argument
2460 addTimer(TimerPrimaryKey timerId, RuntimeTimerState timerState) argument
2500 removeTimer(TimerPrimaryKey timerId) argument
2544 getTimerState(TimerPrimaryKey timerId) argument
2549 getNonPersistentTimerState( TimerPrimaryKey timerId) argument
2638 TaskExpiredWork(EJBTimerService timerService, TimerPrimaryKey timerId) argument
2659 TimerSynch(TimerPrimaryKey timerId, int state, Date timeout, BaseContainer container, EJBTimerService timerService) argument
[all...] |
| H A D | EJBTimerTask.java | 65 EJBTimerTask(Date timeout, TimerPrimaryKey timerId, argument
69 timerId_ = timerId;
|
| H A D | ContainerSynchronization.java | 115 void addTimerSynchronization(TimerPrimaryKey timerId, Synchronization sync) argument
117 timerSyncs.put(timerId, sync);
120 // Might be null if no timer synch object for this timerId in this tx
121 Synchronization getTimerSynchronization(TimerPrimaryKey timerId) { argument
122 return (Synchronization) timerSyncs.get(timerId);
125 void removeTimerSynchronization(TimerPrimaryKey timerId) { argument
126 timerSyncs.remove(timerId);
|
| H A D | TimerLocal.java | 64 void cancel(TimerPrimaryKey timerId) throws Exception; argument
68 TimerState createTimer(String timerId, argument
75 TimerState findTimer(TimerPrimaryKey timerId); argument
77 void remove(TimerPrimaryKey timerId); argument
|
| H A D | TimerWrapper.java | 78 TimerWrapper(TimerPrimaryKey timerId, EJBTimerService timerService) { argument
79 timerId_ = timerId;
298 SerializedTimerWrapper(TimerPrimaryKey timerId) { argument
299 timerId_ = timerId;
321 public TimerHandleImpl(TimerPrimaryKey timerId) { argument
322 timerId_ = timerId;
354 public static TimerWrapper getTimerInternal(TimerPrimaryKey timerId) argument
364 if( timerService.timerExists(timerId) ) {
365 timer = new TimerWrapper(timerId, timerService);
|
| H A D | TimerState.java | 72 query="SELECT t.timerId FROM Timer t WHERE t.containerId = ?1"
76 query="SELECT t.timerId FROM Timer t WHERE t.containerId = ?1 AND t.state=?2"
80 query="SELECT t.timerId FROM Timer t WHERE t.containerId = ?1 AND t.ownerId=?2"
84 query="SELECT t.timerId FROM Timer t WHERE t.containerId = ?1 AND t.ownerId=?2 AND t.state=?3"
88 query="SELECT t.timerId FROM Timer t WHERE t.ownerId = ?1"
92 query="SELECT t.timerId FROM Timer t WHERE t.ownerId = ?1 AND t.state=?2"
113 query="SELECT t FROM Timer t WHERE t.ownerId = ?1 ORDER BY t.timerId"
177 private String timerId; field in class:TimerState
216 return timerId;
219 public void setTimerId(String timerId) { argument
336 TimerState(String timerId, long containerId, long applicationId, String ownerId, Object timedObjectPrimaryKey, Date initialExpiration, long intervalDuration, TimerSchedule schedule, Serializable info) argument
[all...] |
| H A D | EJBTimerServiceWrapper.java | 276 TimerPrimaryKey timerId = null;
278 timerId = timerService_.createTimer
287 return new TimerWrapper(timerId, timerService_);
306 TimerPrimaryKey timerId = null;
308 timerId = timerService_.createTimer
317 return new TimerWrapper(timerId, timerService_);
323 TimerPrimaryKey timerId = null;
325 timerId = timerService_.createTimer
334 return new TimerWrapper(timerId, timerService_);
|
| H A D | TimerBean.java | 104 public TimerState findTimer(TimerPrimaryKey timerId) { argument
105 return em.find(TimerState.class, timerId);
274 (String timerId, long containerId, long applicationId, String ownerId,
282 timer = new TimerState (timerId, containerId, applicationId, ownerId,
292 logger.log(Level.FINE, "TimerBean.createTimer() ::timerId=" +
322 timerId, initialExpiration, containerId, ownerId);
345 public void remove(TimerPrimaryKey timerId) { argument
346 TimerState timer = em.find(TimerState.class, timerId);
353 for(TimerPrimaryKey timerId: timerIds) {
355 remove(timerId);
273 createTimer(String timerId, long containerId, long applicationId, String ownerId, Object timedObjectPrimaryKey, Date initialExpiration, long intervalDuration, TimerSchedule schedule, TimerConfig timerConfig) argument
363 cancel(TimerPrimaryKey timerId) argument
691 testCreate(String timerId, EJBContext context, String ownerId, Date initialExpiration, long intervalDuration, Serializable info) argument
[all...] |
| H A D | RuntimeTimerState.java | 117 RuntimeTimerState(TimerPrimaryKey timerId, argument
124 this(timerId, initialExpiration, intervalDuration, container.getContainerId(),
128 RuntimeTimerState(TimerPrimaryKey timerId, argument
140 timerId_ = timerId;
|
| H A D | BaseContainer.java | 2176 protected void addSchedule(TimerPrimaryKey timerId, TimerSchedule ts) { argument
2180 scheduleIds.put(timerId, m);
|