Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 78 for writePing (0.06 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        connection.withLock {
          if (!connection.isHealthy(System.nanoTime())) {
            throw ConnectionShutdownException()
          }
        }
        connection.writePing()
        connection.shutdown(ErrorCode.PROTOCOL_ERROR)
        assertThat(connection.openStreamCount()).isEqualTo(1)
        connection.awaitPong() // Prevent the peer from exiting prematurely.
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_gen.go

    		err = en.Append(0xa2, 0x72, 0x63)
    		if err != nil {
    			return
    		}
    		err = en.WriteInt(za0002.RetryCount)
    		if err != nil {
    			err = msgp.WrapError(err, "Entries", za0001, "RetryCount")
    			return
    		}
    	}
    	// write "v"
    	err = en.Append(0xa1, 0x76)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Version)
    	if err != nil {
    		err = msgp.WrapError(err, "Version")
    		return
    	}
    	return
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/ViewHelper.java

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 52.4K bytes
    - Viewed (0)
  5. cmd/data-usage-cache_gen.go

    		err = en.Append(0xa2, 0x6e, 0x76)
    		if err != nil {
    			return
    		}
    		err = en.WriteInt(za0002.NumVersions)
    		if err != nil {
    			err = msgp.WrapError(err, "Tiers", za0001, "NumVersions")
    			return
    		}
    		// write "no"
    		err = en.Append(0xa2, 0x6e, 0x6f)
    		if err != nil {
    			return
    		}
    		err = en.WriteInt(za0002.NumObjects)
    		if err != nil {
    			err = msgp.WrapError(err, "Tiers", za0001, "NumObjects")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 86.4K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2_gen.go

    		err = en.Append(0xa3, 0x45, 0x63, 0x4d)
    		if err != nil {
    			return
    		}
    		err = en.WriteInt(z.ErasureM)
    		if err != nil {
    			err = msgp.WrapError(err, "ErasureM")
    			return
    		}
    		// write "EcN"
    		err = en.Append(0xa3, 0x45, 0x63, 0x4e)
    		if err != nil {
    			return
    		}
    		err = en.WriteInt(z.ErasureN)
    		if err != nil {
    			err = msgp.WrapError(err, "ErasureN")
    			return
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 56K bytes
    - Viewed (0)
  7. src/test/java/jcifs/dcerpc/msrpc/lsarpcTest.java

            verify(mockDeferredNdrBuffer).advance(2 * (domainInfo.name.length / 2));
            verify(mockDeferredNdrBuffer).derive(anyInt());
            verify(mockDeferredNdrBuffer, times(5)).enc_ndr_short(0); // Writing 5 shorts with value 0
            verify(domainInfo.sid).encode(mockDeferredNdrBuffer); // Should be called with deferred buffer
        }
    
        @Test
        void testLsarDomainInfoEncodeNullReferents() throws NdrException {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 60.8K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 75.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/opensearch/config/cbean/ca/bs/BsRoleTypeCA.java

     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 49K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    	removeRoots(append(erasureDisks, fsDir))
    }
    
    // ExecExtendedObjectLayerTest will execute the tests with combinations of encrypted & compressed.
    // This can be used to test functionality when reading and writing data.
    func ExecExtendedObjectLayerAPITest(t *testing.T, objAPITest objAPITestType, endpoints []string) {
    	execExtended(t, func(t *testing.T, init func(), makeBucketOptions MakeBucketOptions) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
Back to top