Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 442 for send0 (0.09 sec)

  1. docs/pt/docs/help-fastapi.md

    Adoro ouvir sobre como o **FastAPI** é usado, o que você gosta nele, em qual projeto/empresa está sendo usado, etc.
    
    ## Vote no FastAPI
    
    * <a href="https://www.slant.co/options/34241/~fastapi-review" class="external-link" target="_blank">Vote no **FastAPI** no Slant</a>.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top