Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 393 for peer (0.04 sec)

  1. cmd/post-policy_test.go

    		var req *http.Request
    		var perr error
    		if testCase.ignoreContentLength {
    			req, perr = newPostRequestV4("", bucketName, testCase.objectName, testCase.data, testCase.accessKey, testCase.secretKey)
    		} else {
    			req, perr = newPostRequestV4WithContentLength("", bucketName, testCase.objectName, testCase.data, testCase.accessKey, testCase.secretKey)
    		}
    		if perr != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.6K bytes
    - Viewed (0)
  2. cmd/untar.go

    )
    
    // Max bzip2 concurrency across calls. 50% of GOMAXPROCS.
    var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2)
    
    func detect(r *bufio.Reader) format {
    	z, err := r.Peek(4)
    	if err != nil {
    		return formatUnknown
    	}
    	for _, f := range magicHeaders {
    		if bytes.Equal(f.header, z[:len(f.header)]) {
    			return f.f
    		}
    	}
    	return formatUnknown
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6K bytes
    - Viewed (2)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

        } finally {
          monitor.leave();
        }
      }
    
      @CanIgnoreReturnValue // pushed down from class to method
      @Override
      public @Nullable E peek() {
        Monitor monitor = this.monitor;
        monitor.enter();
        try {
          return q.peek();
        } finally {
          monitor.leave();
        }
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 18.9K bytes
    - Viewed (0)
  4. cmd/consolelogger.go

    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    }
    
    // HasLogListeners returns true if console log listeners are registered
    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponseTest.java

            SrvPipePeekResponse peek = resp.getOutputData(SrvPipePeekResponse.class);
            assertNotNull(peek);
            assertEquals(16, resp.getOutputLength());
            // Default zeros
            assertEquals(0, peek.getNamedPipeState());
            assertEquals(0, peek.getReadDataAvailable());
            assertEquals(0, peek.getNumberOfMessages());
            assertEquals(0, peek.getMessageLength());
        }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  6. docs/es/docs/environment-variables.md

    $ MY_NAME="Wade Wilson" python main.py
    
    // Ahora puede leer la variable de entorno
    
    Hello Wade Wilson from Python
    
    // La env var ya no existe después
    $ python main.py
    
    Hello World from Python
    ```
    
    </div>
    
    /// tip | Consejo
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. src/test/java/jcifs/smb/SmbPipeInputStreamTest.java

            Smb2IoctlResponse ioResp = mock(Smb2IoctlResponse.class);
            SrvPipePeekResponse peek = mock(SrvPipePeekResponse.class);
            when(peek.getReadDataAvailable()).thenReturn(7);
            when(ioResp.getOutputData()).thenReturn(peek);
    
            when(tree.send(any(Smb2IoctlRequest.class), eq(RequestParam.NO_RETRY))).thenReturn(ioResp);
    
            // Act
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

            delegate.put(element)
            editCount++
          }
        }
    
        override fun iterator() = error("unsupported")
    
        override fun offer(e: T) = error("unsupported")
    
        override fun peek(): T = error("unsupported")
    
        override fun offer(
          element: T,
          timeout: Long,
          unit: TimeUnit,
        ) = error("unsupported")
    
        override fun take() = error("unsupported")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/TreeTraverser.java

          this.queue = new ArrayDeque<>();
          queue.add(root);
        }
    
        @Override
        public boolean hasNext() {
          return !queue.isEmpty();
        }
    
        @Override
        public T peek() {
          return queue.element();
        }
    
        @Override
        public T next() {
          T result = queue.remove();
          Iterables.addAll(queue, children(result));
          return result;
        }
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  10. docs/es/docs/tutorial/body.md

    {* ../../docs_src/body/tutorial001_py310.py hl[16] *}
    
    ...y declara su tipo como el modelo que creaste, `Item`.
    
    ## Resultados
    
    Con solo esa declaración de tipo en Python, **FastAPI** hará lo siguiente:
    
    * Leer el body del request como JSON.
    * Convertir los tipos correspondientes (si es necesario).
    * Validar los datos.
        * Si los datos son inválidos, devolverá un error claro e indicado, señalando exactamente dónde y qué fue lo incorrecto.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 7K bytes
    - Viewed (0)
Back to top