Socket File Transfer

[javad_2005]

Server Socket ^s.... FileStream ^fs.. array^data=gcnew array(4096); int len; do { len=fs->Read(data,0,4096); s->Send(data,0,len); } file Send but don't Complete i think socket send byte with Speed and data Replace with data!

[led mike]

javad_2005 wrote:

file Send but don't Complete

Send to what? Don't Complete means what?

javad_2005 wrote:

i think socket send byte with Speed and data Replace with data!

I have no idea what that means but it sounds like something I would not believe.

led mike

[Mark Salsbery]

None of the Socket::Send() overloads matches your code.  Which one are you using? What type of array is data? Where's the loop logic code? Is the socket blocking or non blocking? You don't check the number of bytes sent?  What if they all don't get sent in one Send() call? Mark

Mark Salsbery Microsoft MVP - Visual C++ :java:

[led mike]

We are like a double decker Filet-o-Fish in this thread. Do they make one of those?

led mike

[javad_2005]

Server Code: enum Command { NULL, Message, CreateFile, WriteFile, Close }; Object ^ RawDeserialize(array<Byte> ^rawdatas, Type ^anytype ) { int rawsize = Marshal::SizeOf(anytype ); if( rawsize > rawdatas->Length ) return nullptr; IntPtr buffer = Marshal::AllocHGlobal( rawsize ); Marshal::Copy( rawdatas, 0, buffer, rawsize ); Object ^retobj = Marshal::PtrToStructure( buffer, anytype ); Marshal::FreeHGlobal( buffer ); return retobj; } ////////////////////////// [StructLayout(LayoutKind::Sequential, Pack=1, CharSet=CharSet::Ansi)] ref struct TcpPacket { [MarshalAs(UnmanagedType::ByValArray,ArraySubType=UnmanagedType::LPWStr,SizeConst=4096)] array<Byte>^data; //////////Packet Buffer Command cmd; /////Command int Length; /////////Data Length public: TcpPacket() { cmd=Command::NULL; data=gcnew array<Byte>(4096); } }; /////////// ref struct ClientInfo { Socket ^socket; array<Byte> ^Buffer; }; /////////// private: System::Void button1_Click(System::Object^ sender, System::EventArgs^ e) { Socket ^TcpSocket=gcnew Socket(AddressFamily::InterNetwork,SocketType::Stream,ProtocolType::Tcp); IPEndPoint ^ipEndPoint=gcnew IPEndPoint(IPAddress::Any,5400); TcpSocket->Bind(ipEndPoint); TcpSocket->Listen(0); ///////////////// TcpSocket->BeginAccept(gcnew AsyncCallback(this,&Form1::OnAccept),TcpSocket); } void OnAccept(IAsyncResult ^ar) { ClientInfo ^info=gcnew ClientInfo; Socket ^socket=safe_cast<Socket ^>(ar->AsyncState); Socket ^SockAccept=socket->EndAccept(ar); TcpPacket ^Packet=gcnew TcpPacket; ////New Packet For Get Packet Size int PSize=Marshal::SizeOf(Packet);/////////Get Packet Size info->socket=SockAccept; info->Buffer=gcnew array<Byte>(PSize); SockAccept->BeginReceive(info->Buffer,0,PSize,SocketFlags::None,gcnew AsyncCallback(this,&Form1::OnReceive),info); } void OnReceive(IAsyncResult ^ar) { ClientInfo ^info=safe_cast<ClientInfo ^>(ar->AsyncState); info->socket->EndReceive(ar); ///Deserialize Buffer TcpPacket ^Packet=gcnew TcpPacket; Type ^typeTcpPacket=Type::GetType(String::Format("{0}",Packet)); Packet=(TcpPacket ^)RawDeserialize( info->Buffer,typeTcpPacket); /////////////////////////// ReleasePacket(Packet); int PSize=Marshal::SizeOf(Packet); info->