| /plan9/sys/src/libsunrpc/ |
| H A D | udp.c | 10 SunMsg msg; member 34 SunMsgUdp *msg; in sunUdpRead() local 42 msg = emalloc(sizeof(SunMsgUdp)); in sunUdpRead() 43 memmove(&msg->udp, buf, Udphdrsize); in sunUdpRead() 44 msg->msg.data = emalloc(n); in sunUdpRead() 45 msg->msg.count = n-Udphdrsize; in sunUdpRead() 46 memmove(msg->msg.data, buf+Udphdrsize, n-Udphdrsize); in sunUdpRead() 47 memmove(&msg->udp, buf, Udphdrsize); in sunUdpRead() 48 msg->msg.creply = arg.creply; in sunUdpRead() 50 fprint(2, "message %p count %d\n", msg, msg->msg.count); in sunUdpRead() [all …]
|
| H A D | fd.c | 14 SunMsg msg; member 34 SunMsgFd *msg; in sunFdRead() local 53 msg = emalloc(sizeof(SunMsgFd)); in sunFdRead() 54 msg->msg.data = p; in sunFdRead() 55 msg->msg.count = tot; in sunFdRead() 56 msg->msg.creply = arg.creply; in sunFdRead() 57 sendp(arg.srv->crequest, msg); in sunFdRead() 70 SunMsgFd *msg; in sunFdWrite() local 74 while((msg = recvp(arg.creply)) != nil){ in sunFdWrite() 75 n = msg->msg.count; in sunFdWrite() [all …]
|
| /plan9/sys/src/9/port/ |
| H A D | ucalloc.c | 15 char msg[256]; member 26 char msg[sizeof pv->msg]; in ucpoolpanic() local 30 vseprint(pv->cur, &pv->msg[sizeof pv->msg], fmt, v); in ucpoolpanic() 32 memmove(msg, pv->msg, sizeof msg); in ucpoolpanic() 34 panic("%s", msg); in ucpoolpanic() 45 pv->cur = vseprint(pv->cur, &pv->msg[sizeof pv->msg], fmt, v); in ucpoolprint() 53 char msg[sizeof pv->msg]; in ucpoolunlock() local 56 if(pv->cur == pv->msg){ in ucpoolunlock() 61 memmove(msg, pv->msg, sizeof msg); in ucpoolunlock() 62 pv->cur = pv->msg; in ucpoolunlock() [all …]
|
| H A D | alloc.c | 17 char msg[256]; /* a rock for messages to be printed at unlock */ member 71 vseprint(pv->msg+strlen(pv->msg), pv->msg+sizeof pv->msg, fmt, v); in poolprint() 80 char msg[sizeof pv->msg]; in ppanic() local 84 vseprint(pv->msg+strlen(pv->msg), pv->msg+sizeof pv->msg, fmt, v); in ppanic() 86 memmove(msg, pv->msg, sizeof msg); in ppanic() 88 panic("%s", msg); in ppanic() 99 pv->msg[0] = 0; in plock() 106 char msg[sizeof pv->msg]; in punlock() local 109 if(pv->msg[0] == 0){ in punlock() 114 memmove(msg, pv->msg, sizeof msg); in punlock() [all …]
|
| /plan9/sys/src/cmd/gs/src/ |
| H A D | bench.c | 78 iadd(int a, int n, char **msg) in iadd() argument 85 *msg = "integer adds"; in iadd() 89 imul(int a, int n, char **msg) in imul() argument 96 *msg = "integer multiplies"; in imul() 100 idiv(int a, int n, char **msg) in idiv() argument 108 *msg = "integer divides"; in idiv() 112 fadd(float a, int n, char **msg) in fadd() argument 120 *msg = "floating adds"; in fadd() 124 fmul(float a, int n, char **msg) in fmul() argument 132 *msg = "floating multiplies"; in fmul() [all …]
|
| /plan9/sys/src/9/boot/ |
| H A D | doauthenticate.c | 29 char *msg; in fromauth() local 47 msg = 0; in fromauth() 50 msg = error; in fromauth() 56 msg = error; in fromauth() 60 msg = error; in fromauth() 64 msg = pbmsg; in fromauth() 69 return msg; in fromauth() 75 char *msg; in doauthenticate() local 90 msg = fromauth(mp, trbuf, tbuf); in doauthenticate() 92 if(msg == 0) in doauthenticate() [all …]
|
| /plan9/sys/src/ape/lib/bsd/ |
| H A D | connect.c | 24 char msg[8+256+1], file[8+256+1]; in connect() local 51 snprintf(msg, sizeof msg, "connect %s!%d%s %d", in connect() 56 snprintf(msg, sizeof msg, "connect %s!%d%s", in connect() 59 n = write(cfd, msg, strlen(msg)); in connect() 79 snprintf(msg, sizeof msg, "UD.%d.%d", getpid(), vers++); in connect() 80 if(_sock_srv(msg, r->other) < 0){ in connect() 92 unlink(msg); in connect() 95 if(write(nfd, msg, strlen(msg)) < 0){ in connect() 98 unlink(msg); in connect() 105 _sock_srvname(file, msg); in connect()
|
| H A D | _sock_srv.c | 35 char msg[8+256+1]; in _sock_srv() local 38 _sock_srvname(msg, path); in _sock_srv() 41 unlink(msg); in _sock_srv() 44 sfd = creat(msg, 0666); in _sock_srv() 50 snprintf(msg, sizeof msg, "%d", fd); in _sock_srv() 51 if(write(sfd, msg, strlen(msg)) < 0){ in _sock_srv()
|
| /plan9/sys/src/ape/lib/ap/plan9/ |
| H A D | kill.c | 10 note(int pid, char *msg, char *fmt) in note() argument 21 if(msg != 0 && write(f, msg, strlen(msg)) < 0){ in note() 33 char *msg; in kill() local 37 msg = 0; in kill() 39 msg = _sigstring(sig); in kill() 40 if(msg == 0) { in kill() 50 r = note(mpid, msg, "/proc/%d/notepg"); in kill() 56 r = note(getpid(), msg, "/proc/%d/notepg"); in kill() 58 r = note(pid, msg, "/proc/%d/note"); in kill()
|
| H A D | wait.c | 19 Waitmsg* msg; member 28 Waitmsg *msg; in lookpid() local 31 if(pid <= 0 || w->msg->pid == pid){ in lookpid() 32 msg = w->msg; in lookpid() 35 return msg; in lookpid() 41 addpid(Waitmsg *msg) in addpid() argument 48 free(msg); in addpid() 51 w->msg = msg; in addpid() 64 if(w->msg[0]){ in waitstatus() 66 bp = w->msg; in waitstatus() [all …]
|
| H A D | signal.c | 11 char *msg; /* just check prefix */ member 93 _notehandler(void *u, char *msg) in _notehandler() argument 102 if(strncmp(msg, sigtab[i].msg, strlen(sigtab[i].msg)) == 0){ in _notehandler() 125 if(strncmp(nam, sigtab[i].msg, strlen(sigtab[i].msg)) == 0) in _stringsig() 137 return sigtab[i].msg; in _sigstring()
|
| /plan9/sys/src/cmd/upas/ml/ |
| H A D | ml.c | 11 void printmsg(int fd, String *msg, char *replyto, char *listname); 12 void appendtoarchive(char* listname, String *firstline, String *msg); 25 String *msg; in main() local 52 msg = s_new(); in main() 61 if(s_read(&in, msg, 2*1024*1024) <= 0) in main() 65 yyinit(s_to_c(msg), s_len(msg)); in main() 82 printmsg(fd, msg, replytoname, listname); in main() 87 if(w->msg != nil && w->msg[0]) in main() 88 sysfatal("%s", w->msg); in main() 93 appendtoarchive(listname, firstline, msg); in main() [all …]
|
| H A D | mlowner.c | 20 String *msg; in main() local 37 msg = s_new(); in main() 40 if(s_read_line(&in, msg) == nil) in main() 44 if(s_read(&in, s_restart(msg), 128*1024) <= 0) in main() 48 yyinit(s_to_c(msg), s_len(msg)); in main() 58 if(strstr(s_to_c(msg), "remove")||strstr(s_to_c(msg), "unsubscribe")) in main() 60 else if(strstr(s_to_c(msg), "subscribe")) in main()
|
| /plan9/sys/src/9/omap/ |
| H A D | mouse.c | 91 static short msg[4]; in ps2mouseputc() local 109 msg[nb] = c; in ps2mouseputc() 112 if(msg[0] & 0x10) in ps2mouseputc() 113 msg[1] |= 0xFF00; in ps2mouseputc() 114 if(msg[0] & 0x20) in ps2mouseputc() 115 msg[2] |= 0xFF00; in ps2mouseputc() 117 buttons = b[(msg[0]&7) | (shift ? 8 : 0)]; in ps2mouseputc() 119 if((msg[3]&0xc8) == 0x08){ in ps2mouseputc() 121 msg[0] = msg[3]; in ps2mouseputc() 124 if((msg[3] >> 3) & 1) in ps2mouseputc() [all …]
|
| /plan9/sys/src/cmd/vnc/ |
| H A D | auth.c | 112 char msg[VerLen+1]; in vncsrvhandshake() local 114 strecpy(msg, msg+sizeof msg, version); in vncsrvhandshake() 116 fprint(2, "server version: %s", msg); in vncsrvhandshake() 117 vncwrbytes(v, msg, VerLen); in vncsrvhandshake() 120 vncrdbytes(v, msg, VerLen); in vncsrvhandshake() 122 fprint(2, "client version: %s", msg); in vncsrvhandshake() 129 char msg[VerLen+1]; in vnchandshake() local 131 msg[VerLen] = 0; in vnchandshake() 132 vncrdbytes(v, msg, VerLen); in vnchandshake() 133 if(strncmp(msg, "RFB ", 4) != 0){ in vnchandshake() [all …]
|
| /plan9/sys/src/9/pc/ |
| H A D | mouse.c | 91 static short msg[4]; in ps2mouseputc() local 121 msg[nb] = c; in ps2mouseputc() 124 if(msg[0] & 0x10) in ps2mouseputc() 125 msg[1] |= 0xFF00; in ps2mouseputc() 126 if(msg[0] & 0x20) in ps2mouseputc() 127 msg[2] |= 0xFF00; in ps2mouseputc() 129 buttons = b[(msg[0]&7) | (shift ? 8 : 0)]; in ps2mouseputc() 131 if((msg[3]&0xc8) == 0x08){ in ps2mouseputc() 134 msg[0] = msg[3]; in ps2mouseputc() 151 if((msg[3] >> 3) & 1) in ps2mouseputc() [all …]
|
| /plan9/sys/src/cmd/ip/ftpfs/ |
| H A D | proto.c | 31 char msg[512]; /* buffer for replies */ variable 86 if(getreply(&ctlin, msg, sizeof(msg), 1) != Success) in hello() 88 if(strstr(msg, "Plan 9")) in hello() 93 if(getreply(&ctlin, msg, sizeof(msg), 1) != Success) in hello() 104 if(getreply(&ctlin, msg, sizeof(msg), 1) != Success) in hello() 107 if(getreply(&ctlin, msg, sizeof(msg), 1) != Success) in hello() 140 switch(getreply(&ctlin, msg, sizeof(msg), 1)){ in rlogin() 157 if(getreply(&ctlin, msg, sizeof(msg), 1) == Success){ in rlogin() 158 if(strstr(msg, "Sess#")) in rlogin() 182 switch(getreply(&ctlin, msg, sizeof(msg), 1)){ in clogin() [all …]
|
| /plan9/sys/src/cmd/auth/secstore/ |
| H A D | secstored.c | 29 uchar *msg; in getdir() local 46 msg = (uchar*)ls; in getdir() 50 conn->write(conn, msg, n); in getdir() 51 msg += n; in getdir() 223 char msg[Maxmsg+1]; in dologin() local 233 if(readstr(conn, msg) < 0){ in dologin() 234 fprint(2, "secstored: remote: %s: %r\n", msg); in dologin() 240 if(PAKserver(conn, S, msg, &pw) < 0){ in dologin() 247 if(readstr(conn, msg) < 10 || strncmp(msg, "STA", 3) != 0){ in dologin() 251 mess = secureidcheck(pw->id, msg+3); in dologin() [all …]
|
| /plan9/sys/src/ape/cmd/pax/ |
| H A D | ttyio.c | 131 int nextask(char *msg, char *answer, int limit) in nextask() argument 135 int nextask(msg, answer, limit) in nextask() 136 char *msg; /* message to display for user */ in nextask() 149 write(ttyf, msg, (uint) strlen(msg)); 244 char msg[200]; /* buffer for message display */ local 250 …sprintf(msg, "%s: Ready for volume %u\n%s: Type \"go\" when ready to proceed (or \"quit\" to abort… 253 ret = nextask(msg, answer, sizeof(answer));
|
| H A D | warn.c | 83 void warnarch(char *msg, OFFSET adjust) in warnarch() argument 87 void warnarch(msg, adjust) in warnarch() 88 char *msg; in warnarch() 95 fprintf(stderr, "]: %s\n", msg); 130 static char msg[40]; /* used for "Unknown error" messages */ in strerror() 135 sprintf(msg, "Unknown error (errno %d)", errno); in strerror() 136 return (msg); in strerror()
|
| /plan9/sys/src/cmd/ |
| H A D | hget.c | 849 char msg[64]; in doftp() local 911 rv = ftprcode(ctl, msg, sizeof(msg)); in doftp() 922 if(w->msg[0] == 0){ in doftp() 926 werrstr("xfer: %s", w->msg); in doftp() 961 ftprcode(int ctl, char *msg, int len) in ftprcode() argument 969 *msg = 0; in ftprcode() 970 i = readline(ctl, msg, len); in ftprcode() 974 fprint(2, "%d <- %s\n", ctl, msg); in ftprcode() 977 rv = strtol(msg, &p, 10); in ftprcode() 978 if(rv >= 100 && rv < 600 && p==msg+3 && *p == ' ') in ftprcode() [all …]
|
| /plan9/sys/src/cmd/gs/libpng/ |
| H A D | pngerror.c | 35 char msg[16]; in png_error() local 48 msg[i]=error_message[i+1]; in png_error() 49 msg[i]='\0'; in png_error() 50 error_message=msg; in png_error() 59 msg[0]='0'; in png_error() 60 msg[1]='\0'; in png_error() 61 error_message=msg; in png_error() 148 char msg[18+64]; in png_chunk_error() local 149 png_format_buffer(png_ptr, msg, error_message); in png_chunk_error() 150 png_error(png_ptr, msg); in png_chunk_error() [all …]
|
| /plan9/sys/src/cmd/upas/bayes/ |
| H A D | msgtok.c | 35 char msg[1024+1]; in main() local 64 ep = msg; in main() 65 p = msg; in main() 72 if(p > msg + 1){ in main() 74 memmove(msg, p-1, ep-(p-1)); in main() 75 off += (p-1) - msg; in main() 76 p = msg+1; in main() 79 n = Bread(&bin, ep, msg+(sizeof msg - 1)- ep); in main() 109 m[0] = dregexec(re[0], p, p==msg || p[-1]=='\n'); in main() 110 m[1] = dregexec(re[1], p, p==msg || p[-1]=='\n'); in main() [all …]
|
| /plan9/sys/src/cmd/ip/ |
| H A D | traceroute.c | 124 char msg[Maxstring]; in tcpilprobe() local 128 n = snprint(msg, sizeof msg, "connect %s", dest); in tcpilprobe() 130 n = write(cfd, msg, n); in tcpilprobe() 143 char msg[Maxstring]; in udpprobe() local 147 n = snprint(msg, sizeof msg, "connect %s", dest); in udpprobe() 148 if(write(cfd, msg, n)< 0) in udpprobe() 162 n = read(dfd, msg, sizeof(msg)-1); in udpprobe() 188 char buf[512], err[Maxstring], msg[Maxstring]; in icmpprobe() local 192 n = snprint(msg, sizeof msg, "connect %s", dest); in icmpprobe() 193 if(write(cfd, msg, n)< 0) in icmpprobe() [all …]
|
| /plan9/sys/src/cmd/disk/kfs/ |
| H A D | con.c | 359 char msg[100]; in adduser() local 407 sprint(msg, "%d:%s:%s:\n", nu, user, user); in adduser() 408 cprint("add user %s", msg); in adduser() 409 c = strlen(msg); in adduser() 415 i = con_write(FID2, msg, statlen(stat), c); in adduser() 426 char user[NAMELEN], param[NAMELEN], msg[100]; in cmd_newuser() local 474 sprint(msg, "create /usr/%s %s %s 775 d", user, user, user); in cmd_newuser() 475 cmd_exec(msg); in cmd_newuser() 476 sprint(msg, "create /usr/%s/tmp %s %s 775 d", user, user, user); in cmd_newuser() 477 cmd_exec(msg); in cmd_newuser() [all …]
|