Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 277 for mkchan (0.05 sec)

  1. cmd/signals.go

    1. "strings"
    2. "time"
    3.  
    4. "github.com/coreos/go-systemd/v22/daemon"
    5. "github.com/minio/minio/internal/logger"
    6. )
    7.  
    8. func shutdownHealMRFWithTimeout() {
    9. const shutdownTimeout = time.Minute
    10.  
    11. finished := make(chan struct{})
    12. go func() {
    13. globalMRFState.shutdown()
    14. close(finished)
    15. }()
    16. select {
    17. case <-time.After(shutdownTimeout):
    18. case <-finished:
    19. }
    20. }
    21.  
    22. func handleSignals() {
    23. // Custom exit function
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. cmd/perf-tests.go

    1. defer n.Unlock()
    2. n.RX = 0
    3. n.RXSample = 0
    4. n.lastToConnect = time.Time{}
    5. n.firstToDisconnect = time.Time{}
    6. }
    7.  
    8. // Reader to read random data.
    9. type netperfReader struct {
    10. n uint64
    11. eof chan struct{}
    12. buf []byte
    13. }
    14.  
    15. func (m *netperfReader) Read(b []byte) (int, error) {
    16. select {
    17. case <-m.eof:
    18. return 0, io.EOF
    19. default:
    20. }
    21. n := copy(b, m.buf)
    22. atomic.AddUint64(&m.n, uint64(n))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingImmutableCollection.java

    1. import org.checkerframework.checker.nullness.qual.Nullable;
    2.  
    3. /**
    4. * A GWT-only class only used by GWT emulations. It is used to consolidate the definitions of method
    5. * delegation to save code size.
    6. *
    7. * @author Hayward Chan
    8. */
    9. // TODO: Make this class GWT serializable.
    10. @ElementTypesAreNonnullByDefault
    11. class ForwardingImmutableCollection<E> extends ImmutableCollection<E> {
    12.  
    13. final transient Collection<E> delegate;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 23 18:43:40 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. cmd/naughty-disk_test.go

    1. return d.disk.GetDiskID()
    2. }
    3.  
    4. func (d *naughtyDisk) SetDiskID(id string) {
    5. d.disk.SetDiskID(id)
    6. }
    7.  
    8. func (d *naughtyDisk) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, weSleep func() bool) (info dataUsageCache, err error) {
    9. if err := d.calcError(); err != nil {
    10. return info, err
    11. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/ForwardingCollectionTest.java

    1. import junit.framework.Test;
    2. import junit.framework.TestCase;
    3. import junit.framework.TestSuite;
    4.  
    5. /**
    6. * Tests for {@link ForwardingCollection}.
    7. *
    8. * @author Robert Konigsberg
    9. * @author Hayward Chan
    10. * @author Louis Wasserman
    11. */
    12. public class ForwardingCollectionTest extends TestCase {
    13. static final class StandardImplForwardingCollection<T> extends ForwardingCollection<T> {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.7K bytes
    - Viewed (0)
  6. docs/de/docs/tutorial/response-model.md

    1. Hierbei können Sie **Typannotationen** genauso verwenden, wie Sie es bei Werten von Funktions-**Parametern** machen; verwenden Sie Pydantic-Modelle, Listen, Dicts und skalare Werte wie Nummern, Booleans, usw.
    2.  
    3. //// tab | Python 3.10+
    4.  
    5. ```Python hl_lines="16 21"
    6. {!> ../../docs_src/response_model/tutorial001_01_py310.py!}
    7. ```
    8.  
    9. ////
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    1. client sarama.Client
    2. producer sarama.SyncProducer
    3. config *sarama.Config
    4. store store.Store[event.Event]
    5. batch *store.Batch[event.Event]
    6. loggerOnce logger.LogOnce
    7. quitCh chan struct{}
    8. }
    9.  
    10. // ID - returns target ID.
    11. func (target *KafkaTarget) ID() event.TargetID {
    12. return target.id
    13. }
    14.  
    15. // Name - returns the Name of the target.
    16. func (target *KafkaTarget) Name() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. docs/de/docs/advanced/path-operation-advanced-configuration.md

    1. Das könnte man mit `openapi_extra` machen:
    2.  
    3. ```Python hl_lines="20-37 39-40"
    4. {!../../docs_src/path_operation_advanced_configuration/tutorial006.py!}
    5. ```
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  9. cmd/storage-interface.go

    1. // has never been replaced.
    2. Healing() *healingTracker
    3. DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error)
    4. NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error)
    5.  
    6. // Volume operations.
    7. MakeVol(ctx context.Context, volume string) (err error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. docs/es/docs/index.md

    1. * Seguridad y autenticación incluyendo soporte para **OAuth2** con **JWT tokens** y **HTTP Basic** auth.
    2. * Técnicas más avanzadas, pero igual de fáciles, para declarar **modelos de JSON profundamente anidados** (gracias a Pydantic).
    3. * Muchas características extra (gracias a Starlette) como:
    4. * **WebSockets**
    5. * **GraphQL**
    6. * pruebas extremadamente fáciles con HTTPX y `pytest`
    7. * **CORS**
    8. * **Cookie Sessions**
    9. * ...y mucho más.
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top