/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/http/ |
H A D | HttpConnection.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 208 * delays the current request in order to speed up a potential future request 211 public boolean discard(Source in, int timeoutMillis) { argument 216 return Util.skipAll(in, timeoutMillis); 271 /** An HTTP body with a fixed length known in advance. */ 411 * being reused. HTTP messages are sent in serial so whenever a message 428 /** An HTTP body with a fixed length specified in advance. */
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
H A D | SpdyConnection.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 48 * <p>Many methods in this API are <strong>synchronous:</strong> the call is 78 * User code to run in response to an incoming stream. Callbacks must not be 89 /** Lazily-created map of in-flight pings awaiting a response. Guarded by this. */ 91 /** User code to run in response to push promise events. */ 196 * Returns the time in ns when this connection became idle or Long.MAX_VALUE 223 * @param in true to create an input stream that the remote peer can use to send data to us. 226 public SpdyStream newStream(List<Header> requestHeaders, boolean out, boolean in) argument 228 return newStream(0, requestHeaders, out, in); 231 newStream(int associatedStreamId, List<Header> requestHeaders, boolean out, boolean in) argument [all...] |
H A D | SpdyStream.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 49 * available bytes in {@code connection.bytesLeftInWriteWindow}. 62 /** Headers sent in the stream reply. Null if reply is either not sent or not sent yet. */ 305 void receiveData(BufferedSource in, int length) throws IOException { argument 307 this.source.receive(in, length); 354 * receive no more bytes beyond those already in the buffer. 425 void receive(BufferedSource in, long byteCount) throws IOException { argument 438 in.skip(byteCount); 445 in [all...] |
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/http/ |
H A D | HttpOverSpdyTest.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 273 InputStream in = connection.getInputStream(); 274 assertEquals("ABC", readAscii(in, 3)); 275 assertEquals(-1, in.read()); 276 assertEquals(-1, in.read()); 315 * arrive in time. 443 private String readAscii(InputStream in, int count) throws IOException { argument 446 int value = in.read(); 448 in [all...] |
H A D | HttpResponseCacheTest.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 143 // Test each documented HTTP/1.1 code, plus the first unused value in each range. 320 InputStream in = urlConnection.getInputStream(); 322 reliableSkip(in, "puppies but hate ".length()); 324 assertEquals(-1, in.read()); 325 in.close(); 330 in = urlConnection.getInputStream(); 336 assertEquals(-1, in.read()); 337 in 2048 reliableSkip(InputStream in, int length) argument [all...] |
H A D | JavaApiConverterTest.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 795 private byte[] readAll(InputStream in) throws IOException { argument 798 while ((value = in.read()) != -1) { 801 in.close();
|
H A D | ResponseCacheTest.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 81 * {@link com.squareup.okhttp.OkResponseCache} found in HttpResponseCacheTest provide 159 InputStream in = urlConnection.getInputStream(); 161 reliableSkip(in, "puppies but hate ".length()); 163 assertEquals(-1, in.read()); 164 in.close(); 167 in = urlConnection.getInputStream(); 173 assertEquals(-1, in.read()); 174 in 1454 reliableSkip(InputStream in, int length) argument [all...] |
H A D | URLConnectionTest.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 412 // Note that 1234.1.1.1 is an invalid host in a URI, but URL isn't as strict. 904 // route selector will try each in sequence. 1048 InputStream in = connection.getInputStream(); 1049 assertEquals('A', (char) in.read()); 1053 in.read(); 1056 in.read(); 1082 private String readAscii(InputStream in, int count) throws IOException { argument 1085 int value = in [all...] |
/external/okhttp/okio/src/main/java/okio/ |
H A D | Base64.java | 6 * (the "License"); you may not use this file except in compliance with 11 * Unless required by applicable law or agreed to in writing, software 30 public static byte[] decode(String in) { argument 32 int limit = in.length(); 34 char c = in.charAt(limit - 1); 47 char c = in.charAt(pos); 118 public static String encode(byte[] in) { argument 119 int length = (in.length + 2) * 4 / 3; 121 int index = 0, end = in.length - in [all...] |
H A D | ByteString.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 33 * string's immutability guarantee cannot be relied upon for security in applets 34 * and other environments that run both trusted and untrusted code in the same 69 // We don't care if we double-allocate in racy code. 91 /** Returns this byte string encoded in hexadecimal. */ 123 * Reads {@code count} bytes from {@code in} and returns the result. 125 * @throws java.io.EOFException if {@code in} has fewer than {@code count} 128 public static ByteString read(InputStream in, int byteCount) throws IOException { argument 131 read = in [all...] |
H A D | Okio.java | 5 * you may not use this file except in compliance with the License. 10 * Unless required by applicable law or agreed to in writing, software 103 /** Returns a source that reads from {@code in}. */ 104 public static Source source(final InputStream in) { argument 113 int bytesRead = in.read(tail.data, tail.limit, maxToCopy); 121 in.close(); 131 return "source(" + in + ")";
|
/external/okhttp/samples/guide/src/main/java/com/squareup/okhttp/guide/ |
H A D | GetExample.java | 20 InputStream in = null; 23 in = connection.getInputStream(); 24 byte[] response = readFully(in); 27 if (in != null) in.close(); 31 byte[] readFully(InputStream in) throws IOException { argument 34 for (int count; (count = in.read(buffer)) != -1; ) {
|
H A D | PostExample.java | 24 InputStream in = null; 37 in = connection.getInputStream(); 38 return readFirstLine(in); 42 if (in != null) in.close(); 46 String readFirstLine(InputStream in) throws IOException { argument 47 BufferedReader reader = new BufferedReader(new InputStreamReader(in, "UTF-8"));
|
/external/nist-sip/java/gov/nist/javax/sip/parser/ |
H A D | PipelinedMsgParser.java | 7 * employees are not subject to copyright protection in the United States 8 * and are considered to be in the public domain. As a result, a formal 49 * keeps reading from the input stream and process messages in a never ending 100 * @param in 106 Pipeline in, boolean debug, int maxMessageSize) { 109 rawInputStream = in; 122 * @param in 126 public PipelinedMsgParser(SIPMessageListener mhandler, Pipeline in, argument 128 this(mhandler, in, false, maxMsgSize); 134 * @param in 105 PipelinedMsgParser(SIPMessageListener sipMessageListener, Pipeline in, boolean debug, int maxMessageSize) argument 138 PipelinedMsgParser(Pipeline in) argument [all...] |
/external/nanohttpd/core/src/main/java/fi/iki/elonen/ |
H A D | NanoHTTPD.java | 28 * A simple, tiny, nicely embeddable HTTP server in Java 42 * <li>Supports parameter parsing of GET and POST methods (+ rudimentary PUT support in 1.25)</li> 56 * <li>Contains a built-in list of most common mime types</li> 73 * Maximum time to wait on Socket.getInputStream().read() (in milliseconds) 87 * Pseudo-Parameter to use to store the actual query string in the parameters map for later re-processing. 151 * @throws IOException if the socket is in use. 264 * @param parms Parsed, percent decoded parameters from URI and, in case of POST, data. 467 * <p></p>This class stores its files in the standard location (that is, 504 * <p></p></[>By default, files are created by <code>File.createTempFile()</code> in 840 * Adds the files in th 1057 decodeHeader(BufferedReader in, Map<String, String> pre, Map<String, String> parms, Map<String, String> headers) argument 1111 decodeMultipartData(String boundary, ByteBuffer fbuf, BufferedReader in, Map<String, String> parms, Map<String, String> files) argument [all...] |
/external/nanohttpd/websocket/src/main/java/fi/iki/elonen/ |
H A D | WebSocket.java | 19 protected InputStream in; field in class:WebSocket 45 this.in = handshakeRequest.getInputStream(); 66 handleWebsocketFrame(WebSocketFrame.read(in)); 156 if (in != null) { 158 in.close();
|
H A D | WebSocketFrame.java | 145 public static WebSocketFrame read(InputStream in) throws IOException { argument 146 byte head = (byte) checkedRead(in.read()); 159 frame.readPayloadInfo(in); 160 frame.readPayload(in); 177 private void readPayloadInfo(InputStream in) throws IOException { argument 178 byte b = (byte) checkedRead(in.read()); 184 _payloadLength = (checkedRead(in.read()) << 8 | checkedRead(in.read())) & 0xFFFF; 189 long _payloadLength = ((long) checkedRead(in.read())) << 56 | 190 ((long) checkedRead(in 221 readPayload(InputStream in) argument [all...] |
/external/nanopb-c/examples/using_double_on_avr/ |
H A D | double_conversion.c | 18 conversion_t in; local 19 in.f = value; 25 sign = (in.i >> 31) & 1; 26 exponent = ((in.i >> 23) & 0xFF) - 127; 27 mantissa = in.i & 0x7FFFFF; 74 /* Figure if value is in range representable by floats. */
|
/external/mesa3d/src/mesa/math/ |
H A D | m_debug_norm.c | 10 * to deal in the Software without restriction, including without limitation 16 * in all copies or substantial portions of the Software. 125 const GLvector4f *in, 130 const GLfloat *s = in->start; 136 for ( i = 0 ; i < in->count ; i++ ) { 142 s = (GLfloat *)((char *)s + in->stride); 148 const GLvector4f *in, 153 const GLfloat *s = in->start; 157 for ( i = 0 ; i < in->count ; i++ ) { 178 s = (GLfloat *)((char *)s + in 123 ref_norm_transform_rescale( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 146 ref_norm_transform_normalize( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument [all...] |
H A D | m_matrix.c | 9 * to deal in the Software without restriction, including without limitation 15 * in all copies or substantial portions of the Software. 31 * -# 4x4 transformation matrices are stored in memory in column major order. 47 * Bitmasks to indicate different kinds of 4x4 matrices in GLmatrix::flags 341 * stored in the GLmatrix::inv attribute. 469 * stored in the GLmatrix::inv attribute. 482 const GLfloat *in = mat->m; local 491 t = MAT(in,0,0) * MAT(in, 554 const GLfloat *in = mat->m; local 650 const GLfloat *in = mat->m; local 683 const GLfloat *in = mat->m; local [all...] |
H A D | m_norm_tmp.h | 10 * to deal in the Software without restriction, including without limitation 16 * in all copies or substantial portions of the Software. 37 * in - the source vector of normals 45 const GLvector4f *in, 50 const GLfloat *from = in->start; 51 const GLuint stride = in->stride; 52 const GLuint count = in->count; 105 dest->count = in->count; 112 const GLvector4f *in, 117 const GLfloat *from = in 43 transform_normalize_normals( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 110 transform_normalize_normals_no_rot( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 175 transform_rescale_normals_no_rot( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 204 transform_rescale_normals( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 236 transform_normals_no_rot( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 266 transform_normals( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 296 normalize_normals( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument 342 rescale_normals( const GLmatrix *mat, GLfloat scale, const GLvector4f *in, const GLfloat *lengths, GLvector4f *dest ) argument [all...] |
/external/mesa3d/src/mesa/state_tracker/ |
H A D | st_format.c | 9 * "Software"), to deal in the Software without restriction, including 16 * next paragraph) shall be included in all copies or substantial portions 755 * The first pipe format in the list that's supported is the one that's chosen. 1602 * that in advance. Specify potential render target flags now. 1707 int *in = colorIn->i; local 1712 out[0] = in[0]; 1718 out[0] = in[0]; 1719 out[1] = in[1]; 1724 out[0] = in[0]; 1725 out[1] = in[ 1749 float *in = colorIn->f; local [all...] |
/external/mesa3d/src/mesa/tnl/ |
H A D | t_draw.c | 9 * to deal in the Software without restriction, including without limitation 15 * in all copies or substantial portions of the Software. 69 const TYPE *in = (TYPE *)ptr; \ 71 *fptr++ = MACRO(*in); \ 72 in++; \ 78 const TYPE *in = (TYPE *)ptr; \ 80 *fptr++ = (GLfloat)(*in); \ 81 in++; \ 103 const GLubyte *in = (GLubyte *) ptr; /* in i local 120 GLhalfARB *in = (GLhalfARB *)ptr; local 149 const GLfixed *in = (GLfixed *) ptr; local 157 const GLfixed *in = (GLfixed *) ptr; local 371 const GLuint *in = (GLuint *)ptr; local 376 const GLushort *in = (GLushort *)ptr; local 381 const GLubyte *in = (GLubyte *)ptr; local [all...] |
H A D | t_vb_fog.c | 9 * to deal in the Software without restriction, including without limitation 15 * in all copies or substantial portions of the Software. 94 * Fog blend factors are in the range [0,1]. 97 compute_fog_blend_factors(struct gl_context *ctx, GLvector4f *out, const GLvector4f *in) argument 100 GLfloat *v = in->start; 101 GLuint stride = in->stride; 102 GLuint n = in->count; 107 out->count = in->count; 136 _mesa_problem(ctx, "Bad fog mode in make_fog_coord");
|
H A D | t_vb_texgen.c | 9 * to deal in the Software without restriction, including without limitation 15 * in all copies or substantial portions of the Software. 69 /* Temporary values used in texgen. 171 /* This is unusual in that we respect the stride of the output vector 172 * (f). This allows us to pass in either a texcoord vector4f, or a 256 GLvector4f *in = VB->AttribPtr[VERT_ATTRIB_TEX0 + unit]; local 264 out->flags |= (in->flags & VEC_SIZE_FLAGS) | VEC_SIZE_3; 266 out->size = MAX2(in->size, 3); 267 if (in->size == 4) 268 _mesa_copy_tab[0x8]( out, in ); 278 GLvector4f *in = VB->AttribPtr[VERT_ATTRIB_TEX0 + unit]; local 306 GLvector4f *in = VB->AttribPtr[VERT_ATTRIB_TEX0 + unit]; local 340 GLvector4f *in = VB->AttribPtr[VERT_ATTRIB_TEX0 + unit]; local [all...] |