草庐IT

send-trim-memory

全部标签

C++ 套接字 Send() 线程安全

我正在为最多1000个客户端编写套接字服务器,服务器是关于我的游戏,我使用非阻塞套接字和大约10个同时从不同套接字接收数据的线程(第一个线程从0-100接收,第二个从101-200等等..)但是如果线程1要向所有1000个客户端发送数据,线程2也想同时向所有1000个客户端发送数据,这样安全吗?数据是否有可能在另一方(客户端)被弄乱?如果是,我想唯一可能发生的问题是有时客户端会收到2个或10个数据包作为1个数据包,对吗?如果是,是否有任何解决方案:( 最佳答案 处理多个套接字的通常模式是使用专用线程轮询I/O事件select(2),

c++ - 检查 write()/send() 是否可以无阻塞地处理整个缓冲区,否则失败(没有部分写入)

我正在使用SOCK_SEQPACKET连接,确保通过单个write()/send()调用发送整个缓冲区对我来说至关重要。我还在使用旨在通过一次调用处理完整数据block的设备驱动程序。同时,我想处理write()/send()由于缓冲区溢出而阻塞的情况,即我想反馈当前实现是否在这里遇到瓶颈。我正在使用glibc,Linux2.6。我需要实现一个接受缓冲区的方法,它要么完全发送一个缓冲区,要么指示由于阻塞导致的失败(即系统缓冲区溢出)。看起来使用send(...,MSG_DONTWAIT)/fcntl(...,O_NONBLOCK)不是解决方案,因为它们在报告EWOULDBLOCK/EA

c++ - boost iostream : how to turn ifstream into memory mapped file?

我想要的是简单地打开文件作为内存映射文件进行读取-以便将来以更快的速度访问它(例如:我们打开文件读取它结束,等待并一次又一次地读取它)同时我希望该文件可以被其他程序修改,当他们修改它时,我希望我的ifstream也能修改。如何使用boostiostreams(或boostinterprocess)做这样的事情?我们可以只是tallos-嘿,这个文件应该为所有应用程序进行内存映射?所以我尝试这样的代码:#include#include#includeusingnamespaceboost::iostreams;intmain(intargc,char**argv){streamout;t

c++ - Qt : send Key_Return and Key_Delete events

我正在使用QtEmbedded开发虚拟键盘,但遇到了一个小问题。事实上,我使用SignalMappers将键映射到键盘事件,以便在QTextEdit小部件中显示文本。一切正常,除了两个事件:Key_Return和Key_Delete;我不知道我做错了什么,也许你会有想法。这是一个经典的代码,发送字符:voidVirtualKeyboard::SendChar(intindex){QCharcharToSend(letters_.at(index)->text().at(0));//Getcharserver_->sendKeyEvent(charToSend.unicode(),QEv

c++ - 简单代码导致错误读取变量: Cannot access memory at address

我正在尝试使用支持python的gdbMinGW-builds.我遇到了一个错误。这是一个相当简单的代码,在MSVC下调试时它工作正常。D:\CppProject\c1\bin\Debug>gdbc1.exeGNUgdb(GDB)7.6(copyright,license,bugreport,etcomittedhere)ReadingsymbolsfromD:\CppProject\c1\bin\Debug\c1.exe...done.(gdb)l1#include2#include34usingnamespacestd;56intmain()7{8vectorv;9v.push_b

c++ - malloc_trim(0) 释放 Thread Arenas 的 Fastbins?

在过去一周左右的时间里,我一直在调查内存使用量随时间累积的应用程序中的问题。我将其缩小到复制astd::vector>>>>>在工作线程中(我意识到这是一种组织内存的荒谬方式)。定期地,工作线程被销毁、重新创建,并且该线程在启动时复制该内存结构。复制的原始数据通过引用从主线程传递到工作线程。使用malloc_stat和malloc_info,我可以看到当工作线程被销毁时,它正在使用的arena/heap在它的fastbins空闲列表中保留了用于该结构的内存。这是有道理的,因为有许多小于64字节的单独分配。问题是,当工作线程被重新创建时,它会创建一个新的arena/heap而不是重复使用

c++ - MVAPICH 在 MPI_Send 上挂起大于急切阈值的消息

在c++/mpi(mvapich)中有一个简单的程序,发送一个float类型的数组。当我使用MPI_Send、MPI_Ssend、MPI_Rsend时,如果数据的大小超过急切阈值(在我的程序中为64k),则在调用MPI_Send期间我的程序挂起。如果数组小于阈值,程序运行正常。源代码如下:#include"mpi.h"#include#includeintmain(intargc,char*argv[]){intmype=0,size=1;MPI_Init(&argc,&argv);MPI_Comm_rank(MPI_COMM_WORLD,&mype);MPI_Comm_size(MP

C++ 原子 : would function call act as memory barrier?

我正在阅读这篇文章MemoryOrderingatCompileTime从中说:Infact,themajorityoffunctioncallsactascompilerbarriers,whethertheycontaintheirowncompilerbarrierornot.Thisexcludesinlinefunctions,functionsdeclaredwiththepureattribute,andcaseswherelink-timecodegenerationisused.Otherthanthosecases,acalltoanexternalfunction

c++ - memory_order_seq_cst 如何与非原子操作同步?

如果使用单个原子变量和std::memory_order_seq_cst,是否保证非原子操作不会被重新排序?例如,如果我有std::atomicquux={false};voidfoo(){bar();quux.store(true,std::memory_order_seq_cst);moo();}是bar()保证在调用store之后不会重新排序,并且moo()在调用之前不会重新排序store,只要我使用std::memory_order_seq_cst,至少从另一个线程的角度来看?或者,换句话说,如果从另一个线程运行,以下假设是否有效?if(quux.load(std::memor

c++ - ZMQ : Sending custom CPP object over the ZMQ queue

我有一个名为GenericMessage的类,显示在下面的第一个代码片段中(在GenericMessage.hxx中定义)。我有一个名为TestFE.cpp的.cpp文件(参见下面的第二个代码片段),它试图通过ZMQ队列发送类GenericMessage的实例(另请参见下面的第四个代码片段-ZmqHandler.hxx)。TesfFE.cpp通过包含ZmqHandler.hxx在此处实现ZMQ推送模式。我还有另一个名为TestBE.cpp的.cpp文件(请参阅下面的第三个代码片段),它通过ZMQ队列接收上述GenericMessage实例。TestBE.cpp在此处实现ZMQ拉模式以通