anne/lyx_mirror
1
0
Fork 0
mirror of https://git.lyx.org/repos/lyx.git synced 2024-11-22 10:00:33 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Backout my lyxserver changes

Browse Source 
git-svn-id: svn://svn.lyx.org/lyx/lyx-devel/trunk@6038 a592a061-630c-0410-9148-cb99ea01b6c8
This commit is contained in:
Angus Leeming 2003-02-06 01:18:36 +00:00
parent c6c442f03b
commit 1c72ddd91f
2 changed files with 36 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/ChangeLog
View File

@ -1,3 +1,9 @@
2003-02-05 Angus Leeming <leeming@lyx.org>
* lyxserver.C (read_ready): revert my patch of 11 September last year
as it sends PC cpu through the roof. Presumably this means that
the lyxserver will no longer run on an Alpha...
2003-01-30 Angus Leeming <leeming@lyx.org> 2003-01-30 Angus Leeming <leeming@lyx.org>
* factory.C (createInset): create an InsetCommandParam of type "index" * factory.C (createInset): create an InsetCommandParam of type "index"

52
src/lyxserver.C
View File

@ -272,38 +272,40 @@ void LyXComm::read_ready()
if (status > 0) { if (status > 0) {
charbuf[status] = '\0'; // turn it into a c string charbuf[status] = '\0'; // turn it into a c string
read_buffer_ += rtrim(charbuf, "\r"); read_buffer_ += rtrim(charbuf, "\r");
// commit any commands read
} else if (errno != EAGAIN) { while (read_buffer_.find('\n') != string::npos) {
// split() grabs the entire string if
// the delim /wasn't/ found. ?:-P
string cmd;
read_buffer_= split(read_buffer_, cmd,'\n');
lyxerr[Debug::LYXSERVER]
<< "LyXComm: status:" << status
<< ", read_buffer_:" << read_buffer_
<< ", cmd:" << cmd << endl;
if (!cmd.empty())
clientcb(client, cmd);
//\n or not \n?
}
}
if (errno == EAGAIN) {
errno = 0;
return;
}
if (errno != 0) {
lyxerr << "LyXComm: " << strerror(errno) << endl;
if (!read_buffer_.empty()) { if (!read_buffer_.empty()) {
lyxerr << "LyXComm: truncated command: " lyxerr << "LyXComm: truncated command: "
<< read_buffer_ << '\n' << read_buffer_ << endl;
<< "Resetting connection" << endl;
read_buffer_.erase(); read_buffer_.erase();
} }
break; // reset connection
// reset connection
closeConnection();
openConnection();
break;
} else {
// errno == EAGAIN
// Nothing new has arrived, so now's the time
// to tell the outside world if there's anything
// in the read buffer.
break;
} }
} }
if (!read_buffer_.empty()) { // The connection gets reset in errno != EAGAIN
read_buffer_ = rtrim(read_buffer_, "\n"); // Why does it need to be reset if errno == 0?
lyxerr[Debug::LYXSERVER] closeConnection();
<< "LyXComm: Received from fd " openConnection();
<< infd << '\n'
<< '\"' << read_buffer_ << '\"' << endl;
clientcb(client, read_buffer_);
}
errno = 0; errno = 0;
} }