Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for Inbound (0.06 sec)

  1. internal/grid/muxserver.go

    		}
    	}()
    
    	// Data inbound to the handler
    	var handlerIn chan []byte
    	if inboundCap > 0 {
    		m.inbound = make(chan []byte, inboundCap)
    		handlerIn = make(chan []byte, 1)
    		go func(inbound chan []byte) {
    			wg.Wait()
    			defer xioutil.SafeClose(handlerIn)
    			m.handleInbound(c, inbound, handlerIn)
    		}(m.inbound)
    	}
    	// Fill outbound block.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java

        }
    
        /**
         * Serialize the inbound Model instance to a StringWriter, perform the regex replacement to resolve
         * POM expressions, then re-parse into the resolved Model instance.
         * <p>
         * <b>NOTE:</b> This will result in a different instance of Model being returned!!!
         *
         * @param model The inbound Model instance, to serialize and reference for expression resolution
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. internal/logger/audit.go

    		if reqInfo == nil {
    			return
    		}
    		reqInfo.RLock()
    		defer reqInfo.RUnlock()
    
    		entry = internalAudit.ToEntry(w, r, reqClaims, xhttp.GlobalDeploymentID)
    		// indicates all requests for this API call are inbound
    		entry.Trigger = "incoming"
    
    		for _, filterKey := range filterKeys {
    			delete(entry.ReqClaims, filterKey)
    			delete(entry.ReqQuery, filterKey)
    			delete(entry.ReqHeader, filterKey)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    	case debugShutdown:
    		c.updateState(StateShutdown)
    	case debugKillInbound:
    		c.connMu.Lock()
    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    				fmt.Println("debug: closing inbound connection")
    			}
    			c.debugInConn.Close()
    		}
    	case debugKillOutbound:
    		c.connMu.Lock()
    		defer c.connMu.Unlock()
    		if c.debugInConn != nil {
    			if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/collect/testing/NavigableSetTestSuiteBuilder.java

          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.EXCLUSIVE));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.INCLUSIVE));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.INCLUSIVE, Bound.INCLUSIVE));
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. guava-testlib/src/com/google/common/collect/testing/NavigableSetTestSuiteBuilder.java

          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.EXCLUSIVE));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.INCLUSIVE));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.INCLUSIVE, Bound.INCLUSIVE));
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/collect/testing/NavigableMapTestSuiteBuilder.java

          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.EXCLUSIVE));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.INCLUSIVE));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.INCLUSIVE, Bound.INCLUSIVE));
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7K bytes
    - Viewed (0)
  8. guava-testlib/src/com/google/common/collect/testing/NavigableMapTestSuiteBuilder.java

          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.EXCLUSIVE));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.EXCLUSIVE, Bound.INCLUSIVE));
          derivedSuites.add(createSubmapSuite(parentBuilder, Bound.INCLUSIVE, Bound.INCLUSIVE));
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 7K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/SortedMultisetTestSuiteBuilder.java

          derivedSuites.add(createSubMultisetSuite(parentBuilder, Bound.NO_BOUND, Bound.EXCLUSIVE));
          derivedSuites.add(createSubMultisetSuite(parentBuilder, Bound.NO_BOUND, Bound.INCLUSIVE));
          derivedSuites.add(createSubMultisetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubMultisetSuite(parentBuilder, Bound.EXCLUSIVE, Bound.EXCLUSIVE));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 12K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/SortedSetTestSuiteBuilder.java

        if (!parentBuilder.getFeatures().contains(CollectionFeature.SUBSET_VIEW)) {
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.NO_BOUND, Bound.EXCLUSIVE));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.INCLUSIVE, Bound.NO_BOUND));
          derivedSuites.add(createSubsetSuite(parentBuilder, Bound.INCLUSIVE, Bound.EXCLUSIVE));
        }
    
        return derivedSuites;
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top