maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/AMojo.class package org.apache.maven.plugin.coreit; public synchronized class AMojo extends org.apache.maven.plugin.AbstractMojo { private String version; private String[] models; public void AMojo(); public void execute(); } org/apache/maven/plugin/coreit/BMojo.class package org.apache.maven.plugin.coreit; public synchronized class BMojo extends org.apache.maven.plugin.AbstractMojo { private String version; private String[] models; public void...

    webSocket = slackApi.rtm(rtmStartResponse.url, this);
  }

  // TODO(jwilson): can I read the response body? Do I have to?
  //                the body from slack is a 0-byte-buffer
  @Override public synchronized void onOpen(WebSocket webSocket, Response response) {
    System.out.println("onOpen: " + response);
  }

  // TOOD(jwilson): decode incoming messages and dispatch them somewhere.

        SmbFileOutputStream out = mock(SmbFileOutputStream.class);
        byte[] payload = new byte[] { 1, 2, 3, 4 };

        w.start();

        // Wait until writer thread signals readiness
        synchronized (w) {
            long deadline = System.currentTimeMillis() + 2000;
            while (!w.isReady() && System.currentTimeMillis() < deadline) {
                w.wait(10);
            }

        int max = NbtAddress.NBNS.length;

        if (max == 0) {
            max = 1; /* No WINs, try only bcast addr */
        }

        synchronized (response) {
            while (max-- > 0) {
                try {
                    synchronized (LOCK) {
                        request.nameTrnId = getNextNameTrnId();
                        nid = request.nameTrnId;

            }
        }
    }

    protected synchronized void doDisconnect(final boolean hard) throws IOException {
        doDisconnect(hard, false);
    }

    @Override
    protected synchronized boolean doDisconnect(final boolean hard, final boolean inUse) throws IOException {

        this.bufferSize = maxSize;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.BufferCache#getBuffer()
     */
    @Override
    public byte[] getBuffer() {
        synchronized (this.cache) {
            byte[] buf;

            if (this.freeBuffers > 0) {
                for (int i = 0; i < this.cache.length; i++) {
                    if (this.cache[i] != null) {

    }

    synchronized SmbTransport transport() {
        if (transport == null) {
            transport = SmbTransport.getSmbTransport(address, port, localAddr, localPort, null);
        }
        return transport;
    }

    void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException {
        synchronized (transport()) {
            if (response != null) {

            this.cache = new ArrayList<>(maxBuffers);
        }

        @Override
        public synchronized byte[] getBuffer() {
            if (!cache.isEmpty()) {
                return cache.remove(0);
            }
            return new byte[bufferSize];
        }

        @Override
        public synchronized void releaseBuffer(byte[] buf) {
            if (buf != null && cache.size() < maxBuffers) {

     *
     * @return the tree handle implementation
     * @throws CIFSException if a connection error occurs
     */
    protected synchronized SmbTreeHandleImpl ensureTreeConnected() throws CIFSException {
        return this.handle.ensureTreeConnected();
    }

    @Override
    protected synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
        return this.handle.ensureOpen();
    }

    /**

      synchronized (state) {
        if (state.seenExceptionsField == expect) {
          state.seenExceptionsField = update;
        }
      }
    }

    @Override
    int decrementAndGetRemainingCount(AggregateFutureState<?> state) {
      synchronized (state) {
        return --state.remainingField;
      }
    }

    @Override