- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 175 for req (0.14 sec)
-
internal/grid/handlers.go
// The request may be reused, so caller should clear any fields. func (h *SingleHandler[Req, Resp]) NewRequest() Req { return h.newReq() } // Register a handler for a Req -> Resp roundtrip. // Requests are automatically recycled. func (h *SingleHandler[Req, Resp]) Register(m *Manager, handle func(req Req) (resp Resp, err *RemoteErr), subroute ...string) error { if h.newReq == nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0) -
cmd/url_test.go
b.ResetTimer() if err := req.ParseForm(); err != nil { b.Fatal(err) } b.RunParallel(func(pb *testing.PB) { for pb.Next() { req.Form.Get("uploadId") } }) // Benchmark ends here. Stop timer. b.StopTimer() } // BenchmarkURLQuery - benchmark URL memory allocations func BenchmarkURLQuery(b *testing.B) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Nov 16 17:28:29 GMT 2021 - 2K bytes - Viewed (0) -
cmd/test-utils_test.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 75.7K bytes - Viewed (0) -
internal/handlers/forwarder.go
} } if xfPort := req.Header.Get(xForwardedPort); xfPort == "" { req.Header.Set(xForwardedPort, forwardedPort(req)) } if xfHost := req.Header.Get(xForwardedHost); xfHost == "" && req.Host != "" { req.Header.Set(xForwardedHost, req.Host) } } func forwardedPort(req *http.Request) string { if req == nil { return "" } if _, port, err := net.SplitHostPort(req.Host); err == nil && port != "" {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/http/NtlmSsp.java
* for the specified servlet request. * * @param req The request being serviced. * @param resp The response. * @param challenge The domain controller challenge. * @throws IOException If an IO error occurs. * @throws ServletException If an error occurs. */ public NtlmPasswordAuthentication doAuthentication( HttpServletRequest req, HttpServletResponse resp, byte[] challenge)
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 4.4K bytes - Viewed (1) -
src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java
} ServerMessageBlock req = (ServerMessageBlock) request; req.addFlags2(this.negotiatedFlags2); req.setUseUnicode(req.isForceUnicode() || this.useUnicode); if ( req.isUseUnicode() ) { req.addFlags2(SmbConstants.FLAGS2_UNICODE); } if ( req instanceof SmbComTransaction ) { ( (SmbComTransaction) req ).setMaxBufferSize(this.snd_buf_size); }
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Tue Jul 07 10:52:42 GMT 2020 - 15.4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbPipeHandleImpl.java
Smb2IoctlRequest req = new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_TRANSCEIVE, fh.getFileId(), inB); req.setFlags(Smb2IoctlRequest.SMB2_O_IOCTL_IS_FSCTL); req.setInputData(new ByteEncodable(buf, off, length)); req.setMaxOutputResponse(maxRecvSize); Smb2IoctlResponse resp = th.send(req, RequestParam.NO_RETRY);
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Mon Apr 13 17:05:22 GMT 2020 - 10.3K bytes - Viewed (0) -
cmd/utils.go
req := logger.GetReqInfo(ctx) if req != nil { req.Lock() defer req.Unlock() req.Objects = make([]logger.ObjectVersion, 0, len(objects)) for _, ov := range objects { req.Objects = append(req.Objects, logger.ObjectVersion{ ObjectName: ov.ObjectName, VersionID: ov.VersionID, }) } return logger.SetReqInfo(ctx, req) } return ctx }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 32K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
func newUnsignedV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { if trailer { // Discard anything unsigned. req.Trailer = make(http.Header) trailers := req.Header.Values(awsTrailerHeader) for _, key := range trailers { req.Trailer.Add(key, "") } } else { req.Trailer = nil } return &s3UnsignedChunkedReader{ trailers: req.Trailer, reader: bufio.NewReader(req.Body),
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat May 06 02:53:12 GMT 2023 - 6.1K bytes - Viewed (1) -
internal/config/identity/plugin/config.go
func (a *Args) Validate() error { req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte(""))) if err != nil { return err } req.Header.Set("Content-Type", "application/json") if a.AuthToken != "" { req.Header.Set("Authorization", a.AuthToken) } client := &http.Client{Transport: a.Transport} resp, err := client.Do(req) if err != nil { return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3)