Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 250 for handleMsg (0.1 sec)

  1. internal/handlers/proxy.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    // Originally from https://github.com/gorilla/handlers with following license
    // https://raw.githubusercontent.com/gorilla/handlers/master/LICENSE, forked
    // and heavily modified for MinIO's internal needs.
    
    package handlers
    
    import (
    	"net"
    	"net/http"
    	"regexp"
    	"strings"
    )
    
    var (
    	// De-facto standard header keys.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:55 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/events.md

    You can probably skip this part.
    
    ///
    
    There's an alternative way to define this logic to be executed during *startup* and during *shutdown*.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. cmd/admin-handlers-users-race_test.go

    Taran Pelkey <******@****.***> 1719565585 -0400
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/cni-watcher_test.go

    		util.GetPodIPsIfPresent(pod),
    		valid.Netns,
    	).Return(nil)
    
    	dpServer := getFakeDP(fs, client.Kube())
    
    	handlers := setupHandlers(ctx, client, dpServer, "istio-system")
    
    	// We are not going to start the server, so the sockpath is irrelevant
    	pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer)
    
    	// label the namespace
    	labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc

      ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get());
      const std::vector<std::unique_ptr<ParallelTensor>>& handles = *outputs;
      std::vector<ParallelTensor*> handle_inputs;
      handle_inputs.reserve(handles.size());
      for (auto& handle : handles) {
        handle_inputs.push_back(handle.get());
      }
      std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            resource_handler.setResourceBase(docRoot.getAbsolutePath());
            Log.info("serving " + resource_handler.getBaseResource());
            final HandlerList handlers = new HandlerList();
            handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
            server.setHandler(handlers);
        }
    
        public void start() {
            try {
                server.start();
            } catch (final Exception e) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractorTest.java

                server = new Server(port);
    
                final RequestHandlerImpl request_handler = new RequestHandlerImpl();
                final HandlerList handlers = new HandlerList();
                handlers.setHandlers(new Handler[] { request_handler, new DefaultHandler() });
                server.setHandler(handlers);
            }
    
            public void start() {
                try {
                    server.start();
                } catch (final Exception e) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  8. fess-crawler-opensearch/src/test/resources/logging.properties

    handlers = java.util.logging.ConsoleHandler
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 59 bytes
    - Viewed (0)
  9. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

            resource_handler.setResourceBase(docRoot.getAbsolutePath());
            Log.info("serving " + resource_handler.getBaseResource());
            final HandlerList handlers = new HandlerList();
            handlers.setHandlers(new Handler[] { resource_handler, new DefaultHandler() });
            server.setHandler(handlers);
        }
    
        public void start() {
            try {
                server.start();
            } catch (final Exception e) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. istioctl/pkg/cli/context.go

    	if err != nil {
    		return "", "", err
    	}
    	return handlers.InferPodInfoFromTypedResource(name, i.NamespaceOrDefault(namespace), MakeKubeFactory(client))
    }
    
    func (i *instance) InferPodsFromTypedResource(name, namespace string) ([]string, string, error) {
    	client, err := i.CLIClient()
    	if err != nil {
    		return nil, "", err
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top