Search Options

Results per page
Sort
Preferred Languages
Advance

Results 821 - 830 of 926 for Executed (0.18 sec)

  1. okhttp/src/test/java/okhttp3/CookiesTest.kt

      }
    
      private operator fun get(url: HttpUrl) {
        val call =
          client.newCall(
            Request.Builder()
              .url(url)
              .build(),
          )
        val response = call.execute()
        response.body.close()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. internal/event/target/mysql.go

    		// FIXME: log returned error. ignore time being.
    		_ = target.insertStmt.Close()
    	}
    
    	if target.db != nil {
    		return target.db.Close()
    	}
    
    	return nil
    }
    
    // Executes the table creation statements.
    func (target *MySQLTarget) executeStmts() error {
    	_, err := target.db.Exec(fmt.Sprintf(mysqlTableExists, target.args.Table))
    	if err != nil {
    		createStmt := mysqlCreateNamespaceTable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. ci/official/README.md

    2. Running the CI scripts locally, as explained below
    3. **Google employees only**: Google employees can use an internal-only tool
    called "MLCI" that makes testing more convenient: it can execute any full CI job
    against a pending change. Search for "MLCI" internally to find it.
    
    You may invoke a CI script of your choice by following these instructions:
    
    ```bash
    cd tensorflow-git-dir
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Feb 01 03:21:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables.go

    func (cfg *IptablesConfigurator) executeCommands(log *istiolog.Scope, iptablesBuilder *builder.IptablesRuleBuilder) error {
    	var execErrs []error
    
    	// Execute iptables-restore
    	execErrs = append(execErrs, cfg.executeIptablesRestoreCommand(log, iptablesBuilder.BuildV4Restore(), &cfg.iptV))
    	// Execute ip6tables-restore
    	if cfg.cfg.EnableIPv6 {
    		execErrs = append(execErrs, cfg.executeIptablesRestoreCommand(log, iptablesBuilder.BuildV6Restore(), &cfg.ipt6V))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  5. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    	}
    	// "Envoy" applies despite this being ztunnel
    	result, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "POST", path, port)
    	if err != nil {
    		return "", fmt.Errorf("failed to execute command on Ztunnel: %v", err)
    	}
    	return string(result), nil
    }
    
    // getComponentPodName returns the pod name and namespace of the Istio component
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

     * <p>As an example, imagine that we have a list of tasks to execute, but we don't want to submit
     * more than 2 per second:
     *
     * <pre>{@code
     * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second"
     * void submitTasks(List<Runnable> tasks, Executor executor) {
     *   for (Runnable task : tasks) {
     *     rateLimiter.acquire(); // may wait
     *     executor.execute(task);
     *   }
     * }
     * }</pre>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        client =
          client.newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                throw AssertionError() // Network interceptors don't execute.
              },
            )
            .build()
        webServer.enqueue(
          MockResponse.Builder()
            .webSocketUpgrade(serverListener)
            .build(),
        )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. mvnw

        JAVACMD="$(
          \unset -f command 2>/dev/null
          \command -v java
        )"
      fi
    fi
    
    if [ ! -x "$JAVACMD" ]; then
      echo "Error: JAVA_HOME is not defined correctly." >&2
      echo "  We cannot execute $JAVACMD" >&2
      exit 1
    fi
    
    if [ -z "$JAVA_HOME" ]; then
      echo "Warning: JAVA_HOME environment variable is not set." >&2
    fi
    
    # traverses directory structure from process work directory to filesystem root
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 14 22:24:15 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. docs/bucket/notifications/README.md

        print(" [x] %r" % body)
    
    channel.basic_consume(callback,
                          queue=queue_name,
                          no_ack=False)
    
    channel.start_consuming()
    ```
    
    Execute this example python program to watch for RabbitMQ events on the console.
    
    ```py
    python rabbit.py
    ```
    
    Open another terminal and upload a JPEG image into `images` bucket.
    
    ```
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/RateLimiter.java

     * <p>As an example, imagine that we have a list of tasks to execute, but we don't want to submit
     * more than 2 per second:
     *
     * <pre>{@code
     * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second"
     * void submitTasks(List<Runnable> tasks, Executor executor) {
     *   for (Runnable task : tasks) {
     *     rateLimiter.acquire(); // may wait
     *     executor.execute(task);
     *   }
     * }
     * }</pre>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
Back to top