Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,580 for pselect (0.19 sec)

  1. src/cmd/vendor/golang.org/x/sys/unix/syscall_linux_mips64x.go

    //sys	Seek(fd int, offset int64, whence int) (off int64, err error) = SYS_LSEEK
    
    func Select(nfd int, r *FdSet, w *FdSet, e *FdSet, timeout *Timeval) (n int, err error) {
    	var ts *Timespec
    	if timeout != nil {
    		ts = &Timespec{Sec: timeout.Sec, Nsec: timeout.Usec * 1000}
    	}
    	return pselect6(nfd, r, w, e, ts, nil)
    }
    
    //sys	sendfile(outfd int, infd int, offset *int64, count int) (written int, err error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  2. internal/s3select/sql/statement.go

    	var selectAST Select
    	err = SQLParser.ParseString(s, &selectAST)
    	if err != nil {
    		err = errQueryParseFailure(err)
    		return
    	}
    
    	// Check if select is "SELECT s.* from S3Object s"
    	if !selectAST.Expression.All &&
    		len(selectAST.Expression.Expressions) == 1 &&
    		len(selectAST.Expression.Expressions[0].Expression.And) == 1 &&
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jan 09 17:19:11 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. 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)
  4. pkg/ctrlz/ctrlz_test.go

    	"testing"
    	"time"
    )
    
    func TestStartStopEnabled(t *testing.T) {
    	server := startAndWaitForServer(t)
    	done := make(chan struct{}, 1)
    	go func() {
    		server.Close()
    		done <- struct{}{}
    	}()
    	select {
    	case <-done:
    	case <-time.After(5 * time.Second):
    		t.Fatal("Timed out waiting for listeningTestProbe to be called")
    	}
    }
    
    func TestSignals(t *testing.T) {
    	c := make(chan os.Signal, 1)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 15 18:23:41 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/ModuleConflictResolver.java

    package org.gradle.api.internal.artifacts.ivyservice.resolveengine;
    
    public interface ModuleConflictResolver<T> {
        /**
         * Selects matching candidate. Returns null if this implementation of the resolver is not able to select a candidate.
         *
         * @param details the conflict resolution details
         */
        void select(ConflictResolverDetails<T> details);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 984 bytes
    - Viewed (0)
  6. internal/store/store.go

    			} else {
    				keyCount := len(names)
    				for i, name := range names {
    					select {
    					case keyCh <- Key{strings.TrimSuffix(name, store.Extension()), keyCount == i+1}:
    					// Get next key.
    					case <-doneCh:
    						return
    					}
    				}
    			}
    
    			select {
    			case <-retryTicker.C:
    			case <-doneCh:
    				return
    			}
    		}
    	}()
    
    	return keyCh
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 25 16:44:20 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. src/database/sql/example_service_test.go

    		}
    		w.WriteHeader(http.StatusOK)
    		return
    	case "/quick-action":
    		// This is a short SELECT. Use the request context as the base of
    		// the context timeout.
    		ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
    		defer cancel()
    
    		id := 5
    		org := 10
    		var name string
    		err := db.QueryRowContext(ctx, `
    select
    	p.name
    from
    	people as p
    	join organization as o on p.organization = o.id
    where
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Feb 28 20:21:26 UTC 2024
    - 4K bytes
    - Viewed (0)
  8. src/internal/trace/oldtrace.go

    	addBuiltin(sChanSend, "chan send")
    	addBuiltin(sChanRecv, "chan receive")
    	addBuiltin(sNetwork, "network")
    	addBuiltin(sSync, "sync")
    	addBuiltin(sSyncCond, "sync.(*Cond).Wait")
    	addBuiltin(sSelect, "select")
    	addBuiltin(sEmpty, "")
    	addBuiltin(sMarkAssistWait, "GC mark assist wait for work")
    	addBuiltin(sSTWUnknown, "")
    	addBuiltin(sSTWGCMarkTermination, "GC mark termination")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  9. src/crypto/internal/nistec/p384.go

    	q.x.Set(x3)
    	q.y.Set(y3)
    	q.z.Set(z3)
    	return q
    }
    
    // Select sets q to p1 if cond == 1, and to p2 if cond == 0.
    func (q *P384Point) Select(p1, p2 *P384Point, cond int) *P384Point {
    	q.x.Select(p1.x, p2.x, cond)
    	q.y.Select(p1.y, p2.y, cond)
    	q.z.Select(p1.z, p2.z, cond)
    	return q
    }
    
    // A p384Table holds the first 15 multiples of a point at offset -1, so [1]P
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 12 00:04:29 UTC 2022
    - 18K bytes
    - Viewed (0)
  10. src/cmd/cgo/internal/testcarchive/testdata/main5.c

    // signals when non-Go signals are raised.
    
    #include <stdio.h>
    #include <stdlib.h>
    #include <unistd.h>
    #include <sys/types.h>
    #include <sys/time.h>
    #include <sys/select.h>
    
    #include "libgo2.h"
    
    int *nilp;
    
    int main(int argc, char** argv) {
    	int verbose;
    	int test;
    
    	if (argc < 2) {
    		printf("Missing argument\n");
    		return 1;
    	}
    
    	test = atoi(argv[1]);
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 2K bytes
    - Viewed (0)
Back to top