Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 212 for dispatch (0.04 sec)

  1. cmd/object_api_suite_test.go

    			t.Errorf("Md5 Mismatch")
    		}
    	}
    
    	for key, value := range objects {
    		var byteBuffer bytes.Buffer
    		err = GetObject(context.Background(), obj, "bucket", key, 0, int64(len(value)), &byteBuffer, "", opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    		if !bytes.Equal(byteBuffer.Bytes(), value) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. src/test/java/jcifs/dcerpc/UnicodeStringTest.java

            for (int i = 0; i < testStringTrue.length(); i++) {
                assertEquals(testStringTrue.charAt(i), (char) unicodeStringTrue.buffer[i], "Character mismatch");
            }
            assertEquals(0, unicodeStringTrue.buffer[testStringTrue.length()], "Last character should be zero");
    
            // Test with a non-empty string and zterm = false
            String testStringFalse = "Hello";
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  3. docs/debugging/xl-meta/main.go

    									fmt.Println("SIZE MISMATCH", len(calculated), len(inFile))
    								} else if len(calculated) > 10 {
    									calculated = calculated[:10]
    									inFile = inFile[:10]
    									extra = "..."
    								}
    								a := hex.EncodeToString(calculated) + extra
    								b := hex.EncodeToString(inFile) + extra
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java

            .url("ws://echo.websocket.org")
            .build();
        client.newWebSocket(request, this);
    
        // Trigger shutdown of the dispatcher's executor so this process exits immediately.
        client.dispatcher().executorService().shutdown();
      }
    
      @Override public void onOpen(WebSocket webSocket, Response response) {
        webSocket.send("Hello...");
        webSocket.send("...World!");
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  5. cmd/data-usage_test.go

    		t.Fatalf("deserialize LastUpdate mismatch\nwant: %+v\ngot:  %+v", want, got)
    	}
    	if len(want.Cache) != len(got.Cache) {
    		t.Errorf("deserialize mismatch length\nwant: %+v\ngot:  %+v", len(want.Cache), len(got.Cache))
    	}
    	for wkey, wval := range want.Cache {
    		gotv := got.Cache[wkey]
    		if !equalAsJSON(gotv, wval) {
    			t.Errorf("deserialize mismatch, key %v\nwant: %#v\ngot:  %#v", wkey, wval, gotv)
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

      }
    
      fun finishJob(url: String) {
        val i = calls.iterator()
        while (i.hasNext()) {
          val call = i.next()
          if (call.request.url.toString() == url) {
            i.remove()
            dispatcherTest.dispatcher.finishedAccessor(call)
            return
          }
        }
        throw AssertionError("No such job: $url")
      }
    
      override fun shutdown() {
        shutdown = true
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/dcerpc/DcerpcError.java

        /**
         * NDR encoding error fault code
         */
        int DCERPC_FAULT_NDR = 0x000006F7;
        /**
         * Invalid tag fault code
         */
        int DCERPC_FAULT_INVALID_TAG = 0x1C000006;
        /**
         * Context mismatch fault code
         */
        int DCERPC_FAULT_CONTEXT_MISMATCH = 0x1C00001A;
        /**
         * Operation range error fault code
         */
        int DCERPC_FAULT_OP_RNG_ERROR = 0x1C010002;
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  8. src/cmd/buildid/buildid.go

    	}
    
    	newID := id[:strings.LastIndex(id, "/")] + "/" + buildid.HashToString(hash)
    	if len(newID) != len(id) {
    		log.Fatalf("%s: build ID length mismatch %q vs %q", file, id, newID)
    	}
    
    	if len(matches) == 0 {
    		return
    	}
    
    	f, err = os.OpenFile(file, os.O_RDWR, 0)
    	if err != nil {
    		log.Fatal(err)
    	}
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/dcerpc/DcerpcError.java

        /**
         * NDR encoding error fault code
         */
        int DCERPC_FAULT_NDR = 0x000006F7;
        /**
         * Invalid tag fault code
         */
        int DCERPC_FAULT_INVALID_TAG = 0x1C000006;
        /**
         * Context mismatch fault code
         */
        int DCERPC_FAULT_CONTEXT_MISMATCH = 0x1C00001A;
        /**
         * Operation range error fault code
         */
        int DCERPC_FAULT_OP_RNG_ERROR = 0x1C010002;
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SSPContextTest.java

                }
                byte[] expected = calculateMIC(data);
                if (mic.length != expected.length || mic[0] != expected[0]) {
                    throw new CIFSException("MIC mismatch");
                }
            }
    
            @Override
            public boolean isMICAvailable() {
                // Available if context is established and integrity is supported
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.2K bytes
    - Viewed (0)
Back to top