- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 72 for GetSink (0.15 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} pushPromises(stream, request, response.pushPromises) if (body != null) { sleepNanos(bodyDelayNanos) val responseBodySink = stream.getSink().withThrottlingAndSocketPolicy( policy = response, disconnectHalfway = response.socketPolicy == DisconnectDuringResponseBody, expectedByteCount = body.contentLength,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/translate/export_graphdef.cc
// source. if (auto next_iter_source = llvm::dyn_cast<mlir::tf_executor::NextIterationSourceOp>( input_inst)) input_inst = next_iter_source.GetSink(); auto node_it = nodes_.find(input_inst); TF_RET_CHECK(node_it != nodes_.end()) << "Use of OpResult encountered before def!"; if (mlir::isa<mlir::tf_executor::ControlType>(input_result.getType())) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 01 11:17:36 UTC 2024 - 35.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v2/tf_executor_to_graph.cc
// source. if (auto next_iter_source = llvm::dyn_cast<mlir::tf_executor::NextIterationSourceOp>( input_inst)) input_inst = next_iter_source.GetSink(); auto node_it = nodes_.find(input_inst); TF_RET_CHECK(node_it != nodes_.end()) << "Use of OpResult encountered before def!"; if (mlir::isa<mlir::tf_executor::ControlType>(input_result.getType())) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 06 23:04:51 UTC 2024 - 35.2K bytes - Viewed (0) -
pkg/proxy/ipvs/netlink.go
See the License for the specific language governing permissions and limitations under the License. */ package ipvs import ( "k8s.io/apimachinery/pkg/util/sets" ) // NetLinkHandle for revoke netlink interface type NetLinkHandle interface { // EnsureAddressBind checks if address is bound to the interface and, if not, binds it. If the address is already bound, return true.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 27 19:02:20 UTC 2023 - 2.3K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/http2/Http2Stream;->checkOutNotClosed$okhttp()V HSPLokhttp3/internal/http2/Http2Stream;->getErrorCode$okhttp()Lokhttp3/internal/http2/ErrorCode; HSPLokhttp3/internal/http2/Http2Stream;->getSink()Lokio/Sink; HSPLokhttp3/internal/http2/Http2Stream;->isLocallyInitiated()Z HSPLokhttp3/internal/http2/Http2Stream;->isOpen()Z HSPLokhttp3/internal/http2/Http2Stream;->receiveHeaders(Lokhttp3/Headers;Z)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
cni/pkg/iptables/iptables_linux.go
} } return nil } func AddLoopbackRoutes(cfg *Config) error { return forEachLoopbackRoute(cfg, netlink.RouteReplace) } func DelLoopbackRoutes(cfg *Config) error { return forEachLoopbackRoute(cfg, netlink.RouteDel) } func forEachLoopbackRoute(cfg *Config, f func(*netlink.Route) error) error { loopbackLink, err := netlink.LinkByName("lo") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/proxy/util/nfacct/handler.go
*/ package nfacct import ( "github.com/vishvananda/netlink/nl" "github.com/vishvananda/netns" "golang.org/x/sys/unix" ) // handler is an injectable interface for creating netlink request. type handler interface { newRequest(cmd int, flags uint16) request } // request is an injectable interface representing a netlink request. type request interface { Serialize() []byte
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 06:47:50 UTC 2024 - 2.6K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_linux.go
family = unix.AF_INET6 } else { family = unix.AF_INET } err := netlink.IpsetCreate(name, "hash:ip", netlink.IpsetCreateOptions{Comments: true, Replace: true, Family: family}) if ipsetErr, ok := err.(nl.IPSetError); ok && ipsetErr == nl.IPSET_ERR_EXIST { return nil } return err } func (m *realDeps) destroySet(name string) error { err := netlink.IpsetDestroy(name) return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 30 18:07:05 UTC 2024 - 3.9K bytes - Viewed (0) -
tools/istio-iptables/pkg/capture/run_linux.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/proxy/ipvs/netlink_linux.go
proxyutil "k8s.io/kubernetes/pkg/proxy/util" netutils "k8s.io/utils/net" "github.com/vishvananda/netlink" "golang.org/x/sys/unix" ) type netlinkHandle struct { netlink.Handle isIPv6 bool } // NewNetLinkHandle will create a new NetLinkHandle func NewNetLinkHandle(isIPv6 bool) NetLinkHandle { return &netlinkHandle{netlink.Handle{}, isIPv6} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 30 16:18:49 UTC 2023 - 5.8K bytes - Viewed (0)