Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 27 for Flush (0.2 sec)

  1. cni/pkg/ipset/nldeps_unspecified.go

    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) flush(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) clearEntriesWithComment(name, comment string) error {
    	return errors.New("not implemented on this platform")
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  2. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/KtFirAnalysisSessionProvider.kt

        if (this == KtReadActionConfinementLifetimeToken::class &&
            KtReadActionConfinementLifetimeToken.allowFromWriteAction.get() &&
            ApplicationManager.getApplication().isWriteAccessAllowed
        ) {
            // We must flush modifications to publish local modifications into FIR tree
            @OptIn(LLFirInternals::class)
            LLFirDeclarationModificationService.getInstance(project).flushModifications()
        }
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Thu Apr 18 10:43:08 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    				fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%x\t%v\t%v\n",
    					secret.Identity, t, secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom))
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func valueOrNA(value string) string {
    	if value == "" {
    		return "NA"
    	}
    	return value
    }
    
    func certNotExpired(cert *Cert) bool {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/workload.go

    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\n",
    				wl.Namespace, wl.Name, ip, wl.Node, waypoint, wl.Protocol)
    		} else {
    			fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node)
    		}
    	}
    	return w.Flush()
    }
    
    // PrintWorkloadDump prints the relevant workloads in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintWorkloadDump(filter WorkloadFilter, outputFormat string) error {
    	zDump := c.ztunnelDump
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/ztunnel/configdump/connections.go

    			for _, c := range wl.Connections.Outbound {
    				fmt.Fprintf(w, "%v\tOutbound\t%v\t%v\t%v\n", name, lookupIP(c.Src), lookupIP(c.ActualDst), lookupIP(c.OriginalDst))
    			}
    		}
    	}
    	return w.Flush()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 15:39:28 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    					} else {
    						write([]byte{0})
    					}
    					return
    				default:
    				}
    
    				// Response not ready, write a filler byte.
    				write([]byte{32})
    				if canWrite {
    					w.(http.Flusher).Flush()
    				}
    			case err := <-doneCh:
    				if err != nil {
    					write([]byte{1})
    					write([]byte(err.Error()))
    				} else {
    					write([]byte{0})
    				}
    				return
    			}
    		}
    	}()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/ztunnel/configdump/services.go

    			_, ip, _ = strings.Cut(svc.Addresses[0], "/")
    		}
    		waypoint := serviceWaypointName(svc, zDump.Services)
    		fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    			svc.Namespace, svc.Name, ip, waypoint)
    	}
    	return w.Flush()
    }
    
    // PrintServiceDump prints the relevant services in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintServiceDump(filter ServiceFilter, outputFormat string) error {
    	zDump := c.ztunnelDump
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/endpoint.go

    				}
    				fmt.Fprintf(w, "%v\t%v\t%v\t%v\n",
    					addr,
    					ep.GetHealthStatus().String(),
    					util.LocalityToString(llb.Locality),
    					eds.ClusterName,
    				)
    			}
    		}
    	}
    
    	return w.Flush()
    }
    
    func (c *ConfigWriter) retrieveSortedEndpointsSlice(filter EndpointFilter) ([]*endpoint.ClusterLoadAssignment, error) {
    	if c.configDump == nil {
    		return nil, fmt.Errorf("config writer has not been primed")
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      fun awaitPong() {
        this.withLock {
          while (awaitPongsReceived < awaitPingsSent) {
            condition.await()
          }
        }
      }
    
      @Throws(IOException::class)
      fun flush() {
        writer.flush()
      }
    
      /**
       * Degrades this connection such that new streams can neither be created locally, nor accepted
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  10. cni/pkg/iptables/iptables.go

    		{"-t", iptablesconstants.NAT, "-D", iptablesconstants.OUTPUT, "-j", ChainInpodOutput},
    	}
    
    	// these sometimes fail due to "Device or resource busy"
    	optionalDeleteCmds := [][]string{
    		// flush-then-delete our created chains
    		{"-t", iptablesconstants.MANGLE, "-F", ChainInpodPrerouting},
    		{"-t", iptablesconstants.MANGLE, "-F", ChainInpodOutput},
    		{"-t", iptablesconstants.NAT, "-F", ChainInpodOutput},
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
Back to top