Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 24 for roundtrip (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/test/java/jcifs/smb/SSPContextTest.java

                assertTrue(ctx.isPreferredMech(mech1), "first supported is preferred");
                assertArrayEquals(new ASN1ObjectIdentifier[] { mech1, mech2 }, ctx.getSupportedMechs(), "supported mechs");
    
                // MIC roundtrip: calculate then verify
                byte[] data = new byte[] { 10, 20, 30 };
                byte[] mic = ctx.calculateMIC(data);
                assertNotNull(mic);
                ctx.verifyMIC(data, mic); // should not throw
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  2. internal/grid/handlers.go

    }
    
    // RoundTripper provides an interface for type roundtrip serialization.
    type RoundTripper interface {
    	msgp.Unmarshaler
    	msgp.Marshaler
    	msgp.Sizer
    
    	comparable
    }
    
    // SingleHandler is a type safe handler for single roundtrip requests.
    type SingleHandler[Req, Resp RoundTripper] struct {
    	id            HandlerID
    	sharedResp    bool
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  3. cmd/bucket-lifecycle_test.go

    		}
    		if actual != tc.expectedStatus {
    			t.Fatalf("Test %d: got %v expected %v", i+1, actual, tc.expectedStatus)
    		}
    	}
    }
    
    // TestRestoreObjStatusRoundTrip restoreObjStatus roundtrip
    func TestRestoreObjStatusRoundTrip(t *testing.T) {
    	testCases := []restoreObjStatus{
    		ongoingRestoreObj(),
    		completedRestoreObj(time.Now().UTC()),
    	}
    	for i, tc := range testCases {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 31 09:57:57 GMT 2022
    - 7K bytes
    - Click Count (0)
  4. cmd/sftp-server-driver.go

    		FileList: handler,
    	}
    }
    
    type forwardForTransport struct {
    	tr  http.RoundTripper
    	fwd string
    }
    
    func (f forwardForTransport) RoundTrip(r *http.Request) (*http.Response, error) {
    	r.Header.Set("X-Forwarded-For", f.fwd)
    	return f.tr.RoundTrip(r)
    }
    
    func (f *sftpDriver) getMinIOClient() (*minio.Client, error) {
    	mcreds := credentials.NewStaticV4(
    		f.permissions.CriticalOptions["AccessKey"],
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Feb 10 16:35:49 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/fscc/FileInternalInfoTest.java

            }
            for (int i = dstIndex + 8; i < destinationBuffer.length; i++) {
                assertEquals(0, destinationBuffer[i]);
            }
        }
    
        @Test
        @DisplayName("Test encode and decode roundtrip")
        void testEncodeDecodeRoundtrip() throws SMBProtocolDecodingException {
            // Setup first instance with test data
            long expectedIndexNumber = 0x1122334455667788L;
            byte[] originalBuffer = new byte[8];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  6. api/go1.26.txt

    pkg net/http, method (*ClientConn) InFlight() int #75772
    pkg net/http, method (*ClientConn) Release() #75772
    pkg net/http, method (*ClientConn) Reserve() error #75772
    pkg net/http, method (*ClientConn) RoundTrip(*Request) (*Response, error) #75772
    pkg net/http, method (*ClientConn) SetStateHook(func(*ClientConn)) #75772
    pkg net/http, method (*Transport) NewClientConn(context.Context, string, string) (*ClientConn, error) #75772
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Dec 11 19:57:52 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  7. src/test/java/jcifs/smb/SmbTransportImplTest.java

            setField(transport, "negotiated", smb1);
            assertFalse(transport.isSMB2());
        }
    
        @Test
        @DisplayName("Digest setter/getter roundtrip")
        void digestRoundtrip() {
            SMBSigningDigest dg = mock(SMBSigningDigest.class);
            transport.setDigest(dg);
            assertSame(dg, transport.getDigest());
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.6K bytes
    - Click Count (0)
  8. cmd/metacache-server-pool.go

    				return entries, io.EOF
    			}
    			if c.status == scanStateError || c.status == scanStateNone {
    				o.ID = ""
    				o.Create = false
    				o.debugln("scan status", c.status, " - waiting a roundtrip to create")
    			} else {
    				// Continue listing
    				o.ID = c.id
    				go c.keepAlive(ctx, rpc)
    			}
    		}
    	}
    
    	if o.ID != "" && !o.Transient {
    		// We have an existing list ID, continue streaming.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  9. cmd/object-api-utils_test.go

    			var decBuf bytes.Buffer
    			decRdr := s2.NewReader(&rdrBuf)
    			_, err = io.Copy(&decBuf, decRdr)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			if !bytes.Equal(tt.data, decBuf.Bytes()) {
    				t.Errorf("roundtrip failed\n\t%q\n\t%q", tt.data, decBuf.Bytes())
    			}
    		})
    	}
    }
    
    func Test_pathNeedsClean(t *testing.T) {
    	type pathTest struct {
    		path, result string
    	}
    
    	cleantests := []pathTest{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
  10. internal/grid/trace.go

    		return c.roundtrip(h, req)
    	}
    
    	// Following trimming is needed for consistency between outputs with other internode traces.
    	local := strings.TrimPrefix(strings.TrimPrefix(t.Local, httpsScheme), httpScheme)
    	remote := strings.TrimPrefix(strings.TrimPrefix(t.Remote, httpsScheme), httpScheme)
    
    	start := time.Now()
    	body := bytesOrLength(req)
    	resp, err := c.roundtrip(h, req)
    	end := time.Now()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jun 01 05:17:37 GMT 2024
    - 4.1K bytes
    - Click Count (0)
Back to Top