Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for readFrame (0.83 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/framer/framer.go

    func NewJSONFramedReader(r io.ReadCloser) io.ReadCloser {
    	return &jsonFrameReader{
    		r:       r,
    		decoder: json.NewDecoder(r),
    	}
    }
    
    // ReadFrame decodes the next JSON object in the stream, or returns an error. The returned
    // byte slice will be modified the next time ReadFrame is invoked and should not be altered.
    func (r *jsonFrameReader) Read(data []byte) (int, error) {
    	// Return whatever remaining data exists from an in progress frame
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 13:33:12 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  2. src/net/http/h2_bundle.go

    // error from ReadFrame and no other frames should be read.
    func http2terminalReadFrameError(err error) bool {
    	if _, ok := err.(http2StreamError); ok {
    		return false
    	}
    	return err != nil
    }
    
    // ReadFrame reads a single frame. The returned Frame is only valid
    // until the next call to ReadFrame.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  3. platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/HierarchicalNameSerializer.java

        }
    
        @Override
        public String read(Decoder decoder) throws Exception {
            String name = readName(decoder);
            return interner.intern(name);
        }
    
        @Override
        public void write(Encoder encoder, String name) throws Exception {
            writeName(name, encoder);
        }
    
        private String readName(Decoder decoder) throws IOException {
            int id = decoder.readSmallInt();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 15 16:06:56 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. src/runtime/trace.go

    	}
    }
    
    // ReadTrace returns the next chunk of binary tracing data, blocking until data
    // is available. If tracing is turned off and all the data accumulated while it
    // was on has been returned, ReadTrace returns nil. The caller must copy the
    // returned data before calling ReadTrace again.
    // ReadTrace must be called from one goroutine at a time.
    func ReadTrace() []byte {
    top:
    	var buf []byte
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  5. src/internal/trace/internal/oldtrace/parser.go

    	// The ordering of CPU profile sample events in the data stream is based on
    	// when each run of the signal handler was able to acquire the spinlock,
    	// with original timestamps corresponding to when ReadTrace pulled the data
    	// off of the profBuf queue. Re-sort them by the timestamp we captured
    	// inside the signal handler.
    	slices.SortFunc(p.cpuSamples, func(a, b Event) int {
    		return cmp.Compare(a.Ts, b.Ts)
    	})
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 21:15:28 UTC 2024
    - 46.8K bytes
    - Viewed (0)
Back to top