Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 1,122 for contextos (0.06 sec)

  1. internal/http/dial_dnscache.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  2. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/BaseMavenParser.java

        @Override
        protected List<O> parseCliOptions(LocalContext context) throws ParserException, IOException {
            ArrayList<O> result = new ArrayList<>();
            // CLI args
            result.add(parseMavenCliOptions(context.parserRequest.args()));
            // maven.config; if exists
            Path mavenConfig = context.rootDirectory != null ? context.rootDirectory.resolve(".mvn/maven.config") : null;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. cmd/lock-rest-server.go

    	success, err := l.ll.Lock(context.Background(), *args)
    	if err == nil && !success {
    		return l.makeResp(resp, errLockConflict)
    	}
    	return l.makeResp(resp, err)
    }
    
    // UnlockHandler - releases the acquired lock.
    func (l *lockRESTServer) UnlockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	resp := lockRPCUnlock.NewResponse()
    	_, err := l.ll.Unlock(context.Background(), *args)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  4. okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt

        assertThat(allAddresses).isEmpty()
      }
    
      @Test
      fun testRequestOnNetwork() {
        assumeNetwork()
    
        val context = InstrumentationRegistry.getInstrumentation().context
        val connectivityManager =
          context.getSystemService(Context.CONNECTIVITY_SERVICE) as ConnectivityManager
    
        val network =
          connectivityManager.activeNetwork ?: throw AssumptionViolatedException("No active network")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. cmd/peer-rest-server.go

    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  6. cmd/peer-s3-server.go

    package cmd
    
    import (
    	"context"
    	"errors"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/pkg/v3/sync/errgroup"
    )
    
    const (
    	peerS3Bucket            = "bucket"
    	peerS3BucketDeleted     = "bucket-deleted"
    	peerS3BucketForceCreate = "force-create"
    	peerS3BucketForceDelete = "force-delete"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. cmd/background-newdisks-heal-ops.go

    	// Be sure that they are included in toHealingDisk
    }
    
    // loadHealingTracker will load the healing tracker from the supplied disk.
    // The disk ID will be validated against the loaded one.
    func loadHealingTracker(ctx context.Context, disk StorageAPI) (*healingTracker, error) {
    	if disk == nil {
    		return nil, errors.New("loadHealingTracker: nil drive given")
    	}
    	diskID, err := disk.GetDiskID()
    	if err != nil {
    		return nil, err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. cmd/sftp-server-driver.go

    	}
    	ok, err := clnt.BucketExists(r.Context(), bucket)
    	if err != nil {
    		return nil, err
    	}
    	if !ok {
    		return nil, os.ErrNotExist
    	}
    
    	pr, pw := io.Pipe()
    
    	wa := &writerAt{
    		buffer: make(map[int64][]byte),
    		w:      pw,
    		r:      pr,
    		wg:     &sync.WaitGroup{},
    	}
    	wa.wg.Add(1)
    	go func() {
    		oi, err := clnt.PutObject(r.Context(), bucket, object, pr, -1, minio.PutObjectOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/ProtoSession.java

        }
    
        protected ProtoSession(
                RepositorySystemSession session,
                RepositorySystem repositorySystem,
                List<RemoteRepository> repositories,
                List<org.eclipse.aether.repository.RemoteRepository> resolverRepositories,
                Lookup lookup,
                Context context) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/collect/IterablesFilterArrayListTest.java

    public final class IterablesFilterArrayListTest
        extends AbstractFilteredIterableTest<Iterable<Integer>> {
      @Override
      Iterable<Integer> createUnfiltered(Iterable<Integer> contents) {
        return Lists.newArrayList(contents);
      }
    
      @Override
      Iterable<Integer> filter(Iterable<Integer> elements, Predicate<? super Integer> predicate) {
        return Iterables.filter(elements, predicate);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Mar 16 21:55:55 UTC 2022
    - 1.1K bytes
    - Viewed (0)
Back to top