Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 524 for isSelect (0.17 sec)

  1. src/internal/types/testdata/check/labels.go

    		}
    	}
    
    L9:
    	switch {
    	case true:
    		break L9
    	defalt /* ERROR "label defalt declared and not used" */ :
    	}
    
    L10:
    	select {
    	default:
    		break L10
    		break L9 /* ERROR "invalid break label L9" */
    	}
    
    	goto L10a
    L10a: L10b:
    	select {
    	default:
    		break L10a /* ERROR "invalid break label L10a" */
    		break L10b
    		continue L10b /* ERROR "invalid continue label L10b" */
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. tensorflow/BUILD

    cc_library(
        name = "grpc",
        visibility = ["//visibility:public"],
        deps = select({
            "//conditions:default": ["@com_github_grpc_grpc//:grpc"],
        }),
    )
    
    cc_library(
        name = "grpc++",
        visibility = ["//visibility:public"],
        deps = select({
            "//conditions:default": ["@com_github_grpc_grpc//:grpc++"],
        }),
    )
    # copybara:comment_end
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 31 16:51:59 UTC 2024
    - 53.5K bytes
    - Viewed (0)
  3. tests/joins_test.go

    	if !regexp.MustCompile("SELECT .* FROM .users. left join pets.*join accounts.*").MatchString(stmt.SQL.String()) {
    		t.Errorf("joins should be ordered, but got %v", stmt.SQL.String())
    	}
    
    	iv := DB.Table(`table_invoices`).Select(`seller, SUM(total) as total, SUM(paid) as paid, SUM(balance) as balance`).Group(`seller`)
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed Jun 12 10:52:33 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. internal/grid/muxserver.go

    func (m *muxServer) handleInbound(c *Connection, inbound <-chan []byte, handlerIn chan<- []byte) {
    	for {
    		select {
    		case <-m.ctx.Done():
    			return
    		case in, ok := <-inbound:
    			if !ok {
    				return
    			}
    			select {
    			case <-m.ctx.Done():
    				return
    			case handlerIn <- in:
    				m.send(message{Op: OpUnblockClMux, MuxID: m.ID, Flags: c.baseFlags})
    			}
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/internal/component/model/ComponentArtifactResolveState.java

     * <ul>
     *     <li>Select a variant of the component instance. The variant selected for artifact resolution may be different to that used for graph resolution,
     *     for example when using an {@link org.gradle.api.artifacts.ArtifactView} to select different variants.</li>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 17:38:42 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go

    		s.mu.Unlock()
    		<-done
    		return ctx.Err()
    	}
    
    	ready := make(chan struct{})
    	w := waiter{n: n, ready: ready}
    	elem := s.waiters.PushBack(w)
    	s.mu.Unlock()
    
    	select {
    	case <-done:
    		s.mu.Lock()
    		select {
    		case <-ready:
    			// Acquired the semaphore after we were canceled.
    			// Pretend we didn't and put the tokens back.
    			s.cur -= n
    			s.notifyWaiters()
    		default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. internal/grid/muxclient.go

    				continue
    			}
    			msg.Seq++
    		}
    	}
    
    	if errState {
    		// Drain requests.
    		for {
    			select {
    			case r, ok := <-requests:
    				if !ok {
    					return
    				}
    				PutByteBuffer(r)
    			default:
    				return
    			}
    		}
    	}
    
    	for !errState {
    		select {
    		case <-m.ctx.Done():
    			if debugPrint {
    				fmt.Println("Client sending disconnect to mux", m.MuxID)
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/runtime/waiting_pods_map.go

    	}
    
    	// Only signal success status after all plugins have allowed
    	if len(w.pendingPlugins) != 0 {
    		return
    	}
    
    	// The select clause works as a non-blocking send.
    	// If there is no receiver, it's a no-op (default case).
    	select {
    	case w.s <- framework.NewStatus(framework.Success, ""):
    	default:
    	}
    }
    
    // Reject declares the waiting pod unschedulable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go

    		defer close(drained)
    		wg.Wait()
    	}()
    
    	select {
    	case <-drained:
    	case <-time.After(wait.ForeverTestTimeout):
    		t.Fatal("timed out waiting for watchers to be terminated")
    	}
    
    	stopChan := make(chan struct{})
    
    	// Set up loop to modify CRD in the background
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    		for {
    			select {
    			case <-stopChan:
    				return
    			default:
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:59:03 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  10. src/reflect/value.go

    // A runtimeSelect is a single case passed to rselect.
    // This must match ../runtime/select.go:/runtimeSelect
    type runtimeSelect struct {
    	dir SelectDir      // SelectSend, SelectRecv or SelectDefault
    	typ *rtype         // channel type
    	ch  unsafe.Pointer // channel
    	val unsafe.Pointer // ptr to data (SendDir) or ptr to receive buffer (RecvDir)
    }
    
    // rselect runs a select. It returns the index of the chosen case.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 119.9K bytes
    - Viewed (0)
Back to top