Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 31 for stream_handle_ (0.21 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          val bodyDelayNanos = response.bodyDelayNanos
          val trailers = response.trailers
          val body = response.body
          val streamHandler = response.streamHandler
          val outFinished = (
            body == null &&
              response.pushPromises.isEmpty() &&
              streamHandler == null
          )
          val flushHeaders = body == null || bodyDelayNanos != 0L
          require(!outFinished || trailers.size == 0) {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    		LastPing:  time.Now().Unix(),
    		BaseFlags: c.baseFlags,
    	}
    	go func() {
    		// TODO: Handle
    	}()
    
    	return &m
    }
    
    func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if len(handler.Subroute) > 0 {
    		ctx = setSubroute(ctx, handler.Subroute)
    	}
    	if msg.DeadlineMS > 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  3. internal/grid/benchmark_test.go

    	const responses = 10
    	// Create n managers.
    	for _, remote := range grid.Managers {
    		// Register a single handler which echos the payload.
    		errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{
    			// Send 10x response.
    			Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr {
    				for i := 0; i < responses; i++ {
    					toSend := GetByteBuffer()[:0]
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  4. internal/grid/connection_test.go

    	defer close(cleanReqs)
    	// 1: Block forever
    	h1 := func(payload []byte) ([]byte, *RemoteErr) {
    		gotCall <- struct{}{}
    		<-cleanReqs
    		return nil, nil
    	}
    	// 2: Also block, but with streaming.
    	h2 := StreamHandler{
    		Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr {
    			gotCall <- struct{}{}
    			select {
    			case <-ctx.Done():
    				gotCall <- struct{}{}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 6K bytes
    - Viewed (0)
  5. internal/grid/README.md

                }
            }
            // out is closed by the caller and should never be closed by the handler.
            return nil
        }
    
        err := manager.RegisterStreamingHandler(grid.HandlerDiskInfo, StreamHandler{
            Handle: handler,
            Subroute: "asubroute",
            OutCapacity: 1,
            InCapacity: 1,
        })
    ```
    
    Sample call:
    ```go
        // Get a connection to the remote host
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. internal/grid/manager.go

    	return nil
    }
    */
    
    // RegisterStreamingHandler will register a stateless handler that serves
    // two-way streaming requests.
    func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if debugPrint {
    		fmt.Println("RegisterStreamingHandler: subroute:", h.Subroute)
    	}
    	if h.Subroute == "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  7. samples/bookinfo/src/productpage/productpage.py

    logging.basicConfig(stream=sys.stdout, level=logging.INFO)
    requests_log = logging.getLogger("requests.packages.urllib3")
    requests_log.setLevel(logging.INFO)
    requests_log.propagate = True
    app.logger.addHandler(logging.StreamHandler(sys.stdout))
    app.logger.setLevel(logging.INFO)
    
    # Set the secret key to some random bytes. Keep this really secret!
    app.secret_key = b'_5#y2L"F4Q8z\n\xec]/'
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 14:35:54 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    			logger.FatalIf(storageStatVolRPC.Register(gm, server.StatVolHandler, endpoint.Path), "unable to register handler")
    			logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerWalkDir, grid.StreamHandler{
    				Subroute:    endpoint.Path,
    				Handle:      server.WalkDirHandler,
    				OutCapacity: 1,
    			}), "unable to register handler")
    
    			createStorage := func(endpoint Endpoint) bool {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  9. cmd/peer-rest-server.go

    	logger.FatalIf(updateMetacacheListingRPC.Register(gm, server.UpdateMetacacheListingHandler), "unable to register handler")
    
    	logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerTrace, grid.StreamHandler{
    		Handle:      server.TraceHandler,
    		Subroute:    "",
    		OutCapacity: 100000,
    		InCapacity:  0,
    	}), "unable to register handler")
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    			return
    		}
    		_, _ = c.inStream.LoadOrCompute(m.MuxID, func() *muxServer {
    			return newMuxStateless(ctx, m, c, *handler)
    		})
    	} else {
    		// Stream:
    		var handler *StreamHandler
    		if subID == nil {
    			if !m.Handler.valid() {
    				gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Invalid Handler"}))
    				return
    			}
    			handler = c.handlers.streams[m.Handler]
    		} else {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
Back to top