本文整理汇总了C#中IBufferPool类的典型用法代码示例。如果您正苦于以下问题:C# IBufferPool类的具体用法?C# IBufferPool怎么用?C# IBufferPool使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
IBufferPool类属于命名空间,在下文中一共展示了IBufferPool类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C#代码示例。
示例1: ChatClientNetChannel
public ChatClientNetChannel(IActorSystem<IRoomActor> rooms, ICallbacksGatewayNode callbacksNode, INetNode node,
ITransportChannel transportChannel, IMessageSerializer serializer, ICoreEvents logger, INetNodeConfig config, IBufferPool bufferPool)
: base(node, transportChannel, serializer, logger, config, bufferPool)
{
_rooms = rooms;
_callbacksNode = callbacksNode;
}
开发者ID:Rurouni,项目名称:MassiveOnlineUniversalServerEngine,代码行数:7,代码来源:ChatClientNetChannel.cs
示例2: GeneralStorageActions
public GeneralStorageActions(TableStorage storage, Reference<WriteBatch> writeBatch, Reference<SnapshotReader> snapshot, IBufferPool bufferPool)
: base(snapshot, bufferPool)
{
this.storage = storage;
this.writeBatch = writeBatch;
this.snapshot = snapshot;
}
开发者ID:felixmm,项目名称:ravendb,代码行数:7,代码来源:GeneralStorageActions.cs
示例3: QueueStorageActions
public QueueStorageActions(TableStorage tableStorage, IUuidGenerator generator, Reference<SnapshotReader> snapshot, Reference<WriteBatch> writeBatch, IBufferPool bufferPool)
: base(snapshot, bufferPool)
{
this.tableStorage = tableStorage;
this.writeBatch = writeBatch;
this.generator = generator;
}
开发者ID:j2jensen,项目名称:ravendb,代码行数:7,代码来源:QueueStorageActions.cs
示例4: TableStorage
public TableStorage(StorageEnvironment environment, IBufferPool bufferPool)
{
this.bufferPool = bufferPool;
env = environment;
Initialize();
}
开发者ID:jrusbatch,项目名称:ravendb,代码行数:7,代码来源:TableStorage.cs
示例5: AsyncProcessingNetChannel
public AsyncProcessingNetChannel(Func<IMessageProcessingPipeBuilder, IMessageProcessingPipeBuilder> configureProcesssingPipe, INetNode node,
ITransportChannel transportChannel, IMessageSerializer serializer, ICoreEvents logger, INetNodeConfig config, IBufferPool bufferPool)
: base(node, transportChannel, serializer, logger, config, bufferPool)
{
_pipeBuilder = configureProcesssingPipe(new MessageProcessingPipeBuilder());
_processor = _pipeBuilder.Build();
}
开发者ID:Rurouni,项目名称:MassiveOnlineUniversalServerEngine,代码行数:7,代码来源:AsyncProcessingNetChannel.cs
示例6: TsPesPacketPool
public TsPesPacketPool(IBufferPool bufferPool)
{
if (null == bufferPool)
throw new ArgumentNullException(nameof(bufferPool));
_bufferPool = bufferPool;
}
开发者ID:henricj,项目名称:phonesm,代码行数:7,代码来源:TsPesPacketPool.cs
示例7: StorageActionsAccessor
public StorageActionsAccessor(TableStorage storage, Reference<WriteBatch> writeBatch, Reference<SnapshotReader> snapshot, IdGenerator generator, IBufferPool bufferPool, OrderedPartCollection<AbstractFileCodec> fileCodecs)
: base(snapshot, generator, bufferPool)
{
this.storage = storage;
this.writeBatch = writeBatch;
this.fileCodecs = fileCodecs;
}
开发者ID:felipeleusin,项目名称:ravendb,代码行数:7,代码来源:StorageActionsAccessor.cs
示例8: TcpConnection
public TcpConnection(Socket socket, SocketSetting setting, IBufferPool receiveDataBufferPool, Action<ITcpConnection, byte[]> messageArrivedHandler, Action<ITcpConnection, SocketError> connectionClosedHandler)
{
Ensure.NotNull(socket, "socket");
Ensure.NotNull(setting, "setting");
Ensure.NotNull(receiveDataBufferPool, "receiveDataBufferPool");
Ensure.NotNull(messageArrivedHandler, "messageArrivedHandler");
Ensure.NotNull(connectionClosedHandler, "connectionClosedHandler");
_socket = socket;
_setting = setting;
_receiveDataBufferPool = receiveDataBufferPool;
_localEndPoint = socket.LocalEndPoint;
_remotingEndPoint = socket.RemoteEndPoint;
_messageArrivedHandler = messageArrivedHandler;
_connectionClosedHandler = connectionClosedHandler;
_sendSocketArgs = new SocketAsyncEventArgs();
_sendSocketArgs.AcceptSocket = _socket;
_sendSocketArgs.Completed += OnSendAsyncCompleted;
_receiveSocketArgs = new SocketAsyncEventArgs();
_receiveSocketArgs.AcceptSocket = socket;
_receiveSocketArgs.Completed += OnReceiveAsyncCompleted;
_logger = ObjectContainer.Resolve<ILoggerFactory>().Create(GetType().FullName);
_framer = ObjectContainer.Resolve<IMessageFramer>();
_framer.RegisterMessageArrivedCallback(OnMessageArrived);
TryReceive();
TrySend();
}
开发者ID:YqlZero,项目名称:ecommon,代码行数:31,代码来源:TcpConnection.cs
示例9: TableBase
protected TableBase(string tableName, IBufferPool bufferPool)
{
if (string.IsNullOrEmpty(tableName))
throw new ArgumentNullException(tableName);
BufferPool = bufferPool;
TableName = tableName;
}
开发者ID:randacc,项目名称:ravendb,代码行数:8,代码来源:TableBase.cs
示例10: IndexingStorageActions
public IndexingStorageActions(TableStorage tableStorage, IUuidGenerator generator, Reference<SnapshotReader> snapshot, Reference<WriteBatch> writeBatch, IStorageActionsAccessor storageActionsAccessor, IBufferPool bufferPool)
: base(snapshot, bufferPool)
{
this.tableStorage = tableStorage;
this.generator = generator;
this.writeBatch = writeBatch;
this.currentStorageActionsAccessor = storageActionsAccessor;
}
开发者ID:bbqchickenrobot,项目名称:ravendb,代码行数:8,代码来源:IndexingStorageActions.cs
示例11: ServiceSocket
/// <summary>
/// Initializes a new instance of the ServiceSocket class.
/// </summary>
/// <param name="socket">The .NET Socket object to encapsulate</param>
/// <param name="IsPeerSocket">Indicates if this socket was spawned from the state server peer port</param>
public ServiceSocket(Socket socket, bool IsPeerSocket, IBufferPool Buffers)
{
this.socket = socket;
fromPeerListener = IsPeerSocket;
sessionKey = null;
id = Guid.NewGuid();
bufferPool = Buffers;
}
开发者ID:tenor,项目名称:p2pStateServer,代码行数:13,代码来源:Sockets.cs
示例12: MappedResultsStorageActions
public MappedResultsStorageActions(TableStorage tableStorage, IUuidGenerator generator, OrderedPartCollection<AbstractDocumentCodec> documentCodecs, Reference<SnapshotReader> snapshot, Reference<WriteBatch> writeBatch, IBufferPool bufferPool)
: base(snapshot, bufferPool)
{
this.tableStorage = tableStorage;
this.generator = generator;
this.documentCodecs = documentCodecs;
this.writeBatch = writeBatch;
}
开发者ID:cocytus,项目名称:ravendb,代码行数:8,代码来源:MappedResultsStorageActions.cs
示例13: HttpListenerContextAdpater
public HttpListenerContextAdpater(HttpListenerContext ctx, InMemoryRavenConfiguration configuration, IBufferPool bufferPool)
{
this.ctx = ctx;
this.configuration = configuration;
this.bufferPool = bufferPool;
ResponseInternal = new HttpListenerResponseAdapter(ctx.Response, bufferPool);
RequestInternal = new HttpListenerRequestAdapter(ctx.Request);
SetMaxAge();
}
开发者ID:remcoros,项目名称:ravendb,代码行数:10,代码来源:HttpListenerContextAdpater.cs
示例14: MappedResultsStorageActions
public MappedResultsStorageActions(TableStorage tableStorage, IUuidGenerator generator, OrderedPartCollection<AbstractDocumentCodec> documentCodecs, Reference<SnapshotReader> snapshot,
Reference<WriteBatch> writeBatch, IBufferPool bufferPool, IStorageActionsAccessor storageActionsAccessor, ConcurrentDictionary<int, RemainingReductionPerLevel> ScheduledReductionsPerViewAndLevel)
: base(snapshot, bufferPool)
{
this.tableStorage = tableStorage;
this.generator = generator;
this.documentCodecs = documentCodecs;
this.writeBatch = writeBatch;
this.storageActionsAccessor = storageActionsAccessor;
this.scheduledReductionsPerViewAndLevel = ScheduledReductionsPerViewAndLevel;
}
开发者ID:VPashkov,项目名称:ravendb,代码行数:11,代码来源:MappedResultsStorageActions.cs
示例15: TableStorage
public TableStorage(StorageEnvironmentOptions options, IBufferPool bufferPool)
{
if (options == null)
throw new ArgumentNullException("options");
_options = options;
this.bufferPool = bufferPool;
env = new StorageEnvironment(_options);
Initialize();
}
开发者ID:felixmm,项目名称:ravendb,代码行数:12,代码来源:TableStorage.cs
示例16: TableStorage
public TableStorage(StorageEnvironmentOptions options, IBufferPool bufferPool)
{
if (options == null)
throw new ArgumentNullException("options");
_options = options;
this.bufferPool = bufferPool;
Debug.Assert(options != null);
env = new StorageEnvironment(options);
Initialize();
CreateSchema();
}
开发者ID:randacc,项目名称:ravendb,代码行数:14,代码来源:TableStorage.cs
示例17: TsPacketizedElementaryStream
public TsPacketizedElementaryStream(IBufferPool bufferPool, ITsPesPacketPool pesPacketPool, Action<TsPesPacket> packetHandler, TsStreamType streamType, uint pid)
{
if (null == bufferPool)
throw new ArgumentNullException(nameof(bufferPool));
if (null == pesPacketPool)
throw new ArgumentNullException(nameof(pesPacketPool));
_bufferPool = bufferPool;
_pesPacketPool = pesPacketPool;
_streamType = streamType;
_pid = pid;
_handler = packetHandler;
}
开发者ID:henricj,项目名称:phonesm,代码行数:15,代码来源:TsPacketizedElementaryStream.cs
示例18: ServerSocket
public ServerSocket(IPEndPoint listeningEndPoint, SocketSetting setting, IBufferPool receiveDataBufferPool, Action<ITcpConnection, byte[], Action<byte[]>> messageArrivedHandler)
{
Ensure.NotNull(listeningEndPoint, "listeningEndPoint");
Ensure.NotNull(setting, "setting");
Ensure.NotNull(receiveDataBufferPool, "receiveDataBufferPool");
Ensure.NotNull(messageArrivedHandler, "messageArrivedHandler");
_listeningEndPoint = listeningEndPoint;
_setting = setting;
_receiveDataBufferPool = receiveDataBufferPool;
_connectionEventListeners = new List<IConnectionEventListener>();
_messageArrivedHandler = messageArrivedHandler;
_socket = SocketUtils.CreateSocket(_setting.SendBufferSize, _setting.ReceiveBufferSize);
_acceptSocketArgs = new SocketAsyncEventArgs();
_acceptSocketArgs.Completed += AcceptCompleted;
_logger = ObjectContainer.Resolve<ILoggerFactory>().Create(GetType().FullName);
}
开发者ID:YqlZero,项目名称:ecommon,代码行数:17,代码来源:ServerSocket.cs
示例19: AttachmentsStorageActions
public AttachmentsStorageActions(Table attachmentsTable,
Reference<WriteBatch> writeBatch,
Reference<SnapshotReader> snapshot,
IUuidGenerator uuidGenerator,
TableStorage tableStorage,
Raven.Storage.Voron.TransactionalStorage transactionalStorage,
IBufferPool bufferPool)
:base(snapshot, bufferPool)
{
this.attachmentsTable = attachmentsTable;
this.writeBatch = writeBatch;
this.uuidGenerator = uuidGenerator;
this.tableStorage = tableStorage;
this.transactionalStorage = transactionalStorage;
metadataIndex = tableStorage.Attachments.GetIndex(Tables.Attachments.Indices.Metadata);
}
开发者ID:j2jensen,项目名称:ravendb,代码行数:17,代码来源:AttachmentsStorageActions.cs
示例20: DocumentsStorageActions
public DocumentsStorageActions(IUuidGenerator uuidGenerator,
OrderedPartCollection<AbstractDocumentCodec> documentCodecs,
IDocumentCacher documentCacher,
Reference<WriteBatch> writeBatch,
Reference<SnapshotReader> snapshot,
TableStorage tableStorage,
IBufferPool bufferPool)
: base(snapshot, bufferPool)
{
this.uuidGenerator = uuidGenerator;
this.documentCodecs = documentCodecs;
this.documentCacher = documentCacher;
this.writeBatch = writeBatch;
this.tableStorage = tableStorage;
metadataIndex = tableStorage.Documents.GetIndex(Tables.Documents.Indices.Metadata);
}
开发者ID:cocytus,项目名称:ravendb,代码行数:17,代码来源:DocumentsStorageActions.cs
注:本文中的IBufferPool类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论