![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to putnode.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / src / sbbs3|
Return to putnode.cpp CVS log | Up to [Synchronet] / sbbs / src / sbbs3 |
1.1 root 1: /* putnode.cpp */
2:
3: /* Synchronet node information writing routines */
4:
1.1.1.2 ! root 5: /* $Id: putnode.cpp,v 1.18 2009/11/09 02:54:55 rswindell Exp $ */
1.1 root 6:
7: /****************************************************************************
8: * @format.tab-size 4 (Plain Text/Source Code File Header) *
9: * @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
10: * *
1.1.1.2 ! root 11: * Copyright 2009 Rob Swindell - http://www.synchro.net/copyright.html *
1.1 root 12: * *
13: * This program is free software; you can redistribute it and/or *
14: * modify it under the terms of the GNU General Public License *
15: * as published by the Free Software Foundation; either version 2 *
16: * of the License, or (at your option) any later version. *
17: * See the GNU General Public License for more details: gpl.txt or *
18: * http://www.fsf.org/copyleft/gpl.html *
19: * *
20: * Anonymous FTP access to the most recent released source is available at *
21: * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
22: * *
23: * Anonymous CVS access to the development source and modification history *
24: * is available at cvs.synchro.net:/cvsroot/sbbs, example: *
25: * cvs -d :pserver:[email protected]:/cvsroot/sbbs login *
26: * (just hit return, no password is necessary) *
27: * cvs -d :pserver:[email protected]:/cvsroot/sbbs checkout src *
28: * *
29: * For Synchronet coding style and modification guidelines, see *
30: * http://www.synchro.net/source.html *
31: * *
32: * You are encouraged to submit any modifications (preferably in Unix diff *
33: * format) via e-mail to [email protected] *
34: * *
35: * Note: If this box doesn't appear square, then you need to fix your tabs. *
36: ****************************************************************************/
37:
38: #include "sbbs.h"
39:
40: /****************************************************************************/
41: /* Write the data from the structure 'node' into node.dab */
42: /* getnodedat(num,&node,1); must have been called before calling this func */
43: /* NOTE: ------^ the indicates the node record has been locked */
44: /****************************************************************************/
45: int sbbs_t::putnodedat(uint number, node_t* node)
46: {
47: char str[256],firston[25];
48: char path[MAX_PATH+1];
49: int wr=0;
50: int wrerr=0;
51: int attempts;
52:
53: if(!number)
54: return(-1);
55:
56: if(number>cfg.sys_nodes) {
57: errormsg(WHERE,ERR_CHK,"node number",number);
58: return(-1);
59: }
60: if(number==cfg.node_num) {
61: if((node->status==NODE_INUSE || node->status==NODE_QUIET)
62: && node->action<NODE_LAST_ACTION
63: && text[NodeActionMain+node->action][0]) {
64: node->misc|=NODE_EXT;
65: memset(str,0,128);
66: sprintf(str,text[NodeActionMain+node->action]
67: ,useron.alias
68: ,useron.level
69: ,getage(&cfg,useron.birth)
70: ,useron.sex
71: ,useron.comp
72: ,useron.note
73: ,unixtodstr(&cfg,useron.firston,firston)
74: ,node->aux&0xff
75: ,node->connection
76: );
77: putnodeext(number,str);
78: }
79: else
80: node->misc&=~NODE_EXT;
81: }
82:
83: sprintf(path,"%snode.dab",cfg.ctrl_dir);
84: if(nodefile==-1) {
85: if((nodefile=nopen(path,O_CREAT|O_RDWR|O_DENYNONE))==-1) {
86: errormsg(WHERE,ERR_OPEN,path,O_CREAT|O_RDWR|O_DENYNONE);
87: return(errno);
88: }
89: }
90:
91: number--; /* make zero based */
92: lock(nodefile,(long)number*sizeof(node_t),sizeof(node_t));
93: for(attempts=0;attempts<10;attempts++) {
94: lseek(nodefile,(long)number*sizeof(node_t),SEEK_SET);
95: wr=write(nodefile,node,sizeof(node_t));
96: if(wr==sizeof(node_t))
97: break;
98: wrerr=errno; /* save write error */
99: mswait(100);
100: }
101: unlock(nodefile,(long)number*sizeof(node_t),sizeof(node_t));
102: if(cfg.node_misc&NM_CLOSENODEDAB) {
103: close(nodefile);
104: nodefile=-1;
105: }
106:
107: if(wr!=sizeof(node_t)) {
108: errno=wrerr;
109: errormsg(WHERE,ERR_WRITE,"nodefile",number+1);
110: return(errno);
111: }
112:
113: utime(path,NULL); /* Update mod time for NFS/smbfs compatibility */
114:
115: return(0);
116: }
117:
118: int sbbs_t::putnodeext(uint number, char *ext)
119: {
120: char str[MAX_PATH+1];
121: int count;
122: int wr;
123:
124: if(!number || number>cfg.sys_nodes) {
125: errormsg(WHERE,ERR_CHK,"node number",number);
126: return(-1);
127: }
128: number--; /* make zero based */
129:
130: sprintf(str,"%snode.exb",cfg.ctrl_dir);
131: if((node_ext=nopen(str,O_CREAT|O_RDWR|O_DENYNONE))==-1) {
132: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_RDWR|O_DENYNONE);
133: return(errno);
134: }
135: for(count=0;count<LOOP_NODEDAB;count++) {
136: if(count)
137: mswait(100);
138: lseek(node_ext,(long)number*128L,SEEK_SET);
139: if(lock(node_ext,(long)number*128L,128)==-1)
140: continue;
141: wr=write(node_ext,ext,128);
142: unlock(node_ext,(long)number*128L,128);
143: if(wr==128)
144: break;
145: }
146: close(node_ext);
147: node_ext=-1;
148:
149: if(count>(LOOP_NODEDAB/2) && count!=LOOP_NODEDAB) {
150: sprintf(str,"NODE.EXB (node %d) COLLISION - Count: %d"
151: ,number+1, count);
1.1.1.2 ! root 152: logline(LOG_NOTICE,"!!",str);
1.1 root 153: }
154: if(count==LOOP_NODEDAB) {
155: errormsg(WHERE,ERR_WRITE,"NODE.EXB",number+1);
156: return(-2);
157: }
158:
159: return(0);
160: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.