Search Options

Results per page
Sort
Preferred Languages
Advance

Results 901 - 910 of 1,093 for Bearer (0.07 sec)

  1. android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java

    import java.io.ByteArrayOutputStream;
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.io.PrintWriter;
    import java.io.Reader;
    import java.io.StringReader;
    import java.io.StringWriter;
    import java.io.Writer;
    import java.lang.reflect.AnnotatedElement;
    import java.lang.reflect.GenericDeclaration;
    import java.lang.reflect.Type;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  2. cmd/metacache-stream_test.go

    "src/compress/gzip/testdata/issue6550.gz.base64", "src/compress/lzw/", "src/compress/lzw/reader.go", "src/compress/lzw/reader_test.go", "src/compress/lzw/writer.go", "src/compress/lzw/writer_test.go", "src/compress/testdata/", "src/compress/testdata/e.txt", "src/compress/testdata/gettysburg.txt", "src/compress/testdata/pi.txt", "src/compress/zlib/", "src/compress/zlib/example_test.go", "src/compress/zlib/reader.go", "src/compress/zlib/reader_test.go", "src/compress/zlib/writer.go", "src/compress/z...
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 15K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/XmlTransformer.java

                    logger.debug("Failed to retrieval a cache.", e);
                }
                return new XPathAPI();
            }
        }
    
        /**
         * Returns the header for the result data.
         * @return The result data header.
         */
        protected String getResultDataHeader() {
            // TODO support other type
            return "<?xml version=\"1.0\"?>\n<doc>\n";
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 23.9K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

    import okhttp3.internal.ws.WebSocketProtocol.toggleMask
    import okio.Buffer
    import okio.BufferedSource
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame reader.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketReader(
      private val isClient: Boolean,
      val source: BufferedSource,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescResponseTest.java

         */
        private byte[] createValidSecurityDescriptorBuffer(int size) {
            ByteBuffer buffer = ByteBuffer.allocate(size);
            buffer.order(ByteOrder.LITTLE_ENDIAN);
    
            // Security descriptor header
            buffer.put((byte) 0x01); // Revision
            buffer.put((byte) 0x00); // Padding
            buffer.putShort((short) 0x8004); // Control flags (SE_DACL_PRESENT | SE_SELF_RELATIVE)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  6. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/it/CrudTestBase.java

            // logger.debug(response.asString());
            return response;
        }
    
        protected Response checkDeleteMethod(final String path) {
            return given().contentType("application/json").header("Authorization", getTestToken()).delete(getApiPath() + "/" + path);
        }
    
        protected List<Map<String, Object>> getItemList(final Map<String, Object> body) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/MIENameTest.java

            }
            byte[] nameBytes = "bob".getBytes(StandardCharsets.US_ASCII);
    
            return Stream.of(
                    // Too short for TOK_ID + MECH_OID_LEN
                    Arguments.of("too short header", new byte[] { 0x04, 0x01, 0x00 }, IllegalArgumentException.class),
    
                    // Wrong TOK_ID
                    Arguments.of("wrong TOK_ID", new byte[] { 0x00, 0x02, 0x00, 0x01 }, IllegalArgumentException.class),
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  9. cmd/bucket-replication-utils_test.go

    			}
    		}
    	}
    }
    
    var replicationStateTest = []struct {
    	name      string
    	rs        ReplicationState
    	arn       string
    	expStatus replication.StatusType
    }{
    	{ // 1. no replication status header
    		name:      "no replicated targets",
    		rs:        ReplicationState{},
    		expStatus: replication.StatusType(""),
    	},
    	{ // 2. replication status for one target
    		name:      "replication status for one target",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  10. cmd/tier-handlers.go

    		return
    	}
    
    	tiers := globalTierConfigMgr.ListTiers()
    	data, err := json.Marshal(tiers)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	w.Header().Set(tierCfgRefreshAtHdr, globalTierConfigMgr.refreshedAt().String())
    	writeSuccessResponseJSON(w, data)
    }
    
    func (api adminAPIHandlers) EditTierHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top