Pipe.java

package org.crucial.dso;

import picocli.CommandLine.Command;
import picocli.CommandLine.Option;

@Command(name = "pipe")
public class Pipe {

    @Option(names = "-n" )
    public String name = "pipe";
    
    private AtomicCounter counter;
    private AtomicReference<String> ipport;
    private static final int BARRIER = 2;

    public Pipe() {}

    public Pipe(String name) {	
      this.name = name;
      this.counter = new AtomicCounter("counter-"+name);
      this.ipport = new AtomicReference("ref-"+name);
    }
    
    public int wait()
    {
       int ret = counter.increment();

       while(ret < BARRIER) {
         try {
           Thread.currentThread().sleep(500);
         } catch (InterruptedException e) {
          // ignore
         }
       }

       return 0;
    }

    @Override
    @Command(name = "begin")
    public String begin() {
	String ret = this.ipport.get();
	this.wait(); 	
    }
   
    @Override
    @Command(name = "end")
    public void end(@Option(names = "-1") String ipport) {      
	this.ipport.set(ipport);   
	this.wait();
    }

    @Override
    @Command(name = "getName")
    public String getName() {
      return this.name;
    }

}