@Namespace(value="tensorflow") @NoOffset @Properties(inherit=tensorflow.class) public class CollectiveExecutor extends PeerAccessInterface
Modifier and Type | Class and Description |
---|---|
static class |
CollectiveExecutor.Handle |
Pointer.CustomDeallocator, Pointer.Deallocator, Pointer.NativeDeallocator, Pointer.ReferenceCounter
Constructor and Description |
---|
CollectiveExecutor(Pointer p)
Pointer cast constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
CompleteParamsAsync(BytePointer device,
CollectiveParams cp,
CancellationManager cancel_mgr,
Pointer done) |
void |
CompleteParamsAsync(String device,
CollectiveParams cp,
CancellationManager cancel_mgr,
Pointer done) |
void |
ExecuteAsync(OpKernelContext ctx,
CollectiveParams col_params,
BytePointer exec_key,
Pointer done) |
void |
ExecuteAsync(OpKernelContext ctx,
CollectiveParams col_params,
String exec_key,
Pointer done) |
static long |
kInvalidId() |
static void |
kInvalidId(long setter) |
void |
Launched(CollectiveParams col_params) |
PerStepCollectiveRemoteAccess |
remote_access() |
void |
StartAbort(Status s) |
void |
WaitForDependencies(CollectiveParams col_params) |
PostToPeer, PostToPeer, RecvFromPeer, RecvFromPeer, RunClosure
address, asBuffer, asByteBuffer, availablePhysicalBytes, calloc, capacity, capacity, close, deallocate, deallocate, deallocateReferences, deallocator, deallocator, equals, fill, formatBytes, free, getDirectBufferAddress, getPointer, getPointer, getPointer, getPointer, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, position, position, put, realloc, referenceCount, releaseReference, retainReference, setNull, sizeof, sizeof, toString, totalBytes, totalCount, totalPhysicalBytes, withDeallocator, zero
public CollectiveExecutor(Pointer p)
Pointer(Pointer)
.public void ExecuteAsync(OpKernelContext ctx, @Const @ByRef CollectiveParams col_params, @StdString BytePointer exec_key, @ByVal @Cast(value="tensorflow::StatusCallback*") Pointer done)
public void ExecuteAsync(OpKernelContext ctx, @Const @ByRef CollectiveParams col_params, @StdString String exec_key, @ByVal @Cast(value="tensorflow::StatusCallback*") Pointer done)
public void CompleteParamsAsync(@StdString BytePointer device, CollectiveParams cp, CancellationManager cancel_mgr, @ByVal @Cast(value="tensorflow::StatusCallback*") Pointer done)
public void CompleteParamsAsync(@StdString String device, CollectiveParams cp, CancellationManager cancel_mgr, @ByVal @Cast(value="tensorflow::StatusCallback*") Pointer done)
public PerStepCollectiveRemoteAccess remote_access()
public void WaitForDependencies(@Const @ByRef CollectiveParams col_params)
public void Launched(@Const @ByRef CollectiveParams col_params)
public static void kInvalidId(long setter)
Copyright © 2022. All rights reserved.