12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182 |
-
-
-
-
- #include <linux/fs.h>
- #include <linux/kernel.h>
- #include <linux/vfs.h>
- #include <linux/task_io_accounting_ops.h>
- #include <linux/uaccess.h>
- #include <linux/pagemap.h>
- #include <linux/xattr.h>
- #include "smb2pdu.h"
- #include "cifsglob.h"
- #include "cifsacl.h"
- #include "cifsproto.h"
- #include "smb2proto.h"
- #include "cifs_unicode.h"
- #include "cifs_debug.h"
- #include "ntlmssp.h"
- #include "smb2status.h"
- #include "smb2glob.h"
- #include "cifspdu.h"
- #include "cifs_spnego.h"
- static const int smb2_req_struct_sizes[NUMBER_OF_SMB2_COMMANDS] = {
- 36,
- 25,
- 4,
- 9,
- 4,
- 57,
- 24,
- 24,
- 49,
- 49,
- 48,
- 57,
- 4,
- 4,
- 33,
- 32,
- 41,
- 33,
- 24
- };
- static void
- smb2_hdr_assemble(struct smb2_hdr *hdr, __le16 smb2_cmd ,
- const struct cifs_tcon *tcon)
- {
- struct smb2_pdu *pdu = (struct smb2_pdu *)hdr;
- char *temp = (char *)hdr;
-
- __u16 parmsize = smb2_req_struct_sizes[le16_to_cpu(smb2_cmd)];
-
- memset(temp, 0, 256);
-
- hdr->smb2_buf_length = cpu_to_be32(parmsize + sizeof(struct smb2_hdr)
- - 4 );
- hdr->ProtocolId = SMB2_PROTO_NUMBER;
- hdr->StructureSize = cpu_to_le16(64);
- hdr->Command = smb2_cmd;
- if (tcon && tcon->ses && tcon->ses->server) {
- struct TCP_Server_Info *server = tcon->ses->server;
- spin_lock(&server->req_lock);
-
- if (server->credits >= server->max_credits)
- hdr->CreditRequest = cpu_to_le16(0);
- else
- hdr->CreditRequest = cpu_to_le16(
- min_t(int, server->max_credits -
- server->credits, 2));
- spin_unlock(&server->req_lock);
- } else {
- hdr->CreditRequest = cpu_to_le16(2);
- }
- hdr->ProcessId = cpu_to_le32((__u16)current->tgid);
- if (!tcon)
- goto out;
-
-
- if ((tcon->ses) && (tcon->ses->server) &&
- (tcon->ses->server->capabilities & SMB2_GLOBAL_CAP_LARGE_MTU))
- hdr->CreditCharge = cpu_to_le16(1);
-
- hdr->TreeId = tcon->tid;
-
- if (tcon->ses)
- hdr->SessionId = tcon->ses->Suid;
-
- if (tcon->ses && tcon->ses->server && tcon->ses->server->sign)
- hdr->Flags |= SMB2_FLAGS_SIGNED;
- out:
- pdu->StructureSize2 = cpu_to_le16(parmsize);
- return;
- }
- static int
- smb2_reconnect(__le16 smb2_command, struct cifs_tcon *tcon)
- {
- int rc;
- struct nls_table *nls_codepage;
- struct cifs_ses *ses;
- struct TCP_Server_Info *server;
-
- if (tcon == NULL)
- return 0;
- if (smb2_command == SMB2_TREE_CONNECT || smb2_command == SMB2_IOCTL)
- return 0;
- if (tcon->tidStatus == CifsExiting) {
-
- if ((smb2_command != SMB2_WRITE) &&
- (smb2_command != SMB2_CREATE) &&
- (smb2_command != SMB2_TREE_DISCONNECT)) {
- cifs_dbg(FYI, "can not send cmd %d while umounting\n",
- smb2_command);
- return -ENODEV;
- }
- }
- if ((!tcon->ses) || (tcon->ses->status == CifsExiting) ||
- (!tcon->ses->server))
- return -EIO;
- ses = tcon->ses;
- server = ses->server;
-
- while (server->tcpStatus == CifsNeedReconnect) {
-
- switch (smb2_command) {
-
- case SMB2_TREE_DISCONNECT:
- case SMB2_CANCEL:
- case SMB2_CLOSE:
- case SMB2_OPLOCK_BREAK:
- return -EAGAIN;
- }
- rc = wait_event_interruptible_timeout(server->response_q,
- (server->tcpStatus != CifsNeedReconnect),
- 10 * HZ);
- if (rc < 0) {
- cifs_dbg(FYI, "%s: aborting reconnect due to a received"
- " signal by the process\n", __func__);
- return -ERESTARTSYS;
- }
-
- if (server->tcpStatus != CifsNeedReconnect)
- break;
-
- if (!tcon->retry) {
- cifs_dbg(FYI, "gave up waiting on reconnect in smb_init\n");
- return -EHOSTDOWN;
- }
- }
- if (!tcon->ses->need_reconnect && !tcon->need_reconnect)
- return 0;
- nls_codepage = load_nls_default();
-
- mutex_lock(&tcon->ses->session_mutex);
- rc = cifs_negotiate_protocol(0, tcon->ses);
- if (!rc && tcon->ses->need_reconnect)
- rc = cifs_setup_session(0, tcon->ses, nls_codepage);
- if (rc || !tcon->need_reconnect) {
- mutex_unlock(&tcon->ses->session_mutex);
- goto out;
- }
- cifs_mark_open_files_invalid(tcon);
- if (tcon->use_persistent)
- tcon->need_reopen_files = true;
- rc = SMB2_tcon(0, tcon->ses, tcon->treeName, tcon, nls_codepage);
- mutex_unlock(&tcon->ses->session_mutex);
- cifs_dbg(FYI, "reconnect tcon rc = %d\n", rc);
- if (rc)
- goto out;
- if (smb2_command != SMB2_INTERNAL_CMD)
- queue_delayed_work(cifsiod_wq, &server->reconnect, 0);
- atomic_inc(&tconInfoReconnectCount);
- out:
-
-
- switch (smb2_command) {
- case SMB2_FLUSH:
- case SMB2_READ:
- case SMB2_WRITE:
- case SMB2_LOCK:
- case SMB2_IOCTL:
- case SMB2_QUERY_DIRECTORY:
- case SMB2_CHANGE_NOTIFY:
- case SMB2_QUERY_INFO:
- case SMB2_SET_INFO:
- rc = -EAGAIN;
- }
- unload_nls(nls_codepage);
- return rc;
- }
- static int
- small_smb2_init(__le16 smb2_command, struct cifs_tcon *tcon,
- void **request_buf)
- {
- int rc = 0;
- rc = smb2_reconnect(smb2_command, tcon);
- if (rc)
- return rc;
-
- *request_buf = cifs_small_buf_get();
- if (*request_buf == NULL) {
-
- return -ENOMEM;
- }
- smb2_hdr_assemble((struct smb2_hdr *) *request_buf, smb2_command, tcon);
- if (tcon != NULL) {
- #ifdef CONFIG_CIFS_STATS
- uint16_t com_code = le16_to_cpu(smb2_command);
- cifs_stats_inc(&tcon->stats.smb2_stats.smb2_com_sent[com_code]);
- #endif
- cifs_stats_inc(&tcon->num_smbs_sent);
- }
- return rc;
- }
- #ifdef CONFIG_CIFS_SMB311
- #define OFFSET_OF_NEG_CONTEXT 0x68
- #define SMB2_PREAUTH_INTEGRITY_CAPABILITIES cpu_to_le16(1)
- #define SMB2_ENCRYPTION_CAPABILITIES cpu_to_le16(2)
- static void
- build_preauth_ctxt(struct smb2_preauth_neg_context *pneg_ctxt)
- {
- pneg_ctxt->ContextType = SMB2_PREAUTH_INTEGRITY_CAPABILITIES;
- pneg_ctxt->DataLength = cpu_to_le16(38);
- pneg_ctxt->HashAlgorithmCount = cpu_to_le16(1);
- pneg_ctxt->SaltLength = cpu_to_le16(SMB311_SALT_SIZE);
- get_random_bytes(pneg_ctxt->Salt, SMB311_SALT_SIZE);
- pneg_ctxt->HashAlgorithms = SMB2_PREAUTH_INTEGRITY_SHA512;
- }
- static void
- build_encrypt_ctxt(struct smb2_encryption_neg_context *pneg_ctxt)
- {
- pneg_ctxt->ContextType = SMB2_ENCRYPTION_CAPABILITIES;
- pneg_ctxt->DataLength = cpu_to_le16(6);
- pneg_ctxt->CipherCount = cpu_to_le16(2);
- pneg_ctxt->Ciphers[0] = SMB2_ENCRYPTION_AES128_GCM;
- pneg_ctxt->Ciphers[1] = SMB2_ENCRYPTION_AES128_CCM;
- }
- static void
- assemble_neg_contexts(struct smb2_negotiate_req *req)
- {
-
- char *pneg_ctxt = (char *)req + OFFSET_OF_NEG_CONTEXT + 4;
- build_preauth_ctxt((struct smb2_preauth_neg_context *)pneg_ctxt);
-
- pneg_ctxt += 2 + sizeof(struct smb2_preauth_neg_context);
- build_encrypt_ctxt((struct smb2_encryption_neg_context *)pneg_ctxt);
- req->NegotiateContextOffset = cpu_to_le32(OFFSET_OF_NEG_CONTEXT);
- req->NegotiateContextCount = cpu_to_le16(2);
- inc_rfc1001_len(req, 4 + sizeof(struct smb2_preauth_neg_context)
- + sizeof(struct smb2_encryption_neg_context));
- }
- #else
- static void assemble_neg_contexts(struct smb2_negotiate_req *req)
- {
- return;
- }
- #endif
- int
- SMB2_negotiate(const unsigned int xid, struct cifs_ses *ses)
- {
- struct smb2_negotiate_req *req;
- struct smb2_negotiate_rsp *rsp;
- struct kvec iov[1];
- int rc = 0;
- int resp_buftype;
- struct TCP_Server_Info *server = ses->server;
- int blob_offset, blob_length;
- char *security_blob;
- int flags = CIFS_NEG_OP;
- cifs_dbg(FYI, "Negotiate protocol\n");
- if (!server) {
- WARN(1, "%s: server is NULL!\n", __func__);
- return -EIO;
- }
- rc = small_smb2_init(SMB2_NEGOTIATE, NULL, (void **) &req);
- if (rc)
- return rc;
- req->hdr.SessionId = 0;
- req->Dialects[0] = cpu_to_le16(ses->server->vals->protocol_id);
- req->DialectCount = cpu_to_le16(1);
- inc_rfc1001_len(req, 2);
-
- if (ses->sign)
- req->SecurityMode = cpu_to_le16(SMB2_NEGOTIATE_SIGNING_REQUIRED);
- else if (global_secflags & CIFSSEC_MAY_SIGN)
- req->SecurityMode = cpu_to_le16(SMB2_NEGOTIATE_SIGNING_ENABLED);
- else
- req->SecurityMode = 0;
- req->Capabilities = cpu_to_le32(ses->server->vals->req_capabilities);
-
- if (ses->server->vals->protocol_id == SMB20_PROT_ID)
- memset(req->ClientGUID, 0, SMB2_CLIENT_GUID_SIZE);
- else {
- memcpy(req->ClientGUID, server->client_guid,
- SMB2_CLIENT_GUID_SIZE);
- if (ses->server->vals->protocol_id == SMB311_PROT_ID)
- assemble_neg_contexts(req);
- }
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- rc = SendReceive2(xid, ses, iov, 1, &resp_buftype, flags);
- rsp = (struct smb2_negotiate_rsp *)iov[0].iov_base;
-
- if (rc != 0)
- goto neg_exit;
- cifs_dbg(FYI, "mode 0x%x\n", rsp->SecurityMode);
-
- if (rsp->DialectRevision == cpu_to_le16(SMB20_PROT_ID))
- cifs_dbg(FYI, "negotiated smb2.0 dialect\n");
- else if (rsp->DialectRevision == cpu_to_le16(SMB21_PROT_ID))
- cifs_dbg(FYI, "negotiated smb2.1 dialect\n");
- else if (rsp->DialectRevision == cpu_to_le16(SMB30_PROT_ID))
- cifs_dbg(FYI, "negotiated smb3.0 dialect\n");
- else if (rsp->DialectRevision == cpu_to_le16(SMB302_PROT_ID))
- cifs_dbg(FYI, "negotiated smb3.02 dialect\n");
- #ifdef CONFIG_CIFS_SMB311
- else if (rsp->DialectRevision == cpu_to_le16(SMB311_PROT_ID))
- cifs_dbg(FYI, "negotiated smb3.1.1 dialect\n");
- #endif
- else {
- cifs_dbg(VFS, "Illegal dialect returned by server 0x%x\n",
- le16_to_cpu(rsp->DialectRevision));
- rc = -EIO;
- goto neg_exit;
- }
- server->dialect = le16_to_cpu(rsp->DialectRevision);
-
- server->negflavor = CIFS_NEGFLAVOR_EXTENDED;
-
- server->maxBuf = min_t(unsigned int, le32_to_cpu(rsp->MaxTransactSize),
- SMB2_MAX_BUFFER_SIZE);
- server->max_read = le32_to_cpu(rsp->MaxReadSize);
- server->max_write = le32_to_cpu(rsp->MaxWriteSize);
-
- server->sec_mode = le16_to_cpu(rsp->SecurityMode);
- server->capabilities = le32_to_cpu(rsp->Capabilities);
-
- server->capabilities |= SMB2_NT_FIND | SMB2_LARGE_FILES;
- security_blob = smb2_get_data_area_len(&blob_offset, &blob_length,
- &rsp->hdr);
-
- if (blob_length == 0)
- cifs_dbg(FYI, "missing security blob on negprot\n");
- rc = cifs_enable_signing(server, ses->sign);
- if (rc)
- goto neg_exit;
- if (blob_length) {
- rc = decode_negTokenInit(security_blob, blob_length, server);
- if (rc == 1)
- rc = 0;
- else if (rc == 0)
- rc = -EIO;
- }
- neg_exit:
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- int smb3_validate_negotiate(const unsigned int xid, struct cifs_tcon *tcon)
- {
- int rc = 0;
- struct validate_negotiate_info_req vneg_inbuf;
- struct validate_negotiate_info_rsp *pneg_rsp;
- u32 rsplen;
- cifs_dbg(FYI, "validate negotiate\n");
-
- if (tcon->ses->session_flags & SMB2_SESSION_FLAG_IS_GUEST)
- return 0;
- if (tcon->ses->user_name == NULL) {
- cifs_dbg(FYI, "Can't validate negotiate: null user mount\n");
- return 0;
- }
- if (tcon->ses->session_flags & SMB2_SESSION_FLAG_IS_NULL)
- cifs_dbg(VFS, "Unexpected null user (anonymous) auth flag sent by server\n");
- vneg_inbuf.Capabilities =
- cpu_to_le32(tcon->ses->server->vals->req_capabilities);
- memcpy(vneg_inbuf.Guid, tcon->ses->server->client_guid,
- SMB2_CLIENT_GUID_SIZE);
- if (tcon->ses->sign)
- vneg_inbuf.SecurityMode =
- cpu_to_le16(SMB2_NEGOTIATE_SIGNING_REQUIRED);
- else if (global_secflags & CIFSSEC_MAY_SIGN)
- vneg_inbuf.SecurityMode =
- cpu_to_le16(SMB2_NEGOTIATE_SIGNING_ENABLED);
- else
- vneg_inbuf.SecurityMode = 0;
- vneg_inbuf.DialectCount = cpu_to_le16(1);
- vneg_inbuf.Dialects[0] =
- cpu_to_le16(tcon->ses->server->vals->protocol_id);
- rc = SMB2_ioctl(xid, tcon, NO_FILE_ID, NO_FILE_ID,
- FSCTL_VALIDATE_NEGOTIATE_INFO, true ,
- (char *)&vneg_inbuf, sizeof(struct validate_negotiate_info_req),
- (char **)&pneg_rsp, &rsplen);
- if (rc != 0) {
- cifs_dbg(VFS, "validate protocol negotiate failed: %d\n", rc);
- return -EIO;
- }
- if (rsplen != sizeof(struct validate_negotiate_info_rsp)) {
- cifs_dbg(VFS, "invalid protocol negotiate response size: %d\n",
- rsplen);
-
- if (rsplen > CIFSMaxBufSize)
- return -EIO;
- }
-
- if (pneg_rsp->Dialect != cpu_to_le16(tcon->ses->server->dialect))
- goto vneg_out;
- if (pneg_rsp->SecurityMode != cpu_to_le16(tcon->ses->server->sec_mode))
- goto vneg_out;
-
- if ((le32_to_cpu(pneg_rsp->Capabilities) | SMB2_NT_FIND |
- SMB2_LARGE_FILES) != tcon->ses->server->capabilities)
- goto vneg_out;
-
- cifs_dbg(FYI, "validate negotiate info successful\n");
- return 0;
- vneg_out:
- cifs_dbg(VFS, "protocol revalidation - security settings mismatch\n");
- return -EIO;
- }
- struct SMB2_sess_data {
- unsigned int xid;
- struct cifs_ses *ses;
- struct nls_table *nls_cp;
- void (*func)(struct SMB2_sess_data *);
- int result;
- u64 previous_session;
-
- int buf0_type;
- struct kvec iov[2];
- };
- static int
- SMB2_sess_alloc_buffer(struct SMB2_sess_data *sess_data)
- {
- int rc;
- struct cifs_ses *ses = sess_data->ses;
- struct smb2_sess_setup_req *req;
- struct TCP_Server_Info *server = ses->server;
- rc = small_smb2_init(SMB2_SESSION_SETUP, NULL, (void **) &req);
- if (rc)
- return rc;
- req->hdr.SessionId = 0;
-
- req->PreviousSessionId = sess_data->previous_session;
- req->Flags = 0;
-
- req->hdr.CreditRequest = cpu_to_le16(3);
-
- if (server->sign)
- req->SecurityMode = SMB2_NEGOTIATE_SIGNING_REQUIRED;
- else if (global_secflags & CIFSSEC_MAY_SIGN)
- req->SecurityMode = SMB2_NEGOTIATE_SIGNING_ENABLED;
- else
- req->SecurityMode = 0;
- #ifdef CONFIG_CIFS_DFS_UPCALL
- req->Capabilities = cpu_to_le32(SMB2_GLOBAL_CAP_DFS);
- #else
- req->Capabilities = 0;
- #endif
- req->Channel = 0;
- sess_data->iov[0].iov_base = (char *)req;
-
- sess_data->iov[0].iov_len = get_rfc1002_length(req) + 4 - 1;
-
- sess_data->buf0_type = CIFS_SMALL_BUFFER;
- return 0;
- }
- static void
- SMB2_sess_free_buffer(struct SMB2_sess_data *sess_data)
- {
- free_rsp_buf(sess_data->buf0_type, sess_data->iov[0].iov_base);
- sess_data->buf0_type = CIFS_NO_BUFFER;
- }
- static int
- SMB2_sess_sendreceive(struct SMB2_sess_data *sess_data)
- {
- int rc;
- struct smb2_sess_setup_req *req = sess_data->iov[0].iov_base;
-
- req->SecurityBufferOffset =
- cpu_to_le16(sizeof(struct smb2_sess_setup_req) -
- 1 - 4 );
- req->SecurityBufferLength = cpu_to_le16(sess_data->iov[1].iov_len);
- inc_rfc1001_len(req, sess_data->iov[1].iov_len - 1 );
-
- rc = SendReceive2(sess_data->xid, sess_data->ses,
- sess_data->iov, 2,
- &sess_data->buf0_type,
- CIFS_LOG_ERROR | CIFS_NEG_OP);
- return rc;
- }
- static int
- SMB2_sess_establish_session(struct SMB2_sess_data *sess_data)
- {
- int rc = 0;
- struct cifs_ses *ses = sess_data->ses;
- mutex_lock(&ses->server->srv_mutex);
- if (ses->server->ops->generate_signingkey) {
- rc = ses->server->ops->generate_signingkey(ses);
- if (rc) {
- cifs_dbg(FYI,
- "SMB3 session key generation failed\n");
- mutex_unlock(&ses->server->srv_mutex);
- return rc;
- }
- }
- if (!ses->server->session_estab) {
- ses->server->sequence_number = 0x2;
- ses->server->session_estab = true;
- }
- mutex_unlock(&ses->server->srv_mutex);
- cifs_dbg(FYI, "SMB2/3 session established successfully\n");
- spin_lock(&GlobalMid_Lock);
- ses->status = CifsGood;
- ses->need_reconnect = false;
- spin_unlock(&GlobalMid_Lock);
- return rc;
- }
- #ifdef CONFIG_CIFS_UPCALL
- static void
- SMB2_auth_kerberos(struct SMB2_sess_data *sess_data)
- {
- int rc;
- struct cifs_ses *ses = sess_data->ses;
- struct cifs_spnego_msg *msg;
- struct key *spnego_key = NULL;
- struct smb2_sess_setup_rsp *rsp = NULL;
- rc = SMB2_sess_alloc_buffer(sess_data);
- if (rc)
- goto out;
- spnego_key = cifs_get_spnego_key(ses);
- if (IS_ERR(spnego_key)) {
- rc = PTR_ERR(spnego_key);
- spnego_key = NULL;
- goto out;
- }
- msg = spnego_key->payload.data[0];
-
- if (msg->version != CIFS_SPNEGO_UPCALL_VERSION) {
- cifs_dbg(VFS,
- "bad cifs.upcall version. Expected %d got %d",
- CIFS_SPNEGO_UPCALL_VERSION, msg->version);
- rc = -EKEYREJECTED;
- goto out_put_spnego_key;
- }
- ses->auth_key.response = kmemdup(msg->data, msg->sesskey_len,
- GFP_KERNEL);
- if (!ses->auth_key.response) {
- cifs_dbg(VFS,
- "Kerberos can't allocate (%u bytes) memory",
- msg->sesskey_len);
- rc = -ENOMEM;
- goto out_put_spnego_key;
- }
- ses->auth_key.len = msg->sesskey_len;
- sess_data->iov[1].iov_base = msg->data + msg->sesskey_len;
- sess_data->iov[1].iov_len = msg->secblob_len;
- rc = SMB2_sess_sendreceive(sess_data);
- if (rc)
- goto out_put_spnego_key;
- rsp = (struct smb2_sess_setup_rsp *)sess_data->iov[0].iov_base;
- ses->Suid = rsp->hdr.SessionId;
- ses->session_flags = le16_to_cpu(rsp->SessionFlags);
- if (ses->session_flags & SMB2_SESSION_FLAG_ENCRYPT_DATA)
- cifs_dbg(VFS, "SMB3 encryption not supported yet\n");
- rc = SMB2_sess_establish_session(sess_data);
- out_put_spnego_key:
- key_invalidate(spnego_key);
- key_put(spnego_key);
- out:
- sess_data->result = rc;
- sess_data->func = NULL;
- SMB2_sess_free_buffer(sess_data);
- }
- #else
- static void
- SMB2_auth_kerberos(struct SMB2_sess_data *sess_data)
- {
- cifs_dbg(VFS, "Kerberos negotiated but upcall support disabled!\n");
- sess_data->result = -EOPNOTSUPP;
- sess_data->func = NULL;
- }
- #endif
- static void
- SMB2_sess_auth_rawntlmssp_authenticate(struct SMB2_sess_data *sess_data);
- static void
- SMB2_sess_auth_rawntlmssp_negotiate(struct SMB2_sess_data *sess_data)
- {
- int rc;
- struct cifs_ses *ses = sess_data->ses;
- struct smb2_sess_setup_rsp *rsp = NULL;
- char *ntlmssp_blob = NULL;
- bool use_spnego = false;
- u16 blob_length = 0;
-
- ses->ntlmssp = kmalloc(sizeof(struct ntlmssp_auth), GFP_KERNEL);
- if (!ses->ntlmssp) {
- rc = -ENOMEM;
- goto out_err;
- }
- ses->ntlmssp->sesskey_per_smbsess = true;
- rc = SMB2_sess_alloc_buffer(sess_data);
- if (rc)
- goto out_err;
- ntlmssp_blob = kmalloc(sizeof(struct _NEGOTIATE_MESSAGE),
- GFP_KERNEL);
- if (ntlmssp_blob == NULL) {
- rc = -ENOMEM;
- goto out;
- }
- build_ntlmssp_negotiate_blob(ntlmssp_blob, ses);
- if (use_spnego) {
-
- cifs_dbg(VFS, "spnego not supported for SMB2 yet\n");
- rc = -EOPNOTSUPP;
- goto out;
- } else {
- blob_length = sizeof(struct _NEGOTIATE_MESSAGE);
-
- }
- sess_data->iov[1].iov_base = ntlmssp_blob;
- sess_data->iov[1].iov_len = blob_length;
- rc = SMB2_sess_sendreceive(sess_data);
- rsp = (struct smb2_sess_setup_rsp *)sess_data->iov[0].iov_base;
-
- if (sess_data->buf0_type != CIFS_NO_BUFFER &&
- rsp->hdr.Status == STATUS_MORE_PROCESSING_REQUIRED)
- rc = 0;
- if (rc)
- goto out;
- if (offsetof(struct smb2_sess_setup_rsp, Buffer) - 4 !=
- le16_to_cpu(rsp->SecurityBufferOffset)) {
- cifs_dbg(VFS, "Invalid security buffer offset %d\n",
- le16_to_cpu(rsp->SecurityBufferOffset));
- rc = -EIO;
- goto out;
- }
- rc = decode_ntlmssp_challenge(rsp->Buffer,
- le16_to_cpu(rsp->SecurityBufferLength), ses);
- if (rc)
- goto out;
- cifs_dbg(FYI, "rawntlmssp session setup challenge phase\n");
- ses->Suid = rsp->hdr.SessionId;
- ses->session_flags = le16_to_cpu(rsp->SessionFlags);
- if (ses->session_flags & SMB2_SESSION_FLAG_ENCRYPT_DATA)
- cifs_dbg(VFS, "SMB3 encryption not supported yet\n");
- out:
- kfree(ntlmssp_blob);
- SMB2_sess_free_buffer(sess_data);
- if (!rc) {
- sess_data->result = 0;
- sess_data->func = SMB2_sess_auth_rawntlmssp_authenticate;
- return;
- }
- out_err:
- kfree(ses->ntlmssp);
- ses->ntlmssp = NULL;
- sess_data->result = rc;
- sess_data->func = NULL;
- }
- static void
- SMB2_sess_auth_rawntlmssp_authenticate(struct SMB2_sess_data *sess_data)
- {
- int rc;
- struct cifs_ses *ses = sess_data->ses;
- struct smb2_sess_setup_req *req;
- struct smb2_sess_setup_rsp *rsp = NULL;
- unsigned char *ntlmssp_blob = NULL;
- bool use_spnego = false;
- u16 blob_length = 0;
- rc = SMB2_sess_alloc_buffer(sess_data);
- if (rc)
- goto out;
- req = (struct smb2_sess_setup_req *) sess_data->iov[0].iov_base;
- req->hdr.SessionId = ses->Suid;
- rc = build_ntlmssp_auth_blob(&ntlmssp_blob, &blob_length, ses,
- sess_data->nls_cp);
- if (rc) {
- cifs_dbg(FYI, "build_ntlmssp_auth_blob failed %d\n", rc);
- goto out;
- }
- if (use_spnego) {
-
- cifs_dbg(VFS, "spnego not supported for SMB2 yet\n");
- rc = -EOPNOTSUPP;
- goto out;
- }
- sess_data->iov[1].iov_base = ntlmssp_blob;
- sess_data->iov[1].iov_len = blob_length;
- rc = SMB2_sess_sendreceive(sess_data);
- if (rc)
- goto out;
- rsp = (struct smb2_sess_setup_rsp *)sess_data->iov[0].iov_base;
- ses->Suid = rsp->hdr.SessionId;
- ses->session_flags = le16_to_cpu(rsp->SessionFlags);
- if (ses->session_flags & SMB2_SESSION_FLAG_ENCRYPT_DATA)
- cifs_dbg(VFS, "SMB3 encryption not supported yet\n");
- rc = SMB2_sess_establish_session(sess_data);
- out:
- kfree(ntlmssp_blob);
- SMB2_sess_free_buffer(sess_data);
- kfree(ses->ntlmssp);
- ses->ntlmssp = NULL;
- sess_data->result = rc;
- sess_data->func = NULL;
- }
- static int
- SMB2_select_sec(struct cifs_ses *ses, struct SMB2_sess_data *sess_data)
- {
- if (ses->sectype != Kerberos && ses->sectype != RawNTLMSSP)
- ses->sectype = RawNTLMSSP;
- switch (ses->sectype) {
- case Kerberos:
- sess_data->func = SMB2_auth_kerberos;
- break;
- case RawNTLMSSP:
- sess_data->func = SMB2_sess_auth_rawntlmssp_negotiate;
- break;
- default:
- cifs_dbg(VFS, "secType %d not supported!\n", ses->sectype);
- return -EOPNOTSUPP;
- }
- return 0;
- }
- int
- SMB2_sess_setup(const unsigned int xid, struct cifs_ses *ses,
- const struct nls_table *nls_cp)
- {
- int rc = 0;
- struct TCP_Server_Info *server = ses->server;
- struct SMB2_sess_data *sess_data;
- cifs_dbg(FYI, "Session Setup\n");
- if (!server) {
- WARN(1, "%s: server is NULL!\n", __func__);
- return -EIO;
- }
- sess_data = kzalloc(sizeof(struct SMB2_sess_data), GFP_KERNEL);
- if (!sess_data)
- return -ENOMEM;
- rc = SMB2_select_sec(ses, sess_data);
- if (rc)
- goto out;
- sess_data->xid = xid;
- sess_data->ses = ses;
- sess_data->buf0_type = CIFS_NO_BUFFER;
- sess_data->nls_cp = (struct nls_table *) nls_cp;
- sess_data->previous_session = ses->Suid;
- while (sess_data->func)
- sess_data->func(sess_data);
- if ((ses->session_flags & SMB2_SESSION_FLAG_IS_GUEST) && (ses->sign))
- cifs_dbg(VFS, "signing requested but authenticated as guest\n");
- rc = sess_data->result;
- out:
- kfree(sess_data);
- return rc;
- }
- int
- SMB2_logoff(const unsigned int xid, struct cifs_ses *ses)
- {
- struct smb2_logoff_req *req;
- int rc = 0;
- struct TCP_Server_Info *server;
- cifs_dbg(FYI, "disconnect session %p\n", ses);
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
-
- if (ses->need_reconnect)
- goto smb2_session_already_dead;
- rc = small_smb2_init(SMB2_LOGOFF, NULL, (void **) &req);
- if (rc)
- return rc;
-
- req->hdr.SessionId = ses->Suid;
- if (server->sign)
- req->hdr.Flags |= SMB2_FLAGS_SIGNED;
- rc = SendReceiveNoRsp(xid, ses, (char *) &req->hdr, 0);
-
- smb2_session_already_dead:
- return rc;
- }
- static inline void cifs_stats_fail_inc(struct cifs_tcon *tcon, uint16_t code)
- {
- cifs_stats_inc(&tcon->stats.smb2_stats.smb2_com_failed[code]);
- }
- #define MAX_SHARENAME_LENGTH (255 + 80 + 1 )
- static inline void init_copy_chunk_defaults(struct cifs_tcon *tcon)
- {
- tcon->max_chunks = 256;
- tcon->max_bytes_chunk = 1048576;
- tcon->max_bytes_copy = 16777216;
- }
- int
- SMB2_tcon(const unsigned int xid, struct cifs_ses *ses, const char *tree,
- struct cifs_tcon *tcon, const struct nls_table *cp)
- {
- struct smb2_tree_connect_req *req;
- struct smb2_tree_connect_rsp *rsp = NULL;
- struct kvec iov[2];
- int rc = 0;
- int resp_buftype;
- int unc_path_len;
- struct TCP_Server_Info *server;
- __le16 *unc_path = NULL;
- cifs_dbg(FYI, "TCON\n");
- if ((ses->server) && tree)
- server = ses->server;
- else
- return -EIO;
- if ((tcon && tcon->seal) &&
- ((ses->server->capabilities & SMB2_GLOBAL_CAP_ENCRYPTION) == 0)) {
- cifs_dbg(VFS, "encryption requested but no server support");
- return -EOPNOTSUPP;
- }
- unc_path = kmalloc(MAX_SHARENAME_LENGTH * 2, GFP_KERNEL);
- if (unc_path == NULL)
- return -ENOMEM;
- unc_path_len = cifs_strtoUTF16(unc_path, tree, strlen(tree), cp) + 1;
- unc_path_len *= 2;
- if (unc_path_len < 2) {
- kfree(unc_path);
- return -EINVAL;
- }
-
- if (tcon)
- tcon->tid = 0;
- rc = small_smb2_init(SMB2_TREE_CONNECT, tcon, (void **) &req);
- if (rc) {
- kfree(unc_path);
- return rc;
- }
- if (tcon == NULL) {
-
- req->hdr.SessionId = ses->Suid;
-
- }
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4 - 1;
-
- req->PathOffset = cpu_to_le16(sizeof(struct smb2_tree_connect_req)
- - 1 - 4 );
- req->PathLength = cpu_to_le16(unc_path_len - 2);
- iov[1].iov_base = unc_path;
- iov[1].iov_len = unc_path_len;
- inc_rfc1001_len(req, unc_path_len - 1 );
- rc = SendReceive2(xid, ses, iov, 2, &resp_buftype, 0);
- rsp = (struct smb2_tree_connect_rsp *)iov[0].iov_base;
- if (rc != 0) {
- if (tcon) {
- cifs_stats_fail_inc(tcon, SMB2_TREE_CONNECT_HE);
- tcon->need_reconnect = true;
- }
- goto tcon_error_exit;
- }
- if (tcon == NULL) {
- ses->ipc_tid = rsp->hdr.TreeId;
- goto tcon_exit;
- }
- switch (rsp->ShareType) {
- case SMB2_SHARE_TYPE_DISK:
- cifs_dbg(FYI, "connection to disk share\n");
- break;
- case SMB2_SHARE_TYPE_PIPE:
- tcon->ipc = true;
- cifs_dbg(FYI, "connection to pipe share\n");
- break;
- case SMB2_SHARE_TYPE_PRINT:
- tcon->ipc = true;
- cifs_dbg(FYI, "connection to printer\n");
- break;
- default:
- cifs_dbg(VFS, "unknown share type %d\n", rsp->ShareType);
- rc = -EOPNOTSUPP;
- goto tcon_error_exit;
- }
- tcon->share_flags = le32_to_cpu(rsp->ShareFlags);
- tcon->capabilities = rsp->Capabilities;
- tcon->maximal_access = le32_to_cpu(rsp->MaximalAccess);
- tcon->tidStatus = CifsGood;
- tcon->need_reconnect = false;
- tcon->tid = rsp->hdr.TreeId;
- strlcpy(tcon->treeName, tree, sizeof(tcon->treeName));
- if ((rsp->Capabilities & SMB2_SHARE_CAP_DFS) &&
- ((tcon->share_flags & SHI1005_FLAGS_DFS) == 0))
- cifs_dbg(VFS, "DFS capability contradicts DFS flag\n");
- init_copy_chunk_defaults(tcon);
- if (tcon->share_flags & SHI1005_FLAGS_ENCRYPT_DATA)
- cifs_dbg(VFS, "Encrypted shares not supported");
- if (tcon->ses->server->ops->validate_negotiate)
- rc = tcon->ses->server->ops->validate_negotiate(xid, tcon);
- tcon_exit:
- free_rsp_buf(resp_buftype, rsp);
- kfree(unc_path);
- return rc;
- tcon_error_exit:
- if (rsp->hdr.Status == STATUS_BAD_NETWORK_NAME) {
- cifs_dbg(VFS, "BAD_NETWORK_NAME: %s\n", tree);
- }
- goto tcon_exit;
- }
- int
- SMB2_tdis(const unsigned int xid, struct cifs_tcon *tcon)
- {
- struct smb2_tree_disconnect_req *req;
- int rc = 0;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- cifs_dbg(FYI, "Tree Disconnect\n");
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- if ((tcon->need_reconnect) || (tcon->ses->need_reconnect))
- return 0;
- rc = small_smb2_init(SMB2_TREE_DISCONNECT, tcon, (void **) &req);
- if (rc)
- return rc;
- rc = SendReceiveNoRsp(xid, ses, (char *)&req->hdr, 0);
- if (rc)
- cifs_stats_fail_inc(tcon, SMB2_TREE_DISCONNECT_HE);
- return rc;
- }
- static struct create_durable *
- create_durable_buf(void)
- {
- struct create_durable *buf;
- buf = kzalloc(sizeof(struct create_durable), GFP_KERNEL);
- if (!buf)
- return NULL;
- buf->ccontext.DataOffset = cpu_to_le16(offsetof
- (struct create_durable, Data));
- buf->ccontext.DataLength = cpu_to_le32(16);
- buf->ccontext.NameOffset = cpu_to_le16(offsetof
- (struct create_durable, Name));
- buf->ccontext.NameLength = cpu_to_le16(4);
-
- buf->Name[0] = 'D';
- buf->Name[1] = 'H';
- buf->Name[2] = 'n';
- buf->Name[3] = 'Q';
- return buf;
- }
- static struct create_durable *
- create_reconnect_durable_buf(struct cifs_fid *fid)
- {
- struct create_durable *buf;
- buf = kzalloc(sizeof(struct create_durable), GFP_KERNEL);
- if (!buf)
- return NULL;
- buf->ccontext.DataOffset = cpu_to_le16(offsetof
- (struct create_durable, Data));
- buf->ccontext.DataLength = cpu_to_le32(16);
- buf->ccontext.NameOffset = cpu_to_le16(offsetof
- (struct create_durable, Name));
- buf->ccontext.NameLength = cpu_to_le16(4);
- buf->Data.Fid.PersistentFileId = fid->persistent_fid;
- buf->Data.Fid.VolatileFileId = fid->volatile_fid;
-
- buf->Name[0] = 'D';
- buf->Name[1] = 'H';
- buf->Name[2] = 'n';
- buf->Name[3] = 'C';
- return buf;
- }
- static __u8
- parse_lease_state(struct TCP_Server_Info *server, struct smb2_create_rsp *rsp,
- unsigned int *epoch)
- {
- char *data_offset;
- struct create_context *cc;
- unsigned int next;
- unsigned int remaining;
- char *name;
- data_offset = (char *)rsp + 4 + le32_to_cpu(rsp->CreateContextsOffset);
- remaining = le32_to_cpu(rsp->CreateContextsLength);
- cc = (struct create_context *)data_offset;
- while (remaining >= sizeof(struct create_context)) {
- name = le16_to_cpu(cc->NameOffset) + (char *)cc;
- if (le16_to_cpu(cc->NameLength) == 4 &&
- strncmp(name, "RqLs", 4) == 0)
- return server->ops->parse_lease_buf(cc, epoch);
- next = le32_to_cpu(cc->Next);
- if (!next)
- break;
- remaining -= next;
- cc = (struct create_context *)((char *)cc + next);
- }
- return 0;
- }
- static int
- add_lease_context(struct TCP_Server_Info *server, struct kvec *iov,
- unsigned int *num_iovec, __u8 *oplock)
- {
- struct smb2_create_req *req = iov[0].iov_base;
- unsigned int num = *num_iovec;
- iov[num].iov_base = server->ops->create_lease_buf(oplock+1, *oplock);
- if (iov[num].iov_base == NULL)
- return -ENOMEM;
- iov[num].iov_len = server->vals->create_lease_size;
- req->RequestedOplockLevel = SMB2_OPLOCK_LEVEL_LEASE;
- if (!req->CreateContextsOffset)
- req->CreateContextsOffset = cpu_to_le32(
- sizeof(struct smb2_create_req) - 4 +
- iov[num - 1].iov_len);
- le32_add_cpu(&req->CreateContextsLength,
- server->vals->create_lease_size);
- inc_rfc1001_len(&req->hdr, server->vals->create_lease_size);
- *num_iovec = num + 1;
- return 0;
- }
- static struct create_durable_v2 *
- create_durable_v2_buf(struct cifs_fid *pfid)
- {
- struct create_durable_v2 *buf;
- buf = kzalloc(sizeof(struct create_durable_v2), GFP_KERNEL);
- if (!buf)
- return NULL;
- buf->ccontext.DataOffset = cpu_to_le16(offsetof
- (struct create_durable_v2, dcontext));
- buf->ccontext.DataLength = cpu_to_le32(sizeof(struct durable_context_v2));
- buf->ccontext.NameOffset = cpu_to_le16(offsetof
- (struct create_durable_v2, Name));
- buf->ccontext.NameLength = cpu_to_le16(4);
- buf->dcontext.Timeout = 0;
- buf->dcontext.Flags = cpu_to_le32(SMB2_DHANDLE_FLAG_PERSISTENT);
- generate_random_uuid(buf->dcontext.CreateGuid);
- memcpy(pfid->create_guid, buf->dcontext.CreateGuid, 16);
-
- buf->Name[0] = 'D';
- buf->Name[1] = 'H';
- buf->Name[2] = '2';
- buf->Name[3] = 'Q';
- return buf;
- }
- static struct create_durable_handle_reconnect_v2 *
- create_reconnect_durable_v2_buf(struct cifs_fid *fid)
- {
- struct create_durable_handle_reconnect_v2 *buf;
- buf = kzalloc(sizeof(struct create_durable_handle_reconnect_v2),
- GFP_KERNEL);
- if (!buf)
- return NULL;
- buf->ccontext.DataOffset =
- cpu_to_le16(offsetof(struct create_durable_handle_reconnect_v2,
- dcontext));
- buf->ccontext.DataLength =
- cpu_to_le32(sizeof(struct durable_reconnect_context_v2));
- buf->ccontext.NameOffset =
- cpu_to_le16(offsetof(struct create_durable_handle_reconnect_v2,
- Name));
- buf->ccontext.NameLength = cpu_to_le16(4);
- buf->dcontext.Fid.PersistentFileId = fid->persistent_fid;
- buf->dcontext.Fid.VolatileFileId = fid->volatile_fid;
- buf->dcontext.Flags = cpu_to_le32(SMB2_DHANDLE_FLAG_PERSISTENT);
- memcpy(buf->dcontext.CreateGuid, fid->create_guid, 16);
-
- buf->Name[0] = 'D';
- buf->Name[1] = 'H';
- buf->Name[2] = '2';
- buf->Name[3] = 'C';
- return buf;
- }
- static int
- add_durable_v2_context(struct kvec *iov, unsigned int *num_iovec,
- struct cifs_open_parms *oparms)
- {
- struct smb2_create_req *req = iov[0].iov_base;
- unsigned int num = *num_iovec;
- iov[num].iov_base = create_durable_v2_buf(oparms->fid);
- if (iov[num].iov_base == NULL)
- return -ENOMEM;
- iov[num].iov_len = sizeof(struct create_durable_v2);
- if (!req->CreateContextsOffset)
- req->CreateContextsOffset =
- cpu_to_le32(sizeof(struct smb2_create_req) - 4 +
- iov[1].iov_len);
- le32_add_cpu(&req->CreateContextsLength, sizeof(struct create_durable_v2));
- inc_rfc1001_len(&req->hdr, sizeof(struct create_durable_v2));
- *num_iovec = num + 1;
- return 0;
- }
- static int
- add_durable_reconnect_v2_context(struct kvec *iov, unsigned int *num_iovec,
- struct cifs_open_parms *oparms)
- {
- struct smb2_create_req *req = iov[0].iov_base;
- unsigned int num = *num_iovec;
-
- oparms->reconnect = false;
- iov[num].iov_base = create_reconnect_durable_v2_buf(oparms->fid);
- if (iov[num].iov_base == NULL)
- return -ENOMEM;
- iov[num].iov_len = sizeof(struct create_durable_handle_reconnect_v2);
- if (!req->CreateContextsOffset)
- req->CreateContextsOffset =
- cpu_to_le32(sizeof(struct smb2_create_req) - 4 +
- iov[1].iov_len);
- le32_add_cpu(&req->CreateContextsLength,
- sizeof(struct create_durable_handle_reconnect_v2));
- inc_rfc1001_len(&req->hdr,
- sizeof(struct create_durable_handle_reconnect_v2));
- *num_iovec = num + 1;
- return 0;
- }
- static int
- add_durable_context(struct kvec *iov, unsigned int *num_iovec,
- struct cifs_open_parms *oparms, bool use_persistent)
- {
- struct smb2_create_req *req = iov[0].iov_base;
- unsigned int num = *num_iovec;
- if (use_persistent) {
- if (oparms->reconnect)
- return add_durable_reconnect_v2_context(iov, num_iovec,
- oparms);
- else
- return add_durable_v2_context(iov, num_iovec, oparms);
- }
- if (oparms->reconnect) {
- iov[num].iov_base = create_reconnect_durable_buf(oparms->fid);
-
- oparms->reconnect = false;
- } else
- iov[num].iov_base = create_durable_buf();
- if (iov[num].iov_base == NULL)
- return -ENOMEM;
- iov[num].iov_len = sizeof(struct create_durable);
- if (!req->CreateContextsOffset)
- req->CreateContextsOffset =
- cpu_to_le32(sizeof(struct smb2_create_req) - 4 +
- iov[1].iov_len);
- le32_add_cpu(&req->CreateContextsLength, sizeof(struct create_durable));
- inc_rfc1001_len(&req->hdr, sizeof(struct create_durable));
- *num_iovec = num + 1;
- return 0;
- }
- int
- SMB2_open(const unsigned int xid, struct cifs_open_parms *oparms, __le16 *path,
- __u8 *oplock, struct smb2_file_all_info *buf,
- struct smb2_err_rsp **err_buf)
- {
- struct smb2_create_req *req;
- struct smb2_create_rsp *rsp;
- struct TCP_Server_Info *server;
- struct cifs_tcon *tcon = oparms->tcon;
- struct cifs_ses *ses = tcon->ses;
- struct kvec iov[4];
- int resp_buftype;
- int uni_path_len;
- __le16 *copy_path = NULL;
- int copy_size;
- int rc = 0;
- unsigned int num_iovecs = 2;
- __u32 file_attributes = 0;
- char *dhc_buf = NULL, *lc_buf = NULL;
- cifs_dbg(FYI, "create/open\n");
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_CREATE, tcon, (void **) &req);
- if (rc)
- return rc;
- if (oparms->create_options & CREATE_OPTION_READONLY)
- file_attributes |= ATTR_READONLY;
- if (oparms->create_options & CREATE_OPTION_SPECIAL)
- file_attributes |= ATTR_SYSTEM;
- req->ImpersonationLevel = IL_IMPERSONATION;
- req->DesiredAccess = cpu_to_le32(oparms->desired_access);
-
- req->FileAttributes = cpu_to_le32(file_attributes);
- req->ShareAccess = FILE_SHARE_ALL_LE;
- req->CreateDisposition = cpu_to_le32(oparms->disposition);
- req->CreateOptions = cpu_to_le32(oparms->create_options & CREATE_OPTIONS_MASK);
- uni_path_len = (2 * UniStrnlen((wchar_t *)path, PATH_MAX)) + 2;
-
- req->NameOffset = cpu_to_le16(sizeof(struct smb2_create_req) - 4);
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
-
- req->NameLength = cpu_to_le16(uni_path_len - 2);
-
- iov[0].iov_len--;
- if (uni_path_len % 8 != 0) {
- copy_size = uni_path_len / 8 * 8;
- if (copy_size < uni_path_len)
- copy_size += 8;
- copy_path = kzalloc(copy_size, GFP_KERNEL);
- if (!copy_path)
- return -ENOMEM;
- memcpy((char *)copy_path, (const char *)path,
- uni_path_len);
- uni_path_len = copy_size;
- path = copy_path;
- }
- iov[1].iov_len = uni_path_len;
- iov[1].iov_base = path;
-
- inc_rfc1001_len(req, uni_path_len - 1);
- if (!server->oplocks)
- *oplock = SMB2_OPLOCK_LEVEL_NONE;
- if (!(server->capabilities & SMB2_GLOBAL_CAP_LEASING) ||
- *oplock == SMB2_OPLOCK_LEVEL_NONE)
- req->RequestedOplockLevel = *oplock;
- else {
- rc = add_lease_context(server, iov, &num_iovecs, oplock);
- if (rc) {
- cifs_small_buf_release(req);
- kfree(copy_path);
- return rc;
- }
- lc_buf = iov[num_iovecs-1].iov_base;
- }
- if (*oplock == SMB2_OPLOCK_LEVEL_BATCH) {
-
- if (server->capabilities & SMB2_GLOBAL_CAP_LEASING) {
- struct create_context *ccontext =
- (struct create_context *)iov[num_iovecs-1].iov_base;
- ccontext->Next =
- cpu_to_le32(server->vals->create_lease_size);
- }
- rc = add_durable_context(iov, &num_iovecs, oparms,
- tcon->use_persistent);
- if (rc) {
- cifs_small_buf_release(req);
- kfree(copy_path);
- kfree(lc_buf);
- return rc;
- }
- dhc_buf = iov[num_iovecs-1].iov_base;
- }
- rc = SendReceive2(xid, ses, iov, num_iovecs, &resp_buftype, 0);
- rsp = (struct smb2_create_rsp *)iov[0].iov_base;
- if (rc != 0) {
- cifs_stats_fail_inc(tcon, SMB2_CREATE_HE);
- if (err_buf)
- *err_buf = kmemdup(rsp, get_rfc1002_length(rsp) + 4,
- GFP_KERNEL);
- goto creat_exit;
- }
- oparms->fid->persistent_fid = rsp->PersistentFileId;
- oparms->fid->volatile_fid = rsp->VolatileFileId;
- if (buf) {
- memcpy(buf, &rsp->CreationTime, 32);
- buf->AllocationSize = rsp->AllocationSize;
- buf->EndOfFile = rsp->EndofFile;
- buf->Attributes = rsp->FileAttributes;
- buf->NumberOfLinks = cpu_to_le32(1);
- buf->DeletePending = 0;
- }
- if (rsp->OplockLevel == SMB2_OPLOCK_LEVEL_LEASE)
- *oplock = parse_lease_state(server, rsp, &oparms->fid->epoch);
- else
- *oplock = rsp->OplockLevel;
- creat_exit:
- kfree(copy_path);
- kfree(lc_buf);
- kfree(dhc_buf);
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- int
- SMB2_ioctl(const unsigned int xid, struct cifs_tcon *tcon, u64 persistent_fid,
- u64 volatile_fid, u32 opcode, bool is_fsctl, char *in_data,
- u32 indatalen, char **out_data, u32 *plen )
- {
- struct smb2_ioctl_req *req;
- struct smb2_ioctl_rsp *rsp;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses;
- struct kvec iov[2];
- int resp_buftype;
- int num_iovecs;
- int rc = 0;
- cifs_dbg(FYI, "SMB2 IOCTL\n");
- if (out_data != NULL)
- *out_data = NULL;
-
- if (plen)
- *plen = 0;
- if (tcon)
- ses = tcon->ses;
- else
- return -EIO;
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_IOCTL, tcon, (void **) &req);
- if (rc)
- return rc;
- req->CtlCode = cpu_to_le32(opcode);
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
- if (indatalen) {
- req->InputCount = cpu_to_le32(indatalen);
-
- req->InputOffset =
- cpu_to_le32(offsetof(struct smb2_ioctl_req, Buffer) - 4);
- iov[1].iov_base = in_data;
- iov[1].iov_len = indatalen;
- num_iovecs = 2;
- } else
- num_iovecs = 1;
- req->OutputOffset = 0;
- req->OutputCount = 0;
-
- req->MaxOutputResponse = cpu_to_le32(CIFSMaxBufSize);
- if (is_fsctl)
- req->Flags = cpu_to_le32(SMB2_0_IOCTL_IS_FSCTL);
- else
- req->Flags = 0;
- iov[0].iov_base = (char *)req;
-
- if (indatalen) {
- iov[0].iov_len = get_rfc1002_length(req) + 4 - 1;
- inc_rfc1001_len(req, indatalen - 1);
- } else
- iov[0].iov_len = get_rfc1002_length(req) + 4;
-
- if (opcode == FSCTL_VALIDATE_NEGOTIATE_INFO)
- req->hdr.Flags |= SMB2_FLAGS_SIGNED;
- rc = SendReceive2(xid, ses, iov, num_iovecs, &resp_buftype, 0);
- rsp = (struct smb2_ioctl_rsp *)iov[0].iov_base;
- if ((rc != 0) && (rc != -EINVAL)) {
- cifs_stats_fail_inc(tcon, SMB2_IOCTL_HE);
- goto ioctl_exit;
- } else if (rc == -EINVAL) {
- if ((opcode != FSCTL_SRV_COPYCHUNK_WRITE) &&
- (opcode != FSCTL_SRV_COPYCHUNK)) {
- cifs_stats_fail_inc(tcon, SMB2_IOCTL_HE);
- goto ioctl_exit;
- }
- }
-
- if ((plen == NULL) || (out_data == NULL))
- goto ioctl_exit;
- *plen = le32_to_cpu(rsp->OutputCount);
-
- if (*plen == 0)
- goto ioctl_exit;
- else if (*plen > 0xFF00) {
- cifs_dbg(VFS, "srv returned invalid ioctl length: %d\n", *plen);
- *plen = 0;
- rc = -EIO;
- goto ioctl_exit;
- }
- if (get_rfc1002_length(rsp) < le32_to_cpu(rsp->OutputOffset) + *plen) {
- cifs_dbg(VFS, "Malformed ioctl resp: len %d offset %d\n", *plen,
- le32_to_cpu(rsp->OutputOffset));
- *plen = 0;
- rc = -EIO;
- goto ioctl_exit;
- }
- *out_data = kmalloc(*plen, GFP_KERNEL);
- if (*out_data == NULL) {
- rc = -ENOMEM;
- goto ioctl_exit;
- }
- memcpy(*out_data,
- (char *)&rsp->hdr.ProtocolId + le32_to_cpu(rsp->OutputOffset),
- *plen);
- ioctl_exit:
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- int
- SMB2_set_compression(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid)
- {
- int rc;
- struct compress_ioctl fsctl_input;
- char *ret_data = NULL;
- fsctl_input.CompressionState =
- cpu_to_le16(COMPRESSION_FORMAT_DEFAULT);
- rc = SMB2_ioctl(xid, tcon, persistent_fid, volatile_fid,
- FSCTL_SET_COMPRESSION, true ,
- (char *)&fsctl_input ,
- 2 , &ret_data , NULL);
- cifs_dbg(FYI, "set compression rc %d\n", rc);
- return rc;
- }
- int
- SMB2_close(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid)
- {
- struct smb2_close_req *req;
- struct smb2_close_rsp *rsp;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- struct kvec iov[1];
- int resp_buftype;
- int rc = 0;
- cifs_dbg(FYI, "Close\n");
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_CLOSE, tcon, (void **) &req);
- if (rc)
- return rc;
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- rc = SendReceive2(xid, ses, iov, 1, &resp_buftype, 0);
- rsp = (struct smb2_close_rsp *)iov[0].iov_base;
- if (rc != 0) {
- cifs_stats_fail_inc(tcon, SMB2_CLOSE_HE);
- goto close_exit;
- }
-
- close_exit:
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- static int
- validate_buf(unsigned int offset, unsigned int buffer_length,
- struct smb2_hdr *hdr, unsigned int min_buf_size)
- {
- unsigned int smb_len = be32_to_cpu(hdr->smb2_buf_length);
- char *end_of_smb = smb_len + 4 + (char *)hdr;
- char *begin_of_buf = 4 + offset + (char *)hdr;
- char *end_of_buf = begin_of_buf + buffer_length;
- if (buffer_length < min_buf_size) {
- cifs_dbg(VFS, "buffer length %d smaller than minimum size %d\n",
- buffer_length, min_buf_size);
- return -EINVAL;
- }
-
- if ((smb_len > 0x7FFFFF) || (buffer_length > 0x7FFFFF)) {
- cifs_dbg(VFS, "buffer length %d or smb length %d too large\n",
- buffer_length, smb_len);
- return -EINVAL;
- }
- if ((begin_of_buf > end_of_smb) || (end_of_buf > end_of_smb)) {
- cifs_dbg(VFS, "illegal server response, bad offset to data\n");
- return -EINVAL;
- }
- return 0;
- }
- static int
- validate_and_copy_buf(unsigned int offset, unsigned int buffer_length,
- struct smb2_hdr *hdr, unsigned int minbufsize,
- char *data)
- {
- char *begin_of_buf = 4 + offset + (char *)hdr;
- int rc;
- if (!data)
- return -EINVAL;
- rc = validate_buf(offset, buffer_length, hdr, minbufsize);
- if (rc)
- return rc;
- memcpy(data, begin_of_buf, buffer_length);
- return 0;
- }
- static int
- query_info(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, u8 info_class,
- size_t output_len, size_t min_len, void *data)
- {
- struct smb2_query_info_req *req;
- struct smb2_query_info_rsp *rsp = NULL;
- struct kvec iov[2];
- int rc = 0;
- int resp_buftype;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- cifs_dbg(FYI, "Query Info\n");
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_QUERY_INFO, tcon, (void **) &req);
- if (rc)
- return rc;
- req->InfoType = SMB2_O_INFO_FILE;
- req->FileInfoClass = info_class;
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
-
- req->InputBufferOffset =
- cpu_to_le16(sizeof(struct smb2_query_info_req) - 1 - 4);
- req->OutputBufferLength = cpu_to_le32(output_len);
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- rc = SendReceive2(xid, ses, iov, 1, &resp_buftype, 0);
- rsp = (struct smb2_query_info_rsp *)iov[0].iov_base;
- if (rc) {
- cifs_stats_fail_inc(tcon, SMB2_QUERY_INFO_HE);
- goto qinf_exit;
- }
- rc = validate_and_copy_buf(le16_to_cpu(rsp->OutputBufferOffset),
- le32_to_cpu(rsp->OutputBufferLength),
- &rsp->hdr, min_len, data);
- qinf_exit:
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- int
- SMB2_query_info(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid,
- struct smb2_file_all_info *data)
- {
- return query_info(xid, tcon, persistent_fid, volatile_fid,
- FILE_ALL_INFORMATION,
- sizeof(struct smb2_file_all_info) + PATH_MAX * 2,
- sizeof(struct smb2_file_all_info), data);
- }
- int
- SMB2_get_srv_num(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, __le64 *uniqueid)
- {
- return query_info(xid, tcon, persistent_fid, volatile_fid,
- FILE_INTERNAL_INFORMATION,
- sizeof(struct smb2_file_internal_info),
- sizeof(struct smb2_file_internal_info), uniqueid);
- }
- static void
- smb2_echo_callback(struct mid_q_entry *mid)
- {
- struct TCP_Server_Info *server = mid->callback_data;
- struct smb2_echo_rsp *smb2 = (struct smb2_echo_rsp *)mid->resp_buf;
- unsigned int credits_received = 1;
- if (mid->mid_state == MID_RESPONSE_RECEIVED)
- credits_received = le16_to_cpu(smb2->hdr.CreditRequest);
- mutex_lock(&server->srv_mutex);
- DeleteMidQEntry(mid);
- mutex_unlock(&server->srv_mutex);
- add_credits(server, credits_received, CIFS_ECHO_OP);
- }
- void smb2_reconnect_server(struct work_struct *work)
- {
- struct TCP_Server_Info *server = container_of(work,
- struct TCP_Server_Info, reconnect.work);
- struct cifs_ses *ses;
- struct cifs_tcon *tcon, *tcon2;
- struct list_head tmp_list;
- int tcon_exist = false;
- int rc;
- int resched = false;
-
- mutex_lock(&server->reconnect_mutex);
- INIT_LIST_HEAD(&tmp_list);
- cifs_dbg(FYI, "Need negotiate, reconnecting tcons\n");
- spin_lock(&cifs_tcp_ses_lock);
- list_for_each_entry(ses, &server->smb_ses_list, smb_ses_list) {
- list_for_each_entry(tcon, &ses->tcon_list, tcon_list) {
- if (tcon->need_reconnect || tcon->need_reopen_files) {
- tcon->tc_count++;
- list_add_tail(&tcon->rlist, &tmp_list);
- tcon_exist = true;
- }
- }
- }
-
- if (tcon_exist)
- server->srv_count++;
- spin_unlock(&cifs_tcp_ses_lock);
- list_for_each_entry_safe(tcon, tcon2, &tmp_list, rlist) {
- rc = smb2_reconnect(SMB2_INTERNAL_CMD, tcon);
- if (!rc)
- cifs_reopen_persistent_handles(tcon);
- else
- resched = true;
- list_del_init(&tcon->rlist);
- cifs_put_tcon(tcon);
- }
- cifs_dbg(FYI, "Reconnecting tcons finished\n");
- if (resched)
- queue_delayed_work(cifsiod_wq, &server->reconnect, 2 * HZ);
- mutex_unlock(&server->reconnect_mutex);
-
- if (tcon_exist)
- cifs_put_tcp_session(server, 1);
- }
- int
- SMB2_echo(struct TCP_Server_Info *server)
- {
- struct smb2_echo_req *req;
- int rc = 0;
- struct kvec iov;
- struct smb_rqst rqst = { .rq_iov = &iov,
- .rq_nvec = 1 };
- cifs_dbg(FYI, "In echo request\n");
- if (server->tcpStatus == CifsNeedNegotiate) {
-
- queue_delayed_work(cifsiod_wq, &server->reconnect, 0);
- return rc;
- }
- rc = small_smb2_init(SMB2_ECHO, NULL, (void **)&req);
- if (rc)
- return rc;
- req->hdr.CreditRequest = cpu_to_le16(1);
- iov.iov_base = (char *)req;
-
- iov.iov_len = get_rfc1002_length(req) + 4;
- rc = cifs_call_async(server, &rqst, NULL, smb2_echo_callback, server,
- CIFS_ECHO_OP);
- if (rc)
- cifs_dbg(FYI, "Echo request failed: %d\n", rc);
- cifs_small_buf_release(req);
- return rc;
- }
- int
- SMB2_flush(const unsigned int xid, struct cifs_tcon *tcon, u64 persistent_fid,
- u64 volatile_fid)
- {
- struct smb2_flush_req *req;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- struct kvec iov[1];
- int resp_buftype;
- int rc = 0;
- cifs_dbg(FYI, "Flush\n");
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_FLUSH, tcon, (void **) &req);
- if (rc)
- return rc;
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- rc = SendReceive2(xid, ses, iov, 1, &resp_buftype, 0);
- if (rc != 0)
- cifs_stats_fail_inc(tcon, SMB2_FLUSH_HE);
- free_rsp_buf(resp_buftype, iov[0].iov_base);
- return rc;
- }
- static int
- smb2_new_read_req(struct kvec *iov, struct cifs_io_parms *io_parms,
- unsigned int remaining_bytes, int request_type)
- {
- int rc = -EACCES;
- struct smb2_read_req *req = NULL;
- rc = small_smb2_init(SMB2_READ, io_parms->tcon, (void **) &req);
- if (rc)
- return rc;
- if (io_parms->tcon->ses->server == NULL)
- return -ECONNABORTED;
- req->hdr.ProcessId = cpu_to_le32(io_parms->pid);
- req->PersistentFileId = io_parms->persistent_fid;
- req->VolatileFileId = io_parms->volatile_fid;
- req->ReadChannelInfoOffset = 0;
- req->ReadChannelInfoLength = 0;
- req->Channel = 0;
- req->MinimumCount = 0;
- req->Length = cpu_to_le32(io_parms->length);
- req->Offset = cpu_to_le64(io_parms->offset);
- if (request_type & CHAINED_REQUEST) {
- if (!(request_type & END_OF_CHAIN)) {
-
- req->hdr.NextCommand =
- cpu_to_le32(get_rfc1002_length(req) + 4);
- } else
- req->hdr.NextCommand = 0;
- if (request_type & RELATED_REQUEST) {
- req->hdr.Flags |= SMB2_FLAGS_RELATED_OPERATIONS;
-
- req->hdr.SessionId = 0xFFFFFFFF;
- req->hdr.TreeId = 0xFFFFFFFF;
- req->PersistentFileId = 0xFFFFFFFF;
- req->VolatileFileId = 0xFFFFFFFF;
- }
- }
- if (remaining_bytes > io_parms->length)
- req->RemainingBytes = cpu_to_le32(remaining_bytes);
- else
- req->RemainingBytes = 0;
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- return rc;
- }
- static void
- smb2_readv_callback(struct mid_q_entry *mid)
- {
- struct cifs_readdata *rdata = mid->callback_data;
- struct cifs_tcon *tcon = tlink_tcon(rdata->cfile->tlink);
- struct TCP_Server_Info *server = tcon->ses->server;
- struct smb2_hdr *buf = (struct smb2_hdr *)rdata->iov.iov_base;
- unsigned int credits_received = 1;
- struct smb_rqst rqst = { .rq_iov = &rdata->iov,
- .rq_nvec = 1,
- .rq_pages = rdata->pages,
- .rq_npages = rdata->nr_pages,
- .rq_pagesz = rdata->pagesz,
- .rq_tailsz = rdata->tailsz };
- cifs_dbg(FYI, "%s: mid=%llu state=%d result=%d bytes=%u\n",
- __func__, mid->mid, mid->mid_state, rdata->result,
- rdata->bytes);
- switch (mid->mid_state) {
- case MID_RESPONSE_RECEIVED:
- credits_received = le16_to_cpu(buf->CreditRequest);
-
- if (server->sign) {
- int rc;
- rc = smb2_verify_signature(&rqst, server);
- if (rc)
- cifs_dbg(VFS, "SMB signature verification returned error = %d\n",
- rc);
- }
-
- task_io_account_read(rdata->got_bytes);
- cifs_stats_bytes_read(tcon, rdata->got_bytes);
- break;
- case MID_REQUEST_SUBMITTED:
- case MID_RETRY_NEEDED:
- rdata->result = -EAGAIN;
- if (server->sign && rdata->got_bytes)
-
- rdata->got_bytes = 0;
-
- task_io_account_read(rdata->got_bytes);
- cifs_stats_bytes_read(tcon, rdata->got_bytes);
- break;
- default:
- if (rdata->result != -ENODATA)
- rdata->result = -EIO;
- }
- if (rdata->result)
- cifs_stats_fail_inc(tcon, SMB2_READ_HE);
- queue_work(cifsiod_wq, &rdata->work);
- mutex_lock(&server->srv_mutex);
- DeleteMidQEntry(mid);
- mutex_unlock(&server->srv_mutex);
- add_credits(server, credits_received, 0);
- }
- int
- smb2_async_readv(struct cifs_readdata *rdata)
- {
- int rc, flags = 0;
- struct smb2_hdr *buf;
- struct cifs_io_parms io_parms;
- struct smb_rqst rqst = { .rq_iov = &rdata->iov,
- .rq_nvec = 1 };
- struct TCP_Server_Info *server;
- cifs_dbg(FYI, "%s: offset=%llu bytes=%u\n",
- __func__, rdata->offset, rdata->bytes);
- io_parms.tcon = tlink_tcon(rdata->cfile->tlink);
- io_parms.offset = rdata->offset;
- io_parms.length = rdata->bytes;
- io_parms.persistent_fid = rdata->cfile->fid.persistent_fid;
- io_parms.volatile_fid = rdata->cfile->fid.volatile_fid;
- io_parms.pid = rdata->pid;
- server = io_parms.tcon->ses->server;
- rc = smb2_new_read_req(&rdata->iov, &io_parms, 0, 0);
- if (rc) {
- if (rc == -EAGAIN && rdata->credits) {
-
- rdata->credits = 0;
-
- spin_lock(&server->req_lock);
- server->in_flight--;
- spin_unlock(&server->req_lock);
- }
- return rc;
- }
- buf = (struct smb2_hdr *)rdata->iov.iov_base;
-
- rdata->iov.iov_len = get_rfc1002_length(rdata->iov.iov_base) + 4;
- if (rdata->credits) {
- buf->CreditCharge = cpu_to_le16(DIV_ROUND_UP(rdata->bytes,
- SMB2_MAX_BUFFER_SIZE));
- buf->CreditRequest = buf->CreditCharge;
- spin_lock(&server->req_lock);
- server->credits += rdata->credits -
- le16_to_cpu(buf->CreditCharge);
- spin_unlock(&server->req_lock);
- wake_up(&server->request_q);
- flags = CIFS_HAS_CREDITS;
- }
- kref_get(&rdata->refcount);
- rc = cifs_call_async(io_parms.tcon->ses->server, &rqst,
- cifs_readv_receive, smb2_readv_callback,
- rdata, flags);
- if (rc) {
- kref_put(&rdata->refcount, cifs_readdata_release);
- cifs_stats_fail_inc(io_parms.tcon, SMB2_READ_HE);
- }
- cifs_small_buf_release(buf);
- return rc;
- }
- int
- SMB2_read(const unsigned int xid, struct cifs_io_parms *io_parms,
- unsigned int *nbytes, char **buf, int *buf_type)
- {
- int resp_buftype, rc = -EACCES;
- struct smb2_read_rsp *rsp = NULL;
- struct kvec iov[1];
- *nbytes = 0;
- rc = smb2_new_read_req(iov, io_parms, 0, 0);
- if (rc)
- return rc;
- rc = SendReceive2(xid, io_parms->tcon->ses, iov, 1,
- &resp_buftype, CIFS_LOG_ERROR);
- rsp = (struct smb2_read_rsp *)iov[0].iov_base;
- if (rsp->hdr.Status == STATUS_END_OF_FILE) {
- free_rsp_buf(resp_buftype, iov[0].iov_base);
- return 0;
- }
- if (rc) {
- cifs_stats_fail_inc(io_parms->tcon, SMB2_READ_HE);
- cifs_dbg(VFS, "Send error in read = %d\n", rc);
- } else {
- *nbytes = le32_to_cpu(rsp->DataLength);
- if ((*nbytes > CIFS_MAX_MSGSIZE) ||
- (*nbytes > io_parms->length)) {
- cifs_dbg(FYI, "bad length %d for count %d\n",
- *nbytes, io_parms->length);
- rc = -EIO;
- *nbytes = 0;
- }
- }
- if (*buf) {
- memcpy(*buf, (char *)&rsp->hdr.ProtocolId + rsp->DataOffset,
- *nbytes);
- free_rsp_buf(resp_buftype, iov[0].iov_base);
- } else if (resp_buftype != CIFS_NO_BUFFER) {
- *buf = iov[0].iov_base;
- if (resp_buftype == CIFS_SMALL_BUFFER)
- *buf_type = CIFS_SMALL_BUFFER;
- else if (resp_buftype == CIFS_LARGE_BUFFER)
- *buf_type = CIFS_LARGE_BUFFER;
- }
- return rc;
- }
- static void
- smb2_writev_callback(struct mid_q_entry *mid)
- {
- struct cifs_writedata *wdata = mid->callback_data;
- struct cifs_tcon *tcon = tlink_tcon(wdata->cfile->tlink);
- struct TCP_Server_Info *server = tcon->ses->server;
- unsigned int written;
- struct smb2_write_rsp *rsp = (struct smb2_write_rsp *)mid->resp_buf;
- unsigned int credits_received = 1;
- switch (mid->mid_state) {
- case MID_RESPONSE_RECEIVED:
- credits_received = le16_to_cpu(rsp->hdr.CreditRequest);
- wdata->result = smb2_check_receive(mid, tcon->ses->server, 0);
- if (wdata->result != 0)
- break;
- written = le32_to_cpu(rsp->DataLength);
-
- if (written > wdata->bytes)
- written &= 0xFFFF;
- if (written < wdata->bytes)
- wdata->result = -ENOSPC;
- else
- wdata->bytes = written;
- break;
- case MID_REQUEST_SUBMITTED:
- case MID_RETRY_NEEDED:
- wdata->result = -EAGAIN;
- break;
- default:
- wdata->result = -EIO;
- break;
- }
- if (wdata->result)
- cifs_stats_fail_inc(tcon, SMB2_WRITE_HE);
- queue_work(cifsiod_wq, &wdata->work);
- mutex_lock(&server->srv_mutex);
- DeleteMidQEntry(mid);
- mutex_unlock(&server->srv_mutex);
- add_credits(tcon->ses->server, credits_received, 0);
- }
- int
- smb2_async_writev(struct cifs_writedata *wdata,
- void (*release)(struct kref *kref))
- {
- int rc = -EACCES, flags = 0;
- struct smb2_write_req *req = NULL;
- struct cifs_tcon *tcon = tlink_tcon(wdata->cfile->tlink);
- struct TCP_Server_Info *server = tcon->ses->server;
- struct kvec iov;
- struct smb_rqst rqst;
- rc = small_smb2_init(SMB2_WRITE, tcon, (void **) &req);
- if (rc) {
- if (rc == -EAGAIN && wdata->credits) {
-
- wdata->credits = 0;
-
- spin_lock(&server->req_lock);
- server->in_flight--;
- spin_unlock(&server->req_lock);
- }
- goto async_writev_out;
- }
- req->hdr.ProcessId = cpu_to_le32(wdata->cfile->pid);
- req->PersistentFileId = wdata->cfile->fid.persistent_fid;
- req->VolatileFileId = wdata->cfile->fid.volatile_fid;
- req->WriteChannelInfoOffset = 0;
- req->WriteChannelInfoLength = 0;
- req->Channel = 0;
- req->Offset = cpu_to_le64(wdata->offset);
-
- req->DataOffset = cpu_to_le16(
- offsetof(struct smb2_write_req, Buffer) - 4);
- req->RemainingBytes = 0;
-
- iov.iov_len = get_rfc1002_length(req) + 4 - 1;
- iov.iov_base = req;
- rqst.rq_iov = &iov;
- rqst.rq_nvec = 1;
- rqst.rq_pages = wdata->pages;
- rqst.rq_npages = wdata->nr_pages;
- rqst.rq_pagesz = wdata->pagesz;
- rqst.rq_tailsz = wdata->tailsz;
- cifs_dbg(FYI, "async write at %llu %u bytes\n",
- wdata->offset, wdata->bytes);
- req->Length = cpu_to_le32(wdata->bytes);
- inc_rfc1001_len(&req->hdr, wdata->bytes - 1 );
- if (wdata->credits) {
- req->hdr.CreditCharge = cpu_to_le16(DIV_ROUND_UP(wdata->bytes,
- SMB2_MAX_BUFFER_SIZE));
- req->hdr.CreditRequest = req->hdr.CreditCharge;
- spin_lock(&server->req_lock);
- server->credits += wdata->credits -
- le16_to_cpu(req->hdr.CreditCharge);
- spin_unlock(&server->req_lock);
- wake_up(&server->request_q);
- flags = CIFS_HAS_CREDITS;
- }
- kref_get(&wdata->refcount);
- rc = cifs_call_async(server, &rqst, NULL, smb2_writev_callback, wdata,
- flags);
- if (rc) {
- kref_put(&wdata->refcount, release);
- cifs_stats_fail_inc(tcon, SMB2_WRITE_HE);
- }
- async_writev_out:
- cifs_small_buf_release(req);
- return rc;
- }
- int
- SMB2_write(const unsigned int xid, struct cifs_io_parms *io_parms,
- unsigned int *nbytes, struct kvec *iov, int n_vec)
- {
- int rc = 0;
- struct smb2_write_req *req = NULL;
- struct smb2_write_rsp *rsp = NULL;
- int resp_buftype;
- *nbytes = 0;
- if (n_vec < 1)
- return rc;
- rc = small_smb2_init(SMB2_WRITE, io_parms->tcon, (void **) &req);
- if (rc)
- return rc;
- if (io_parms->tcon->ses->server == NULL)
- return -ECONNABORTED;
- req->hdr.ProcessId = cpu_to_le32(io_parms->pid);
- req->PersistentFileId = io_parms->persistent_fid;
- req->VolatileFileId = io_parms->volatile_fid;
- req->WriteChannelInfoOffset = 0;
- req->WriteChannelInfoLength = 0;
- req->Channel = 0;
- req->Length = cpu_to_le32(io_parms->length);
- req->Offset = cpu_to_le64(io_parms->offset);
-
- req->DataOffset = cpu_to_le16(
- offsetof(struct smb2_write_req, Buffer) - 4);
- req->RemainingBytes = 0;
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4 - 1;
-
- inc_rfc1001_len(req, io_parms->length - 1 );
- rc = SendReceive2(xid, io_parms->tcon->ses, iov, n_vec + 1,
- &resp_buftype, 0);
- rsp = (struct smb2_write_rsp *)iov[0].iov_base;
- if (rc) {
- cifs_stats_fail_inc(io_parms->tcon, SMB2_WRITE_HE);
- cifs_dbg(VFS, "Send error in write = %d\n", rc);
- } else
- *nbytes = le32_to_cpu(rsp->DataLength);
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- static unsigned int
- num_entries(char *bufstart, char *end_of_buf, char **lastentry, size_t size)
- {
- int len;
- unsigned int entrycount = 0;
- unsigned int next_offset = 0;
- char *entryptr;
- FILE_DIRECTORY_INFO *dir_info;
- if (bufstart == NULL)
- return 0;
- entryptr = bufstart;
- while (1) {
- if (entryptr + next_offset < entryptr ||
- entryptr + next_offset > end_of_buf ||
- entryptr + next_offset + size > end_of_buf) {
- cifs_dbg(VFS, "malformed search entry would overflow\n");
- break;
- }
- entryptr = entryptr + next_offset;
- dir_info = (FILE_DIRECTORY_INFO *)entryptr;
- len = le32_to_cpu(dir_info->FileNameLength);
- if (entryptr + len < entryptr ||
- entryptr + len > end_of_buf ||
- entryptr + len + size > end_of_buf) {
- cifs_dbg(VFS, "directory entry name would overflow frame end of buf %p\n",
- end_of_buf);
- break;
- }
- *lastentry = entryptr;
- entrycount++;
- next_offset = le32_to_cpu(dir_info->NextEntryOffset);
- if (!next_offset)
- break;
- }
- return entrycount;
- }
- int
- SMB2_query_directory(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, int index,
- struct cifs_search_info *srch_inf)
- {
- struct smb2_query_directory_req *req;
- struct smb2_query_directory_rsp *rsp = NULL;
- struct kvec iov[2];
- int rc = 0;
- int len;
- int resp_buftype = CIFS_NO_BUFFER;
- unsigned char *bufptr;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- __le16 asteriks = cpu_to_le16('*');
- char *end_of_smb;
- unsigned int output_size = CIFSMaxBufSize;
- size_t info_buf_size;
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- rc = small_smb2_init(SMB2_QUERY_DIRECTORY, tcon, (void **) &req);
- if (rc)
- return rc;
- switch (srch_inf->info_level) {
- case SMB_FIND_FILE_DIRECTORY_INFO:
- req->FileInformationClass = FILE_DIRECTORY_INFORMATION;
- info_buf_size = sizeof(FILE_DIRECTORY_INFO) - 1;
- break;
- case SMB_FIND_FILE_ID_FULL_DIR_INFO:
- req->FileInformationClass = FILEID_FULL_DIRECTORY_INFORMATION;
- info_buf_size = sizeof(SEARCH_ID_FULL_DIR_INFO) - 1;
- break;
- default:
- cifs_dbg(VFS, "info level %u isn't supported\n",
- srch_inf->info_level);
- rc = -EINVAL;
- goto qdir_exit;
- }
- req->FileIndex = cpu_to_le32(index);
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
- len = 0x2;
- bufptr = req->Buffer;
- memcpy(bufptr, &asteriks, len);
- req->FileNameOffset =
- cpu_to_le16(sizeof(struct smb2_query_directory_req) - 1 - 4);
- req->FileNameLength = cpu_to_le16(len);
-
- output_size = min_t(unsigned int, output_size, server->maxBuf);
- output_size = min_t(unsigned int, output_size, 2 << 15);
- req->OutputBufferLength = cpu_to_le32(output_size);
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4 - 1;
- iov[1].iov_base = (char *)(req->Buffer);
- iov[1].iov_len = len;
- inc_rfc1001_len(req, len - 1 );
- rc = SendReceive2(xid, ses, iov, 2, &resp_buftype, 0);
- rsp = (struct smb2_query_directory_rsp *)iov[0].iov_base;
- if (rc) {
- if (rc == -ENODATA && rsp->hdr.Status == STATUS_NO_MORE_FILES) {
- srch_inf->endOfSearch = true;
- rc = 0;
- } else
- cifs_stats_fail_inc(tcon, SMB2_QUERY_DIRECTORY_HE);
- goto qdir_exit;
- }
- rc = validate_buf(le16_to_cpu(rsp->OutputBufferOffset),
- le32_to_cpu(rsp->OutputBufferLength), &rsp->hdr,
- info_buf_size);
- if (rc)
- goto qdir_exit;
- srch_inf->unicode = true;
- if (srch_inf->ntwrk_buf_start) {
- if (srch_inf->smallBuf)
- cifs_small_buf_release(srch_inf->ntwrk_buf_start);
- else
- cifs_buf_release(srch_inf->ntwrk_buf_start);
- }
- srch_inf->ntwrk_buf_start = (char *)rsp;
- srch_inf->srch_entries_start = srch_inf->last_entry = 4 +
- (char *)&rsp->hdr + le16_to_cpu(rsp->OutputBufferOffset);
-
- end_of_smb = get_rfc1002_length(rsp) + 4 + (char *)&rsp->hdr;
- srch_inf->entries_in_buffer =
- num_entries(srch_inf->srch_entries_start, end_of_smb,
- &srch_inf->last_entry, info_buf_size);
- srch_inf->index_of_last_entry += srch_inf->entries_in_buffer;
- cifs_dbg(FYI, "num entries %d last_index %lld srch start %p srch end %p\n",
- srch_inf->entries_in_buffer, srch_inf->index_of_last_entry,
- srch_inf->srch_entries_start, srch_inf->last_entry);
- if (resp_buftype == CIFS_LARGE_BUFFER)
- srch_inf->smallBuf = false;
- else if (resp_buftype == CIFS_SMALL_BUFFER)
- srch_inf->smallBuf = true;
- else
- cifs_dbg(VFS, "illegal search buffer type\n");
- return rc;
- qdir_exit:
- free_rsp_buf(resp_buftype, rsp);
- return rc;
- }
- static int
- send_set_info(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, u32 pid, int info_class,
- unsigned int num, void **data, unsigned int *size)
- {
- struct smb2_set_info_req *req;
- struct smb2_set_info_rsp *rsp = NULL;
- struct kvec *iov;
- int rc = 0;
- int resp_buftype;
- unsigned int i;
- struct TCP_Server_Info *server;
- struct cifs_ses *ses = tcon->ses;
- if (ses && (ses->server))
- server = ses->server;
- else
- return -EIO;
- if (!num)
- return -EINVAL;
- iov = kmalloc(sizeof(struct kvec) * num, GFP_KERNEL);
- if (!iov)
- return -ENOMEM;
- rc = small_smb2_init(SMB2_SET_INFO, tcon, (void **) &req);
- if (rc) {
- kfree(iov);
- return rc;
- }
- req->hdr.ProcessId = cpu_to_le32(pid);
- req->InfoType = SMB2_O_INFO_FILE;
- req->FileInfoClass = info_class;
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
-
- req->BufferOffset =
- cpu_to_le16(sizeof(struct smb2_set_info_req) - 1 - 4);
- req->BufferLength = cpu_to_le32(*size);
- inc_rfc1001_len(req, *size - 1 );
- memcpy(req->Buffer, *data, *size);
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4;
- for (i = 1; i < num; i++) {
- inc_rfc1001_len(req, size[i]);
- le32_add_cpu(&req->BufferLength, size[i]);
- iov[i].iov_base = (char *)data[i];
- iov[i].iov_len = size[i];
- }
- rc = SendReceive2(xid, ses, iov, num, &resp_buftype, 0);
- rsp = (struct smb2_set_info_rsp *)iov[0].iov_base;
- if (rc != 0)
- cifs_stats_fail_inc(tcon, SMB2_SET_INFO_HE);
- free_rsp_buf(resp_buftype, rsp);
- kfree(iov);
- return rc;
- }
- int
- SMB2_rename(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, __le16 *target_file)
- {
- struct smb2_file_rename_info info;
- void **data;
- unsigned int size[2];
- int rc;
- int len = (2 * UniStrnlen((wchar_t *)target_file, PATH_MAX));
- data = kmalloc(sizeof(void *) * 2, GFP_KERNEL);
- if (!data)
- return -ENOMEM;
- info.ReplaceIfExists = 1;
-
- info.RootDirectory = 0;
- info.FileNameLength = cpu_to_le32(len);
- data[0] = &info;
- size[0] = sizeof(struct smb2_file_rename_info);
- data[1] = target_file;
- size[1] = len + 2 ;
- rc = send_set_info(xid, tcon, persistent_fid, volatile_fid,
- current->tgid, FILE_RENAME_INFORMATION, 2, data,
- size);
- kfree(data);
- return rc;
- }
- int
- SMB2_rmdir(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid)
- {
- __u8 delete_pending = 1;
- void *data;
- unsigned int size;
- data = &delete_pending;
- size = 1;
- return send_set_info(xid, tcon, persistent_fid, volatile_fid,
- current->tgid, FILE_DISPOSITION_INFORMATION, 1, &data,
- &size);
- }
- int
- SMB2_set_hardlink(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, __le16 *target_file)
- {
- struct smb2_file_link_info info;
- void **data;
- unsigned int size[2];
- int rc;
- int len = (2 * UniStrnlen((wchar_t *)target_file, PATH_MAX));
- data = kmalloc(sizeof(void *) * 2, GFP_KERNEL);
- if (!data)
- return -ENOMEM;
- info.ReplaceIfExists = 0;
-
- info.RootDirectory = 0;
- info.FileNameLength = cpu_to_le32(len);
- data[0] = &info;
- size[0] = sizeof(struct smb2_file_link_info);
- data[1] = target_file;
- size[1] = len + 2 ;
- rc = send_set_info(xid, tcon, persistent_fid, volatile_fid,
- current->tgid, FILE_LINK_INFORMATION, 2, data, size);
- kfree(data);
- return rc;
- }
- int
- SMB2_set_eof(const unsigned int xid, struct cifs_tcon *tcon, u64 persistent_fid,
- u64 volatile_fid, u32 pid, __le64 *eof, bool is_falloc)
- {
- struct smb2_file_eof_info info;
- void *data;
- unsigned int size;
- info.EndOfFile = *eof;
- data = &info;
- size = sizeof(struct smb2_file_eof_info);
- if (is_falloc)
- return send_set_info(xid, tcon, persistent_fid, volatile_fid,
- pid, FILE_ALLOCATION_INFORMATION, 1, &data, &size);
- else
- return send_set_info(xid, tcon, persistent_fid, volatile_fid,
- pid, FILE_END_OF_FILE_INFORMATION, 1, &data, &size);
- }
- int
- SMB2_set_info(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, FILE_BASIC_INFO *buf)
- {
- unsigned int size;
- size = sizeof(FILE_BASIC_INFO);
- return send_set_info(xid, tcon, persistent_fid, volatile_fid,
- current->tgid, FILE_BASIC_INFORMATION, 1,
- (void **)&buf, &size);
- }
- int
- SMB2_oplock_break(const unsigned int xid, struct cifs_tcon *tcon,
- const u64 persistent_fid, const u64 volatile_fid,
- __u8 oplock_level)
- {
- int rc;
- struct smb2_oplock_break *req = NULL;
- cifs_dbg(FYI, "SMB2_oplock_break\n");
- rc = small_smb2_init(SMB2_OPLOCK_BREAK, tcon, (void **) &req);
- if (rc)
- return rc;
- req->VolatileFid = volatile_fid;
- req->PersistentFid = persistent_fid;
- req->OplockLevel = oplock_level;
- req->hdr.CreditRequest = cpu_to_le16(1);
- rc = SendReceiveNoRsp(xid, tcon->ses, (char *) req, CIFS_OBREAK_OP);
-
- if (rc) {
- cifs_stats_fail_inc(tcon, SMB2_OPLOCK_BREAK_HE);
- cifs_dbg(FYI, "Send error in Oplock Break = %d\n", rc);
- }
- return rc;
- }
- static void
- copy_fs_info_to_kstatfs(struct smb2_fs_full_size_info *pfs_inf,
- struct kstatfs *kst)
- {
- kst->f_bsize = le32_to_cpu(pfs_inf->BytesPerSector) *
- le32_to_cpu(pfs_inf->SectorsPerAllocationUnit);
- kst->f_blocks = le64_to_cpu(pfs_inf->TotalAllocationUnits);
- kst->f_bfree = kst->f_bavail =
- le64_to_cpu(pfs_inf->CallerAvailableAllocationUnits);
- return;
- }
- static int
- build_qfs_info_req(struct kvec *iov, struct cifs_tcon *tcon, int level,
- int outbuf_len, u64 persistent_fid, u64 volatile_fid)
- {
- int rc;
- struct smb2_query_info_req *req;
- cifs_dbg(FYI, "Query FSInfo level %d\n", level);
- if ((tcon->ses == NULL) || (tcon->ses->server == NULL))
- return -EIO;
- rc = small_smb2_init(SMB2_QUERY_INFO, tcon, (void **) &req);
- if (rc)
- return rc;
- req->InfoType = SMB2_O_INFO_FILESYSTEM;
- req->FileInfoClass = level;
- req->PersistentFileId = persistent_fid;
- req->VolatileFileId = volatile_fid;
-
- req->InputBufferOffset =
- cpu_to_le16(sizeof(struct smb2_query_info_req) - 1 - 4);
- req->OutputBufferLength = cpu_to_le32(
- outbuf_len + sizeof(struct smb2_query_info_rsp) - 1 - 4);
- iov->iov_base = (char *)req;
-
- iov->iov_len = get_rfc1002_length(req) + 4;
- return 0;
- }
- int
- SMB2_QFS_info(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, struct kstatfs *fsdata)
- {
- struct smb2_query_info_rsp *rsp = NULL;
- struct kvec iov;
- int rc = 0;
- int resp_buftype;
- struct cifs_ses *ses = tcon->ses;
- struct smb2_fs_full_size_info *info = NULL;
- rc = build_qfs_info_req(&iov, tcon, FS_FULL_SIZE_INFORMATION,
- sizeof(struct smb2_fs_full_size_info),
- persistent_fid, volatile_fid);
- if (rc)
- return rc;
- rc = SendReceive2(xid, ses, &iov, 1, &resp_buftype, 0);
- if (rc) {
- cifs_stats_fail_inc(tcon, SMB2_QUERY_INFO_HE);
- goto qfsinf_exit;
- }
- rsp = (struct smb2_query_info_rsp *)iov.iov_base;
- info = (struct smb2_fs_full_size_info *)(4 +
- le16_to_cpu(rsp->OutputBufferOffset) + (char *)&rsp->hdr);
- rc = validate_buf(le16_to_cpu(rsp->OutputBufferOffset),
- le32_to_cpu(rsp->OutputBufferLength), &rsp->hdr,
- sizeof(struct smb2_fs_full_size_info));
- if (!rc)
- copy_fs_info_to_kstatfs(info, fsdata);
- qfsinf_exit:
- free_rsp_buf(resp_buftype, iov.iov_base);
- return rc;
- }
- int
- SMB2_QFS_attr(const unsigned int xid, struct cifs_tcon *tcon,
- u64 persistent_fid, u64 volatile_fid, int level)
- {
- struct smb2_query_info_rsp *rsp = NULL;
- struct kvec iov;
- int rc = 0;
- int resp_buftype, max_len, min_len;
- struct cifs_ses *ses = tcon->ses;
- unsigned int rsp_len, offset;
- if (level == FS_DEVICE_INFORMATION) {
- max_len = sizeof(FILE_SYSTEM_DEVICE_INFO);
- min_len = sizeof(FILE_SYSTEM_DEVICE_INFO);
- } else if (level == FS_ATTRIBUTE_INFORMATION) {
- max_len = sizeof(FILE_SYSTEM_ATTRIBUTE_INFO);
- min_len = MIN_FS_ATTR_INFO_SIZE;
- } else if (level == FS_SECTOR_SIZE_INFORMATION) {
- max_len = sizeof(struct smb3_fs_ss_info);
- min_len = sizeof(struct smb3_fs_ss_info);
- } else {
- cifs_dbg(FYI, "Invalid qfsinfo level %d\n", level);
- return -EINVAL;
- }
- rc = build_qfs_info_req(&iov, tcon, level, max_len,
- persistent_fid, volatile_fid);
- if (rc)
- return rc;
- rc = SendReceive2(xid, ses, &iov, 1, &resp_buftype, 0);
- if (rc) {
- cifs_stats_fail_inc(tcon, SMB2_QUERY_INFO_HE);
- goto qfsattr_exit;
- }
- rsp = (struct smb2_query_info_rsp *)iov.iov_base;
- rsp_len = le32_to_cpu(rsp->OutputBufferLength);
- offset = le16_to_cpu(rsp->OutputBufferOffset);
- rc = validate_buf(offset, rsp_len, &rsp->hdr, min_len);
- if (rc)
- goto qfsattr_exit;
- if (level == FS_ATTRIBUTE_INFORMATION)
- memcpy(&tcon->fsAttrInfo, 4 + offset
- + (char *)&rsp->hdr, min_t(unsigned int,
- rsp_len, max_len));
- else if (level == FS_DEVICE_INFORMATION)
- memcpy(&tcon->fsDevInfo, 4 + offset
- + (char *)&rsp->hdr, sizeof(FILE_SYSTEM_DEVICE_INFO));
- else if (level == FS_SECTOR_SIZE_INFORMATION) {
- struct smb3_fs_ss_info *ss_info = (struct smb3_fs_ss_info *)
- (4 + offset + (char *)&rsp->hdr);
- tcon->ss_flags = le32_to_cpu(ss_info->Flags);
- tcon->perf_sector_size =
- le32_to_cpu(ss_info->PhysicalBytesPerSectorForPerf);
- }
- qfsattr_exit:
- free_rsp_buf(resp_buftype, iov.iov_base);
- return rc;
- }
- int
- smb2_lockv(const unsigned int xid, struct cifs_tcon *tcon,
- const __u64 persist_fid, const __u64 volatile_fid, const __u32 pid,
- const __u32 num_lock, struct smb2_lock_element *buf)
- {
- int rc = 0;
- struct smb2_lock_req *req = NULL;
- struct kvec iov[2];
- int resp_buf_type;
- unsigned int count;
- cifs_dbg(FYI, "smb2_lockv num lock %d\n", num_lock);
- rc = small_smb2_init(SMB2_LOCK, tcon, (void **) &req);
- if (rc)
- return rc;
- req->hdr.ProcessId = cpu_to_le32(pid);
- req->LockCount = cpu_to_le16(num_lock);
- req->PersistentFileId = persist_fid;
- req->VolatileFileId = volatile_fid;
- count = num_lock * sizeof(struct smb2_lock_element);
- inc_rfc1001_len(req, count - sizeof(struct smb2_lock_element));
- iov[0].iov_base = (char *)req;
-
- iov[0].iov_len = get_rfc1002_length(req) + 4 - count;
- iov[1].iov_base = (char *)buf;
- iov[1].iov_len = count;
- cifs_stats_inc(&tcon->stats.cifs_stats.num_locks);
- rc = SendReceive2(xid, tcon->ses, iov, 2, &resp_buf_type, CIFS_NO_RESP);
- if (rc) {
- cifs_dbg(FYI, "Send error in smb2_lockv = %d\n", rc);
- cifs_stats_fail_inc(tcon, SMB2_LOCK_HE);
- }
- return rc;
- }
- int
- SMB2_lock(const unsigned int xid, struct cifs_tcon *tcon,
- const __u64 persist_fid, const __u64 volatile_fid, const __u32 pid,
- const __u64 length, const __u64 offset, const __u32 lock_flags,
- const bool wait)
- {
- struct smb2_lock_element lock;
- lock.Offset = cpu_to_le64(offset);
- lock.Length = cpu_to_le64(length);
- lock.Flags = cpu_to_le32(lock_flags);
- if (!wait && lock_flags != SMB2_LOCKFLAG_UNLOCK)
- lock.Flags |= cpu_to_le32(SMB2_LOCKFLAG_FAIL_IMMEDIATELY);
- return smb2_lockv(xid, tcon, persist_fid, volatile_fid, pid, 1, &lock);
- }
- int
- SMB2_lease_break(const unsigned int xid, struct cifs_tcon *tcon,
- __u8 *lease_key, const __le32 lease_state)
- {
- int rc;
- struct smb2_lease_ack *req = NULL;
- cifs_dbg(FYI, "SMB2_lease_break\n");
- rc = small_smb2_init(SMB2_OPLOCK_BREAK, tcon, (void **) &req);
- if (rc)
- return rc;
- req->hdr.CreditRequest = cpu_to_le16(1);
- req->StructureSize = cpu_to_le16(36);
- inc_rfc1001_len(req, 12);
- memcpy(req->LeaseKey, lease_key, 16);
- req->LeaseState = lease_state;
- rc = SendReceiveNoRsp(xid, tcon->ses, (char *) req, CIFS_OBREAK_OP);
-
- if (rc) {
- cifs_stats_fail_inc(tcon, SMB2_OPLOCK_BREAK_HE);
- cifs_dbg(FYI, "Send error in Lease Break = %d\n", rc);
- }
- return rc;
- }
|