ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/socket/loop.C
(Generate patch)

Comparing deliantra/server/socket/loop.C (file contents):
Revision 1.1 by elmex, Sun Aug 13 17:16:06 2006 UTC vs.
Revision 1.3 by root, Tue Aug 29 08:01:38 2006 UTC

1 1
2/* 2/*
3 * static char *rcsid_loop_c = 3 * static char *rcsid_loop_c =
4 * "$Id: loop.C,v 1.1 2006/08/13 17:16:06 elmex Exp $"; 4 * "$Id: loop.C,v 1.3 2006/08/29 08:01:38 root Exp $";
5 */ 5 */
6 6
7/* 7/*
8 CrossFire, A Multiplayer game for X-windows 8 CrossFire, A Multiplayer game for X-windows
9 9
… …
156 156
157 /* find the first space, make it null, and update the 157 /* find the first space, make it null, and update the
158 * params pointer. 158 * params pointer.
159 */ 159 */
160 for (cp = buf; *cp != '\0'; cp++) 160 for (cp = buf; *cp != '\0'; cp++)
161 if (*cp==' ') { 161 if (*cp==' ') {
162 *cp = '\0'; 162 *cp = '\0';
163 params = cp + 1; 163 params = cp + 1;
164 break; 164 break;
165 } 165 }
166 if (!strcmp(buf, "image_info")) send_image_info(ns, params); 166 if (!strcmp(buf, "image_info")) send_image_info(ns, params);
167 else if (!strcmp(buf,"image_sums")) send_image_sums(ns, params); 167 else if (!strcmp(buf,"image_sums")) send_image_sums(ns, params);
168 else if (!strcmp(buf,"skill_info")) send_skill_info(ns, params); 168 else if (!strcmp(buf,"skill_info")) send_skill_info(ns, params);
169 else if (!strcmp(buf,"spell_paths")) send_spell_paths(ns, params); 169 else if (!strcmp(buf,"spell_paths")) send_spell_paths(ns, params);
170 else Write_String_To_Socket(ns, bigbuf, len); 170 else Write_String_To_Socket(ns, bigbuf, len);
… …
185 * we basically read a byte at a time until we get a newline, error, 185 * we basically read a byte at a time until we get a newline, error,
186 * or no more characters to read. 186 * or no more characters to read.
187 */ 187 */
188 do { 188 do {
189 /* hack to disable old socket mode without creating too many conflicts */ 189 /* hack to disable old socket mode without creating too many conflicts */
190 if (1 || ns->inbuf.len >= MAXSOCKBUF-1) { 190 if (1 || ns->inbuf.len >= MAXSOCKBUF-1) {
191 ns->status = Ns_Dead; 191 ns->status = Ns_Dead;
192 LOG(llevDebug, "Old input socket sent too much data without newline\n"); 192 LOG(llevDebug, "Old input socket sent too much data without newline\n");
193 return; 193 return;
194 } 194 }
195#ifdef WIN32 /* ***win32: change oldsocket read() to recv() */ 195#ifdef WIN32 /* ***win32: change oldsocket read() to recv() */
196 stat = recv(ns->fd, ns->inbuf.buf + ns->inbuf.len, 1,0); 196 stat = recv(ns->fd, ns->inbuf.buf + ns->inbuf.len, 1,0);
197 197
198 if (stat==-1 && WSAGetLastError() !=WSAEWOULDBLOCK) { 198 if (stat==-1 && WSAGetLastError() !=WSAEWOULDBLOCK) {
199#else 199#else
200 do { 200 do {
201 stat = read(ns->fd, ns->inbuf.buf + ns->inbuf.len, 1); 201 stat = read(ns->fd, ns->inbuf.buf + ns->inbuf.len, 1);
202 } while ((stat<0) && (errno == EINTR)); 202 } while ((stat<0) && (errno == EINTR));
203 203
204 if (stat<0 && errno != EAGAIN && errno !=EWOULDBLOCK) { 204 if (stat<0 && errno != EAGAIN && errno !=EWOULDBLOCK) {
205#endif 205#endif
206 LOG(llevError, "Cannot read from socket: %s\n", strerror_local(errno)); 206 LOG(llevError, "Cannot read from socket: %s\n", strerror_local(errno));
207 ns->status = Ns_Dead; 207 ns->status = Ns_Dead;
208 return; 208 return;
209 } 209 }
210 if (stat == 0) return; 210 if (stat == 0) return;
211 } while (ns->inbuf.buf[ns->inbuf.len++]!='\n'); 211 } while (ns->inbuf.buf[ns->inbuf.len++]!='\n');
212 212
213 ns->inbuf.buf[ns->inbuf.len]=0; 213 ns->inbuf.buf[ns->inbuf.len]=0;
214 214
215 cp = strchr((const char*)ns->inbuf.buf, ' '); 215 cp = strchr((const char*)ns->inbuf.buf, ' ');
216 if (cp) { 216 if (cp) {
217 /* Replace the space with a null, skip any more spaces */ 217 /* Replace the space with a null, skip any more spaces */
218 *cp++=0; 218 *cp++=0;
219 while (isspace(*cp)) cp++; 219 while (isspace(*cp)) cp++;
220 } 220 }
221 221
222 /* Strip off all spaces and control characters from end of line */ 222 /* Strip off all spaces and control characters from end of line */
223 for (i=ns->inbuf.len-1; i>=0; i--) { 223 for (i=ns->inbuf.len-1; i>=0; i--) {
224 if (ns->inbuf.buf[i]<=32) ns->inbuf.buf[i]=0; 224 if (ns->inbuf.buf[i]<=32) ns->inbuf.buf[i]=0;
225 else break; 225 else break;
226 } 226 }
227 ns->inbuf.len=0; /* reset for next read */ 227 ns->inbuf.len=0; /* reset for next read */
228 228
229 /* If just a return, don't do anything */ 229 /* If just a return, don't do anything */
230 if (ns->inbuf.buf[0] == 0) return; 230 if (ns->inbuf.buf[0] == 0) return;
231 if (!strcasecmp((const char*)ns->inbuf.buf,"quit")) { 231 if (!strcasecmp((const char*)ns->inbuf.buf,"quit")) {
232 ns->status = Ns_Dead; 232 ns->status = Ns_Dead;
233 return; 233 return;
234 } 234 }
235 if (!strcasecmp((const char*)ns->inbuf.buf, "listen")) { 235 if (!strcasecmp((const char*)ns->inbuf.buf, "listen")) {
236 if (cp) { 236 if (cp) {
237 char *buf="Socket switched to listen mode\n"; 237 char *buf="Socket switched to listen mode\n";
238 238
239 free(ns->comment); 239 free(ns->comment);
240 ns->comment = strdup_local(cp); 240 ns->comment = strdup_local(cp);
241 ns->old_mode = Old_Listen; 241 ns->old_mode = Old_Listen;
242 cs_write_string(ns, buf, strlen(buf)); 242 cs_write_string(ns, buf, strlen(buf));
243 } else { 243 } else {
244 char *buf="Need to supply a comment/url to listen\n"; 244 char *buf="Need to supply a comment/url to listen\n";
245 cs_write_string(ns, buf, strlen(buf)); 245 cs_write_string(ns, buf, strlen(buf));
246 } 246 }
247 return; 247 return;
248 } 248 }
249 if (!strcasecmp((const char*)ns->inbuf.buf, "name")) { 249 if (!strcasecmp((const char*)ns->inbuf.buf, "name")) {
250 char *cp1=NULL; 250 char *cp1=NULL;
251 if (cp) cp1= strchr(cp, ' '); 251 if (cp) cp1= strchr(cp, ' ');
252 if (cp1) { 252 if (cp1) {
253 *cp1++ = 0; 253 *cp1++ = 0;
254 while (isspace(*cp1)) cp1++; 254 while (isspace(*cp1)) cp1++;
255 } 255 }
256 if (!cp || !cp1) { 256 if (!cp || !cp1) {
257 char *buf="Need to provide a name/password to name\n"; 257 char *buf="Need to provide a name/password to name\n";
258 cs_write_string(ns, buf, strlen(buf)); 258 cs_write_string(ns, buf, strlen(buf));
259 return; 259 return;
260 } 260 }
261 261
262 if (verify_player(cp, cp1)==0) { 262 if (verify_player(cp, cp1)==0) {
263 char *buf="Welcome back\n"; 263 char *buf="Welcome back\n";
264 free(ns->comment); 264 free(ns->comment);
265 ns->comment = strdup_local(cp); 265 ns->comment = strdup_local(cp);
266 ns->old_mode = Old_Player; 266 ns->old_mode = Old_Player;
267 cs_write_string(ns, buf, strlen(buf)); 267 cs_write_string(ns, buf, strlen(buf));
268 } 268 }
269 else if (verify_player(cp, cp1)==2) { 269 else if (verify_player(cp, cp1)==2) {
270 ns->password_fails++; 270 ns->password_fails++;
271 if (ns->password_fails >= MAX_PASSWORD_FAILURES) { 271 if (ns->password_fails >= MAX_PASSWORD_FAILURES) {
272 char *buf="You failed to log in too many times, you will now be kicked.\n"; 272 char *buf="You failed to log in too many times, you will now be kicked.\n";
273 LOG(llevInfo, "A player connecting from %s in oldsocketmode has been dropped for password failure\n", 273 LOG(llevInfo, "A player connecting from %s in oldsocketmode has been dropped for password failure\n",
274 ns->host); 274 ns->host);
275 cs_write_string(ns, buf, strlen(buf)); 275 cs_write_string(ns, buf, strlen(buf));
276 ns->status = Ns_Dead; 276 ns->status = Ns_Dead;
277 } 277 }
278 else { 278 else {
279 char *buf="Could not login you in. Check your name and password.\n"; 279 char *buf="Could not login you in. Check your name and password.\n";
280 cs_write_string(ns, buf, strlen(buf)); 280 cs_write_string(ns, buf, strlen(buf));
281 } 281 }
282 } 282 }
283 else { 283 else {
284 char *buf="Could not login you in. Check your name and password.\n"; 284 char *buf="Could not login you in. Check your name and password.\n";
285 cs_write_string(ns, buf, strlen(buf)); 285 cs_write_string(ns, buf, strlen(buf));
286 } 286 }
287 return; 287 return;
288 } 288 }
289 289
290 command = find_oldsocket_command((char*)ns->inbuf.buf); 290 command = find_oldsocket_command((char*)ns->inbuf.buf);
291 if (!command && ns->old_mode==Old_Player) { 291 if (!command && ns->old_mode==Old_Player) {
292 command = find_oldsocket_command2((char*)ns->inbuf.buf); 292 command = find_oldsocket_command2((char*)ns->inbuf.buf);
293 } 293 }
294 if (!command) { 294 if (!command) {
295 snprintf(buf, sizeof(buf), "Could not find command: %s\n", ns->inbuf.buf); 295 snprintf(buf, sizeof(buf), "Could not find command: %s\n", ns->inbuf.buf);
296 cs_write_string(ns, buf, strlen(buf)); 296 cs_write_string(ns, buf, strlen(buf));
297 return; 297 return;
298 } 298 }
299 299
300 /* This is a bit of a hack, but works. Basically, we make some 300 /* This is a bit of a hack, but works. Basically, we make some
301 * fake object and player pointers and give at it. 301 * fake object and player pointers and give at it.
302 * This works as long as the functions we are calling don't need 302 * This works as long as the functions we are calling don't need
… …
331 char *data; 331 char *data;
332 332
333 /* Loop through this - maybe we have several complete packets here. */ 333 /* Loop through this - maybe we have several complete packets here. */
334 // limit to a few commands only, though, as to not monopolise the server 334 // limit to a few commands only, though, as to not monopolise the server
335 for (cnt = 16; cnt--; ) { 335 for (cnt = 16; cnt--; ) {
336 /* If it is a player, and they don't have any speed left, we 336 /* If it is a player, and they don't have any speed left, we
337 * return, and will read in the data when they do have time. 337 * return, and will read in the data when they do have time.
338 */ 338 */
339 if (pl && pl->state==ST_PLAYING && pl->ob != NULL && pl->ob->speed_left < 0) { 339 if (pl && pl->state==ST_PLAYING && pl->ob != NULL && pl->ob->speed_left < 0) {
340 return; 340 return;
341 } 341 }
342 342
343 if (ns->status == Ns_Old) { 343 if (ns->status == Ns_Old) {
344 Handle_Oldsocket(ns); 344 Handle_Oldsocket(ns);
345 return; 345 return;
346 } 346 }
347 i=SockList_ReadPacket(ns->fd, &ns->inbuf, MAXSOCKBUF-1); 347 i=SockList_ReadPacket(ns->fd, &ns->inbuf, MAXSOCKBUF-1);
348 /* Special hack - let the user switch to old mode if in the Ns_Add 348 /* Special hack - let the user switch to old mode if in the Ns_Add
349 * phase. Don't demand they add in the special length bytes 349 * phase. Don't demand they add in the special length bytes
350 */ 350 */
351 if (ns->status == Ns_Add) { 351 if (ns->status == Ns_Add) {
352 if (!strncasecmp((const char*)ns->inbuf.buf,"oldsocketmode", 13)) { 352 if (!strncasecmp((const char*)ns->inbuf.buf,"oldsocketmode", 13)) {
353 ns->status = Ns_Old; 353 ns->status = Ns_Old;
354 ns->inbuf.len=0; 354 ns->inbuf.len=0;
355 cs_write_string(ns, "Switched to old socket mode\n", 28); 355 cs_write_string(ns, "Switched to old socket mode\n", 28);
356 LOG(llevDebug,"Switched socket to old socket mode\n"); 356 LOG(llevDebug,"Switched socket to old socket mode\n");
357 return; 357 return;
358 } 358 }
359 } 359 }
360 360
361 if (i<0) { 361 if (i<0) {
362#ifdef ESRV_DEBUG 362#ifdef ESRV_DEBUG
363 LOG(llevDebug,"HandleClient: Read error on connection player %s\n", (pl?pl->ob->name:"None")); 363 LOG(llevDebug,"HandleClient: Read error on connection player %s\n", (pl?pl->ob->name:"None"));
364#endif 364#endif
365 /* Caller will take care of cleaning this up */ 365 /* Caller will take care of cleaning this up */
366 ns->status =Ns_Dead; 366 ns->status =Ns_Dead;
367 return; 367 return;
368 } 368 }
369 /* Still dont have a full packet */ 369 /* Still dont have a full packet */
370 if (i==0) return; 370 if (i==0) return;
371 371
372// //D//TODO//temporarily log long commands 372// //D//TODO//temporarily log long commands
373// if (ns->inbuf.len >= 40 && pl && pl->ob) 373// if (ns->inbuf.len >= 40 && pl && pl->ob)
374// LOG (llevDebug, "HandleClient: long comamnd from <%s,%s> %d<%s>\n", pl->ob->name, ns->host, ns->inbuf.len, ns->inbuf.buf + 2); 374// LOG (llevDebug, "HandleClient: long comamnd from <%s,%s> %d<%s>\n", pl->ob->name, ns->host, ns->inbuf.len, ns->inbuf.buf + 2);
375 375
376 /* First, break out beginning word. There are at least 376 /* First, break out beginning word. There are at least
377 * a few commands that do not have any paremeters. If 377 * a few commands that do not have any paremeters. If
378 * we get such a command, don't worry about trying 378 * we get such a command, don't worry about trying
379 * to break it up. 379 * to break it up.
380 */ 380 */
381 data = (char *)strchr((char*)ns->inbuf.buf +2, ' '); 381 data = (char *)strchr((char*)ns->inbuf.buf +2, ' ');
382 if (data) { 382 if (data) {
383 *data='\0'; 383 *data='\0';
384 data++; 384 data++;
385 len = ns->inbuf.len - (data - (char*)ns->inbuf.buf); 385 len = ns->inbuf.len - (data - (char*)ns->inbuf.buf);
386 } 386 }
387 else len=0; 387 else len=0;
388 388
389 ns->inbuf.buf[ns->inbuf.len]='\0'; /* Terminate buffer - useful for string data */ 389 ns->inbuf.buf[ns->inbuf.len]='\0'; /* Terminate buffer - useful for string data */
390 for (i=0; nscommands[i].cmdname !=NULL; i++) { 390 for (i=0; nscommands[i].cmdname !=NULL; i++) {
391 if (strcmp((char*)ns->inbuf.buf+2,nscommands[i].cmdname)==0) { 391 if (strcmp((char*)ns->inbuf.buf+2,nscommands[i].cmdname)==0) {
392 nscommands[i].cmdproc((char*)data,len,ns); 392 nscommands[i].cmdproc((char*)data,len,ns);
393 ns->inbuf.len=0; 393 ns->inbuf.len=0;
394 return;//D// not doing this causes random memory corruption 394 return;//D// not doing this causes random memory corruption
395 goto next_packet; 395 goto next_packet;
396 } 396 }
397 } 397 }
398 /* Player must be in the playing state or the flag on the 398 /* Player must be in the playing state or the flag on the
399 * the command must be zero for the user to use the command - 399 * the command must be zero for the user to use the command -
400 * otherwise, a player cam save, be in the play_again state, and 400 * otherwise, a player cam save, be in the play_again state, and
401 * the map they were on gets swapped out, yet things that try to look 401 * the map they were on gets swapped out, yet things that try to look
402 * at the map causes a crash. If the command is valid, but 402 * at the map causes a crash. If the command is valid, but
403 * one they can't use, we still swallow it up. 403 * one they can't use, we still swallow it up.
404 */ 404 */
405 if (pl) for (i=0; plcommands[i].cmdname !=NULL; i++) { 405 if (pl) for (i=0; plcommands[i].cmdname !=NULL; i++) {
406 if (strcmp((char*)ns->inbuf.buf+2,plcommands[i].cmdname)==0) { 406 if (strcmp((char*)ns->inbuf.buf+2,plcommands[i].cmdname)==0) {
407 if (pl->state == ST_PLAYING || !(plcommands[i].flag & 1)) 407 if (pl->state == ST_PLAYING || !(plcommands[i].flag & 1))
408 plcommands[i].cmdproc((char*)data,len,pl); 408 plcommands[i].cmdproc((char*)data,len,pl);
409 ns->inbuf.len=0; 409 ns->inbuf.len=0;
410 //D// not doing this causes random memory corruption 410 //D// not doing this causes random memory corruption
411 if (plcommands[i].flag & 2) 411 if (plcommands[i].flag & 2)
412 goto next_packet; 412 goto next_packet;
413 return; 413 return;
414 } 414 }
415 } 415 }
416 /* If we get here, we didn't find a valid command. Logging 416 /* If we get here, we didn't find a valid command. Logging
417 * this might be questionable, because a broken client/malicious 417 * this might be questionable, because a broken client/malicious
418 * user could certainly send a whole bunch of invalid commands. 418 * user could certainly send a whole bunch of invalid commands.
419 */ 419 */
420 LOG(llevDebug,"Bad command from client (%s)\n",ns->inbuf.buf+2); 420 LOG(llevDebug,"Bad command from client (%s)\n",ns->inbuf.buf+2);
421 next_packet: 421 next_packet:
422 ; 422 ;
423 } 423 }
424} 424}
425 425
… …
459 } 459 }
460 sendto(fd,(void *)&fd,1,0,(struct sockaddr *)&insock,sizeof(insock)); 460 sendto(fd,(void *)&fd,1,0,(struct sockaddr *)&insock,sizeof(insock));
461} 461}
462#endif 462#endif
463 463
464extern unsigned long todtick;
465
466/** Waits for new connection */
467static void block_until_new_connection(void)
468{
469
470 struct timeval Timeout;
471 fd_set readfs;
472 int cycles;
473
474 LOG(llevInfo, "Waiting for connections...\n");
475
476 cycles=1;
477 do {
478 /* Every minutes is a bit often for updates - especially if nothing is going
479 * on. This slows it down to every 6 minutes.
480 */
481 cycles++;
482 if (cycles%2 == 0)
483 tick_the_clock();
484
485 FD_ZERO(&readfs);
486 FD_SET((uint32)init_sockets[0].fd, &readfs);
487
488 /* If fastclock is set, we need to seriously slow down the updates
489 * to the metaserver as well as watchdog. Do same for flush_old_maps() -
490 * that is time sensitive, so there is no good reason to call it 2000 times
491 * a second.
492 */
493 if (settings.fastclock > 0) {
494#ifdef WATCHDOG
495 if (cycles % 120000 == 0) {
496 watchdog();
497 flush_old_maps();
498 }
499#endif
500 if (cycles == 720000) {
501 metaserver_update();
502 cycles=1;
503 }
504 Timeout.tv_sec=0;
505 Timeout.tv_usec=50;
506 } else {
507 Timeout.tv_sec=60;
508 Timeout.tv_usec=0;
509 if (cycles == 7) {
510 metaserver_update();
511 cycles=1;
512 }
513 flush_old_maps();
514 }
515 }
516 while (select(socket_info.max_filedescriptor, &readfs, NULL, NULL, &Timeout)==0);
517
518 reset_sleep(); /* Or the game would go too fast */
519}
520
521void flush_sockets(void) 464void flush_sockets(void)
522{ 465{
523 player *pl; 466 player *pl;
524 467
525 for (pl = first_player; pl != NULL; pl = pl->next) 468 for (pl = first_player; pl != NULL; pl = pl->next)
… …
542 socklen_t addrlen=sizeof(struct sockaddr); 485 socklen_t addrlen=sizeof(struct sockaddr);
543 player *pl, *next; 486 player *pl, *next;
544 487
545#ifdef CS_LOGSTATS 488#ifdef CS_LOGSTATS
546 if ((time(NULL)-cst_lst.time_start)>=CS_LOGTIME) 489 if ((time(NULL)-cst_lst.time_start)>=CS_LOGTIME)
547 write_cs_stats(); 490 write_cs_stats();
548#endif 491#endif
549 492
550 FD_ZERO(&tmp_read); 493 FD_ZERO(&tmp_read);
551 FD_ZERO(&tmp_write); 494 FD_ZERO(&tmp_write);
552 FD_ZERO(&tmp_exceptions); 495 FD_ZERO(&tmp_exceptions);
553 496
554 for(i=0;i<socket_info.allocated_sockets;i++) { 497 for(i=0;i<socket_info.allocated_sockets;i++) {
555 if (init_sockets[i].status == Ns_Dead) { 498 if (init_sockets[i].status == Ns_Dead) {
556 free_newsocket(&init_sockets[i]); 499 free_newsocket(&init_sockets[i]);
557 init_sockets[i].status = Ns_Avail; 500 init_sockets[i].status = Ns_Avail;
558 socket_info.nconns--; 501 socket_info.nconns--;
559 } else if (init_sockets[i].status != Ns_Avail){ 502 } else if (init_sockets[i].status != Ns_Avail){
560 FD_SET((uint32)init_sockets[i].fd, &tmp_read); 503 FD_SET((uint32)init_sockets[i].fd, &tmp_read);
561 FD_SET((uint32)init_sockets[i].fd, &tmp_write); 504 FD_SET((uint32)init_sockets[i].fd, &tmp_write);
562 FD_SET((uint32)init_sockets[i].fd, &tmp_exceptions); 505 FD_SET((uint32)init_sockets[i].fd, &tmp_exceptions);
563 } 506 }
564 } 507 }
565 508
566 /* Go through the players. Let the loop set the next pl value, 509 /* Go through the players. Let the loop set the next pl value,
567 * since we may remove some 510 * since we may remove some
568 */ 511 */
569 for (pl=first_player; pl!=NULL; ) { 512 for (pl=first_player; pl!=NULL; ) {
570 if (pl->socket.status == Ns_Dead) { 513 if (pl->socket.status == Ns_Dead) {
571 player *npl=pl->next; 514 player *npl=pl->next;
572 515
573 save_player(pl->ob, 0); 516 save_player(pl->ob, 0);
574 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) { 517 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) {
575 terminate_all_pets(pl->ob); 518 terminate_all_pets(pl->ob);
576 remove_ob(pl->ob); 519 remove_ob(pl->ob);
577 } 520 }
578 leave(pl,1); 521 leave(pl,1);
579 final_free_player(pl); 522 final_free_player(pl);
580 pl=npl; 523 pl=npl;
581 } 524 }
582 else { 525 else {
583 FD_SET((uint32)pl->socket.fd, &tmp_read); 526 FD_SET((uint32)pl->socket.fd, &tmp_read);
584 FD_SET((uint32)pl->socket.fd, &tmp_write); 527 FD_SET((uint32)pl->socket.fd, &tmp_write);
585 FD_SET((uint32)pl->socket.fd, &tmp_exceptions); 528 FD_SET((uint32)pl->socket.fd, &tmp_exceptions);
586 pl=pl->next; 529 pl=pl->next;
587 } 530 }
588 } 531 }
589
590#if 0
591 // the event system and plugins require the server ti run at all times.
592 // since its primarily cf.schmorp.de we are interested in, and
593 // that is supposed to run all the time anyway, its globally disabled
594 // until we can use Event.
595 if (socket_info.nconns==1 && first_player==NULL)
596 block_until_new_connection();
597#endif
598 532
599 /* Reset timeout each time, since some OS's will change the values on 533 /* Reset timeout each time, since some OS's will change the values on
600 * the return from select. 534 * the return from select.
601 */ 535 */
602 socket_info.timeout.tv_sec = 0; 536 socket_info.timeout.tv_sec = 0;
603 socket_info.timeout.tv_usec = 0; 537 socket_info.timeout.tv_usec = 0;
604 538
605 pollret= select(socket_info.max_filedescriptor, &tmp_read, &tmp_write, 539 pollret= select(socket_info.max_filedescriptor, &tmp_read, &tmp_write,
606 &tmp_exceptions, &socket_info.timeout); 540 &tmp_exceptions, &socket_info.timeout);
607 541
608 if (pollret==-1) { 542 if (pollret==-1) {
609 LOG(llevError, "select failed: %s\n", strerror_local(errno)); 543 LOG(llevError, "select failed: %s\n", strerror_local(errno));
610 return; 544 return;
611 } 545 }
612 546
613 /* We need to do some of the processing below regardless */ 547 /* We need to do some of the processing below regardless */
614/* if (!pollret) return;*/ 548/* if (!pollret) return;*/
615 549
616 /* Following adds a new connection */ 550 /* Following adds a new connection */
617 if (pollret && FD_ISSET(init_sockets[0].fd, &tmp_read)) { 551 if (pollret && FD_ISSET(init_sockets[0].fd, &tmp_read)) {
618 int newsocknum=0; 552 int newsocknum=0;
619 553
620#ifdef ESRV_DEBUG 554#ifdef ESRV_DEBUG
621 LOG(llevDebug,"doeric_server: New Connection\n"); 555 LOG(llevDebug,"doeric_server: New Connection\n");
622#endif 556#endif
623 /* If this is the case, all sockets currently in used */ 557 /* If this is the case, all sockets currently in used */
624 if (socket_info.allocated_sockets <= socket_info.nconns) { 558 if (socket_info.allocated_sockets <= socket_info.nconns) {
625 init_sockets = (NewSocket *) realloc(init_sockets,sizeof(NewSocket)*(socket_info.nconns+1)); 559 init_sockets = (NewSocket *) realloc(init_sockets,sizeof(NewSocket)*(socket_info.nconns+1));
626 if (!init_sockets) fatal(OUT_OF_MEMORY); 560 if (!init_sockets) fatal(OUT_OF_MEMORY);
627 newsocknum = socket_info.allocated_sockets; 561 newsocknum = socket_info.allocated_sockets;
628 socket_info.allocated_sockets++; 562 socket_info.allocated_sockets++;
629 init_sockets[newsocknum].faces_sent_len = nrofpixmaps; 563 init_sockets[newsocknum].faces_sent_len = nrofpixmaps;
630 init_sockets[newsocknum].faces_sent = (uint8*) malloc(nrofpixmaps*sizeof(*init_sockets[newsocknum].faces_sent)); 564 init_sockets[newsocknum].faces_sent = (uint8*) malloc(nrofpixmaps*sizeof(*init_sockets[newsocknum].faces_sent));
631 if (!init_sockets[newsocknum].faces_sent) fatal(OUT_OF_MEMORY); 565 if (!init_sockets[newsocknum].faces_sent) fatal(OUT_OF_MEMORY);
632 init_sockets[newsocknum].status = Ns_Avail; 566 init_sockets[newsocknum].status = Ns_Avail;
633 } 567 }
634 else { 568 else {
635 int j; 569 int j;
636 570
637 for (j=1; j<socket_info.allocated_sockets; j++) 571 for (j=1; j<socket_info.allocated_sockets; j++)
638 if (init_sockets[j].status == Ns_Avail) { 572 if (init_sockets[j].status == Ns_Avail) {
639 newsocknum=j; 573 newsocknum=j;
640 break; 574 break;
641 } 575 }
642 } 576 }
643 init_sockets[newsocknum].fd=accept(init_sockets[0].fd, (struct sockaddr *)&addr, &addrlen); 577 init_sockets[newsocknum].fd=accept(init_sockets[0].fd, (struct sockaddr *)&addr, &addrlen);
644 if (init_sockets[newsocknum].fd==-1) { 578 if (init_sockets[newsocknum].fd==-1) {
645 LOG(llevError, "accept failed: %s\n", strerror_local(errno)); 579 LOG(llevError, "accept failed: %s\n", strerror_local(errno));
646 } 580 }
647 else { 581 else {
648 char buf[MAX_BUF]; 582 char buf[MAX_BUF];
649 long ip; 583 long ip;
650 NewSocket *ns; 584 NewSocket *ns;
651 585
652 ns = &init_sockets[newsocknum]; 586 ns = &init_sockets[newsocknum];
653 587
654 ip = ntohl(addr.sin_addr.s_addr); 588 ip = ntohl(addr.sin_addr.s_addr);
655 sprintf(buf, "%ld.%ld.%ld.%ld", (ip>>24)&255, (ip>>16)&255, (ip>>8)&255, ip&255); 589 sprintf(buf, "%ld.%ld.%ld.%ld", (ip>>24)&255, (ip>>16)&255, (ip>>8)&255, ip&255);
656 590
657 if (checkbanned(NULL, buf)) { 591 if (checkbanned(NULL, buf)) {
658 LOG(llevInfo, "Banned host tried to connect: [%s]\n", buf); 592 LOG(llevInfo, "Banned host tried to connect: [%s]\n", buf);
659 close(init_sockets[newsocknum].fd); 593 close(init_sockets[newsocknum].fd);
660 init_sockets[newsocknum].fd = -1; 594 init_sockets[newsocknum].fd = -1;
661 } 595 }
662 else { 596 else {
663 InitConnection(ns, buf); 597 InitConnection(ns, buf);
664 socket_info.nconns++; 598 socket_info.nconns++;
665 } 599 }
666 } 600 }
667 } 601 }
668 602
669 /* Check for any exceptions/input on the sockets */ 603 /* Check for any exceptions/input on the sockets */
670 if (pollret) for(i=1;i<socket_info.allocated_sockets;i++) { 604 if (pollret) for(i=1;i<socket_info.allocated_sockets;i++) {
671 if (init_sockets[i].status == Ns_Avail) continue; 605 if (init_sockets[i].status == Ns_Avail) continue;
672 if (FD_ISSET(init_sockets[i].fd,&tmp_exceptions)) { 606 if (FD_ISSET(init_sockets[i].fd,&tmp_exceptions)) {
673 free_newsocket(&init_sockets[i]); 607 free_newsocket(&init_sockets[i]);
674 init_sockets[i].status = Ns_Avail; 608 init_sockets[i].status = Ns_Avail;
675 socket_info.nconns--; 609 socket_info.nconns--;
676 continue; 610 continue;
677 } 611 }
678 if (FD_ISSET(init_sockets[i].fd, &tmp_read)) { 612 if (FD_ISSET(init_sockets[i].fd, &tmp_read)) {
679 HandleClient(&init_sockets[i], NULL); 613 HandleClient(&init_sockets[i], NULL);
680 } 614 }
681 if (FD_ISSET(init_sockets[i].fd, &tmp_write)) { 615 if (FD_ISSET(init_sockets[i].fd, &tmp_write)) {
682 init_sockets[i].can_write=1; 616 init_sockets[i].can_write=1;
683 } 617 }
684 } 618 }
685 619
686 /* This does roughly the same thing, but for the players now */ 620 /* This does roughly the same thing, but for the players now */
687 for (pl=first_player; pl!=NULL; pl=next) { 621 for (pl=first_player; pl!=NULL; pl=next) {
688 622
689 next=pl->next; 623 next=pl->next;
690 if (pl->socket.status==Ns_Dead) continue; 624 if (pl->socket.status==Ns_Dead) continue;
691 625
692 if (FD_ISSET(pl->socket.fd,&tmp_write)) { 626 if (FD_ISSET(pl->socket.fd,&tmp_write)) {
693 if (!pl->socket.can_write) { 627 if (!pl->socket.can_write) {
694#if 0 628#if 0
695 LOG(llevDebug,"Player %s socket now write enabled\n", pl->ob->name); 629 LOG(llevDebug,"Player %s socket now write enabled\n", pl->ob->name);
696#endif 630#endif
697 pl->socket.can_write=1; 631 pl->socket.can_write=1;
698 write_socket_buffer(&pl->socket); 632 write_socket_buffer(&pl->socket);
699 } 633 }
700 /* if we get an error on the write_socket buffer, no reason to 634 /* if we get an error on the write_socket buffer, no reason to
701 * continue on this socket. 635 * continue on this socket.
702 */ 636 */
703 if (pl->socket.status==Ns_Dead) continue; 637 if (pl->socket.status==Ns_Dead) continue;
704 } 638 }
705 else pl->socket.can_write=0; 639 else pl->socket.can_write=0;
706 640
707 if (FD_ISSET(pl->socket.fd,&tmp_exceptions)) { 641 if (FD_ISSET(pl->socket.fd,&tmp_exceptions)) {
708 save_player(pl->ob, 0); 642 save_player(pl->ob, 0);
709 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) { 643 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) {
710 terminate_all_pets(pl->ob); 644 terminate_all_pets(pl->ob);
711 remove_ob(pl->ob); 645 remove_ob(pl->ob);
712 } 646 }
713 leave(pl,1); 647 leave(pl,1);
714 final_free_player(pl); 648 final_free_player(pl);
715 } 649 }
716 else { 650 else {
717 HandleClient(&pl->socket, pl); 651 HandleClient(&pl->socket, pl);
718 /* If the player has left the game, then the socket status 652 /* If the player has left the game, then the socket status
719 * will be set to this be the leave function. We don't 653 * will be set to this be the leave function. We don't
720 * need to call leave again, as it has already been called 654 * need to call leave again, as it has already been called
721 * once. 655 * once.
722 */ 656 */
723 if (pl->socket.status==Ns_Dead) { 657 if (pl->socket.status==Ns_Dead) {
724 save_player(pl->ob, 0); 658 save_player(pl->ob, 0);
725 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) { 659 if(!QUERY_FLAG(pl->ob,FLAG_REMOVED)) {
726 terminate_all_pets(pl->ob); 660 terminate_all_pets(pl->ob);
727 remove_ob(pl->ob); 661 remove_ob(pl->ob);
728 } 662 }
729 leave(pl,1); 663 leave(pl,1);
730 final_free_player(pl); 664 final_free_player(pl);
731 } else { 665 } else {
732 666
733 /* Update the players stats once per tick. More efficient than 667 /* Update the players stats once per tick. More efficient than
734 * sending them whenever they change, and probably just as useful 668 * sending them whenever they change, and probably just as useful
735 */ 669 */
736 esrv_update_stats(pl); 670 esrv_update_stats(pl);
737 if (pl->last_weight != -1 && pl->last_weight != WEIGHT(pl->ob)) { 671 if (pl->last_weight != -1 && pl->last_weight != WEIGHT(pl->ob)) {
738 esrv_update_item(UPD_WEIGHT, pl->ob, pl->ob); 672 esrv_update_item(UPD_WEIGHT, pl->ob, pl->ob);
739 if(pl->last_weight != WEIGHT(pl->ob)) 673 if(pl->last_weight != WEIGHT(pl->ob))
740 LOG(llevError, "esrv_update_item(UPD_WEIGHT) did not set player weight: is %lu, should be %lu\n", (unsigned long)pl->last_weight, WEIGHT(pl->ob)); 674 LOG(llevError, "esrv_update_item(UPD_WEIGHT) did not set player weight: is %lu, should be %lu\n", (unsigned long)pl->last_weight, WEIGHT(pl->ob));
741 } 675 }
742 /* draw_client_map does sanity checking that map is 676 /* draw_client_map does sanity checking that map is
743 * valid, so don't do it here. 677 * valid, so don't do it here.
744 */ 678 */
745 draw_client_map(pl->ob); 679 draw_client_map(pl->ob);
746 if (pl->socket.update_look) esrv_draw_look(pl->ob); 680 if (pl->socket.update_look) esrv_draw_look(pl->ob);
747 } 681 }
748 } 682 }
749 } 683 }
750} 684}

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines