- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 747 for Consts (0.18 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageInflater.kt
* limitations under the License. */ package okhttp3.internal.ws import java.io.Closeable import java.io.IOException import java.util.zip.Inflater import okio.Buffer import okio.InflaterSource private const val OCTETS_TO_ADD_BEFORE_INFLATION = 0x0000ffff class MessageInflater( private val noContextTakeover: Boolean, ) : Closeable { private val deflatedBytes = Buffer() // Lazily-created.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Sep 21 06:26:07 UTC 2025 - 2.4K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" ) const ( memTotal = "total" memUsed = "used" memFree = "free" memBuffers = "buffers" memCache = "cache" memUsedPerc = "used_perc" memShared = "shared" memAvailable = "available" )
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Apr 17 05:10:25 UTC 2024 - 2.2K bytes - Viewed (0) -
src/bufio/net_test.go
}() clientConn, err := net.DialUnix("unixpacket", nil, addr) if err != nil { // Leaves the server goroutine hanging. Oh well. t.Fatal(err) } defer wg.Wait() defer clientConn.Close() const data = "data" r := bufio.NewReader(strings.NewReader(data)) n, err := io.Copy(clientConn, r) if err != nil { t.Fatal(err) } if n != int64(len(data)) {
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Feb 07 19:37:07 UTC 2025 - 1.9K bytes - Viewed (0) -
internal/logger/target/loggertypes/types.go
package loggertypes // TargetType indicates type of the target e.g. console, http, kafka type TargetType uint8 //go:generate stringer -type=TargetType -trimprefix=Target $GOFILE // Constants for target types const ( _ TargetType = iota TargetConsole TargetHTTP TargetKafka ) // TargetStats contains statistics for a target. type TargetStats struct { // QueueLength is the queue length if any messages are queued.Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 1.4K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/HandshakeCertificates.kt
* (Android vs. Java), by platform release (Android 4.4 vs. Android 9), and with user * customizations. * * Most TLS clients that connect to hosts on the public Internet should call this method. * Otherwise it is necessary to manually prepare a comprehensive set of trusted roots. *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat May 10 11:15:14 UTC 2025 - 8.4K bytes - Viewed (0) -
src/cmd/addr2line/addr2line_test.go
// Reattach drive letter. f = []string{f[0] + ":" + f[1], f[2]} } if len(f) != 2 { t.Fatalf("no line number found in %q", pathAndLineNo) } return funcname, f[0], f[1] } const symName = "cmd/addr2line.TestAddr2Line" func testAddr2Line(t *testing.T, dbgExePath, addr string) { funcName, srcPath, srcLineNo := runAddr2Line(t, dbgExePath, addr) if symName != funcName {Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Fri Sep 06 13:23:48 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
if !globalIsDistErasure { // Only useful in distributed setups return nil, nil } hosts := endpoints.hostsSorted() remote = make([]*peerRESTClient, 0, len(hosts)) all = make([]*peerRESTClient, len(hosts)) for i, host := range hosts { if host == nil { continue } all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host))Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 26.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/RouteSelectorTest.kt
call = call, ) companion object { private const val PROXY_A_PORT = 1001 private const val PROXY_A_HOST = "proxya" private val proxyA = Proxy( Proxy.Type.HTTP, InetSocketAddress.createUnresolved(PROXY_A_HOST, PROXY_A_PORT), ) private const val PROXY_B_PORT = 1002 private const val PROXY_B_HOST = "proxyb" private val proxyB = Proxy(Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 20.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FallbackTestClientSocketFactory.kt
} } companion object { /** * The cipher suite used during TLS connection fallback to indicate a fallback. See * https://tools.ietf.org/html/draft-ietf-tls-downgrade-scsv-00 */ const val TLS_FALLBACK_SCSV = "TLS_FALLBACK_SCSV" }Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2K bytes - Viewed (0) -
logger/logger.go
"context" "errors" "fmt" "io" "log" "os" "time" "gorm.io/gorm/utils" ) // ErrRecordNotFound record not found error var ErrRecordNotFound = errors.New("record not found") // Colors const ( Reset = "\033[0m" Red = "\033[31m" Green = "\033[32m" Yellow = "\033[33m" Blue = "\033[34m" Magenta = "\033[35m" Cyan = "\033[36m" White = "\033[37m"
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Jan 12 10:19:28 UTC 2025 - 6.3K bytes - Viewed (0)