RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-30 23:40:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

msgr: kill dead code

Browse Source
This commit is contained in:
Sage Weil 2009-10-13 13:08:15 -07:00
parent a0fa5b0f9a
commit d7f9d19d11
1 changed files with 0 additions and 44 deletions

44
src/msg/tcp.cc
View File

@ -7,50 +7,6 @@
* tcp crap
*/
/*
inlined, see tcp.h
bool tcp_read(int sd, char *buf, int len)
{
while (len > 0) {
int got = ::recv( sd, buf, len, 0 );
if (got == 0) {
generic_dout(18) << "tcp_read socket " << sd << " closed" << dendl;
return false;
}
if (got < 0) {
generic_dout(18) << "tcp_read bailing with " << got << dendl;
return false;
}
assert(got >= 0);
len -= got;
buf += got;
//generic_dout(DBL) << "tcp_read got " << got << ", " << len << " left" << dendl;
}
return true;
}
int tcp_write(int sd, char *buf, int len)
{
//generic_dout(DBL) << "tcp_write writing " << len << dendl;
assert(len > 0);
while (len > 0) {
int did = ::send( sd, buf, len, 0 );
if (did < 0) {
generic_dout(1) << "tcp_write error did = " << did << " errno " << errno << " " << strerror(errno) << dendl;
//derr(0) << "tcp_write error did = " << did << " errno " << errno << " " << strerror(errno) << dendl;
}
//assert(did >= 0);
if (did < 0) return did;
len -= did;
buf += did;
//generic_dout(DBL) << "tcp_write did " << did << ", " << len << " left" << dendl;
}
return 0;
}
*/
int tcp_read(int sd, char *buf, int len) {
while (len > 0) {
int got = ::recv( sd, buf, len, 0 );