Search Options

Results per page
Sort
Preferred Languages
Advance

Results 931 - 940 of 1,178 for rsync (0.05 sec)

  1. cmd/metrics-resource.go

    	resourceMetricsMapMu sync.RWMutex
    	// resourceMetricsHelpMap maps metric name to its help string
    	resourceMetricsHelpMap map[MetricName]string
    	resourceMetricsGroups  []*MetricsGroupV2
    	// initial values for drives (at the time  of server startup)
    	// used for calculating avg values for drive metrics
    	latestDriveStats      map[string]madmin.DiskIOStats
    	latestDriveStatsMu    sync.RWMutex
    	lastDriveStatsRefresh time.Time
    )
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 23:30:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. internal/disk/stat_test.go

    		testCase := testCase
    		t.Run("", func(t *testing.T) {
    			tmpfile, err := os.CreateTemp("", "testfile")
    			if err != nil {
    				t.Error(err)
    			}
    			tmpfile.WriteString(testCase.stat)
    			tmpfile.Sync()
    			tmpfile.Close()
    
    			iostats, err := readDriveStats(tmpfile.Name())
    			if err != nil && !testCase.expectErr {
    				t.Fatalf("unexpected err; %v", err)
    			}
    			if testCase.expectErr && err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  3. .github/workflows/create_issue.js

        github enables querying for PR and also create issue using rest endpoint
        context has the commit message details in the payload
      @return {string} Returns the issue number and title
    */
    module.exports = async ({github, context}) => {
      const rollback_commit = context.payload.head_commit.id;
      const pr_match_groups = context.payload.head_commit.message.match(/\Rollback of PR #(\d+).*/) || [];
      if (pr_match_groups.length != 2) {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 18 23:04:59 UTC 2021
    - 2.8K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/healthServer.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import (
    	"net/http"
    	"sync/atomic"
    
    	"istio.io/istio/cni/pkg/constants"
    )
    
    // StartHealthServer initializes and starts a web server that exposes liveness and readiness endpoints at port 8000.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  5. tensorflow/c/eager/c_api_experimental_test.cc

      ASSERT_TRUE(TF_GetCode(status) == TF_OK) << TF_Message(status);
      TF_DeleteFunction(fn);
    
      for (bool async : {false, true, false}) {
        TFE_Executor* old_executor = TFE_ContextGetExecutorForThread(ctx);
        TFE_Executor* executor = TFE_NewExecutor(
            /*is_async=*/async, /*enable_streaming_enqueue=*/true,
            /*in_flight_nodes_limit=*/0);
        TFE_ContextSetExecutorForThread(ctx, executor);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 03:14:26 UTC 2023
    - 31.5K bytes
    - Viewed (0)
  6. internal/store/queuestore.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"bytes"
    	"encoding/json"
    	"errors"
    	"os"
    	"path/filepath"
    	"sort"
    	"sync"
    	"time"
    
    	"github.com/google/uuid"
    	jsoniter "github.com/json-iterator/go"
    	"github.com/klauspost/compress/s2"
    	"github.com/valyala/bytebufferpool"
    )
    
    const (
    	defaultLimit = 100000 // Default store limit.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  7. istioctl/pkg/internaldebug/internal-debug.go

    By default it will use the default serviceAccount from (istio-system) namespace if the pod is not specified.
    `,
    		Example: `  # Retrieve sync status for all Envoys in a mesh
      istioctl x internal-debug syncz
    
      # Retrieve sync diff for a single Envoy and Istiod
      istioctl x internal-debug syncz istio-egressgateway-59585c5b9c-ndc59.istio-system
    
      # SECURITY OPTIONS
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. cmd/xl-storage_noatime_supported.go

    	"syscall"
    )
    
    var (
    	// Disallow updating access times
    	// Add non-block to avoid syscall to attempt to set epoll on files.
    	readMode = os.O_RDONLY | 0x40000 | syscall.O_NONBLOCK // O_NOATIME
    
    	// Write with data sync only used only for `xl.meta` writes
    	writeMode = 0x1000 | syscall.O_NONBLOCK // O_DSYNC
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 16:36:24 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  9. docs/zh/docs/tutorial/sql-databases.md

        ...
    ```
    
    /// info
    
    如果您需要异步连接到关系数据库,请参阅[Async SQL (Relational) Databases](https://fastapi.tiangolo.com/zh/advanced/async-sql-databases/)
    
    ///
    
    /// note | "Very Technical Details"
    
    如果您很好奇并且拥有深厚的技术知识,您可以在[Async](https://fastapi.tiangolo.com/zh/async/#very-technical-details)文档中查看有关如何处理 `async def`于`def`差别的技术细节。
    
    ///
    
    ## 迁移
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  10. src/cmd/buildid/buildid.go

    		usage()
    	}
    
    	file := flag.Arg(0)
    	id, err := buildid.ReadFile(file)
    	if err != nil {
    		log.Fatal(err)
    	}
    	if !*wflag {
    		fmt.Printf("%s\n", id)
    		return
    	}
    
    	// Keep in sync with src/cmd/go/internal/work/buildid.go:updateBuildID
    
    	f, err := os.Open(file)
    	if err != nil {
    		log.Fatal(err)
    	}
    	matches, hash, err := buildid.FindAndHash(f, id, 0)
    	f.Close()
    	if err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top