- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 698 for sock (0.02 sec)
-
CHANGELOG/CHANGELOG-1.29.md
- Updated the CRI-O socket path, so users who configure kubelet to use a location like `/run/crio/crio.sock` don't see strange behaviour from CRI stats provider. ([#118704](https://github.com/kubernetes/kubernetes/pull/118704), [@dgl](https://github.com/dgl))
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Wed Mar 12 00:36:01 UTC 2025 - 429.6K bytes - Viewed (1) -
cmd/lock-rest-client_test.go
} // Attempt all calls. _, err = lkClient.RLock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Rlock to fail") } _, err = lkClient.Lock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for Lock to fail") } _, err = lkClient.RUnlock(t.Context(), dsync.LockArgs{}) if err == nil { t.Fatal("Expected for RUnlock to fail") }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 2K bytes - Viewed (0) -
cmd/lock-rest-server.go
return l.makeResp(resp, err) } // LockHandler - Acquires a lock. func (l *lockRESTServer) LockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) { // Add a timeout similar to what we expect upstream. ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.Acquire) defer cancel() resp := lockRPCLock.NewResponse() success, err := l.ll.Lock(ctx, *args) if err == nil && !success {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jan 31 19:54:34 UTC 2025 - 6.3K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return ObjectLocked{} } if !ret.RetainUntilDate.Before(t) { return ObjectLocked{} } return nil } // https://docs.aws.amazon.com/AmazonS3/latest/dev/object-lock-overview.html#object-lock-retention-modes // If you try to delete objects protected by governance mode and have s3:BypassGovernanceRetention, the operation will succeed.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 08 02:38:25 UTC 2025 - 13.3K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
package cmd import ( "context" "os" "reflect" "sync" "testing" "github.com/minio/minio/internal/dsync" ) // Helper function to create a lock server for testing func createLockTestServer(ctx context.Context, t *testing.T) (string, *lockRESTServer, string) { obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 3.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java
lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed) setField(lock, "pid", 123); setField(lock, "byteOffset", 100L); setField(lock, "lengthInBytes", 200L); LockingAndXRange unlock = new LockingAndXRange(false); setField(unlock, "pid", 456); setField(unlock, "byteOffset", 300L); setField(unlock, "lengthInBytes", 400L);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.1K bytes - Viewed (0) -
src/test/java/jcifs/smb1/smb1/TransTransactNamedPipeResponseTest.java
import org.junit.jupiter.api.Test; import org.mockito.InjectMocks; import org.mockito.Mock; import org.mockito.MockitoAnnotations; /** * Unit tests for the {@link TransTransactNamedPipeResponse} class. */ class TransTransactNamedPipeResponseTest { @Mock private SmbNamedPipe mockPipe; @Mock private TransactNamedPipeInputStream mockPipeIn; @InjectMocks
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 5.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java
/** * Test class for Smb2LockRequest functionality */ @DisplayName("Smb2LockRequest Tests") class Smb2LockRequestTest { @Mock private Configuration mockConfig; @Mock private CIFSContext mockContext; @Mock private Smb2Lock mockLock; private byte[] testFileId; private Smb2Lock[] testLocks; private Smb2LockRequest request; @BeforeEach
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 25.3K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/AggregateLogJobTest.java
public void test_execute_concurrentCalls() { // Setup mock SearchLogHelper for concurrent testing final Object lock = new Object(); final int[] callCount = { 0 }; SearchLogHelper mockSearchLogHelper = new SearchLogHelper() { @Override public void storeSearchLog() { synchronized (lock) { callCount[0]++;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 12.1K bytes - Viewed (0) -
src/test/java/jcifs/SmbWatchHandleTest.java
import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; /** * Test class for SmbWatchHandle interface */ @ExtendWith(MockitoExtension.class) class SmbWatchHandleTest { @Mock private SmbWatchHandle watchHandle; @Mock private FileNotifyInformation fileNotifyInfo1; @Mock private FileNotifyInformation fileNotifyInfo2;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 13.2K bytes - Viewed (0)