- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 442 for send0 (0.09 sec)
-
docs/pt/docs/help-fastapi.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/shared-lock.go
// The context of the lock is canceled, this can happen // if one lock lost quorum due to cluster instability // in that case, try to lock again. break keepLock case ld.lockContext <- lkctx: // Send the lock context to anyone asking for it } } } } func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) { ctx, cancel := context.WithCancel(context.Background()) go func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/metrics-v2_test.go
val: 0.61, label: labels[3], }, { val: 0.79, label: labels[2], }, } ticker := time.NewTicker(1 * time.Millisecond) defer ticker.Stop() for _, obs := range observations { // Send observations once every 1ms, to simulate delay between // observations. This is to test the channel based // synchronization used internally. select { case <-ticker.C:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Mar 04 18:05:56 UTC 2024 - 2.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbWatchHandleImpl.java
} if ( log.isTraceEnabled() ) { log.trace("Sending NtTransNotifyChange for " + this.handle); } try { resp = th.send(req, resp, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY); } catch ( SmbException e ) { if ( e.getNtStatus() == 0xC0000120 ) { // cancelled
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.5K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
if (requestHeaders.name(i) == Header.TARGET_PATH_UTF8) { path = requestHeaders.value(i) break } i++ } if (path == null) { // TODO: send bad request error throw AssertionError() } val file = File(baseDirectory.toString() + path) if (file.isDirectory) { serveDirectory(stream, file.listFiles()!!)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.1K bytes - Viewed (0) -
docs/en/docs/tutorial/response-status-code.md
/// ## About HTTP status codes /// note If you already know what HTTP status codes are, skip to the next section. /// In HTTP, you send a numeric status code of 3 digits as part of the response. These status codes have a name associated to recognize them, but the important part is the number. In short:
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 11:13:18 UTC 2024 - 3.9K bytes - Viewed (0) -
docs/pt/docs/deployment/concepts.md
A palavra **processo** normalmente é usada de forma mais específica, referindo-se apenas ao que está sendo executado no sistema operacional (como no último ponto acima): * Um programa específico enquanto está **em execução** no sistema operacional. * Isso não se refere ao arquivo, nem ao código, refere-se **especificamente** à coisa que está sendo **executada** e gerenciada pelo sistema operacional.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Oct 04 11:04:50 UTC 2024 - 19.7K bytes - Viewed (0) -
internal/grid/connection.go
if err != nil { return err } if msg.Flags&FlagCRCxxh3 != 0 { h := xxh3.Hash(dst) dst = binary.LittleEndian.AppendUint32(dst, uint32(h)) } return c.send(c.ctx, dst) } // sendMsg will send func (c *Connection) sendMsg(conn net.Conn, msg message, payload msgp.MarshalSizer) error { if payload != nil { if sz := payload.Msgsize(); cap(msg.Payload) < sz { PutByteBuffer(msg.Payload)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java
protected void doSendFragment ( byte[] buf, int off, int length ) throws IOException { if ( this.handle.isStale() ) { throw new IOException("DCERPC pipe is no longer open"); } this.handle.send(buf, off, length); } @Override protected int doReceiveFragment ( byte[] buf ) throws IOException { if ( buf.length < getMaxRecv() ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jan 26 11:51:07 UTC 2020 - 5.2K bytes - Viewed (0) -
cmd/callhome.go
for { select { case hi, hasMore := <-healthInfoCh: if !hasMore { auditOptions := AuditLogOptions{Event: "callhome:diagnostics"} // Received all data. Send to SUBNET and return err := sendHealthInfo(ctx, healthInfo) if err != nil { internalLogIf(ctx, fmt.Errorf("Unable to perform callhome: %w", err)) auditOptions.Error = err.Error() }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 17 16:53:34 UTC 2024 - 5.3K bytes - Viewed (0)