Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 413 for readPing (0.04 sec)

  1. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObjectInfo", object, &er)
    	}
    
    	if !opts.NoLock {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return ObjectInfo{}, err
    		}
    		ctx = lkctx.Context()
    		defer lk.RUnlock(lkctx)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. gradlew

    # Attempt to set APP_HOME
    
    # Resolve links: $0 may be a link
    app_path=$0
    
    # Need this for daisy-chained symlinks.
    while
        APP_HOME=${app_path%"${app_path##*/}"}  # leaves a trailing /; empty if no leading path
        [ -h "$app_path" ]
    do
        ls=$( ls -ld "$app_path" )
        link=${ls#*' -> '}
        case $link in             #(
          /*)   app_path=$link ;; #(
          *)    app_path=$APP_HOME$link ;;
        esac
    done
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Aug 01 08:06:31 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  3. cmd/storage-rest-common_gen.go

    		}
    		switch msgp.UnsafeString(field) {
    		case "id":
    			z.DiskID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DiskID")
    				return
    			}
    		case "m":
    			z.ScanMode, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "ScanMode")
    				return
    			}
    		case "c":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Cache")
    					return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. cmd/metacache-walk_gen.go

    				return
    			}
    		case "ForwardTo":
    			z.ForwardTo, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "ForwardTo")
    				return
    			}
    		case "Limit":
    			z.Limit, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Limit")
    				return
    			}
    		case "DiskID":
    			z.DiskID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DiskID")
    				return
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/MultipartReaderTest.kt

      }
    
      /**
       * Read 100 MiB of 'a' chars. This was really slow due to a performance bug in [MultipartReader],
       * and will be really slow if we regress the fix for that.
       */
      @Test
      fun `reading a large part with small byteCount`() {
        val multipartBody =
          MultipartBody
            .Builder("foo")
            .addPart(
              headersOf("header-name", "header-value"),
              object : RequestBody() {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

        /*
         * We overload this because we want readAndXWireFormat to
         * read the parameter words and bytes. This is so when
         * commands are batched together we can recursivly call
         * readAndXWireFormat without reading the non-existent header.
         */
    
        @Override
        public int decode(final byte[] buffer, int bufferIndex) throws SMBProtocolDecodingException {
            final int start = this.headerStart = bufferIndex;
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  7. src/test/java/jcifs/http/NetworkExplorerTest.java

                        throw new ServletException(e);
                    }
                }
            };
    
            assertDoesNotThrow(() -> networkExplorer.init(servletConfig));
    
            // Verify parameter reading
            verify(servletConfig).getInitParameter("jcifs.smb.client.domain");
            verify(servletConfig).getInitParameter("jcifs.http.enableBasic");
        }
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         * must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds.
         *
         * The call timeout spans the entire call: resolving DNS, connecting, writing the request body,
         * server processing, and reading the response body. If the call requires redirects or retries
         * all must complete within one timeout period.
         *
         * The default value is 0 which imposes no timeout.
         */
        fun callTimeout(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

         */
        protected static class ProcessDestroyer extends TimerTask {
    
            /** The process to monitor and destroy. */
            private final Process p;
    
            /** The input stream thread reading process output. */
            private final InputStreamThread ist;
    
            /** Flag indicating if the destroyer has been executed. */
            private final AtomicBoolean executed = new AtomicBoolean(false);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Fri Jul 18 14:34:06 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig);
    
            // Assert
            assertNotNull(testResponse);
        }
    
        @Test
        @DisplayName("Test state changes after reading parameters")
        void testStateAfterReadingParameters() {
            // Arrange
            byte[] buffer = new byte[10];
            SMBUtil.writeInt2(1500, buffer, 0);
            SMBUtil.writeInt2(0xFFFF, buffer, 2);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
Back to top