- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 816 for Gevent (0.04 seconds)
-
src/main/webapp/js/admin/admin.js
} ) .click(function() { document.location = $(this).attr("data-href"); }); }); $("#confirmToDelete").on("show.bs.modal", function(event) { var button = $(event.relatedTarget); var docId = button.data("docid"); var title = button.data("title"); var url = button.data("url"); $(this) .find(".modal-body #delete-doc-title")Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Mon Aug 06 20:44:47 GMT 2018 - 3.1K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
} return updateScope; } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) { fireEvent(event, listeners, node, null); } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) { fireEvent(event, listeners, node, replacement, null); } private void fireEvent(Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 36.5K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
return nil } return err } atomic.AddInt64(&h.totalMessages, 1) err = h.send(auditEntry) if err != nil { atomic.AddInt64(&h.failedMessages, 1) return err } // Delete the event from store. return h.store.Del(key) } // Cancel - cancels the target func (h *Target) Cancel() { // If queuestore is configured, cancel it's context to // stop the replay go-routine.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
package okhttp3.sse import okhttp3.Response abstract class EventSourceListener { /** * Invoked when an event source has been accepted by the remote peer and may begin transmitting * events. */ open fun onOpen( eventSource: EventSource, response: Response, ) { } open fun onEvent( eventSource: EventSource, id: String?, type: String?, data: String, ) { }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Oct 03 07:51:20 GMT 2025 - 1.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/ActivityHelper.java
*/ public void setEcsServiceName(final String ecsServiceName) { this.ecsServiceName = ecsServiceName; } /** * Set the ECS event dataset. * @param ecsEventDataset The ECS event dataset. */ public void setEcsEventDataset(final String ecsEventDataset) { this.ecsEventDataset = ecsEventDataset; }Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 10.8K bytes - Click Count (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/Location.java
package org.apache.maven.api.services.xml; public interface Location { /** * Return the line number where the current event ends, * returns -1 if none is available. * @return the current line number */ int getLineNumber(); /** * Return the column number where the current event ends, * returns -1 if none is available. * @return the current column number */ int getColumnNumber();Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 1.9K bytes - Click Count (0) -
cmd/object-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } event := evalActionFromLifecycle(ctx, *lc, rcfg, replcfg, objInfo) if event.Action.Delete() { // apply whatever the expiry rule is. applyExpiryRule(event, lcEventSrc_s3GetObject, objInfo) if !event.Action.DeleteRestored() { // If the ILM action is not on restored object return error.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 120.6K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
} canceled -> { events += "plan $id TCP connect canceled" ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled")) } connectTcpNextPlan != null -> { events += "plan $id needs follow-up" ConnectResult(this, nextPlan = connectTcpNextPlan) } else -> { events += "plan $id TCP connected"Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 6.1K bytes - Click Count (0) -
lib/wasm/wasm_exec.js
if (this.exited) { this._resolveExitPromise(); } } _makeFuncWrapper(id) { const go = this; return function () { const event = { id: id, this: this, args: arguments }; go._pendingEvent = event; go._resume(); return event.result; }; } }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Sun Dec 08 15:34:47 GMT 2024 - 16.6K bytes - Click Count (0) -
internal/logger/logger.go
if consoleTgt != nil { // Sending to the console never fails consoleTgt.Send(ctx, errToEntry(ctx, "logging", fmt.Errorf("unable to send log event to Logger target (%s): %v", t.String(), err), entry.Level)) } } } } // Event sends a event log to log targets func Event(ctx context.Context, subsystem, msg string, args ...any) { if DisableLog { return }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0)