Subversion Repository Public Repository

litesoft

Diff Revisions 2 vs 24 for /trunk/Java/core/Server/src/org/litesoft/changemanagement/nonpublic/LowLevelChangeListenerManager.java

Diff revisions: vs.
  @@ -199,31 +199,37 @@
199 199 super( pListener );
200 200 }
201 201
202 + @Override
202 203 public boolean isAll()
203 204 {
204 205 return true;
205 206 }
206 207
208 + @Override
207 209 public boolean isAll( String pName )
208 210 {
209 211 return true;
210 212 }
211 213
214 + @Override
212 215 public boolean hasAll( String[] pNames )
213 216 {
214 217 return true;
215 218 }
216 219
220 + @Override
217 221 public boolean hasAll( String pName, Serializable[] pUniqueKeys )
218 222 {
219 223 return true;
220 224 }
221 225
226 + @Override
222 227 public ServerStateChangeSet createListFrom( ServerStateChangeSet pAllChanges_Immutable )
223 228 {
224 229 return pAllChanges_Immutable;
225 230 }
226 231
232 + @Override
227 233 public String toString()
228 234 {
229 235 return "All POs";
  @@ -286,6 +292,7 @@
286 292 private Map<String, KeyInterestHelper> mNamesToKeyInterestHelpers =
287 293 new HashMap<String, KeyInterestHelper>();
288 294
295 + @Override
289 296 public String toString()
290 297 {
291 298 StringBuilder sb = new StringBuilder( "Only: " );
  @@ -312,12 +319,14 @@
312 319 return (helper != null) && helper.isInterestedIn( pUniqueKey );
313 320 }
314 321
322 + @Override
315 323 public boolean isAll( String pName )
316 324 {
317 325 KeyInterestHelper helper = mNamesToKeyInterestHelpers.get( pName );
318 326 return (helper != null) && helper.isAll();
319 327 }
320 328
329 + @Override
321 330 public boolean hasAll( String[] pNames )
322 331 {
323 332 for ( String zName : pNames )
  @@ -330,12 +339,14 @@
330 339 return true;
331 340 }
332 341
342 + @Override
333 343 public boolean hasAll( String pName, Serializable[] pUniqueKeys )
334 344 {
335 345 KeyInterestHelper helper = mNamesToKeyInterestHelpers.get( pName );
336 346 return (helper != null) && helper.isInterestedInAll( pUniqueKeys );
337 347 }
338 348
349 + @Override
339 350 public ServerStateChangeSet createListFrom( ServerStateChangeSet pAllChanges )
340 351 {
341 352 List<ServerStateChange> zAllChanges_Immutable = pAllChanges.getChanges();
  @@ -426,21 +437,25 @@
426 437 super( pClassName );
427 438 }
428 439
440 + @Override
429 441 public boolean isAll()
430 442 {
431 443 return true;
432 444 }
433 445
446 + @Override
434 447 public boolean isInterestedIn( Serializable pUniqueKey )
435 448 {
436 449 return true;
437 450 }
438 451
452 + @Override
439 453 public boolean isInterestedInAll( Serializable[] pUniqueKeys )
440 454 {
441 455 return true;
442 456 }
443 457
458 + @Override
444 459 public String toString()
445 460 {
446 461 return getClassName();
  @@ -468,16 +483,19 @@
468 483 mUniqueKeys.addAll( pHelper.mUniqueKeys );
469 484 }
470 485
486 + @Override
471 487 public boolean isAll()
472 488 {
473 489 return false;
474 490 }
475 491
492 + @Override
476 493 public boolean isInterestedIn( Serializable pUniqueKey )
477 494 {
478 495 return mUniqueKeys.contains( pUniqueKey );
479 496 }
480 497
498 + @Override
481 499 public boolean isInterestedInAll( Serializable[] pUniqueKeys )
482 500 {
483 501 for ( Serializable key : pUniqueKeys )
  @@ -490,6 +508,7 @@
490 508 return true;
491 509 }
492 510
511 + @Override
493 512 public String toString()
494 513 {
495 514 return getClassName() + mUniqueKeys;
  @@ -564,6 +583,7 @@
564 583 private Node mHead = null;
565 584 private Node mTail = null;
566 585
586 + @Override
567 587 public NodeQueue start()
568 588 {
569 589 Thread zThread = new Thread( this );
  @@ -573,6 +593,7 @@
573 593 }
574 594
575 595 @SuppressWarnings({"InfiniteLoopStatement"})
596 + @Override
576 597 public void run()
577 598 {
578 599 while ( true )
  @@ -581,6 +602,7 @@
581 602 }
582 603 }
583 604
605 + @Override
584 606 public synchronized void waitTillEmpty()
585 607 {
586 608 while ( mHead != null )
  @@ -623,6 +645,7 @@
623 645 }
624 646 }
625 647
648 + @Override
626 649 public synchronized void put( ServerStateChangedListener pListener, ServerStateChangeSet pAllChanges )
627 650 {
628 651 Node zNode = new Node( pListener, pAllChanges );