rpc - Code Search

src/main/java/jcifs/smb/SmbEnumerationUtil.java

        try ( DcerpcHandle handle = getHandle(ctx, loc, address, "\\PIPE\\netdfs") ) {
            MsrpcDfsRootEnum rpc = new MsrpcDfsRootEnum(loc.getServer());
            handle.sendrecv(rpc);
            if ( rpc.retval != 0 ) {
                throw new SmbException(rpc.retval, true);
            }
            return rpc.getEntries();
        }
    }

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sat Jul 20 08:41:19 GMT 2019

- 12.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/SIDCacheImpl.java

                    rpc = new MsrpcGetMembersInAlias(aliasHandle, sidarray);
                    handle.sendrecv(rpc);
                    if ( rpc.retval != 0 )
                        throw new SmbException(rpc.retval, false);
                    SID[] sids = new SID[rpc.sids.num_sids];

                    String origin_server = handle.getServer();

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sun Jul 01 13:12:10 GMT 2018

- 12.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/msrpc/samr.java

        public int retval;
        public rpc.policy_handle handle;
        public int access_mask;
        public rpc.sid_t sid;
        public rpc.policy_handle domain_handle;

        public SamrOpenDomain(rpc.policy_handle handle,
                    int access_mask,
                    rpc.sid_t sid,
                    rpc.policy_handle domain_handle) {
            this.handle = handle;

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:39:42 GMT 2019

- 14K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-set.go

		i++
	}
}

// updateMetacacheListing will update the metacache listing.
func (o *listPathOptions) updateMetacacheListing(m metacache, rpc *peerRESTClient) (metacache, error) {
	if rpc == nil {
		return localMetacacheMgr.updateCacheEntry(m)
	}
	return rpc.UpdateMetacacheListing(context.Background(), m)
}

func getMetacacheBlockInfo(fi FileInfo, block int) (*metacacheBlock, error) {
	var tmp metacacheBlock

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Wed May 01 17:59:08 GMT 2024

- 30.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SID.java

        MsrpcGetMembersInAlias rpc = null;

        try {
            aliasHandle = new SamrAliasHandle(handle, domainHandle, 0x0002000c, rid);
            rpc = new MsrpcGetMembersInAlias(aliasHandle, sidarray);
            handle.sendrecv(rpc);
            if (rpc.retval != 0)
                throw new SmbException(rpc.retval, false);
            SID[] sids = new SID[rpc.sids.num_sids];

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 21:10:40 GMT 2019

- 26.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/msrpc/samr.java

            return 0x07;
        }

        public int retval;
        public rpc.policy_handle handle;
        public int access_mask;
        public rpc.sid_t sid;
        public rpc.policy_handle domain_handle;


        public SamrOpenDomain ( rpc.policy_handle handle, int access_mask, rpc.sid_t sid, rpc.policy_handle domain_handle ) {
            this.handle = handle;

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:40:13 GMT 2019

- 15.1K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/msrpc/lsarpc.java

                    sid = new rpc.sid_t();
                }
                _src = _src.deferred;
                sid.decode(_src);

            }
        }
    }
    public static class LsarDnsDomainInfo extends NdrObject {

        public rpc.unicode_string name;
        public rpc.unicode_string dns_domain;
        public rpc.unicode_string dns_forest;

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:39:42 GMT 2019

- 33K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/dcerpc/msrpc/lsarpc.java

                    this.sid = new rpc.sid_t();
                }
                _src = _src.deferred;
                this.sid.decode(_src);

            }
        }
    }

    public static class LsarDnsDomainInfo extends NdrObject {

        public rpc.unicode_string name;
        public rpc.unicode_string dns_domain;
        public rpc.unicode_string dns_forest;

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:40:13 GMT 2019

- 35.6K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

tensorflow/c/eager/BUILD

        "//tensorflow/core/distributed_runtime/rpc:grpc_channel",
        "//tensorflow/core/distributed_runtime/rpc:grpc_server_lib",
        "//tensorflow/core/distributed_runtime/rpc:grpc_worker_cache",
        "//tensorflow/core/distributed_runtime/rpc:grpc_worker_service",
        "//tensorflow/core/distributed_runtime/rpc:rpc_rendezvous_mgr",
        "//tensorflow/core/distributed_runtime/rpc/eager:grpc_eager_client",

Plain Text

- Registered: Tue Apr 30 12:39:09 GMT 2024

- Last Modified: Thu Apr 11 23:52:39 GMT 2024

- 33.3K bytes

- Viewed (0)

github.com/minio/minio

cmd/metacache-server-pool.go

		}
		entries.truncate(0)
		go func() {
			rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
			if rpc != nil {
				ctx, cancel := context.WithTimeout(GlobalContext, 5*time.Second)
				defer cancel()
				c, err := rpc.GetMetacacheListing(ctx, *o)
				if err == nil {
					c.error = "no longer used"
					c.status = scanStateError
					rpc.UpdateMetacacheListing(ctx, *c)
				}
			}
		}()

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Thu Apr 04 12:04:40 GMT 2024

- 12.8K bytes

- Viewed (0)

Search Options