- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for onConnect (0.48 sec)
-
src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java
} else if (entry.getValue().length == 1) { curlRequest.param(entry.getKey(), entry.getValue()[0]); } }); try (final CurlResponse curlResponse = curlRequest.onConnect((req, con) -> { con.setDoOutput(true); if (httpMethod != Method.GET && request.getContentLength() > 2) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.4K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/CurlRequest.java
if (body != null) { throw new CurlException("body method is already called."); } this.bodyStream = stream; return this; } public CurlRequest onConnect(final BiConsumer<CurlRequest, HttpURLConnection> connectionBuilder) { this.connectionBuilder = connectionBuilder; return this; } public CurlRequest param(final String key, final String value) {
Java - Registered: Thu May 09 15:34:10 GMT 2024 - Last Modified: Sun Feb 12 12:21:25 GMT 2023 - 12.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
final ObjectMapper mapper = new ObjectMapper(); final AtomicBoolean resetJobs = new AtomicBoolean(false); try (CurlResponse response = ComponentUtil.getCurlHelper().post("/_bulk").onConnect((req, con) -> { con.setDoOutput(true); try (final BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(tempFile)));
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 25.2K bytes - Viewed (0) -
internal/grid/msg_string.go
package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[OpConnect-1] _ = x[OpConnectResponse-2] _ = x[OpPing-3] _ = x[OpPong-4] _ = x[OpConnectMux-5] _ = x[OpMuxConnectError-6] _ = x[OpDisconnectClientMux-7] _ = x[OpDisconnectServerMux-8] _ = x[OpMuxClientMsg-9]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 1.2K bytes - Viewed (0) -
internal/grid/msg.go
// Op is operation type messages. type Op uint8 // HandlerID is the ID for the handler of a specific type. type HandlerID uint8 const ( // OpConnect is a connect request. OpConnect Op = iota + 1 // OpConnectResponse is a response to a connect request. OpConnectResponse // OpPing is a ping request. // If a mux id is specified that mux is pinged.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/grid/manager.go
} var message message _, _, err = message.parse(msg) if err != nil { writeErr(fmt.Errorf("error parsing grid connect: %w", err)) return } if message.Op != OpConnect { writeErr(fmt.Errorf("unexpected connect op: %v", message.Op)) return } var cReq connectReq _, err = cReq.UnmarshalMsg(message.Payload) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/grid/connection.go
} c.updateState(StateConnectionError) time.Sleep(sleep) } if err != nil { retry(err) continue } // Send connect message. m := message{ Op: OpConnect, } req := connectReq{ Host: c.Local, ID: c.id, } err = c.sendMsg(conn, m, &req) if err != nil { retry(err) continue } // Wait for response
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0)