---

WriterLock.java

class WriterLock extends Signaller 
{
     WriterPreferenceReadWriteLock wprw;
     
     synchronized void signalWaiters ()
     {
          this.notify();
     }
     
     public WriterLock(WriterPreferenceReadWriteLock wprw)
     {
          this.wprw = wprw;
     }
     
     public void acquire ()
     {
          java.lang.Object ie = null;
          synchronized (this)
          {
               if (!this.wprw.startWriteFromNewWriter())
               {
                    for (; true; )
                    {
                         try {
                              this.wait();
                              if (this.wprw.startWriteFromWaitingWriter())
                              {
                                   return;
                              }
                         }
                         catch (java.lang.InterruptedException ex) {
                              this.wprw.cancelledWaitingWriter();
                              this.notify();
                              ie = ex;
                              break;
                         }
                    }
               }
          }
          if (ie != null)
          {
               this.wprw.readerLock_.signalWaiters();
               throw ((java.lang.Throwable) ie);
          }
     }
     
     public boolean attempt (int msecs)
     {
          java.lang.Object ie = null;
          synchronized (this)
          {
               if (msecs <= 0)
               {
                    return this.wprw.startWrite();
               } else
               {
                    if (this.wprw.startWriteFromNewWriter())
                    {
                         return true;
                    } else
                    {
                         int waitTime = msecs;
                         int start = java.lang.System.currentTimeMillis();
                         for (; true; )
                         {
                              try {
                                   this.wait(waitTime);
                              }
                              catch (java.lang.InterruptedException ex) {
                                   this.wprw.cancelledWaitingWriter();
                                   this.notify();
                                   ie = ex;
                                   break;
                              }
                              if (this.wprw.startWriteFromWaitingWriter())
                              {
                                   return true;
                              } else
                              {
                                   waitTime = (msecs - (java.lang.System.currentTimeMillis() - start));
                                   if (waitTime <= 0)
                                   {
                                        this.wprw.cancelledWaitingWriter();
                                        this.notify();
                                        break;
                                   }
                              }
                         }
                    }
               }
          }
          this.wprw.readerLock_.signalWaiters();
          if (ie != null)
          {
               throw ((java.lang.Throwable) ie);
          } else
          {
               return false;
          }
     }
     
     public void release ()
     {
          Signaller s = this.wprw.endWrite();
          if (s != null)
          {
               s.signalWaiters();
          }
     }
}

---