ceph/src/jaegertracing/thrift/lib/netstd/Thrift/Transport/TServerTransport.cs

   1 // Licensed to the Apache Software Foundation(ASF) under one
   2 // or more contributor license agreements.See the NOTICE file
   3 // distributed with this work for additional information
   4 // regarding copyright ownership.The ASF licenses this file
   5 // to you under the Apache License, Version 2.0 (the
   6 // "License"); you may not use this file except in compliance
   7 // with the License. You may obtain a copy of the License at
   8 //
   9 //     http://www.apache.org/licenses/LICENSE-2.0
  10 //
  11 // Unless required by applicable law or agreed to in writing,
  12 // software distributed under the License is distributed on an
  13 // "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  14 // KIND, either express or implied. See the License for the
  15 // specific language governing permissions and limitations
  16 // under the License.
  17
  18 using System.Threading;
  19 using System.Threading.Tasks;
  20
  21 namespace Thrift.Transport
  22 {
  23     // ReSharper disable once InconsistentNaming
  24     public abstract class TServerTransport
  25     {
  26         public abstract void Listen();
  27         public abstract void Close();
  28         public abstract bool IsClientPending();
  29
  30         protected virtual async ValueTask<TTransport> AcceptImplementationAsync()
  31         {
  32             return await AcceptImplementationAsync(CancellationToken.None);
  33         }
  34
  35         protected abstract ValueTask<TTransport> AcceptImplementationAsync(CancellationToken cancellationToken);
  36
  37         public async ValueTask<TTransport> AcceptAsync()
  38         {
  39             return await AcceptAsync(CancellationToken.None);
  40         }
  41
  42         public async ValueTask<TTransport> AcceptAsync(CancellationToken cancellationToken)
  43         {
  44             var transport = await AcceptImplementationAsync(cancellationToken);
  45
  46             if (transport == null)
  47             {
  48                 throw new TTransportException($"{nameof(AcceptImplementationAsync)} should not return null");
  49             }
  50
  51             return transport;
  52         }
  53     }
  54 }