Changeset 191
- Timestamp:
- 07/15/11 04:22:10 (13 years ago)
- Location:
- trunk/src/com/bowman/cardserv
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/com/bowman/cardserv/ClusteredCache.java
r188 r191 372 372 protected void addRequest(int successFactor, CamdNetMessage request, boolean alwaysWait) { 373 373 super.addRequest(successFactor, request, alwaysWait); 374 if(!alwaysWait ) { // dont send any notification when we wont be forwarding to card374 if(!alwaysWait && successFactor != -1) { // dont send any notification when we wont be forwarding to card 375 375 request.setArbiterNumber(null); // remove any arbitration marker 376 376 sendMessage(request, null); // tell all proxy peers that we're now processing this request … … 582 582 if(reply.getConnectorName() != null) reply.setConnectorName("remote: " + reply.getConnectorName()); 583 583 if(!this.contains(request)) super.processReply(request, reply); 584 else receivedDiscarded++; 584 else { 585 receivedDiscarded++; 586 if(monitor != null) monitor.onReply(request, reply); // allow plugin to track discards 587 } 585 588 if(debug) logger.fine("Cache reply received for: " + request.hashCodeStr() + " -> " + reply.hashCodeStr() + 586 589 " (from: " + reply.getOriginAddress() + ") " + packet.getLength() + " bytes"); -
trunk/src/com/bowman/cardserv/DefaultCache.java
r187 r191 17 17 protected MessageCacheMap pendingEcms; 18 18 protected MessageCacheMap ecmMap; 19 protected CacheListener listener, forwarder;19 protected CacheListener listener, monitor; 20 20 21 21 protected long maxAge; … … 142 142 143 143 public synchronized boolean processReply(CamdNetMessage request, CamdNetMessage reply) { 144 if(monitor != null) monitor.onReply(request, reply); 144 145 if(reply == null || reply.isEmpty()) { 145 146 removeRequest(request); 146 147 notifyAll(); 147 148 } else { 148 if(forwarder != null) forwarder.onReply(request, reply);149 149 if(listener != null) listener.onReply(request, reply); 150 150 if(pendingEcms.containsKey(request)) { … … 187 187 CamdNetMessage oldRequest = (CamdNetMessage)pendingEcms.put(request, request); 188 188 if(pendingEcms.size() > pendingPeak) pendingPeak = pendingEcms.size(); 189 if(oldRequest == null) { 190 if(forwarder != null) forwarder.onRequest(successFactor, request); 191 if(listener != null) listener.onRequest(successFactor, request); 192 } 189 if(monitor != null) monitor.onRequest(successFactor, request); 190 if(oldRequest == null && listener != null) listener.onRequest(successFactor, request); 193 191 } 194 192 … … 221 219 } 222 220 223 public void set Forwarder(CacheListener forwarder) {224 this. forwarder = forwarder;225 } 226 227 public CacheListener get Forwarder() {228 return forwarder;221 public void setMonitor(CacheListener monitor) { 222 this.monitor = monitor; 223 } 224 225 public CacheListener getMonitor() { 226 return monitor; 229 227 } 230 228 -
trunk/src/com/bowman/cardserv/interfaces/CacheHandler.java
r133 r191 22 22 void setListener(CacheListener listener); 23 23 CacheListener getListener(); 24 void set Forwarder(CacheListener forwarder);25 CacheListener get Forwarder();24 void setMonitor(CacheListener monitor); 25 CacheListener getMonitor(); 26 26 27 27 }
Note:
See TracChangeset
for help on using the changeset viewer.