Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for Hijack (0.15 sec)

  1. src/net/http/responsecontroller.go

    			rw = t.Unwrap()
    		default:
    			return errNotSupported()
    		}
    	}
    }
    
    // Hijack lets the caller take over the connection.
    // See the Hijacker interface for details.
    func (c *ResponseController) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	rw := c.rw
    	for {
    		switch t := rw.(type) {
    		case Hijacker:
    			return t.Hijack()
    		case rwUnwrapper:
    			rw = t.Unwrap()
    		default:
    			return nil, nil, errNotSupported()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  2. internal/http/response-recorder.go

    	headersLogged bool
    }
    
    // Hijack - hijacks the underlying connection
    func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	hj, ok := lrw.ResponseWriter.(http.Hijacker)
    	if !ok {
    		return nil, nil, fmt.Errorf("response writer does not support hijacking. Type is %T", lrw.ResponseWriter)
    	}
    	return hj.Hijack()
    }
    
    // NewResponseRecorder - returns a wrapped response writer to trap
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 02 00:13:19 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. src/net/http/httptest/server_test.go

    	hijacked := make(chan net.Conn)
    	ts := NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		defer close(hijacked)
    		hj, ok := w.(http.Hijacker)
    		if !ok {
    			t.Fatal("failed to hijack")
    		}
    		c, _, err := hj.Hijack()
    		if err != nil {
    			t.Fatal(err)
    		}
    		hijacked <- c
    	}))
    
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		defer wg.Done()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 18 16:57:12 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go

    }
    
    func (tw *baseTimeoutWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	tw.mu.Lock()
    	defer tw.mu.Unlock()
    
    	if tw.timedOut {
    		return nil, nil, http.ErrHandlerTimeout
    	}
    
    	// the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
    	// http.Hijacker if the inner object (tw.w) implements http.Hijacker.
    	conn, rw, err := tw.w.(http.Hijacker).Hijack()
    	if err == nil {
    		tw.hijacked = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/httplog/httplog.go

    	rl.recordStatus(status)
    	rl.w.WriteHeader(status)
    }
    
    func (rl *respLogger) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	rl.hijacked = true
    
    	// the outer ResponseWriter object returned by WrapForHTTP1Or2 implements
    	// http.Hijacker if the inner object (rl.w) implements http.Hijacker.
    	return rl.w.(http.Hijacker).Hijack()
    }
    
    func (rl *respLogger) recordStatus(status int) {
    	rl.mutex.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 07 10:10:35 UTC 2023
    - 9.7K bytes
    - Viewed (0)
  6. platforms/software/testing-base-infrastructure/src/integTest/resources/org/gradle/api/internal/tasks/testing/JULRedirectorIntegrationTest/loggingConfig/src/test/java/com/example/LumberJackTest.java

    import static org.junit.Assert.assertEquals;
    
    import org.junit.Test;
    
    public class LumberJackTest {
        @Test
        public void singsTheSong() {
            LumberJack jack = new LumberJack();
            jack.sing();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 13 20:33:30 UTC 2024
    - 898 bytes
    - Viewed (0)
  7. platforms/software/dependency-management/src/test/resources/org/gradle/api/internal/artifacts/ivyservice/modulecache/ModuleMetadataSerializerTest/ivy/with-dependencies.xml

            <dependency org="com.android.tools.ddms" name="ddmlib" rev="24.5.0" force="true" conf="runtime-&gt;compile(*),runtime(*),master(*)"/>
            <dependency org="com.android.tools.jack" name="jack-api" rev="0.9.0" force="true" conf="runtime-&gt;compile(*),runtime(*),master(*)"/>
            <dependency org="com.android.tools.jill" name="jill-api" rev="0.9.0" force="true" conf="runtime-&gt;compile(*),runtime(*),master(*)"/>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  8. src/os/user/listgroups_unix_test.go

    -minussign:*:21:root
    # Next line is invalid (empty group name)
    :*:22:root
    
    daemon:*:1:root
        indented:*:7:root
    # comment:*:4:found
         # comment:*:4:found
    kmem:*:2:root
    manymembers:x:777:jill,jody,john,jack,jov,user777
    ` + largeGroup()
    
    func largeGroup() (res string) {
    	var b strings.Builder
    	b.WriteString("largegroup:x:1000:user1")
    	for i := 2; i <= 7500; i++ {
    		fmt.Fprintf(&b, ",user%d", i)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top