- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,524 for var (0.02 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
@Throws(IOException::class) internal fun writeOneFrame(): Boolean { val writer: WebSocketWriter? val pong: ByteString? var messageOrClose: Any? = null var receivedCloseCode = -1 var receivedCloseReason: String? = null var streamsToClose: Streams? = null var writerToClose: WebSocketWriter? = null synchronized(this@RealWebSocket) { if (failed) { return false // Failed web socket.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0) -
src/bytes/bytes_test.go
} } } // For ease of reading, the test cases use strings that are converted to byte // slices before invoking the functions. var abcd = "abcd" var faces = "☺☻☹" var commas = "1,2,3,4" var dots = "1....2....3....4" type BinOpTest struct { a string b string i int } func TestEqual(t *testing.T) { // Run the tests and check for allocation at the same time.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Aug 19 19:09:04 UTC 2024 - 61.2K bytes - Viewed (0) -
cmd/perf-tests.go
objAPI := newObjectLayerFn() if objAPI == nil { return SpeedTestResult{}, errServerNotInitialized } var wg sync.WaitGroup var errOnce sync.Once var retError string var totalBytesWritten uint64 var totalBytesRead uint64 objCountPerThread := make([]uint64, opts.concurrency) uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.8K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} internal var headers: Headers.Builder internal var trailers: Headers.Builder // At most one of (body,webSocketListener,streamHandler) is non-null. private var bodyVar: MockResponseBody? = null private var streamHandlerVar: StreamHandler? = null private var webSocketListenerVar: WebSocketListener? = null var body: MockResponseBody? get() = bodyVar
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/webapp/js/admin/plugins/form-validator/uk.js
on(a){if(a=a.replace(/[^0-9]/g,""),a.length<9)return!1;var b=!1,c=[];c=a.split("");var d=Number(c[7]+c[8]),e=c[0],f=c[1];if(0===e&&f>0)return!1;for(var g=0,h=0;h<7;h++)g+=c[h]*(8-h);for(var i=0,j=0,k=8;k>=2;k--)i+=c[j]*k,j++;for(;g>0;)g-=97;return g=Math.abs(g),d===g&&(b=!0),b||(g%=97,g>=55?g-=55:g+=42,g===d&&(b=!0)),b},errorMessage:"",errorMessageKey:"badUKVatAnswer"}),a.formUtils.addValidator({name:"ukutr",validatorFunction:function(a){var b=[0,6,7,8,9,10,5,4,3,2],c=[2,1,9,8,7,6,5,4,3,2,1],d=0...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jan 01 05:12:47 UTC 2018 - 1.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
} fun decode( source: BufferedSource, byteCount: Long, sink: BufferedSink, ) { var node = root var accumulator = 0 var accumulatorBitCount = 0 for (i in 0 until byteCount) { val byteIn = source.readByte() and 0xff accumulator = accumulator shl 8 or byteIn accumulatorBitCount += 8 while (accumulatorBitCount >= 8) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 8.3K bytes - Viewed (0) -
internal/crypto/key_test.go
} } } var sealUnsealETagTests = []string{ "", "90682b8e8cc7609c", "90682b8e8cc7609c4671e1d64c73fc30", "90682b8e8cc7609c4671e1d64c73fc307fb3104f", } func TestSealETag(t *testing.T) { var key ObjectKey for i := range key { key[i] = byte(i) } for i, etag := range sealUnsealETagTests {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 6.7K bytes - Viewed (0) -
scan.go
joinFields[idx] = relFields continue } } var val interface{} values[idx] = &val } else { var val interface{} values[idx] = &val } } } } switch reflectValue.Kind() { case reflect.Slice, reflect.Array: var ( elem reflect.Value isArrayKind = reflectValue.Kind() == reflect.Array )
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Jun 24 09:42:59 UTC 2024 - 10.1K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
} }.build() class Builder { internal var client: OkHttpClient? = null internal var url: HttpUrl? = null internal var includeIPv6 = true internal var post = false internal var systemDns = Dns.SYSTEM internal var bootstrapDnsHosts: List<InetAddress>? = null internal var resolvePrivateAddresses = false internal var resolvePublicAddresses = true fun build(): DnsOverHttps {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Oct 31 09:27:31 UTC 2024 - 9.8K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
return } // DecodeMsg implements msgp.Decodable func (z *DeleteOptions) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } var zb0001Mask uint8 /* 1 bits */ _ = zb0001Mask for zb0001 > 0 { zb0001-- field, err = dc.ReadMapKeyPtr() if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 150.2K bytes - Viewed (0)