maven-surefire-plugin once **/Test*.java **/Abstract*.java shade-maven-plugin org.codehaus.mojo 1.0-alpha-9 package shade classworlds:classworlds junit:junit jmock:jmock org.codehaus.plexus:plexus-classworlds org.codehaus.plexus:plexus-utils org.codehaus.plexus plexus-component-api org.codehaus.plexus plexus-utils org.codehaus.plexus plexus-classworlds jmock jmock 1.0.1 test maven-pmd-plugin maven-javadoc-plugin http://java.sun.com/j2ee/1.4/docs/api http://java.sun.com/j2se/1.5.0/docs/api http://jakarta.apa...

}

func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error {
	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
	if err != nil {
		if errors.Is(err, errConfigNotFound) {
			c.Lock()
			defer c.Unlock()
			c.state = srState{}
			c.enabled = false
		}
		return err
	}

	// attempt to read just the version key in the state file to ensure we
	// are reading a compatible version.

		return
	}

	// Take read lock on object, here so subsequent lower-level
	// calls do not need to.
	lock := objectAPI.NewNSLock(bucket, object)
	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
	if err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}
	ctx = lkctx.Context()
	defer lock.RUnlock(lkctx)

	getObjectNInfo := objectAPI.GetObjectNInfo

Plexus Container 1.0-alpha-16 maven-surefire-plugin once **/Test*.java **/Abstract*.java maven-assembly-plugin jar-with-dependencies org.codehaus.plexus plexus-component-api org.codehaus.plexus plexus-utils org.codehaus.plexus plexus-classworlds jmock jmock 1.0.1 test META-INF/maven/org.codehaus.plexus/plexus-container-default/pom.properties #Generated by Maven #Tue Jan 23 15:16:59 GMT 2007 version=1.0-alpha-16 groupId=org.codehaus.plexus artifactId=plexus-container-default...

Plexus Container 1.0-alpha-16 maven-surefire-plugin once **/Test*.java **/Abstract*.java maven-assembly-plugin jar-with-dependencies org.codehaus.plexus plexus-component-api org.codehaus.plexus plexus-utils org.codehaus.plexus plexus-classworlds jmock jmock 1.0.1 test META-INF/maven/org.codehaus.plexus/plexus-container-default/pom.properties #Generated by Maven #Tue Jan 23 15:16:59 GMT 2007 version=1.0-alpha-16 groupId=org.codehaus.plexus artifactId=plexus-container-default...

	// callback(x) calls goCallback(x)
	callbackMutex.Lock()
	callbackToken++
	i := callbackToken
	callbackFuncs[i] = f
	callbackMutex.Unlock()

	// Pass the address of i because the C function was written to
	// take a pointer.  We could pass an int if we felt like
	// rewriting the C code.
	C.callback(unsafe.Pointer(&i))

	callbackMutex.Lock()
	delete(callbackFuncs, i)
	callbackMutex.Unlock()
}

- github.com/Azure/go-autorest/autorest/date: [v0.3.0](https://github.com/Azure/go-autorest/tree/autorest/date/v0.3.0)
- github.com/Azure/go-autorest/autorest/mocks: [v0.4.2](https://github.com/Azure/go-autorest/tree/autorest/mocks/v0.4.2)
- github.com/Azure/go-autorest/autorest/to: [v0.4.0](https://github.com/Azure/go-autorest/tree/autorest/to/v0.4.0)

    derived.cancel(false);
    assertTrue(primary.isCancelled());
    assertFalse(primary.wasInterrupted());
  }

  @J2ktIncompatible
  @GwtIncompatible // mocks
  // TODO(cpovirk): eliminate use of mocks
  public void testCatchingAsync_resultCancelledAfterFallback() throws Exception {
    final SettableFuture<Integer> secondary = SettableFuture.create();

of an interface type or of elements of a composite type remains unchanged:
</p>

<pre>
// A Mutex is a data type with two methods, Lock and Unlock.
type Mutex struct         { /* Mutex fields */ }
func (m *Mutex) Lock()    { /* Lock implementation */ }
func (m *Mutex) Unlock()  { /* Unlock implementation */ }

// NewMutex has the same composition as Mutex but its method set is empty.

    derived.cancel(false);
    assertTrue(primary.isCancelled());
    assertFalse(primary.wasInterrupted());
  }

  @J2ktIncompatible
  @GwtIncompatible // mocks
  // TODO(cpovirk): eliminate use of mocks
  public void testCatchingAsync_resultCancelledAfterFallback() throws Exception {
    final SettableFuture<Integer> secondary = SettableFuture.create();