/dports/net/concourse-fly/concourse-6.7.1/vendor/code.cloudfoundry.org/garden/client/connection/ |
H A D | stream_handler.go | 16 type streamHandler struct { struct 17 log lager.Logger 18 wg *sync.WaitGroup 28 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) { 42 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) { 50 func (sh *streamHandler) wait(decoder *json.Decoder) (int, error) {
|
/dports/misc/concourse/concourse-6.7.2/vendor/code.cloudfoundry.org/garden/client/connection/ |
H A D | stream_handler.go | 16 type streamHandler struct { struct 17 log lager.Logger 18 wg *sync.WaitGroup 28 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) { 42 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) { 50 func (sh *streamHandler) wait(decoder *json.Decoder) (int, error) {
|
/dports/net/concourse-fly/concourse-6.7.1/atc/worker/gclient/connection/ |
H A D | stream_handler.go | 13 type streamHandler struct { struct 14 log lager.Logger 15 wg *sync.WaitGroup 25 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) { 39 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) { 52 func (sh *streamHandler) wait(decoder *json.Decoder) <-chan waitReturn {
|
/dports/misc/concourse/concourse-6.7.2/atc/worker/gclient/connection/ |
H A D | stream_handler.go | 13 type streamHandler struct { struct 14 log lager.Logger 15 wg *sync.WaitGroup 25 func (sh *streamHandler) streamIn(processWriter io.WriteCloser, stdin io.Reader) { 39 func (sh *streamHandler) streamOut(streamWriter io.Writer, streamReader io.Reader) { 52 func (sh *streamHandler) wait(decoder *json.Decoder) <-chan waitReturn {
|
/dports/devel/jiic/jiic/de/tu_darmstadt/informatik/rbg/hatlak/iso9660/impl/ |
H A D | ISO9660DirectoryRecord.java | 38 private StreamHandler streamHandler; field in ISO9660DirectoryRecord 46 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660File file, LayoutHelper helper) … in ISO9660DirectoryRecord() 55 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660MovedDirectory moved, LayoutHelp… in ISO9660DirectoryRecord() 64 …public ISO9660DirectoryRecord(StreamHandler streamHandler, ISO9660Directory dir, LayoutHelper help… in ISO9660DirectoryRecord() 72 …public ISO9660DirectoryRecord(StreamHandler streamHandler, Object object, ISO9660Directory dir, La… in ISO9660DirectoryRecord() 91 private void init(StreamHandler streamHandler, LayoutHelper helper) { in init()
|
H A D | ISO9660PathTableRecord.java | 27 private StreamHandler streamHandler; field in ISO9660PathTableRecord 32 …public ISO9660PathTableRecord(StreamHandler streamHandler, Object type, Object object, int parent)… in ISO9660PathTableRecord() 51 …public ISO9660PathTableRecord(StreamHandler streamHandler, Object type, DataReference ref, int par… in ISO9660PathTableRecord()
|
H A D | CreateISO.java | 32 private StreamHandler streamHandler; field in CreateISO 34 …public CreateISO(StreamHandler streamHandler, ISO9660RootDirectory root) throws FileNotFoundExcept… in CreateISO()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cronet/android/test/javatests/src/org/chromium/net/urlconnection/ |
H A D | CronetHttpURLStreamHandlerTest.java | 60 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionHttp() local 75 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionHttps() local 87 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionProtocolNotSupported() local 102 CronetHttpURLStreamHandler streamHandler = in testOpenConnectionWithProxy() local
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/rafthttp/ |
H A D | http.go | 226 type streamHandler struct { struct 227 tr *Transport 228 peerGetter peerGetter 229 r Raft 230 id types.ID 231 cid types.ID 244 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd31/etcd-3.1.20/rafthttp/ |
H A D | http.go | 249 type streamHandler struct { struct 250 tr *Transport 251 peerGetter peerGetter 252 r Raft 253 id types.ID 254 cid types.ID 267 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/rafthttp/ |
H A D | http.go | 251 type streamHandler struct { struct 252 tr *Transport 253 peerGetter peerGetter 254 r Raft 255 id types.ID 256 cid types.ID 269 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd32/etcd-3.2.32/rafthttp/ |
H A D | http.go | 249 type streamHandler struct { struct 250 tr *Transport 251 peerGetter peerGetter 252 r Raft 253 id types.ID 254 cid types.ID 267 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd33/etcd-3.3.23/rafthttp/ |
H A D | http.go | 251 type streamHandler struct { struct 252 tr *Transport 253 peerGetter peerGetter 254 r Raft 255 id types.ID 256 cid types.ID 269 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd/etcd-2.3.8/rafthttp/ |
H A D | http.go | 218 type streamHandler struct { struct 219 tr *Transport 220 peerGetter peerGetter 221 r Raft 222 id types.ID 223 cid types.ID 236 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/rafthttp/ |
H A D | http.go | 245 type streamHandler struct { struct 246 tr *Transport 247 peerGetter peerGetter 248 r Raft 249 id types.ID 250 cid types.ID 263 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/rafthttp/ |
H A D | http.go | 241 type streamHandler struct { struct 242 tr *Transport 243 peerGetter peerGetter 244 r Raft 245 id types.ID 246 cid types.ID 259 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
H A D | http.go | 318 type streamHandler struct { struct 319 lg *zap.Logger 320 tr *Transport 321 peerGetter peerGetter 322 r Raft 323 id types.ID 324 cid types.ID 342 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
H A D | http.go | 350 type streamHandler struct { struct 351 lg *zap.Logger 352 tr *Transport 353 peerGetter peerGetter 354 r Raft 355 id types.ID 356 cid types.ID 370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/devel/etcd34/etcd-3.4.18/etcdserver/api/rafthttp/ |
H A D | http.go | 350 type streamHandler struct { struct 351 lg *zap.Logger 352 tr *Transport 353 peerGetter peerGetter 354 r Raft 355 id types.ID 356 cid types.ID 370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
H A D | http.go | 324 type streamHandler struct { struct 325 lg *zap.Logger 326 tr *Transport 327 peerGetter peerGetter 328 r Raft 329 id types.ID 330 cid types.ID 348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/rafthttp/ |
H A D | http.go | 324 type streamHandler struct { struct 325 lg *zap.Logger 326 tr *Transport 327 peerGetter peerGetter 328 r Raft 329 id types.ID 330 cid types.ID 348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/rafthttp/ |
H A D | http.go | 324 type streamHandler struct { struct 325 lg *zap.Logger 326 tr *Transport 327 peerGetter peerGetter 328 r Raft 329 id types.ID 330 cid types.ID 348 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/rafthttp/ |
H A D | http.go | 350 type streamHandler struct { struct 351 lg *zap.Logger 352 tr *Transport 353 peerGetter peerGetter 354 r Raft 355 id types.ID 356 cid types.ID 370 func (h *streamHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
/dports/java/icedtea-web/icedtea-web-1.6.2/plugin/icedteanp/java/sun/applet/ |
H A D | PluginMain.java | 151 PluginStreamHandler streamHandler = connect(args[0], args[1]); in main() local 179 public static void initSecurityContext(PluginStreamHandler streamHandler) { in initSecurityContext() 191 PluginStreamHandler streamHandler = null; in connect() local 262 private static void setCookieHandler(PluginStreamHandler streamHandler) { in setCookieHandler()
|
/dports/devel/jiic/jiic/de/tu_darmstadt/informatik/rbg/hatlak/iso9660/volumedescriptors/ |
H A D | ISO9660VolumeDescriptor.java | 30 StreamHandler streamHandler; field in ISO9660VolumeDescriptor 34 public ISO9660VolumeDescriptor(StreamHandler streamHandler, int type, LayoutHelper helper) { in ISO9660VolumeDescriptor()
|