![[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 / sbbs3|
Return to putnode.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 root 1: /* putnode.cpp */
2:
3: /* Synchronet node information writing routines */
4:
5: /* $Id: putnode.cpp,v 1.4 2000/11/14 01:24:21 rswindell Exp $ */
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: * *
11: * Copyright 2000 Rob Swindell - http://www.synchro.net/copyright.html *
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: void sbbs_t::putnodedat(uint number, node_t* node)
46: {
47: char str[256],firston[25];
48:
49: if(!number || number>cfg.sys_nodes) {
50: errormsg(WHERE,ERR_CHK,"node number",number);
51: return; }
52: if(number==cfg.node_num) {
53: if((node->status==NODE_INUSE || node->status==NODE_QUIET)
54: && node->action<NODE_LAST_ACTION
55: && text[NodeActionMain+node->action][0]) {
56: node->misc|=NODE_EXT;
57: memset(str,0,128);
58: sprintf(str,text[NodeActionMain+node->action]
59: ,useron.alias
60: ,useron.level
61: ,getage(&cfg,useron.birth)
62: ,useron.sex
63: ,useron.comp
64: ,useron.note
65: ,unixtodstr(&cfg,useron.firston,firston)
66: ,node->aux&0xff
67: ,node->connection
68: );
69: putnodeext(number,str); }
70: else
71: node->misc&=~NODE_EXT; }
72:
73: if(nodefile==-1) {
74: sprintf(str,"%snode.dab",cfg.ctrl_dir);
75: if((nodefile=nopen(str,O_CREAT|O_RDWR|O_DENYNONE))==-1) {
76: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_RDWR|O_DENYNONE);
77: return;
78: }
79: }
80:
81: number--; /* make zero based */
82: lseek(nodefile,(long)number*sizeof(node_t),SEEK_SET);
83: if(write(nodefile,node,sizeof(node_t))!=sizeof(node_t)) {
84: unlock(nodefile,(long)number*sizeof(node_t),sizeof(node_t));
85: errormsg(WHERE,ERR_WRITE,"nodefile",number+1);
86: return;
87: }
88: unlock(nodefile,(long)number*sizeof(node_t),sizeof(node_t));
89: close(nodefile);
90: nodefile=-1;
91: }
92:
93: /****************************************************************************/
94: /* Creates a short message for node 'num' than contains 'strin' */
95: /****************************************************************************/
96: void sbbs_t::putnmsg(int num, char *strin)
97: {
98: char str[256];
99: int file,i;
100: node_t node;
101:
102: sprintf(str,"%smsgs/n%3.3u.msg",cfg.data_dir,num);
103: if((file=nopen(str,O_WRONLY|O_CREAT))==-1) {
104: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT);
105: return; }
106: lseek(file,0L,SEEK_END); // Instead of opening with O_APPEND
107: i=strlen(strin);
108: if(write(file,strin,i)!=i) {
109: close(file);
110: errormsg(WHERE,ERR_WRITE,str,i);
111: return; }
112: close(file);
113: getnodedat(num,&node,0);
114: if((node.status==NODE_INUSE || node.status==NODE_QUIET)
115: && !(node.misc&NODE_NMSG)) {
116: getnodedat(num,&node,1);
117: node.misc|=NODE_NMSG;
118: putnodedat(num,&node); }
119: }
120:
121: void sbbs_t::putnodeext(uint number, char *ext)
122: {
123: char str[256];
124: int count=0;
125:
126: if(!number || number>cfg.sys_nodes) {
127: errormsg(WHERE,ERR_CHK,"node number",number);
128: return; }
129: number--; /* make zero based */
130:
131: sprintf(str,"%snode.exb",cfg.ctrl_dir);
132: if((node_ext=nopen(str,O_CREAT|O_RDWR|O_DENYNONE))==-1) {
133: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_RDWR|O_DENYNONE);
134: return;
135: }
136: while(count<LOOP_NODEDAB) {
137: if(count>10)
138: mswait(55);
139: lseek(node_ext,(long)number*128L,SEEK_SET);
140: if(lock(node_ext,(long)number*128L,128)==-1) {
141: count++;
142: continue; }
143: if(write(node_ext,ext,128)==128)
144: break;
145: count++; }
146: unlock(node_ext,(long)number*128L,128);
147: close(node_ext);
148: node_ext=-1;
149:
150: if(count>(LOOP_NODEDAB/2) && count!=LOOP_NODEDAB) {
151: sprintf(str,"NODE.EXB COLLISION - Count: %d",count);
152: logline("!!",str);
153: }
154: if(count==LOOP_NODEDAB) {
155: errormsg(WHERE,ERR_WRITE,"NODE.EXB",number+1);
156: return;
157: }
158: }
159:
160:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.