Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Wignall (0.21 sec)

  1. istioctl/pkg/dashboard/dashboard.go

    	}
    
    	return fmt.Errorf("failure running port forward process: %v", err)
    }
    
    func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) {
    	go func() {
    		signals := make(chan os.Signal, 1)
    		signal.Notify(signals, os.Interrupt)
    		defer signal.Stop(signals)
    		<-signals
    		fw.Close()
    	}()
    }
    
    func openBrowser(url string, writer io.Writer, browser bool) {
    	var err error
    
    	fmt.Fprintf(writer, "%s\n", url)
    
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Apr 15 01:29:35 GMT 2024
    - 20.5K bytes
    - Viewed (0)
  2. cmd/object-api-interface.go

    	MaxParts            int                 // used in GetObjectAttributes. Signals how many parts we should return
    	PartNumberMarker    int                 // used in GetObjectAttributes. Signals the part number after which results should be returned
    	PartNumber          int                 // only useful in case of GetObject/HeadObject
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/net/HttpHeaders.java

      /**
       * The HTTP <a
       * href="https://wicg.github.io/turtledove/#handling-direct-from-seller-signals">{@code
       * Ad-Auction-Signals}</a> header field name.
       *
       * @since 33.0.0
       */
      public static final String AD_AUCTION_SIGNALS = "Ad-Auction-Signals";
    
      /**
       * The HTTP <a href="https://wicg.github.io/turtledove/#http-headerdef-ad-auction-allowed">{@code
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:08:08 GMT 2024
    - 34.3K bytes
    - Viewed (0)
  4. cmd/notification.go

    		}
    		client := client
    		ng.Go(GlobalContext, func() error {
    			return client.SignalService(serviceReloadDynamic, subSys, false)
    		}, idx, *client.host)
    	}
    	return ng.Wait()
    }
    
    // SignalService - calls signal service RPC call on all peers.
    func (sys *NotificationSys) SignalService(sig serviceSignal) []NotificationPeerErr {
    	ng := WithNPeers(len(sys.peerClients))
    	for idx, client := range sys.peerClients {
    		if client == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

            SynchronousQueue(),
            threadFactory,
          )
    
        override fun nanoTime() = System.nanoTime()
    
        override fun coordinatorNotify(taskRunner: TaskRunner) {
          taskRunner.condition.signal()
        }
    
        /**
         * Wait a duration in nanoseconds. Unlike [java.lang.Object.wait] this interprets 0 as
         * "don't wait" instead of "wait forever".
         */
        @Throws(InterruptedException::class)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  6. cni/pkg/cmd/root.go

    		if err = installer.Run(ctx); err != nil {
    			if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
    				log.Infof("installer complete: %v", err)
    				// Error was caused by interrupt/termination signal
    				err = nil
    			} else {
    				log.Errorf("installer failed: %v", err)
    			}
    		}
    
    		if cleanErr := installer.Cleanup(); cleanErr != nil {
    			if err != nil {
    Go
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.5K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

              signalledCallback = true
              responseCallback.onResponse(this@RealCall, response)
            } catch (e: IOException) {
              if (signalledCallback) {
                // Do not signal the callback twice!
                Platform.get().log("Callback failure for ${toLoggableString()}", Platform.INFO, e)
              } else {
                responseCallback.onFailure(this@RealCall, e)
              }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  8. cmd/globals.go

    	globalTLSCerts *certs.Manager
    
    	globalHTTPServer        *xhttp.Server
    	globalTCPOptions        xhttp.TCPOptions
    	globalHTTPServerErrorCh = make(chan error)
    	globalOSSignalCh        = make(chan os.Signal, 1)
    
    	// global Trace system to send HTTP request/response
    	// and Storage/OS calls info to registered listeners.
    	globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  9. cmd/server-main.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/hex"
    	"errors"
    	"fmt"
    	"io"
    	"log"
    	"math/rand"
    	"net"
    	"os"
    	"os/signal"
    	"path/filepath"
    	"runtime"
    	"strings"
    	"syscall"
    	"time"
    
    	"github.com/coreos/go-systemd/v22/daemon"
    	"github.com/dustin/go-humanize"
    	"github.com/minio/cli"
    	"github.com/minio/madmin-go/v3"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 34.9K bytes
    - Viewed (1)
  10. internal/grid/handlers.go

    	responses *Stream
    	newResp   func() Resp
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    	// If the request context is canceled, the stream will no longer process requests.
    	Requests chan<- Req
    }
    
    // Results returns the results from the remote server one by one.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
Back to top