- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 97 for writePing (0.17 sec)
-
okhttp/src/test/java/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.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0) -
okhttp/src/main/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
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
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 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 53.8K bytes - Viewed (0) -
okhttp/src/test/java/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
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
// It is more critical than other attributes because append mode depends on it. // We do only really care if we open for writing and not shared for writing // otherwise there are no guarantees anyway, but this stuff is legacy anyways. SmbComSeek seekReq = new SmbComSeek(config, 0); seekReq.setMode(0x2); // from EOF
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Mon Mar 13 12:00:57 GMT 2023 - 81.6K bytes - Viewed (0) -
cmd/erasure-object.go
// into memory, any mutation on xl.meta subsequently is // inconsequential to the overall read operation. // - xl.meta metadata is still verified for quorum under lock() // however writing the response doesn't need to serialize // concurrent writers unlockOnDefer = true nsUnlocker = func() { lock.RUnlock(lkctx) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
} @Override protected ConcurrentMap<K, V> delegate() { return delegate; } void writeMapTo(ObjectOutputStream out) throws IOException { out.writeInt(delegate.size()); for (Entry<K, V> entry : delegate.entrySet()) { out.writeObject(entry.getKey()); out.writeObject(entry.getValue()); } out.writeObject(null); // terminate entries
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 91.9K bytes - Viewed (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* 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
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 51.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsElevateWordCA.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
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 54.5K bytes - Viewed (0)