RA.dis

import random


class P(DistProcess):

     def setup(ps, requests):
       reqc = None
       s = ps
       waiting = set()
       replied = set()
       
     def cs(task):
       # to enter cs, enque and send request to all, then await replies from all
         --start
         reqc = logical_clock()
         send(Request(reqc), s)

         --reply
         await(len(replied) == len(s))

       # critical section
         --cs
         task()

       # to exit cs, deque and send releases to all
         --release
         reqc = None
         output("Is releasing.")
         send(Reply(logical_clock()), waiting)
         --end
         waiting = set()
         replied = set()

     def main():
          def anounce():
               output("In cs!")
          while True:
               cs(anounce)

     # when receiving requests from others, enque and reply
     def OnRequest():
         if (reqc == None or (_timestamp, _source) < (reqc, self)):
           send(Reply(logical_clock()), _source)
         else:
           waiting.add(_source)

     def OnReply(lc):
         if reqc != None and lc > reqc: replied.add(_source)

def main():
     
     # create n process
     ps = createprocs(P,int(sys.argv[1]))
     proc = int(sys.argv[1])
     req = int(sys.argv[2])
     assign = [0]*proc
     time.sleep(5)
     while req:
         j = random.randrange(0, proc)
         assign[j]+=1
         req=req-1
         
     # setup the processes
     j=0
     for p in ps: 
         setupprocs([p], [ps-{p}])
         j=j+1
         
     time.sleep(5)
     startprocs(ps)
     time.sleep(5)