Req - Code Search

internal/logger/logger.go

			logKind = ek
		}
	}

	req := GetReqInfo(ctx)
	if req == nil {
		req = &ReqInfo{
			API:       "SYSTEM",
			RequestID: fmt.Sprintf("%X", time.Now().UTC().UnixNano()),
		}
	}
	req.RLock()
	defer req.RUnlock()

	API := "SYSTEM"
	switch {
	case req.API != "":
		API = req.API
	case subsystem != "":
		API += "." + subsystem
	}

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 12.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java

            }
        };

        // When
        BufferCache.getBuffers(req, rsp);

        // Then
        assertNotNull(req.txn_buf, "Request buffer should be allocated");
        assertNotNull(rsp.txn_buf, "Response buffer should be allocated");
        assertEquals(SmbComTransaction.TRANSACTION_BUF_SIZE, req.txn_buf.length, "Request buffer should have correct size");

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 9.6K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbFile.java

        SmbComTransaction req;
        SmbComTransactionResponse resp;

        if (listType == 0) {
            connect0();
            req = new NetServerEnum2(tree.session.transport.server.oemDomainName, NetServerEnum2.SV_TYPE_DOMAIN_ENUM);
        } else if (listType == TYPE_WORKGROUP) {
            req = new NetServerEnum2(url.getHost(), NetServerEnum2.SV_TYPE_ALL);

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 112.2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

                .thenReturn(resp);

        CommonServerMessageBlockResponse out = handle.send(req, RequestParam.NO_RETRY);
        assertSame(resp, out);

        verify(treeConnection, times(1)).send(eq(resourceLoc), eq((CommonServerMessageBlockRequest) req), isNull(),
                any(RequestParam[].class));
    }

    @Test

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 14.4K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SmbTreeHandleImpl.java

    }

    /**
     *
     * @param req
     * @param params
     * @return response
     * @throws CIFSException
     */
    public <T extends CommonServerMessageBlockResponse> T send(final jcifs.internal.Request<T> req, final RequestParam... params)
            throws CIFSException {
        return send(req, null, params);
    }

    /**
     * @param request

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sun Aug 31 08:00:57 GMT 2025

- 11.1K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/helper/QueryHelper.java

     *
     * @param req the HTTP servlet request
     * @param query the search query string
     * @return the preference value for JSON search requests, or null if not applicable
     */
    protected String processJsonSearchPreference(final HttpServletRequest req, final String query) {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Jul 17 08:28:31 GMT 2025

- 19.9K bytes

- Click Count (0)

github.com/minio/minio

internal/event/target/webhook.go

	tokens := strings.Fields(target.args.AuthToken)
	switch len(tokens) {
	case 2:
		req.Header.Set("Authorization", target.args.AuthToken)
	case 1:
		req.Header.Set("Authorization", "Bearer "+target.args.AuthToken)
	}

	req.Header.Set("Content-Type", "application/json")

	resp, err := target.httpClient.Do(req)
	if err != nil {
		return err
	}
	xhttp.DrainBody(resp.Body)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Sep 06 23:06:30 GMT 2024

- 8.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/ServerMessageBlock2Request.java

    }

    /**
     * Create the response object for this request
     *
     * @param tc the CIFS context
     * @param req the request object
     * @return the response object
     */
    protected abstract T createResponse(CIFSContext tc, ServerMessageBlock2Request<T> req);

    /**
     *
     * {@inheritDoc}
     *

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Mon Aug 25 14:34:10 GMT 2025

- 7.2K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/taglib/FessFunctions.java

     */
    public static String html(final boolean isOpen) {
        if (isOpen) {
            return "<html lang=\"" + LaRequestUtil.getOptionalRequest().map(req -> {
                if (req.getAttribute(LastaWebKey.USER_LOCALE_KEY) instanceof Locale locale) {
                    return locale;
                }
                return Locale.ENGLISH;

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 25.4K bytes

- Click Count (1)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/smb1/SmbSessionTest.java

    void sendResetsResponseAndForwards() throws Exception {
        SmbSession session = new SmbSession(addr, 445, inet, 0, auth);
        // prepare a dummy request/response using a real SMB block type
        ServerMessageBlock req = new SmbComOpenAndX("test.txt", 0, 0, null);
        ServerMessageBlock resp = new SmbComOpenAndX("test.txt", 0, 0, null);
        resp.received = true;

        session.transport(); // initialise transport

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 5.6K bytes

- Click Count (0)

Search Options