Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 187 for mateix (0.12 sec)

  1. cmd/sftp-server-driver.go

    	return err
    }
    
    type writerAt struct {
    	w      *io.PipeWriter
    	r      *io.PipeReader
    	wg     *sync.WaitGroup
    	buffer map[int64][]byte
    	err    error
    
    	nextOffset int64
    	m          sync.Mutex
    }
    
    func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) {
    	w.m.Lock()
    	defer w.m.Unlock()
    
    	if w.nextOffset == offset {
    		n, err = w.w.Write(b)
    		w.nextOffset += int64(n)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  2. docs/de/docs/deployment/server-workers.md

    ```
    
    </div>
    
    Sehen wir uns an, was jede dieser Optionen bedeutet:
    
    * `main:app`: Das ist die gleiche Syntax, die auch von Uvicorn verwendet wird. `main` bedeutet das Python-Modul mit dem Namen `main`, also eine Datei `main.py`. Und `app` ist der Name der Variable, welche die **FastAPI**-Anwendung ist.
        * Stellen Sie sich einfach vor, dass `main:app` einer Python-`import`-Anweisung wie der folgenden entspricht:
    
            ```Python
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver.go

    	when a new ztunnel connects with different uid, only propagate deletes to older ztunnels.
    */
    
    type connMgr struct {
    	connectionSet map[*ZtunnelConnection]struct{}
    	latestConn    *ZtunnelConnection
    	mu            sync.Mutex
    }
    
    func (c *connMgr) addConn(conn *ZtunnelConnection) {
    	log.Debug("ztunnel connected")
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	c.connectionSet[conn] = struct{}{}
    	c.latestConn = conn
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  4. cmd/metrics-v3-types.go

    	descriptorMap map[MetricName]MetricDescriptor
    
    	// For bucket metrics, the list of buckets is stored here. It is used in the
    	// Collect() call. This is protected by the `bucketsLock`.
    	bucketsLock sync.Mutex
    	buckets     []string
    }
    
    // NewMetricsGroup creates a new MetricsGroup. To create a metrics group for
    // metrics with a `bucket` dimension (label), use `NewBucketMetricsGroup`.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	nrRequests   uint64
    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    // checkPathLength - returns error if given path name length more than 255
    func checkPathLength(pathName string) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. internal/rest/client.go

    	// TraceOutput will print debug information on non-200 calls if set.
    	TraceOutput io.Writer // Debug trace output
    
    	httpClient *http.Client
    	url        *url.URL
    	auth       func() string
    
    	sync.RWMutex // mutex for lastErr
    	lastErr      error
    	lastErrTime  time.Time
    }
    
    type restError string
    
    func (e restError) Error() string {
    	return string(e)
    }
    
    func (e restError) Timeout() bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. internal/grid/muxclient.go

    	BaseFlags          Flags
    	ctx                context.Context
    	cancelFn           context.CancelCauseFunc
    	parent             *Connection
    	respWait           chan<- Response
    	respMu             sync.Mutex
    	singleResp         bool
    	closed             bool
    	stateless          bool
    	acked              bool
    	init               bool
    	deadline           time.Duration
    	outBlock           chan struct{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    	state State
    
    	// Non-atomic
    	Remote string
    	Local  string
    
    	// ID of this connection instance.
    	id uuid.UUID
    
    	// Remote uuid, if we have been connected.
    	remoteID    *uuid.UUID
    	reconnectMu sync.Mutex
    
    	// Context for the server.
    	ctx context.Context
    
    	// Active mux connections.
    	outgoing *xsync.MapOf[uint64, *muxClient]
    
    	// Incoming streams
    	inStream *xsync.MapOf[uint64, *muxServer]
    
    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. guava-tests/test/com/google/common/reflect/TypeTokenTest.java

        assertEquals(int[].class, arrayOf(int.class).getRawType());
      }
    
      @SuppressWarnings("unused") // used by reflection
      private static class Holder<T> {
        List<T>[] matrix;
    
        void setList(List<T> list) {}
      }
    
      public void testWildcardCaptured_methodParameter_upperBound() throws Exception {
        TypeToken<Holder<?>> type = new TypeToken<Holder<?>>() {};
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 21:13:09 UTC 2024
    - 89.1K bytes
    - Viewed (0)
  10. docs/en/docs/async.md

    * **Machine Learning**: it normally requires lots of "matrix" and "vector" multiplications. Think of a huge spreadsheet with numbers and multiplying all of them together at the same time.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Aug 28 23:33:37 UTC 2024
    - 23.5K bytes
    - Viewed (0)
Back to top